Package javax.jms

Examples of javax.jms.MessageProducer.send()

100
101
102
103
104
105
106
107
108
109
110
        invoiceMessage.setInt("orderId", orderId);
        invoiceMessage.setFloat("amount", amount);

        // send it!
        MessageProducer producer = session.createProducer(invoiceQueue);
        producer.send(invoiceMessage);

        logger.log(
            Level.FINE,
            "sent invoice message for PO #{0,number,integer} with amount {1,number,currency}",
            new Object[] { orderId, amount });
View Full Code Here
91
92
93
94
95
96
97
98
99
100
101
        MapMessage message = session.createMapMessage();
        message.setString("customerId", customerId);

        // send it!
        MessageProducer producer = session.createProducer(shippingQueue);
        producer.send(message);

        logger.log(Level.FINE, "sent shipping message for customer {0}",
            customerId);
      }
      finally {
View Full Code Here
71
72
73
74
75
76
77
78
79
80
81
    TextMessage msg = session.createTextMessage();

    int i;
    for (i = 0; i < 10; i++) {
      msg.setText("Msg " + i);
      pub.send(msg);
    }
    session.commit();

    System.out.println(i + " messages published.");
View Full Code Here
54
55
56
57
58
59
60
61
62
63
64
    TextMessage msg = sess.createTextMessage();

    int i;
    for (i = 0; i < 1000; i++) {
      msg.setText("Msg " + i);
      pub.send(msg);
      Thread.sleep(250L);
      System.out.println("publish message " + i);
    }
  }
}
View Full Code Here
58
59
60
61
62
63
64
65
66
67
68
    cnx.start();

    // Producing messages with a very short time to live: 20 ms.
    System.out.println("Sends Message1 with a very short time to live");
    TextMessage msg = prodSession.createTextMessage("Message1");
    producer.send(queue1, msg, DeliveryMode.NON_PERSISTENT, Message.DEFAULT_PRIORITY, 20);
   
    // Waiting for the message to be expired.
    System.out.println("Waits for the message to be expired");
    Thread.sleep(100);
View Full Code Here
70
71
72
73
74
75
76
77
78
79
80
    System.out.println("receives: " + msg);
   
    // Producing "undeliverable" messages
    System.out.println("Send Message2");  
    msg = prodSession.createTextMessage("Message2");
    producer.send(queue1, msg);
   
    msg = (TextMessage) consumer.receive();
    System.out.println("Receives: " + msg.getText() + " then deny it!");
    consSession.rollback();
   
View Full Code Here
84
85
86
87
88
89
90
91
92
93
94
       
    // Producing "forbidden" messages
    System.out.println("Send Message3");  
    msg = prodSession.createTextMessage("Message3");
    try {
      producer.send(queue2, msg);
    } catch (JMSException exc) {
      System.out.println(exc.getMessage());
    }
   
//    // Producing a message to a deleted destination
View Full Code Here
53
54
55
56
57
58
59
60
61
62
63
    TextMessage msg = sess.createTextMessage();

    int i;
    for (i = 0; i < 5000; i++) {
      msg.setText("Msg " + i);
      pub.send(msg);
      Thread.sleep(250L);
      System.out.println("publish message " + i);
    }
  }
}
View Full Code Here
54
55
56
57
58
59
60
61
62
63
64
    producer = session.createProducer(queue);
    message = session.createTextMessage();

    for (int i = 1; i <= 100000; i++) {
      message.setText("Test number " + i);
      producer.send(message);

      if ((i % 100) == 0)session.commit();

      if ((i % 1000) == 0) System.out.println(i + " messages sent");
    }
View Full Code Here
52
53
54
55
56
57
58
59
60
61
62
    TextMessage msg = sess.createTextMessage();

    for (int i = 1; i <= 10; i++) {
      msg.setText("Soap test " + i);
      producer.send(queue, msg);
      System.out.println("SOAP test " + i);
    }

    sess.commit();
    cnx.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.