Java Reference
In-Depth Information
5.
Creates a
MessageProducer
and a
TextMessage
:
MessageProducer producer = session.createProducer(dest);
TextMessage message = session.createTextMessage();
6.
Sends one or more messages to the destination:
for (int i = 0; i < NUM_MSGS; i++) {
message.setText("This is message " + (i + 1) + " from produ-
cer");
System.out.println("Sending message: " + message.getText());
producer.send(message);
}
7.
Sends an empty control message to indicate the end of the message stream:
producer.send(session.createMessage());
Sending an empty message of no specified type is a convenient way to indicate to
the consumer that the final message has arrived.
8.
Closes the connection in a
finally
block, automatically closing the session and
MessageProducer
:
} finally {
if (connection != null) {
try { connection.close(); }
catch (JMSException e) { }
}
}
The receiving client,
synchconsumer/src/java/SynchConsumer.java
, per-
forms the following steps:
1.
Injects resources for a connection factory, queue, and topic.
2.
Assigns either the queue or the topic to a destination object, based on the specified
destination type.
3.
Creates a
Connection
and a
Session
.
4.
Creates a
MessageConsumer
:
consumer = session.createConsumer(dest);
