Package javax.jms

Examples of javax.jms.QueueSender.send()

86
87
88
89
90
91
92
93
94
95
96
        }
        sender.send(validDestination,msg);
        sender.close();
        validDestination = new AMQQueue("amq.direct","knownQ");
        sender = queueSession.createSender(validDestination);
        sender.send(msg);




    }
View Full Code Here
116
117
118
119
120
121
122
123
124
125
126
            QueueSender sender = session.createSender(queue);
            for (int i = 0 ; i < 10 ; i++) {
                String s = "Test" + i;
                TextMessage msg = session.createTextMessage(s);
                sender.send(msg);
            }

            Assert.assertTrue(latch.await(3, TimeUnit.SECONDS));
            Assert.assertEquals(10, result.size());
            for (int i = 0 ; i < result.size() ; i++) {
View Full Code Here
92
93
94
95
96
97
98
99
100
101
102
        QueueConnection qConn = connectionFactory.createQueueConnection();
        QueueSession qSess = qConn.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
        QueueSender qSender = qSess.createSender(queue);
        TextMessage message = qSess.createTextMessage("<?xml version=\"1.0\" encoding=\"UTF-8\"?><hello>world</hello>");
        qSender.send(message);

        receiver.getMessageList().assertMessagesReceived(1);
        List msgs = receiver.getMessageList().flushMessages();
        NormalizedMessage msg = (NormalizedMessage) msgs.get(0);
        assertEquals("Messages match", message.getText(), new SourceTransformer().contentToString(msg));
View Full Code Here
87
88
89
90
91
92
93
94
95
96
97
      ObjectMessage message = session.createObjectMessage();
      message.setObject( data );
      message.setStringProperty( INDEX_NAME_JMS_PROPERTY, indexName );

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

      session.close();
    }
    catch (JMSException e) {
      throw log.unableToSendJMSWork( indexName, processor.getJmsQueueName(), e );
View Full Code Here
86
87
88
89
90
91
92
93
94
95
96
      ObjectMessage message = session.createObjectMessage();
      message.setObject( data );
      message.setStringProperty( INDEX_NAME_JMS_PROPERTY, indexName );

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

      session.close();
    }
    catch (JMSException e) {
      throw new SearchException( "Unable to send Search work to JMS queue: " + processor.getJmsQueueName(), e );
View Full Code Here
86
87
88
89
90
91
92
93
94
95
96
      ObjectMessage message = session.createObjectMessage();
      message.setObject( data );
      message.setStringProperty( INDEX_NAME_JMS_PROPERTY, indexName );

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

      session.close();
    }
    catch (JMSException e) {
      throw new SearchException( "Unable to send Search work to JMS queue: " + processor.getJmsQueueName(), e );
View Full Code Here
336
337
338
339
340
341
342
343
344
345
346
            getLogger().log(Level.FINE, "client sending request: ",  jmsMessage);
            //getting  Destination Style
            if (base.isDestinationStyleQueue()) {
                QueueSender sender = (QueueSender)pooledSession.producer();
                sender.setTimeToLive(ttl);
                sender.send((Queue)base.targetDestination, jmsMessage, deliveryMode, priority, ttl);
            } else {
                TopicPublisher publisher = (TopicPublisher)pooledSession.producer();
                publisher.setTimeToLive(ttl);
                publisher.publish((Topic)base.targetDestination, jmsMessage, deliveryMode, priority, ttl);
            }
View Full Code Here
147
148
149
150
151
152
153
154
155
156
157
          false, Session.AUTO_ACKNOWLEDGE);
      QueueSender queueSender = queueSession.createSender(queue);
      TextMessage message = queueSession.createTextMessage();
      message.setStringProperty("messageType", messageType);
      message.setText(contents);
      queueSender.send(message);

      return NotificationAcknowledgment.getAckString();

    } catch (JMSException e) {
      e.printStackTrace();
View Full Code Here
86
87
88
89
90
91
92
93
94
95
96
      ObjectMessage message = session.createObjectMessage();
      message.setObject( data );
      message.setStringProperty( Environment.INDEX_NAME_JMS_PROPERTY, indexName );

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

      session.close();
    }
    catch (JMSException e) {
      throw log.unableToSendJMSWork( indexName, processor.getJmsQueueName(), e );
View Full Code Here
65
66
67
68
69
70
71
72
73
74
75
    public void sendAMessage(String msg) throws JMSException {
     
        QueueSender sender = session.createSender(queue);       
        ObjectMessage objectMsg = session.createObjectMessage(msg);
       
        sender.send(objectMsg);       
        sender.close();
    }
      
   
    public static void main(String args[]) throws Exception
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.