Package javax.jms

Examples of javax.jms.QueueConnection.start()

488
489
490
491
492
493
494
495
496
497
498
            s_send = qc.createQueueSession(true, Session.AUTO_ACKNOWLEDGE);
            /* Create a session on top of the connection which will be used only for
            receiving messages, transacted and with auto-acknowledge-mode */
            s_rec   = qc.createQueueSession(true, Session.AUTO_ACKNOWLEDGE);
            /* start the connection */
            qc.start();
            /* Create a receiver */
            QueueReceiver qr = s_rec.createReceiver(q);
            /* Create a sender for sending messages */
            QueueSender qsender = s_send.createSender(q);
            /* create a couple of messages for sending */
 
View Full Code Here
561
562
563
564
565
566
567
568
569
570
571
            s_send = qc.createQueueSession(true, Session.AUTO_ACKNOWLEDGE);
            /* Create a session on top of the connection which will be used only for
            receiving messages, transacted and with auto-acknowledge-mode */
            s_rec   = qc.createQueueSession(true, Session.AUTO_ACKNOWLEDGE);
            /* start the connection */
            qc.start();
            /* Create a receiver */
            QueueReceiver qr = s_rec.createReceiver(q);
            /* Create a sender for sending messages */
            QueueSender qsender = s_send.createSender(q);
            /* create a couple of messages for sending */
 
View Full Code Here
642
643
644
645
646
647
648
649
650
651
652
            s_send = qc.createQueueSession(true, Session.AUTO_ACKNOWLEDGE);
            /* Create a session on top of the connection which will be used only for
            receiving messages, transacted and with auto-acknowledge-mode */
            s_rec   = qc.createQueueSession(true, Session.AUTO_ACKNOWLEDGE);
            /* start the connection */
            qc.start();
            /* Create a receiver */
            QueueReceiver qr = s_rec.createReceiver(q);
            /* Create a sender for sending messages */
            QueueSender qsender = s_send.createSender(q);
            /* create a message for sending */
 
View Full Code Here
741
742
743
744
745
746
747
748
749
750
751
            s_send = qc.createQueueSession(true, Session.AUTO_ACKNOWLEDGE);
            /* Create a session on top of the connection which will be used only for
            receiving messages, transacted and with auto-acknowledge-mode */
            s_rec   = qc.createQueueSession(true, Session.AUTO_ACKNOWLEDGE);
            /* start the connection */
            qc.start();
            /* Create a receiver */
            QueueReceiver qr = s_rec.createReceiver(q);
            /* Create a sender for sending messages */
            QueueSender qsender = s_send.createSender(q);
            /* send messages with priority */
 
View Full Code Here
794
795
796
797
798
799
800
801
802
803
804
            s_send = qc.createQueueSession(true, Session.AUTO_ACKNOWLEDGE);
            /* Create a session on top of the connection which will be used only for
            receiving messages, transacted and with auto-acknowledge-mode*/
            s_rec   = qc.createQueueSession(true, Session.AUTO_ACKNOWLEDGE);
            /* start the connection */
            qc.start();
            /* Create some receivers, each with a different selector */
            QueueReceiver qr_plain = s_rec.createReceiver(q);
            QueueReceiver qr_aaa   = s_rec.createReceiver(q, "myprop='aaa'");
            QueueReceiver qr_bbb   = s_rec.createReceiver(q, "myprop='bbb'");
            /* Create a sender for sending messages */
 
View Full Code Here
922
923
924
925
926
927
928
929
930
931
932
            s_send = qc.createQueueSession(true, Session.AUTO_ACKNOWLEDGE);
            /* Create a session on top of the connection which will be used only for
            receiving messages, transacted and with auto-acknowledge-mode */
            s_rec   = qc.createQueueSession(true, Session.AUTO_ACKNOWLEDGE);
            /* start the connection */
            qc.start();
            /* Create a receiver and set a message-listener. This will be used to see,
               whether messages are delivered before the session is commited */
            QueueReceiver qr = s_rec.createReceiver(q);
            /* Create a sender for sending messages */
            QueueSender qsender = s_send.createSender(q);
View Full Code Here
112
113
114
115
116
117
118
119
120
121
122
                    queueConnectionFactory.createQueueConnection();
            queueSession =
                    queueConnection.createQueueSession(false,
                            Session.AUTO_ACKNOWLEDGE);
            queueReceiver = queueSession.createReceiver(queue);
            queueConnection.start();
            while (true) {
                Message m = queueReceiver.receive(1);
                if (m != null) {
                    if (m instanceof TextMessage) {
                        message = (TextMessage) m;
View Full Code Here
132
133
134
135
136
137
138
139
140
141
142
                                      "Failed to locate connection factory");
        }

        // Create a connection to the queue.
        QueueConnection connection = factory.createQueueConnection();
        connection.start();

        String ackMode = (String) configuration.getProperty("jms.ackmode");

        if (ackMode != null) {
            if (ackMode.equals("auto")) {
View Full Code Here
194
195
196
197
198
199
200
201
202
203
204
                    if (cmdline.exists("summary")) {
                        summary = true;
                    }
                   
                    QueueConnection connection = factory.createQueueConnection();
                    connection.start();

                    QueueSession session = connection.createQueueSession(
                        false, Session.CLIENT_ACKNOWLEDGE);

                    // if the persistent flag is not specified then create the
View Full Code Here
2529
2530
2531
2532
2533
2534
2535
2536
2537
2538
2539
    public Map lookForMessage (String channel) {
        QueueConnection qc = null;
        QueueSession qs = null;
        try {
            qc = queueConnectionFactory().createQueueConnection();
            qc.start();
            qs = qc.createQueueSession (true, 0);
            QueueReceiver rec = qs.createReceiver
                (channelInQueue(), "processKey = '"
                 + ((Long)ctx.getPrimaryKey()).toString() + "'"
                 + " AND channelName = '" + channel + "'");
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.