plz. find below my receiver code
| private void createJMSClient ()
| {
| final Properties props = new Properties();
| props.put(Context.INITIAL_CONTEXT_FACTORY,
"org.jnp.interfaces.NamingContextFactory");
| props.put(Context.URL_PKG_PREFIXES,
"org.jboss.naming:org.jnp.interfaces");
| props.put(Context.PROVIDER_URL,
"NOICLT13274:1100,NOICLT22560:1100,NOICLT13407:1100");
| props.put("jnp.timeout", "1000");
| props.put("jnp.sotimeout", "1000");
| props.put("jnp.disablediscovery", "true");
| props.put("jnp.partitionName", "NOICLT22560_PARTITION");
|
| try
| {
| final Context context = new InitialContext(props);
| ConnectionFactory mTopicConnectionFactory = (ConnectionFactory)
context.lookup("ClusteredConnectionFactory");
| System.out.println(mTopicConnectionFactory);
| Topic mTopic = (Topic) context.lookup("topic/CMSPublic");
|
| Connection mTopicConnection = mTopicConnectionFactory.createConnection();
| Session mTopicSession = mTopicConnection.createSession(false,
Session.AUTO_ACKNOWLEDGE);
|
| // Create subscriber
| MessageConsumer mSubscriber = mTopicSession.createConsumer(mTopic);
| mSubscriber.setMessageListener(this);
| mTopicConnection.setExceptionListener(this);
|
| mTopicConnection.start();
| isConnected = true;
| }
| catch (final CommunicationException anException)
| {
| // anException.printStackTrace();
| System.err.println("Server is not avaliable!!! \n Trying to reconnect
the server!! " + anException.getMessage());
| }
| catch (final NamingException anException)
| {
| // anException.printStackTrace();
| System.err.println("Server is not avaliable!!! \n Trying to reconnect
the server!! " + anException.getMessage());
| }
|
| catch (final JMSException anException)
| {
| // anException.printStackTrace();
| System.err.println("Server is not avaliable!!! \n Trying to reconnect
the server!! " + anException.getMessage());
| }
| catch (Exception finalException)
| {
| // finalException.printStackTrace();
| System.err.println("Exception while starting JMS event listener. You
may not be able to receive event, please restart your application");
| }
|
| }
|
View the original post :
http://www.jboss.org/index.html?module=bb&op=viewtopic&p=4250896#...
Reply to the post :
http://www.jboss.org/index.html?module=bb&op=posting&mode=reply&a...