• Post Reply Bookmark Topic Watch Topic
  • New Topic
programming forums Java Mobile Certification Databases Caching Books Engineering Micro Controllers OS Languages Paradigms IDEs Build Tools Frameworks Application Servers Open Source This Site Careers Other Pie Elite all forums
this forum made possible by our volunteer staff, including ...
Marshals:
  • Campbell Ritchie
  • Jeanne Boyarsky
  • Ron McLeod
  • Paul Clapham
  • Liutauras Vilda
Sheriffs:
  • paul wheaton
  • Rob Spoor
  • Devaka Cooray
Saloon Keepers:
  • Stephan van Hulst
  • Tim Holloway
  • Carey Brown
  • Frits Walraven
  • Tim Moores
Bartenders:
  • Mikalai Zaikin

JMS Temporary Topic/Queue

 
Ranch Hand
Posts: 312
  • Mark post as helpful
  • send pies
    Number of slices to send:
    Optional 'thank-you' note:
  • Quote
  • Report post to moderator
Hi,
I am using the following program to send/receive Topic Message using Temporary Topic. But after the receive() method the program waits for the message. How to solve the program.
Regards,
M.S.Raman
package com.ibm.mq;
import java.util.*;
import javax.jms.*;
import javax.naming.*;
import com.ibm.mq.jms.*;
public class MQ_JMS_Sample6 {
private java.lang.String CTX_FACTORY = "com.ibm.ejs.ns.jndi.CNInitialContextFactory";
private java.lang.String INIT_URL = "iiop://localhost:900/";
private javax.jms.TopicConnectionFactory factory;
private javax.jms.TopicConnection conn;
private javax.jms.TopicSession session;
private javax.jms.Topic topic;
private javax.naming.Context jndiContext;
private javax.jms.TopicSubscriber subscriber;
private javax.jms.TopicPublisher publisher;
public MQ_JMS_Sample6() {
try
{
jndiContext= getInitialContext();
}catch(NamingException ne)
{
System.out.println("NamingException occured: " + ne);
}
try
{
System.out.println("Inside the try loop");
factory= (TopicConnectionFactory)jndiContext.lookup("jms/TopicConnection1");
System.out.println("The factory: " + factory);
//topic= (Topic) jndiContext.lookup("jms/AllComputers");
//System.out.println("The Topic:" + topic);
}
catch(Exception je)
{
System.out.println("JMSException occured: " + je);
}
try
{
conn= factory.createTopicConnection();
session= conn.createTopicSession(false,Session.AUTO_ACKNOWLEDGE);
topic=session.createTemporaryTopic();
System.out.println("The Topic:" + topic);
//subscriber= session.createDurableSubscriber(topic,"Raman");
publisher= session.createPublisher(topic);
System.out.println("publisher: " + publisher);
TextMessage msgp= session.createTextMessage();
msgp.setText("Hi Raman this msg is sent thro temp topic");
System.out.println("THE MESSAGE IS : " + msgp.getText());
conn.start();
publisher.publish(msgp);
System.out.println("The message is published");
subscriber= session.createSubscriber(topic);
System.out.println("The Subscriber is : " + subscriber);
//********************************
Following statements are not printed
//********************************
TextMessage msg= (TextMessage)subscriber.receive();

System.out.println("Msg be received:" + msg.getText());

System.out.println("End of the program");


}
catch(Exception e1)
{
System.out.println("Exception occured: " + e1);
}

}
/**
* Insert the method's description here.
* Creation date: (3/20/01 12:09:27 PM)
* @return javax.naming.InitialContext
*/
public javax.naming.Context getInitialContext() throws javax.naming.NamingException{
Properties p= new Properties();
p.put(Context.INITIAL_CONTEXT_FACTORY,CTX_FACTORY);
p.put(Context.PROVIDER_URL,INIT_URL);
return new InitialContext(p);

}
/**
* Insert the method's description here.
* Creation date: (3/20/01 12:03:07 PM)
* @param args java.lang.String[]
*/
public static void main(String[] args) {new MQ_JMS_Sample6();}
}
 
With a little knowledge, a cast iron skillet is non-stick and lasts a lifetime.
reply
    Bookmark Topic Watch Topic
  • New Topic