[JBoss Messaging] - Re: Connecting to two JBoss messaging servers causes interfe
by davidrh
Simple test class is attached below. It basically sends messages to one server until it gets an exception, at which point it starts sending them to a second server.
I am running this test case on the server1 (localhost) machine. I run it and leave it for a few minutes sending messages to the server1 JBoss Messaging instance on localhost. I then shutdown the server1 instance and the messages begin to be sent to server2 (as expected). If you leave it run for a few minutes more, eventually sending to server2 will fail as well with the exception:
| 2006-11-09 14:21:36,859 ERROR org.jboss.jms.client.container.ExceptionInterceptor - Caught RuntimeException
| org.jboss.remoting.CannotConnectException: Can not get connection to server. Problem establishing socket connection for locator - InvokerLocator [socket://161.117.20.9:4457/?dataType=jms&marshaller=org.jboss.jms.server.remoting.JMSWireFormat&serializationtype=jboss&socket.check_connection=false&unmarshaller=org.jboss.jms.server.remoting.JMSWireFormat]
| at org.jboss.remoting.transport.socket.MicroSocketClientInvoker.transport(MicroSocketClientInvoker.java:323)
| at org.jboss.remoting.MicroRemoteClientInvoker.invoke(MicroRemoteClientInvoker.java:125)
| at org.jboss.remoting.Client.invoke(Client.java:589)
| at org.jboss.remoting.Client.invoke(Client.java:581)
| at org.jboss.jms.client.delegate.ClientConnectionFactoryDelegate.invoke(ClientConnectionFactoryDelegate.java:199)
| at org.jboss.jms.client.delegate.ClientConnectionFactoryDelegate$getIdBlock_2799534920426283165.invokeNext(ClientConnectionFactoryDelegate$getIdBlock_2799534920426283165.java)
| at org.jboss.jms.client.container.ExceptionInterceptor.invoke(ExceptionInterceptor.java:69)
| at org.jboss.jms.client.delegate.ClientConnectionFactoryDelegate$getIdBlock_2799534920426283165.invokeNext(ClientConnectionFactoryDelegate$getIdBlock_2799534920426283165.java)
| at org.jboss.jms.client.container.ClientLogInterceptor.invoke(ClientLogInterceptor.java:107)
| at org.jboss.jms.client.delegate.ClientConnectionFactoryDelegate$getIdBlock_2799534920426283165.invokeNext(ClientConnectionFactoryDelegate$getIdBlock_2799534920426283165.java)
| at org.jboss.jms.client.delegate.ClientConnectionFactoryDelegate.getIdBlock(ClientConnectionFactoryDelegate.java)
| at org.jboss.jms.message.MessageIdGenerator.getNextBlock(MessageIdGenerator.java:72)
| at org.jboss.jms.message.MessageIdGenerator.getId(MessageIdGenerator.java:86)
| at org.jboss.jms.client.container.ProducerAspect.handleSend(ProducerAspect.java:230)
| at sun.reflect.GeneratedMethodAccessor5.invoke(Unknown Source)
| 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 TestMultiConnectionMessageProducer.test(TestMultiConnectionMessageProducer.java:140)
| at TestMultiConnectionMessageProducer.main(TestMultiConnectionMessageProducer.java:27)
| Caused by: java.net.ConnectException: Connection refused: connect
| at java.net.PlainSocketImpl.socketConnect(Native Method)
| at java.net.PlainSocketImpl.doConnect(PlainSocketImpl.java:305)
| at java.net.PlainSocketImpl.connectToAddress(PlainSocketImpl.java:171)
| at java.net.PlainSocketImpl.connect(PlainSocketImpl.java:158)
| at java.net.Socket.connect(Socket.java:452)
| at java.net.Socket.connect(Socket.java:402)
| at java.net.Socket.<init>(Socket.java:309)
| at java.net.Socket.<init>(Socket.java:124)
| at org.jboss.remoting.transport.socket.SocketClientInvoker.createSocket(SocketClientInvoker.java:183)
| at org.jboss.remoting.transport.socket.MicroSocketClientInvoker.getConnection(MicroSocketClientInvoker.java:685)
| at org.jboss.remoting.transport.socket.MicroSocketClientInvoker.transport(MicroSocketClientInvoker.java:319)
| ... 32 more
|
I've put the session.createQueue calls in for each message dispatch as this is what the Spring JmsTemplate class does (which is what we're using in our application). When I debug our application, the first call to the session.createQueue method after the server has failed takes quite a long time (30 seconds or more). I can't replicate this delay in the test case at the moment. In our application, this causes a delay in the failover as at the point of calling createQueue, we don't know that the server has failed yet.
You'll notice in the output that the ExceptionListener on the connection can fire quite a while (30 seconds) after the connection has actually been lost. We use the ExceptionListener to shutdown our session pool and initiate reconnection in a separate thread. Until the listener fires, we may still hand out sessions from the pool that are for the server that is no longer there.
As an aside, when we detect a failed connection what should we do to clean it up? If I put in the code to try closing the Producer, Session and Connection and ignore any exceptions it takes quite a long time to execute (around 60 seconds for session.close() and 60 seconds for connection.close()). With this close code in place, when it tries the second server the error that is generated is:
| 2006-11-09 14:41:00,937 ERROR org.jboss.jms.client.container.ExceptionInterceptor - Caught Exception:
| org.jboss.aop.NotFoundInDispatcherException: Object with oid: -2147483641 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$createQueue_6431069199924553036.invokeNext(ClientSessionDelegate$createQueue_6431069199924553036.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$createQueue_6431069199924553036.invokeNext(ClientSessionDelegate$createQueue_6431069199924553036.java)
| at org.jboss.jms.client.container.ExceptionInterceptor.invoke(ExceptionInterceptor.java:69)
| at org.jboss.jms.client.delegate.ClientSessionDelegate$createQueue_6431069199924553036.invokeNext(ClientSessionDelegate$createQueue_6431069199924553036.java)
| at org.jboss.jms.client.container.ClientLogInterceptor.invoke(ClientLogInterceptor.java:107)
| at org.jboss.jms.client.delegate.ClientSessionDelegate$createQueue_6431069199924553036.invokeNext(ClientSessionDelegate$createQueue_6431069199924553036.java)
| at org.jboss.jms.client.delegate.ClientSessionDelegate.createQueue(ClientSessionDelegate.java)
| at org.jboss.jms.client.JBossSession.createQueue(JBossSession.java:272)
| at TestMultiConnectionMessageProducer.test(TestMultiConnectionMessageProducer.java:135)
| at TestMultiConnectionMessageProducer.main(TestMultiConnectionMessageProducer.java:27)
| org.jboss.jms.util.MessagingJMSException: Caught exception
| Connection 2 failed:
| at org.jboss.jms.client.container.ExceptionInterceptor.invoke(ExceptionInterceptor.java:99)
| at org.jboss.jms.client.delegate.ClientSessionDelegate$createQueue_6431069199924553036.invokeNext(ClientSessionDelegate$createQueue_6431069199924553036.java)
| at org.jboss.jms.client.container.ClientLogInterceptor.invoke(ClientLogInterceptor.java:107)
| at org.jboss.jms.client.delegate.ClientSessionDelegate$createQueue_6431069199924553036.invokeNext(ClientSessionDelegate$createQueue_6431069199924553036.java)
| at org.jboss.jms.client.delegate.ClientSessionDelegate.createQueue(ClientSessionDelegate.java)
| at org.jboss.jms.client.JBossSession.createQueue(JBossSession.java:272)
| at TestMultiConnectionMessageProducer.test(TestMultiConnectionMessageProducer.java:135)
| at TestMultiConnectionMessageProducer.main(TestMultiConnectionMessageProducer.java:27)
|
Thanks for your assistance,
David
Test Case:
| import java.util.Hashtable;
|
| import javax.jms.Connection;
| import javax.jms.ConnectionFactory;
| import javax.jms.ExceptionListener;
| 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 TestMultiConnectionMessageProducer {
|
| /**
| * @param args
| */
| public static void main(String[] args) {
| TestMultiConnectionMessageProducer ml = new TestMultiConnectionMessageProducer();
|
| try {
| ml.test();
| } catch (JMSException e) {
| // TODO Auto-generated catch block
| e.printStackTrace();
| }
| }
|
| private void test() throws JMSException {
| // Setup connection 1
| Hashtable properties1 = new Hashtable();
| properties1.put(Context.INITIAL_CONTEXT_FACTORY,
| "org.jnp.interfaces.NamingContextFactory");
| properties1.put(Context.URL_PKG_PREFIXES,
| "org.jboss.naming:org.jnp.interfaces");
| properties1.put(Context.PROVIDER_URL, "jnp://localhost:1099");
| properties1.put(Context.SECURITY_PRINCIPAL, "admin");
| properties1.put(Context.SECURITY_CREDENTIALS, "admin");
|
| ConnectionFactory connectionFactory1 = null;
|
| try {
| Context context1 = new InitialContext(properties1);
| connectionFactory1 = (ConnectionFactory) context1
| .lookup("ConnectionFactory");
| } catch (NamingException ne) {
| throw new RuntimeException(ne);
| }
|
| final Connection connection1 = connectionFactory1.createConnection();
| ExceptionListener listener1 = new ExceptionListener() {
| public void onException(JMSException jmse) {
| System.out.println("Fired exception listener on connection 1");
| }
| };
| connection1.setExceptionListener(listener1);
|
| Session session1 = connection1.createSession(false,
| Session.AUTO_ACKNOWLEDGE);
|
| boolean connection1OK = true;
|
| // Setup connection 2
| 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://server2: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);
| }
|
| final Connection connection2 = connectionFactory2.createConnection();
| ExceptionListener listener2 = new ExceptionListener() {
| public void onException(JMSException jmse) {
| System.out.println("Fired exception listener on connection 2");
| }
| };
| connection2.setExceptionListener(listener2);
|
| Session session2 = connection2.createSession(false,
| Session.AUTO_ACKNOWLEDGE);
|
| boolean connection2OK = true;
| boolean finished = false;
| while (!finished && (connection1OK || connection2OK)) {
| if (connection1OK) {
| try {
| TextMessage msg1 = session1.createTextMessage("Message");
| System.out.println("Creating queue 1");
| Queue queue1 = session1.createQueue("publish.request");
| System.out.println("Creating producer 1");
| MessageProducer producer1 = session1.createProducer(queue1);
| System.out.println("Sending message to queue 1");
| producer1.send(msg1);
| producer1.close();
| System.out.println("Connection 1 OK");
| System.out.println("==========================");
| } catch (Exception e) {
| connection1OK = false;
| System.out.println("Connection 1 failed:");
| e.printStackTrace();
| // try {
| // System.out.println("Closing session 1");
| // session1.close();
| // } catch (Exception e1) {
| // }
| // try {
| // System.out.println("Closing connection 1");
| // connection1.close();
| // } catch (Exception e1) {
| // }
| }
| }
| if (!connection1OK && connection2OK) {
| try {
| System.out.println("Trying server 2");
| TextMessage msg2 = session2.createTextMessage("Message");
| System.out.println("Creating queue 2");
| Queue queue2 = session2.createQueue("publish.request");
| System.out.println("Creating producer 2");
| MessageProducer producer2 = session2.createProducer(queue2);
| System.out.println("Sending message to queue 2");
| producer2.send(msg2);
| producer2.close();
| System.out.println("Connection 2 OK");
| System.out.println("==========================");
| } catch (Exception e2) {
| connection2OK = false;
| System.out.println("Connection 2 failed:");
| e2.printStackTrace();
| }
| }
|
| try {
| Thread.currentThread().sleep(1000);
| } catch (InterruptedException e) {
| finished = true;
| }
| }
| }
| }
|
View the original post : http://www.jboss.com/index.html?module=bb&op=viewtopic&p=3984374#3984374
Reply to the post : http://www.jboss.com/index.html?module=bb&op=posting&mode=reply&p=3984374
19Â years, 6Â months
[EJB 3.0] - Re: EntityManagerFactory null from JNDI?
by dfarkish3
"rocken7" wrote : EntityManagerFactory is null in jndi. No errors, no warnings, notta just null or "not found" etc.
|
| Yep I've seen posts on this, but no good answer.
|
| jboss-4.0.4.GA
|
| So far my SLSB beans work remotely for unit tests.
|
| But ...
|
| How do you get an EntitManagerFactory from outside the container?
|
| JNDI always returns either not found or null.
|
| In my META-INF/persistence.xml file (of the deployed test jar):
|
| <?xml version="1.0" encoding="UTF-8"?>
| | <persistence>
| | <persistence-unit name="fudb">
| | <jta-data-source>java:/MySqlDS</jta-data-source>
| | <exclude-unlisted-classes>false</exclude-unlisted-classes>
| | <class>com.fubar.ads.clicks.model.DataDemographic</class>
| | <properties>
| | <property name="hibernate.hbm2ddl.auto" value="update"/>
| | <property name="hibernate.dialect" value="org.hibernate.dialect.MySQLDialect"/>
| | <property name="jboss.entity.manager.jndi.name" value="fudb"/>
| | <property name="jboss.entity.manager.factory.jndi.name" value="fudbFactory"/>
| | </properties>
| | </persistence-unit>
| | </persistence>
|
|
| All of the following test methods fail:
|
|
| | // testEMF() blows with javax.persistence.PersistenceException: No Persistence provider for EntityManager named
| |
| | public void testEMF() throws Exception
| | {
| | EntityManagerFactory emf = Persistence.createEntityManagerFactory("fudb");
| | assertNotNull("EntityManagerFactory not accessible.", emf );
| | }
| |
| | public void testEMF2() throws Exception
| | {
| | InitialContext ctx = getInitialContext();
| | Object em = ctx.lookup("java:/fudb");
| | assertNotNull("obj is null.", em );
| | }
| |
| | public void testEMF2b() throws Exception
| | {
| | InitialContext ctx = getInitialContext();
| | Object em = ctx.lookup("fudb");
| | assertNotNull("obj is null.", em );
| | }
| |
| | public void testEMF3() throws Exception
| | {
| | InitialContext ctx = getInitialContext();
| | Object em = ctx.lookup("java:/fudbFactory");
| | assertNotNull("obj is null.", em );
| | }
| |
| | public void testEMF3b() throws Exception
| | {
| | InitialContext ctx = getInitialContext();
| | Object em = ctx.lookup("fudbFactory");
| | assertNotNull("obj is null.", em );
| | }
| |
| | public static InitialContext getInitialContext() throws Exception
| | {
| | Hashtable props = getInitialContextProperties();
| | return new InitialContext(props);
| | }
| |
| | private static Hashtable getInitialContextProperties()
| | {
| | Hashtable<String, Object> props = new Hashtable<String, Object>();
| | props.put("java.naming.factory.initial", "org.jnp.interfaces.NamingContextFactory" );
| | //"org.jnp.interfaces.LocalOnlyContextFactory"
| | props.put("java.naming.factory.url.pkgs", "org.jboss.naming:org.jnp.interfaces");
| | props.put("java.naming.provider.url", "jnp://localhost:1099/");
| | return props;
| | }
| |
|
| And in JNDIView for Global Bindings:
|
| fudbFactory: org.jboss.ejb3.entity.InjectedEntityManagerFactory:Reference Class Name: org.jboss.ejb3.entity.InjectedEntityManagerFactory Type: nns Content: /fudbFactory
| |
| | fudb: org.jboss.ejb3.entity.TransactionScopedEntityManager:Reference Class Name: org.jboss.ejb3.entity.TransactionScopedEntityManager Type: nns Content: /fudb
| |
|
| I've tried lots of random things due to my lack of full docs, so maybe my approach totally wrong ... Why null in jndi? Is this a bug?
|
| -Jud
| [Have you found a solution for this null problem? I tried to get EntityManager or EntityManagerFactory using jndi and in both cases I get null. Thanks, David]
View the original post : http://www.jboss.com/index.html?module=bb&op=viewtopic&p=3984368#3984368
Reply to the post : http://www.jboss.com/index.html?module=bb&op=posting&mode=reply&p=3984368
19Â years, 6Â months