Package javax.jms

Examples of javax.jms.QueueSender.send()

481
482
483
484
485
486
487
488
489
490
491
         TextMessage message = session.createTextMessage();
         message.setText("testOnCreateMDBTimer");
         message.setIntProperty("UNIQUE_ID", 123456788);
         message.setJMSReplyTo(queueB);
         sender.send(message);

         // Get the initial onMessage ack
         Message reply = receiver.receive(15000);
         log.info("onMessage reply: " + reply);
         assertTrue("onMessage reply != null", reply != null);
View Full Code Here
760
761
762
763
764
765
766
767
768
769
770
      // Make the message
      final TextMessage message = sendSession.createTextMessage(contents);

      // Send the message
      final QueueSender sender = sendSession.createSender(queue);
      sender.send(message);
      log.info("Sent message " + message + " with contents: " + contents);

      // Clean up
      sendSession.close();
      connection.close();
View Full Code Here
66
67
68
69
70
71
72
73
74
75
76
            QueueConnection connection = qcf.createQueueConnection();
            connection.start();
            QueueSession session = connection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
            QueueSender queueSender = session.createSender(queue);
            TextMessage tmsg = session.createTextMessage("JMS - Test Queue Message");
            queueSender.send(tmsg);
            queueSender.close();
            session.close();
            connection.stop();
            out.println("<html xmlns='http://www.w3.org/1999/xhtml' xml:lang='en' lang='en'>");
            out.println("<head><title>JMS Sender</title></head>");
View Full Code Here
1079
1080
1081
1082
1083
1084
1085
1086
1087
1088
1089
            QueueSender sender = session.createSender(queue);
            for (int i = 0 ; i < 10 ; i++) {
                String s = "Test" + i;
                stdout.println("----> Sending: " +s );
                TextMessage msg = session.createTextMessage(s);
                sender.send(msg);
            }
        }
        finally {
            try {
                conn.stop();
View Full Code Here
99
100
101
102
103
104
105
106
107
108
109
            QueueSender sender = session.createSender(queue);
            for (int i = 0 ; i < 10 ; i++) {
                String s = "Test" + i;
                System.out.println("----> Sending: " +s );
                TextMessage msg = session.createTextMessage(s);
                sender.send(msg);
            }

            Thread.sleep(1000);

        } finally {
View Full Code Here
123
124
125
126
127
128
129
130
131
132
133
        try {
            session = conn.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
            QueueSender sender = session.createSender(queue);
            TextMessage msg = session.createTextMessage(value);
            log.info("Sending '" + value + "' via queue");
            sender.send(msg);
        } catch (JMSException e) {
            throw new ServletException(e);
        } finally {
            try {
                if (session != null) {
View Full Code Here
74
75
76
77
78
79
80
81
82
83
84
      ObjectMessage message = session.createObjectMessage();
      message.setObject( (Serializable) filteredQueue );

      sender = session.createSender( factory.getJmsQueue() );
      sender.send( message );

      session.close();
    }
    catch (JMSException e) {
      throw new HibernateException( "Unable to send Search work to JMS queue: " + factory.getJmsQueueName(), e );
View Full Code Here
61
62
63
64
65
66
67
68
69
70
71
        QueueSender sender = queueSession.createSender(invalidDestination);
        TextMessage msg = queueSession.createTextMessage("Hello");
        try
        {
            sender.send(msg);
            fail("Expected InvalidDestinationException");
        }
        catch (InvalidDestinationException ex)
        {
            // pass
View Full Code Here
75
76
77
78
79
80
81
82
83
84
85
        sender = queueSession.createSender(null);
        invalidDestination = new AMQQueue("amq.direct","unknownQ");

        try
        {
            sender.send(invalidDestination,msg);
            fail("Expected InvalidDestinationException");
        }
        catch (InvalidDestinationException ex)
        {
            // pass
View Full Code Here
82
83
84
85
86
87
88
89
90
91
92
        }
        catch (InvalidDestinationException ex)
        {
            // pass
        }
        sender.send(validDestination,msg);
        sender.close();
        validDestination = new AMQQueue("amq.direct","knownQ");
        sender = queueSession.createSender(validDestination);
        sender.send(msg);
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.