Download Oracle Streams Advanced Queuing User's Guide and Reference

Publishing Messages Specifying Topic
TopicConnectionFactory
tc_fact
= null;
TopicConnection
t_conn
= null;
TopicSession
jms_sess;
TopicPublisher
publisher1;
Topic
shipped_orders;
int
myport = 5521;
/* create connection and session */
tc_fact = AQjmsFactory.getTopicConnectionFactory(
"MYHOSTNAME",
"MYSID",
myport,
"oci8");
t_conn = tc_fact.createTopicConnection("jmstopic", "jmstopic");
/* create TopicSession */
jms_sess = t_conn.createTopicSession(true, Session.CLIENT_ACKNOWLEDGE);
/* get shipped orders topic */
shipped_orders = ((AQjmsSession )jms_sess).getTopic(
"OE",
"Shipped_Orders_Topic");
publisher1 = jms_sess.createPublisher(shipped_orders);
/* create TextMessage */
TextMessage
jms_sess.createTextMessage();
/* publish without specifying the topic */
publisher1.publish(text_message);
Example 14–7
Publishing Specifying Correlation and Delay
TopicConnectionFactory
tc_fact
= null;
TopicConnection
t_conn
= null;
TopicSession
jms_sess;
TopicPublisher
publisher1;
Topic
shipped_orders;
int
myport = 5521;
/* create connection and session */
tc_fact = AQjmsFactory.getTopicConnectionFactory(
"MYHOSTNAME",
"MYSID",
myport,
"oci8");
t_conn = tc_fact.createTopicConnection("jmstopic", "jmstopic");
jms_sess = t_conn.createTopicSession(true, Session.CLIENT_ACKNOWLEDGE);
shipped_orders = ((AQjmsSession )jms_sess).getTopic(
"OE",
"Shipped_Orders_Topic");
publisher1 = jms_sess.createPublisher(shipped_orders);
/* Create TextMessage */
TextMessage
jms_sess.createTextMessage();
/* Set correlation and delay */
/* Set correlation */
jms_sess.setJMSCorrelationID("FOO");
/* Set delay of 30 seconds */
jms_sess.setLongProperty("JMS_OracleDelay", 30);
/* Publish */
publisher1.publish(text_message);
Publishing Messages Specifying Topic
public void publish(javax.jms.Topic topic, javax.jms.Message message)
throws JMSException
Oracle JMS Publish/Subscribe 14-5