Examples of org.apache.qpid.client.AMQConnection.start()

Class org.apache.qpid.client.AMQConnection

Examples of org.apache.qpid.client.AMQConnection.start()

org.apache.qpid.client.AMQConnection.start()
Start the connection, i.e. start flowing messages. Note that this method must be called only from a single thread and is not thread safe (which is legal according to the JMS specification). @throws JMSException

          int ssn_per_con = sessions_per_con;
          String addrTemp = addr;
          for (int i = 0; i< connection_count; i++)
          {
            AMQConnection con = new AMQConnection(url);
            con.start();
            clients.add(con);            
            for (int j = 0; j< ssn_per_con; j++)
              {
              String index = createPrefix(i,j);
              if (useUniqueDests)

View Full Code Here

        AMQConnection con =  (AMQConnection) getConnection("guest", "guest");
        AMQTopic topic = new AMQTopic(con,"MyTopic");
        TopicSession session1 = con.createTopicSession(false, AMQSession.NO_ACKNOWLEDGE);
        TopicPublisher publisher = session1.createPublisher(null);
        MessageConsumer consumer1 = session1.createConsumer(topic);
        con.start();
        publisher.publish(topic, session1.createTextMessage("Hello"));
        TextMessage m = (TextMessage) consumer1.receive(2000);
        assertNotNull(m);
        try
        {

View Full Code Here

        Session session2 = con.createSession(false, AMQSession.NO_ACKNOWLEDGE);
        _logger.info("Create Durable Subscriber on Session 2");
        TopicSubscriber consumer2 = session2.createDurableSubscriber(topic, MY_SUBSCRIPTION);


        _logger.info("Starting connection");
        con.start();


        _logger.info("Producer sending message A");
        producer.send(session1.createTextMessage("A"));


        //check the dur sub's underlying queue now has msg count 1

View Full Code Here

    {
        setTestClientSystemProperty("qpid.default_mandatory_topic","true");


        // set up subscription
        AMQConnection connection = (AMQConnection) getConnection();
        connection.start();


        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        Topic topic = new AMQTopic(connection, MY_TOPIC);
        MessageProducer producer = session.createProducer(topic);

View Full Code Here

        MessageProducer producer = sessionProd.createProducer(topic);


        Session session2 = con.createSession(false, ackMode);
        TopicSubscriber consumer2 = session2.createDurableSubscriber(topic, MY_SUBSCRIPTION);


        con.start();


        //send message A and check both consumers receive
        producer.send(session1.createTextMessage("A"));


        Message msg;

View Full Code Here

    private void durabilityImplSessionPerConnection(int ackMode) throws Exception
    {
        Message msg;
        // Create producer.
        AMQConnection con0 = (AMQConnection) getConnection();
        con0.start();
        Session session0 = con0.createSession(false, ackMode);


        AMQTopic topic = new AMQTopic(con0, MY_TOPIC);


        Session sessionProd = con0.createSession(false, ackMode);

View Full Code Here

        Session sessionProd = con0.createSession(false, ackMode);
        MessageProducer producer = sessionProd.createProducer(topic);


        // Create consumer 1.
        AMQConnection con1 = (AMQConnection) getConnection();
        con1.start();
        Session session1 = con1.createSession(false, ackMode);


        MessageConsumer consumer1 = session1.createConsumer(topic);


        // Create consumer 2.

View Full Code Here


        MessageConsumer consumer1 = session1.createConsumer(topic);


        // Create consumer 2.
        AMQConnection con2 = (AMQConnection) getConnection();
        con2.start();
        Session session2 = con2.createSession(false, ackMode);


        TopicSubscriber consumer2 = session2.createDurableSubscriber(topic, MY_SUBSCRIPTION);


        // Send message and check that both consumers get it and only it.

View Full Code Here

        assertEquals(null, msg);


        // Re-attach a new consumer to the durable subscription, and check that it gets message B it left (if not NO_ACK)
        // and also gets message C sent after it was disconnected.
        AMQConnection con3 = (AMQConnection) getConnection();
        con3.start();
        Session session3 = con3.createSession(false, ackMode);


        TopicSubscriber consumer3 = session3.createDurableSubscriber(topic, MY_SUBSCRIPTION);


        if(ackMode == AMQSession.NO_ACKNOWLEDGE)

View Full Code Here

        publisher.publish(session1.createTextMessage("Hello2"));
        session1.commit();
        con2 =  (AMQConnection) getClientConnection("guest", "guest", "clientid");
        session2 = con2.createTopicSession(true, AMQSession.NO_ACKNOWLEDGE);
        sub = session2.createDurableSubscriber(topic, "subscription0");
        con2.start();
        tm = (TextMessage) sub.receive(2000);
        session2.commit();
        assertNotNull(tm);
        assertEquals("Hello2", tm.getText());
        session2.unsubscribe("subscription0");

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.