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

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


        AMQTopic topic = new AMQTopic(con0, "MyTopic");


        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("guest", "guest");
        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("guest", "guest");
        con2.start();
        Session session2 = con2.createSession(false, ackMode);


        TopicSubscriber consumer2 = session2.createDurableSubscriber(topic, "MySubscription");


        // 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("guest", "guest");
        con3.start();
        Session session3 = con3.createSession(false, ackMode);


        TopicSubscriber consumer3 = session3.createDurableSubscriber(topic, "MySubscription");


        if(ackMode == AMQSession.NO_ACKNOWLEDGE)

View Full Code Here

        AMQQueue queue = new AMQQueue(new AMQBindingURL("test-queue"));
        MessageConsumer consumer = session.createConsumer(queue);


        MessageProducer producer_not_used_but_created_for_testing = session.createProducer(queue);


        connection.start();


        _logger.info("About to close consumer");


        consumer.close();

View Full Code Here

            });


        Connection con2 = (AMQConnection) getConnection("guest", "guest");
        AMQSession producerSession = (AMQSession) con2.createSession(false, Session.CLIENT_ACKNOWLEDGE);
        MessageProducer mandatoryProducer = producerSession.createProducer(queue);
        con.start();
        StreamMessage sm = producerSession.createStreamMessage();
        sm.writeInt(42);
        mandatoryProducer.send(sm);
        Thread.sleep(2000);
        con.close();

View Full Code Here

                    lock.notify();
                }
            }
        });


        con.start();


        long waitTime = 30000L;
        long waitUntilTime = System.currentTimeMillis() + waitTime;


        synchronized (lock)

View Full Code Here

        assertEquals("Incorrect vhost delivery data", 0, vhost.getTotalDataDelivered());
        assertEquals("Incorrect vhost receipt total", 5, vhost.getTotalMessagesReceived());
        assertEquals("Incorrect vhost receipt data", 1000, vhost.getTotalDataReceived());
        
        Connection test = new AMQConnection(_brokerUrl, USER, USER, "clientid", "test");
        test.start();
        receiveUsing(test, 5);
        
        for (ManagedConnection mc : _jmxUtils.getManagedConnections("test"))
        {
            if (addresses.contains(mc.getRemoteAddress()))

View Full Code Here

     * Test message totals when a connection is closed.
     */
    public void testMessageTotalsWithClosedConnections() throws Exception
    {
        Connection temp = new AMQConnection(_brokerUrl, USER, USER, "clientid", "test");
        temp.start();
        
        sendUsing(_test, 10, 100);
        sendUsing(temp, 10, 100);
        sendUsing(_test, 10, 100);
        Thread.sleep(2000);

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, "MySubscription");


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


        _logger.info("Producer sending message A");
        producer.send(session1.createTextMessage("A"));
        
        ((AMQSession<?, ?>) session1).sync();

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.