Package javax.jms

Examples of javax.jms.TopicConnection.start()

181
182
183
184
185
186
187
188
189
190
191
            assertEquals("DurableSubscription backing queue should have 1 message on it initially",
                          new Integer(1), dursubQueue.getMessageCount());
           
            // Create a connection and start it
            TopicConnection connection = (TopicConnection) getConnection();
            connection.start();
           
            // Send messages which don't match and do match the selector, checking message count
            TopicSession pubSession = connection.createTopicSession(true, org.apache.qpid.jms.Session.SESSION_TRANSACTED);
            Topic topic = pubSession.createTopic(TOPIC_NAME);
            TopicPublisher publisher = pubSession.createPublisher(topic);
View Full Code Here
251
252
253
254
255
256
257
258
259
260
261
     */
    public void testBindingAndMessageDurabability() throws Exception
    {
        // Create a connection and start it
        TopicConnection connection = (TopicConnection) getConnection();
        connection.start();

        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        Queue queue = session.createQueue(QUEUE_NAME);
        MessageProducer messageProducer = session.createProducer(queue);

View Full Code Here
267
268
269
270
271
272
273
274
275
276
277
        // Restart the broker
        restartBroker();

        // Drain the queue of all messages
        connection = (TopicConnection) getConnection();
        connection.start();
        consumeQueueMessages(connection, true);
    }

    /**
     * Test that all of the committed persistent messages previously sent to
View Full Code Here
146
147
148
149
150
151
152
153
154
155
156
    private void prepareDurableSubscription() throws Exception
    {

        // Create a connection
        TopicConnection connection = _connFac.createTopicConnection();
        connection.start();
        connection.setExceptionListener(new ExceptionListener()
        {
            public void onException(JMSException e)
            {
                e.printStackTrace();
View Full Code Here
104
105
106
107
108
109
110
111
112
113
114
    conControl.replay();

    SingleConnectionFactory scf = new SingleConnectionFactory(con);
    TopicConnection con1 = scf.createTopicConnection();
    con1.start();
    con1.stop();  // should be ignored
    con1.close();  // should be ignored
    TopicConnection con2 = scf.createTopicConnection();
    con2.start();
    con2.stop();  // should be ignored
View Full Code Here
108
109
110
111
112
113
114
115
116
117
118
    TopicConnection con1 = scf.createTopicConnection();
    con1.start();
    con1.stop();  // should be ignored
    con1.close();  // should be ignored
    TopicConnection con2 = scf.createTopicConnection();
    con2.start();
    con2.stop();  // should be ignored
    con2.close();  // should be ignored
    scf.destroy();  // should trigger actual close

    conControl.verify();
View Full Code Here
217
218
219
220
221
222
223
224
225
226
227
    MockControl conControl = MockControl.createControl(TopicConnection.class);
    TopicConnection con = (TopicConnection) conControl.getMock();

    cf.createConnection();
    cfControl.setReturnValue(con, 1);
    con.start();
    conControl.setVoidCallable(2);
    con.stop();
    conControl.setVoidCallable(1);
    con.close();
    conControl.setVoidCallable(1);
View Full Code Here
248
249
250
251
252
253
254
255
256
257
258
    MockControl conControl = MockControl.createControl(TopicConnection.class);
    TopicConnection con = (TopicConnection) conControl.getMock();

    cf.createTopicConnection();
    cfControl.setReturnValue(con, 1);
    con.start();
    conControl.setVoidCallable(2);
    con.stop();
    conControl.setVoidCallable(1);
    con.close();
    conControl.setVoidCallable(1);
View Full Code Here
435
436
437
438
439
440
441
442
443
444
445
    MockControl conControl = MockControl.createControl(TopicConnection.class);
    TopicConnection con = (TopicConnection) conControl.getMock();

    cf.createTopicConnection();
    cfControl.setReturnValue(con, 1);
    con.start();
    conControl.setVoidCallable(2);
    con.stop();
    conControl.setVoidCallable(1);
    con.close();
    conControl.setVoidCallable(1);
View Full Code Here
447
448
449
450
451
452
453
454
455
456
457
    cfControl.replay();
    conControl.replay();

    SingleConnectionFactory scf = new SingleConnectionFactory102(cf, true);
    TopicConnection con1 = scf.createTopicConnection();
    con1.start();
    con1.close();  // should be ignored
    TopicConnection con2 = scf.createTopicConnection();
    con2.start();
    con2.close();  // should be ignored
    scf.destroy();  // should trigger actual close
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
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.