Package javax.jms

Examples of javax.jms.QueueConnection.start()

28
29
30
31
32
33
34
35
36
37
38
        try {
          Context ctx = new InitialContext();
          QueueConnectionFactory factory = (QueueConnectionFactory)
           ctx.lookup("QueueCF");
      QueueConnection connection = factory.createQueueConnection();
      connection.start();
     
      Queue queue = (Queue)ctx.lookup("request");
      session =
        connection.createQueueSession(false, Session.DUPS_OK_ACKNOWLEDGE);
      QueueReceiver receiver = session.createReceiver(queue);
View Full Code Here
239
240
241
242
243
244
245
246
247
248
249
    QueueSession session = null;
    try {
      session = con.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
      Queue queueToUse = resolveQueue(session);
      Message requestMessage = createRequestMessage(session, invocation);
      con.start();
      Message responseMessage = doExecuteRequest(session, queueToUse, requestMessage);
      return extractInvocationResult(responseMessage);
    }
    finally {
      JmsUtils.closeSession(session);
View Full Code Here
205
206
207
208
209
210
211
212
213
214
215
    QueueRequestor requestor = null;
    try {
      session = con.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
      Queue queueToUse = resolveQueue(session);
      Message requestMessage = createRequestMessage(session, invocation);
      con.start();
      Message responseMessage = doExecuteRequest(session, queueToUse, requestMessage);
      return extractInvocationResult(responseMessage);
    }
    finally {
      JmsUtils.closeQueueRequestor(requestor);
View Full Code Here
98
99
100
101
102
103
104
105
106
107
108
                InitialContext ctx = new InitialContext(properties);
                // Lookup connection factory
                QueueConnectionFactory connFactory =
                        (QueueConnectionFactory) ctx.lookup(StatusMonitorAgentConstants.CF_NAME);
                QueueConnection queueConnection = connFactory.createQueueConnection();
                queueConnection.start();
                QueueSession queueSession =
                        queueConnection.createQueueSession(false, QueueSession.AUTO_ACKNOWLEDGE);

                // Send message
                Queue queue = queueSession.createQueue(StatusMonitorAgentConstants.QUEUE_NAME_MB +
View Full Code Here
95
96
97
98
99
100
101
102
103
104
105
                // Lookup connection factory
                QueueConnectionFactory connFactory =
                        (QueueConnectionFactory) ctx.lookup(StatusMonitorAgentConstants.CF_NAME);
                QueueConnection queueConnection = connFactory.createQueueConnection();
                queueConnection.start();
                QueueSession queueSession =
                        queueConnection.createQueueSession(false, QueueSession.AUTO_ACKNOWLEDGE);

                // Send message
                Queue queue = queueSession.createQueue(StatusMonitorAgentConstants.QUEUE_NAME_CEP +
View Full Code Here
77
78
79
80
81
82
83
84
85
86
87
    conControl.replay();

    SingleConnectionFactory scf = new SingleConnectionFactory(con);
    QueueConnection con1 = scf.createQueueConnection();
    con1.start();
    con1.stop();  // should be ignored
    con1.close();  // should be ignored
    QueueConnection con2 = scf.createQueueConnection();
    con2.start();
    con2.stop();  // should be ignored
View Full Code Here
155
156
157
158
159
160
161
162
163
164
165
    MockControl conControl = MockControl.createControl(QueueConnection.class);
    QueueConnection con = (QueueConnection) 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
186
187
188
189
190
191
192
193
194
195
196
    MockControl conControl = MockControl.createControl(QueueConnection.class);
    QueueConnection con = (QueueConnection) conControl.getMock();

    cf.createQueueConnection();
    cfControl.setReturnValue(con, 1);
    con.start();
    conControl.setVoidCallable(2);
    con.stop();
    conControl.setVoidCallable(1);
    con.close();
    conControl.setVoidCallable(1);
View Full Code Here
404
405
406
407
408
409
410
411
412
413
414
    MockControl conControl = MockControl.createControl(QueueConnection.class);
    QueueConnection con = (QueueConnection) conControl.getMock();

    cf.createQueueConnection();
    cfControl.setReturnValue(con, 1);
    con.start();
    conControl.setVoidCallable(2);
    con.stop();
    conControl.setVoidCallable(1);
    con.close();
    conControl.setVoidCallable(1);
View Full Code Here
416
417
418
419
420
421
422
423
424
425
426
    cfControl.replay();
    conControl.replay();

    SingleConnectionFactory scf = new SingleConnectionFactory102(cf, false);
    QueueConnection con1 = scf.createQueueConnection();
    con1.start();
    con1.close();  // should be ignored
    QueueConnection con2 = scf.createQueueConnection();
    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.