Issues w/ JBoss Messging Cluster Environment when using Dura

[guy.finger]

I am trying to set up the JBoss cluster in two machines. Here are the steps I have followed to set up and test the examples -

1) Installed the JBoss4.0.5 on 2 machines by using the default partition name
2) Modified the config files to refer to our in house Oracle Database
3) Installed the jboss-messaging1.2.CR1 on both the machines
4) Modified/added the config files to refer in house Oracle Database
5) Started the servers
6) Verified that the JMS related Tables have created in Oracle Database or not. They are created.
6) Ran the examples on Node1 machine
- When both Nodes are up and running
- Queue and Topic examples ran well
- Getting exceptions while trying to run the other(Queue Failover, mdb etc.) examples.
- When I shut down the Node1 server
- None of the examples are running
7) Modifed jndi.properties file to set PORVIDER_URL parameter to 2 Nodes URLs on Node1 machine
- When both Nodes are up and running
- Queue and Topic examples ran well
- Getting exceptions while trying to run the other(Queue Failover, mdb etc.) examples.
- When I shut down the Node1 server
- Queue and Topic examples ran well
- Getting exceptions while trying to run the other(Queue Failover, mdb etc.) examples.

After the above steps, I have following questions -

1) Why is Auto-Failover is not working?
2) Is there something wrong w/ my cluster configuration?
3) Do the clients need to know about all the running clusters?
4) How do both the clusters know each other?
5) Is there any heartbeat mechanism b/w both the clusters?
6) How do I make one of the cluster as ACTIVE node and the other as INACTIVE?(Inactive one becomes only active when the current active one becomes unavailable)


Also I have written clients for both publisher and subscriber. We are planning to use durable subscriber. But I am unable to retrive any messages from my subscriber.

Here is the code -

Publisher

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.Topic;
import javax.jms.TopicConnection;
import javax.jms.TopicConnectionFactory;
import javax.jms.TopicPublisher;
import javax.jms.TopicSubscriber;
import javax.jms.TopicSession;
import javax.jms.TextMessage;
import javax.jms.DeliveryMode;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;
import java.util.Hashtable;
import javax.jms.MessageListener;

/** A JMS client example program that sends a TextMessage to a Topic*/

public class TopicSendClient{

 TopicConnection conn = null;
 TopicConnection conn1 = null;

 TopicSession session = null;

 Topic topic = null;

 String CLIENT_ID = "TopicClient";

 long MESSAGE_LIFESPAN = 1800000; //30 minutes

 public void setupPubSub() {
 System.out.println("setupPubSub()");


 // Initial environment with various properties
 Hashtable<Object, Object> env = new Hashtable<Object, Object>();
 env.put(Context.INITIAL_CONTEXT_FACTORY, "org.jnp.interfaces.NamingContextFactory");
 env.put(Context.PROVIDER_URL, "jnp://server1:1099,jnp://server2:1099");
 env.put(Context.URL_PKG_PREFIXES, "org.jboss.naming:org.jnp.interfaces");

 try{
 System.out.println("Before()");
 InitialContext iniCtx = new InitialContext(env);

 System.out.println("ConnectionFactory Not exists");

 //InitialContext iniCtx = new InitialContext();
 Object tmp = iniCtx.lookup("ConnectionFactory");

 System.out.println("ConnectionFactory exists");

 TopicConnectionFactory tcf = (TopicConnectionFactory) tmp;

 //topic = (Topic) iniCtx.lookup("topic/testDistributedTopic");
 topic = (Topic) iniCtx.lookup("topic/testTopic");

 System.out.println("TCF exists");

 conn = tcf.createTopicConnection();
 //conn1 = tcf.createTopicConnection();

 //conn.setClientID(CLIENT_ID);

 System.out.println("Topic testTopic exists");

 session = conn.createTopicSession(false, TopicSession.AUTO_ACKNOWLEDGE);

 conn.start();
 }catch(Exception e){
 System.out.println("TopicConnection Not started"+e.getMessage());
 e.printStackTrace();
 }


 }


 public void sendAsync(String text) throws JMSException, NamingException {

 System.out.println("Begin sendAsync");

 // Setup the pub/sub connection, session
 setupPubSub();

 // Send a text msg
 TopicPublisher send = session.createPublisher(topic);


 TextMessage tm = session.createTextMessage(text);

 //send.publish(tm);
 send.publish( tm, DeliveryMode.PERSISTENT, Message.DEFAULT_PRIORITY, -1 );

 System.out.println("sendAsync, sent text="+ tm.getText());

 send.close();

 System.out.println("End sendAsync");

 }


 public void stop() throws JMSException {

 conn.stop();

 session.close();

 conn.close();

 }


 public static void main(String args[]) throws Exception {

 System.out.println("Begin TopicSendClient, now="+System.currentTimeMillis());

 TopicSendClient client = new TopicSendClient();

 client.sendAsync("A text msg, now="+System.currentTimeMillis());

 client.stop();

 System.out.println("End TopicSendClient");

 System.exit(0);

 }
}

Subscriber

import javax.jms.JMSException;

import javax.jms.Message;

import javax.jms.MessageListener;

import javax.jms.Topic;

import javax.jms.TopicConnection;

import javax.jms.TopicConnectionFactory;

import javax.jms.TopicPublisher;

import javax.jms.TopicSubscriber;

import javax.jms.TopicSession;

import javax.jms.TextMessage;

import javax.naming.Context;

import javax.naming.InitialContext;

import javax.naming.NamingException;

import java.util.Hashtable;

/** A JMS client example program that synchronously receives a message a Topic */

public class TopicRecvClient {

 TopicConnection conn = null;

 TopicSession session = null;

 Topic topic = null;

 String CLIENT_ID = "guest";

 long MESSAGE_LIFESPAN = 1800000; //30 minutes
 //long MESSAGE_LIFESPAN = 5000;


 public void setupPubSub() throws JMSException, NamingException{

 // Initial environment with various properties
 Hashtable<Object, Object> env = new Hashtable<Object, Object>();
 env.put(Context.INITIAL_CONTEXT_FACTORY, "org.jnp.interfaces.NamingContextFactory");
 env.put(Context.PROVIDER_URL, "jnp://server1:1099,jnp://server2:1099");
 env.put(Context.URL_PKG_PREFIXES, "org.jboss.naming:org.jnp.interfaces");
 env.put (Context.SECURITY_PRINCIPAL, "guest");
 env.put (Context.SECURITY_CREDENTIALS, "guest");
 //env.put(Context.OBJECT_FACTORIES, "foo.bar.ObjFactory");
 //env.put("foo", "bar")

 InitialContext iniCtx = new InitialContext(env);

 Object tmp = iniCtx.lookup("ConnectionFactory");

 TopicConnectionFactory tcf = (TopicConnectionFactory) tmp;

 conn = tcf.createTopicConnection("guest","guest");
 //conn = tcf.createTopicConnection();

 topic = (Topic) iniCtx.lookup("topic/testTopic");

 //conn.setClientID(CLIENT_ID);

 session = conn.createTopicSession(false, TopicSession.AUTO_ACKNOWLEDGE);

 conn.start();

 }


 public void recvSync() throws JMSException, NamingException
 {

 System.out.println("Begin recvSync");

 // Setup the pub/sub connection, session

 setupPubSub();

 // Wait upto 5 seconds for the message

 //TopicSubscriber recv = session.createSubscriber(topic);

 TopicSubscriber recv = session.createDurableSubscriber(topic, "SampleSubscription");


 Message msg = recv.receive(5000);

 if( msg == null )

 System.out.println("Timed out waiting for msg");

 else

 System.out.println("TopicSubscriber.recv, msgt="+msg);

 }


 public void stop() throws JMSException
 {

 conn.stop();

 session.close();

 conn.close();

 }

 public static void main(String args[]) throws Exception
 {

 System.out.println("Begin TopicRecvClient, now="+System.currentTimeMillis());

 TopicRecvClient client = new TopicRecvClient();


 client.recvSync();
 client.stop();

 System.out.println("End TopicRecvClient");

 System.exit(0);

 }
}

Thanks!!!
Rajendra

[clebert.suconic]

At this point... failover will only kick in when a server crashes or the connection dies.

We will be working on a clean leave for 1.2.1.

If you kill your server, your failover should work.

[guy.finger]

Are you saying that my setup is correct?

Additionally, could you please review my examples and let me know why I am not receiving messages published through the publisher?

[guy.finger]

Could any one please respond?

I am unable to subcribe the messages I have published through my client. I am using Durable Subscriber. I am running the Subscriber client after I publsih all the mesages.

Please verify whether my set up is correct or not.

[timfox]

Hi-

The messaging team are currently working 20 hours a day on the 1.2.GA release so are unable to answer your question right now.

If you have a support contract you could use that to get a quick response.

JBoss Messaging 1.2.GA will be out very shortly and we'll include a section on configuring clustering which should help you out.

Thanks.

[timfox]

As a brief note:

Have you followed the instructions on how to install clustering in the clustering guide in the distro? (docs/clustering/pdf/ClusteringGuide.pdf)

This will take you through how to install clustering and running the examples.

Once you have the examples running you know clustering works.

Then you can use the examples as a template to get your own program to work.

[guy.finger]

I have followed the instructions specified ClusterGuide.pdf file only. Some reason, I am not able to receive any of the messages by using Durable Subscriber.

I have heard that, I need to modify the some state config file to specify the user name and then use that particular user in my client while creating connection.

Could any one of you give me more details about the same?