[jboss-user] [JBoss Messaging] - JBoss Messaging Assistance
jbossbill
do-not-reply at jboss.com
Tue Oct 24 04:26:51 EDT 2006
Hi,
We are using JBoss Messaging 1.0.1.GA
We have an application where we have set up simple failover.
We connect to 2 JBoss Messaging Servers on start up and use one as the primary and send messages to that server until it goes down, then we send to the other server. For consuming messages we connect to both servers and set up a MessageListener to receive messages. We use an ExceptionListener to detect a problem with any of the connections and initiate reconnection in a background thread.
Our main application is running on the same machine as one of the messaging servers. Each are running in a different application server.
Our issue is whenever the JBoss Messaging Server on the same machine as our main application goes down for whatever reason it has an effect on the other Server. We believe that the JBoss Messaging Servers should be in-dependant of each other, so one going down should NOT effect the other Server. But we have noticed that when one server goes down, the other server produces a warning from the SimpleConnectionManager which detects a problem with the remote client and removes all connection resources for the client process.
We have come up with a test to replicate our issue in our application.
Following is the test code that we used:
import java.util.Hashtable;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.MessageListener;
import javax.jms.MessageProducer;
import javax.jms.Queue;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;
public class TestMultiSessionMessageProducer {
/**
* @param args
*/
public static void main(String[] args) {
TestMultiSessionMessageProducer ml = new TestMultiSessionMessageProducer();
try {
ml.test();
} catch (JMSException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
private void test() throws JMSException {
// JMS Server1
Hashtable properties = new Hashtable();
properties.put(Context.INITIAL_CONTEXT_FACTORY,
"org.jnp.interfaces.NamingContextFactory");
properties.put(Context.URL_PKG_PREFIXES,
"org.jboss.naming:org.jnp.interfaces");
properties.put(Context.PROVIDER_URL, "jnp://161.117.20.38:1099");
properties.put(Context.SECURITY_PRINCIPAL, "admin");
properties.put(Context.SECURITY_CREDENTIALS, "admin");
ConnectionFactory connectionFactory = null;
try {
Context context = new InitialContext(properties);
connectionFactory = (ConnectionFactory) context
.lookup("ConnectionFactory");
} catch (NamingException ne) {
throw new RuntimeException(ne);
}
Connection connection = connectionFactory.createConnection();
Session session = connection.createSession(false,
Session.AUTO_ACKNOWLEDGE);
Queue queue = session.createQueue("publish.request");
MessageProducer producer = session.createProducer(queue);
// JMS Server2
Hashtable properties2 = new Hashtable();
properties2.put(Context.INITIAL_CONTEXT_FACTORY,
"org.jnp.interfaces.NamingContextFactory");
properties2.put(Context.URL_PKG_PREFIXES,
"org.jboss.naming:org.jnp.interfaces");
properties2.put(Context.PROVIDER_URL, "jnp://localhost:1099");
properties2.put(Context.SECURITY_PRINCIPAL, "admin");
properties2.put(Context.SECURITY_CREDENTIALS, "admin");
ConnectionFactory connectionFactory2 = null;
try {
Context context2 = new InitialContext(properties2);
connectionFactory2 = (ConnectionFactory) context2
.lookup("ConnectionFactory");
} catch (NamingException ne) {
throw new RuntimeException(ne);
}
Connection connection2 = connectionFactory2.createConnection();
Session session2 = connection2.createSession(false,
Session.AUTO_ACKNOWLEDGE);
Queue queue2 = session2.createQueue("publish.request");
MessageProducer producer2 = session2.createProducer(queue2);
boolean serverOne = true;
try {
int j = 0;
while (++j < 13000) {
System.out.println(j);
StringBuffer sb = new StringBuffer();
sb.append("");
for (int i=0; i < 100; i++) {
sb.append("" + i + "");
}
sb.append("");
TextMessage msg = session
.createTextMessage(sb.toString());
TextMessage msg2 = session2
.createTextMessage(sb.toString());
if (serverOne) {
try {
producer.send(msg);
serverOne = false;
} catch (Exception e) {
// send msg to other server
producer2.send(msg2);
serverOne = false;
}
} else
try {
producer2.send(msg2);
serverOne = true;
} catch (Exception e) {
// send msg to other server
producer.send(msg);
serverOne = true;
}
}
} finally {
if(producer != null)
producer.close();
if(session != null)
session.close();
if(connection != null)
connection.close();
if(producer2 != null)
producer2.close();
if(session2 != null)
session2.close();
if(connection != null)
connection2.close();
}
}
}
These are the steps we used to cause our issue:
1. Setup two JBoss Messaging Servers on different machines, create a queue named 'publish.request' on each
2. Start both JBoss Messaging Servers
2. Run test code on one of the machines running a JBoss Messaging Server
3. Kill the JBoss Messaging Server running on the same machine as the test code
4. Wait until you notice a warning shown on the JBoss Messaging Server which was NOT killed:
"17:06:44,640 WARN [SimpleConnectionManager] A problem has been detected with the connection to remote client 4h39k1l-65jq6z-etnyf5al-1-etnyf86b-9. It is possible the client has exited without closing its connection(s) or there is a network problem. All connection resources corresponding to that client process will now be removed."
5. When the test code tries to send a message to the Server which was not killed it fails with the following exception thrown in the test code console output:
2006-10-24 17:06:47,015 ERROR org.jboss.jms.client.container.ExceptionInterceptor - Caught Exception:
org.jboss.aop.NotFoundInDispatcherException: Object with oid: -2147483645 was not found in the Dispatcher
at org.jboss.aop.Dispatcher.invoke(Dispatcher.java:85)
at org.jboss.jms.server.remoting.JMSServerInvocationHandler.invoke(JMSServerInvocationHandler.java:127)
at org.jboss.remoting.ServerInvoker.invoke(ServerInvoker.java:1008)
at org.jboss.remoting.ServerInvoker.invoke(ServerInvoker.java:857)
at org.jboss.remoting.transport.socket.ServerThread.processInvocation(ServerThread.java:454)
at org.jboss.remoting.transport.socket.ServerThread.dorun(ServerThread.java:541)
at org.jboss.remoting.transport.socket.ServerThread.run(ServerThread.java:261)
at org.jboss.remoting.MicroRemoteClientInvoker.invoke(MicroRemoteClientInvoker.java:172)
at org.jboss.remoting.Client.invoke(Client.java:589)
at org.jboss.remoting.Client.invoke(Client.java:581)
at org.jboss.jms.client.delegate.DelegateSupport.invoke(DelegateSupport.java:111)
at org.jboss.jms.client.delegate.ClientSessionDelegate$send_N3028277934545793941.invokeNext(ClientSessionDelegate$send_N3028277934545793941.java)
at org.jboss.jms.client.container.TransactionAspect.handleSend(TransactionAspect.java:176)
at org.jboss.aop.advice.org.jboss.jms.client.container.TransactionAspect16.invoke(TransactionAspect16.java)
at org.jboss.jms.client.delegate.ClientSessionDelegate$send_N3028277934545793941.invokeNext(ClientSessionDelegate$send_N3028277934545793941.java)
at org.jboss.jms.client.container.ClosedInterceptor.invoke(ClosedInterceptor.java:182)
at org.jboss.aop.advice.PerInstanceInterceptor.invoke(PerInstanceInterceptor.java:117)
at org.jboss.jms.client.delegate.ClientSessionDelegate$send_N3028277934545793941.invokeNext(ClientSessionDelegate$send_N3028277934545793941.java)
at org.jboss.jms.client.container.ExceptionInterceptor.invoke(ExceptionInterceptor.java:69)
at org.jboss.jms.client.delegate.ClientSessionDelegate$send_N3028277934545793941.invokeNext(ClientSessionDelegate$send_N3028277934545793941.java)
at org.jboss.jms.client.container.ClientLogInterceptor.invoke(ClientLogInterceptor.java:107)
at org.jboss.jms.client.delegate.ClientSessionDelegate$send_N3028277934545793941.invokeNext(ClientSessionDelegate$send_N3028277934545793941.java)
at org.jboss.jms.client.delegate.ClientSessionDelegate.send(ClientSessionDelegate.java)
at org.jboss.jms.client.container.ProducerAspect.handleSend(ProducerAspect.java:253)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
at java.lang.reflect.Method.invoke(Method.java:324)
at org.jboss.aop.advice.PerInstanceAdvice.invoke(PerInstanceAdvice.java:130)
at org.jboss.jms.client.delegate.ClientProducerDelegate$send_3961598017717988886.invokeNext(ClientProducerDelegate$send_3961598017717988886.java)
at org.jboss.jms.client.container.ClosedInterceptor.invoke(ClosedInterceptor.java:182)
at org.jboss.aop.advice.PerInstanceInterceptor.invoke(PerInstanceInterceptor.java:117)
at org.jboss.jms.client.delegate.ClientProducerDelegate$send_3961598017717988886.invokeNext(ClientProducerDelegate$send_3961598017717988886.java)
at org.jboss.jms.client.container.ExceptionInterceptor.invoke(ExceptionInterceptor.java:69)
at org.jboss.jms.client.delegate.ClientProducerDelegate$send_3961598017717988886.invokeNext(ClientProducerDelegate$send_3961598017717988886.java)
at org.jboss.jms.client.container.ClientLogInterceptor.invoke(ClientLogInterceptor.java:107)
at org.jboss.jms.client.delegate.ClientProducerDelegate$send_3961598017717988886.invokeNext(ClientProducerDelegate$send_3961598017717988886.java)
at org.jboss.jms.client.delegate.ClientProducerDelegate.send(ClientProducerDelegate.java)
at org.jboss.jms.client.JBossMessageProducer.send(JBossMessageProducer.java:172)
at org.jboss.jms.client.JBossMessageProducer.send(JBossMessageProducer.java:220)
at org.jboss.jms.client.JBossMessageProducer.send(JBossMessageProducer.java:147)
at org.jboss.jms.client.JBossMessageProducer.send(JBossMessageProducer.java:138)
at TestMultiSessionMessageProducer.test(TestMultiSessionMessageProducer.java:117)
at TestMultiSessionMessageProducer.main(TestMultiSessionMessageProducer.java:26)
2006-10-24 17:06:47,031 ERROR org.jboss.jms.client.container.ExceptionInterceptor - Linked exception is:
org.jboss.aop.NotFoundInDispatcherException: Object with oid: -2147483645 was not found in the Dispatcher
at org.jboss.aop.Dispatcher.invoke(Dispatcher.java:85)
at org.jboss.jms.server.remoting.JMSServerInvocationHandler.invoke(JMSServerInvocationHandler.java:127)
at org.jboss.remoting.ServerInvoker.invoke(ServerInvoker.java:1008)
at org.jboss.remoting.ServerInvoker.invoke(ServerInvoker.java:857)
at org.jboss.remoting.transport.socket.ServerThread.processInvocation(ServerThread.java:454)
at org.jboss.remoting.transport.socket.ServerThread.dorun(ServerThread.java:541)
at org.jboss.remoting.transport.socket.ServerThread.run(ServerThread.java:261)
at org.jboss.remoting.MicroRemoteClientInvoker.invoke(MicroRemoteClientInvoker.java:172)
at org.jboss.remoting.Client.invoke(Client.java:589)
at org.jboss.remoting.Client.invoke(Client.java:581)
at org.jboss.jms.client.delegate.DelegateSupport.invoke(DelegateSupport.java:111)
at org.jboss.jms.client.delegate.ClientSessionDelegate$send_N3028277934545793941.invokeNext(ClientSessionDelegate$send_N3028277934545793941.java)
at org.jboss.jms.client.container.TransactionAspect.handleSend(TransactionAspect.java:176)
at org.jboss.aop.advice.org.jboss.jms.client.container.TransactionAspect16.invoke(TransactionAspect16.java)
at org.jboss.jms.client.delegate.ClientSessionDelegate$send_N3028277934545793941.invokeNext(ClientSessionDelegate$send_N3028277934545793941.java)
at org.jboss.jms.client.container.ClosedInterceptor.invoke(ClosedInterceptor.java:182)
at org.jboss.aop.advice.PerInstanceInterceptor.invoke(PerInstanceInterceptor.java:117)
at org.jboss.jms.client.delegate.ClientSessionDelegate$send_N3028277934545793941.invokeNext(ClientSessionDelegate$send_N3028277934545793941.java)
at org.jboss.jms.client.container.ExceptionInterceptor.invoke(ExceptionInterceptor.java:69)
at org.jboss.jms.client.delegate.ClientSessionDelegate$send_N3028277934545793941.invokeNext(ClientSessionDelegate$send_N3028277934545793941.java)
at org.jboss.jms.client.container.ClientLogInterceptor.invoke(ClientLogInterceptor.java:107)
at org.jboss.jms.client.delegate.ClientSessionDelegate$send_N3028277934545793941.invokeNext(ClientSessionDelegate$send_N3028277934545793941.java)
at org.jboss.jms.client.delegate.ClientSessionDelegate.send(ClientSessionDelegate.java)
at org.jboss.jms.client.container.ProducerAspect.handleSend(ProducerAspect.java:253)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
at java.lang.reflect.Method.invoke(Method.java:324)
at org.jboss.aop.advice.PerInstanceAdvice.invoke(PerInstanceAdvice.java:130)
at org.jboss.jms.client.delegate.ClientProducerDelegate$send_3961598017717988886.invokeNext(ClientProducerDelegate$send_3961598017717988886.java)
at org.jboss.jms.client.container.ClosedInterceptor.invoke(ClosedInterceptor.java:182)
at org.jboss.aop.advice.PerInstanceInterceptor.invoke(PerInstanceInterceptor.java:117)
at org.jboss.jms.client.delegate.ClientProducerDelegate$send_3961598017717988886.invokeNext(ClientProducerDelegate$send_3961598017717988886.java)
at org.jboss.jms.client.container.ExceptionInterceptor.invoke(ExceptionInterceptor.java:69)
at org.jboss.jms.client.delegate.ClientProducerDelegate$send_3961598017717988886.invokeNext(ClientProducerDelegate$send_3961598017717988886.java)
at org.jboss.jms.client.container.ClientLogInterceptor.invoke(ClientLogInterceptor.java:107)
at org.jboss.jms.client.delegate.ClientProducerDelegate$send_3961598017717988886.invokeNext(ClientProducerDelegate$send_3961598017717988886.java)
at org.jboss.jms.client.delegate.ClientProducerDelegate.send(ClientProducerDelegate.java)
at org.jboss.jms.client.JBossMessageProducer.send(JBossMessageProducer.java:172)
at org.jboss.jms.client.JBossMessageProducer.send(JBossMessageProducer.java:220)
at org.jboss.jms.client.JBossMessageProducer.send(JBossMessageProducer.java:147)
at org.jboss.jms.client.JBossMessageProducer.send(JBossMessageProducer.java:138)
at TestMultiSessionMessageProducer.test(TestMultiSessionMessageProducer.java:117)
at TestMultiSessionMessageProducer.main(TestMultiSessionMessageProducer.java:26)
Any assistance would be most appreciated.
Cheers,
Bill
View the original post : http://www.jboss.com/index.html?module=bb&op=viewtopic&p=3980288#3980288
Reply to the post : http://www.jboss.com/index.html?module=bb&op=posting&mode=reply&p=3980288
More information about the jboss-user
mailing list