[JBoss Messaging] - NullPointerException when trying to open a session for sendi
by josey
I am getting a NullPointerException when trying to open a session for sending a JMS message.
I have two clusters, each with one node started up. I run into the error when trying to send a message from within the server that is not running the JMS server (I removed the deploy/messaging folder from this server).
I know that the server trying to send the message can see the server that is running the JMS server because I can successfully send a JMS message when running a standalone app from this same machine using the same JMS message sending code. This also shows that the JMS destination is accessible via JNDI.
Also, when I run the same code in the server on which the JMS server is running it is able to send the JMS message without a problem.
* Version: JBoss AS 5.1.0GA (also had the problem on 5.0.1); the JBossMessaging version that comes with JBoss AS 5.1.0GA
* IP address for jboss-batch-11, the server running the JMS server: 172.16.77.70
* Using Java 1.6.
* Additional note: This code worked fine in JBoss 4.0.5, JBossMQ.
Here is the relevant log output (exception stacktrace found at the end).
| DEBUG [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:28,102][com.squaretrade.jms.PersistentQueueProcessingThread] PersistentQueueProcessingThread.java(69): Requesting object from queue
| DEBUG [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:28,334][com.squaretrade.jms.PersistentQueueProcessingThread] PersistentQueueProcessingThread.java(72): Message dequeued; ready to process
| DEBUG [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:28,418][com.squaretrade.jms.MessageDeliveryDelegate] MessageDeliveryDelegate.java(127): Looking up the destination
| INFO [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:28,422][com.squaretrade.locator.Locator] Locator.java(238): LOOKING UP JMS RESOURCE: queue/DataReplication
| INFO [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:28,513][com.squaretrade.locator.Locator] Locator.java(364): USING PROVIDER URL FOR REMOTE CONTEXT: jboss-batch-local-11:1100,jboss-batch-local-12:1100
| DEBUG [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:28,554][org.jnp.interfaces.TimedSocketFactory] Logger.java(228): createSocket, hostAddr: jboss-batch-local-11/172.16.77.70, port: 1100, localAddr: null, localPort: 0, timeout: 0
| FINE [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:28,654][sun.rmi.loader] Log.java(212): ha-jms-queue-processor@199aa4e: interfaces = [org.jnp.interfaces.Naming, org.jboss.ha.framework.interfaces.HARMIProxy], codebase = "http://172.16.77.70:8083/", defaultLoader = BaseClassLoader@1015293{vfszip:/usr/local/jboss-5.1.0.GA/server/app/deploy/app.ear/}
| FINE [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:28,656][sun.rmi.loader] Log.java(212): ha-jms-queue-processor@199aa4e: name = "java.lang.reflect.Proxy", codebase = "http://172.16.77.70:8083/", defaultLoader = BaseClassLoader@1015293{vfszip:/usr/local/jboss-5.1.0.GA/server/app/deploy/app.ear/}
| FINE [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:28,659][sun.rmi.loader] Log.java(212): ha-jms-queue-processor@199aa4e: name = "org.jboss.ha.framework.interfaces.HARMIClient", codebase = "http://172.16.77.70:8083/", defaultLoader = BaseClassLoader@1015293{vfszip:/usr/local/jboss-5.1.0.GA/server/app/deploy/app.ear/}
| FINE [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:28,662][sun.rmi.loader] Log.java(212): ha-jms-queue-processor@199aa4e: name = "java.util.ArrayList", codebase = "http://172.16.77.70:8083/", defaultLoader = BaseClassLoader@1015293{vfszip:/usr/local/jboss-5.1.0.GA/server/app/deploy/app.ear/}
| FINE [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:28,664][sun.rmi.loader] Log.java(212): ha-jms-queue-processor@199aa4e: name = "org.jboss.ha.framework.server.HARMIServerImpl_Stub", codebase = "http://172.16.77.70:8083/", defaultLoader = BaseClassLoader@1015293{vfszip:/usr/local/jboss-5.1.0.GA/server/app/deploy/app.ear/}
| FINE [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:28,666][sun.rmi.loader] Log.java(212): ha-jms-queue-processor@199aa4e: name = "java.rmi.server.RemoteStub", codebase = "http://172.16.77.70:8083/", defaultLoader = BaseClassLoader@1015293{vfszip:/usr/local/jboss-5.1.0.GA/server/app/deploy/app.ear/}
| FINE [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:28,668][sun.rmi.loader] Log.java(212): ha-jms-queue-processor@199aa4e: name = "java.rmi.server.RemoteObject", codebase = "http://172.16.77.70:8083/", defaultLoader = BaseClassLoader@1015293{vfszip:/usr/local/jboss-5.1.0.GA/server/app/deploy/app.ear/}
| FINE [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:28,670][sun.rmi.client.ref] Log.java(212): ha-jms-queue-processor@199aa4e: get connection
| FINE [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:28,672][sun.rmi.transport.tcp] Log.java(212): ha-jms-queue-processor@199aa4e: create connection
| FINE [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:28,674][sun.rmi.transport.tcp.proxy] Log.java(212): ha-jms-queue-processor@199aa4e: host: 172.16.77.70, port: 1101
| FINE [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:28,739][sun.rmi.loader] Log.java(212): ha-jms-queue-processor@199aa4e: name = "java.rmi.dgc.Lease", codebase = "http://172.16.77.70:8083/", defaultLoader = BaseClassLoader@1015293{vfszip:/usr/local/jboss-5.1.0.GA/server/app/deploy/app.ear/}
| FINE [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:28,742][sun.rmi.loader] Log.java(212): ha-jms-queue-processor@199aa4e: name = "java.rmi.dgc.VMID", codebase = "http://172.16.77.70:8083/", defaultLoader = BaseClassLoader@1015293{vfszip:/usr/local/jboss-5.1.0.GA/server/app/deploy/app.ear/}
| FINE [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:28,744][sun.rmi.loader] Log.java(212): ha-jms-queue-processor@199aa4e: name = "[B", codebase = "", defaultLoader = BaseClassLoader@1015293{vfszip:/usr/local/jboss-5.1.0.GA/server/app/deploy/app.ear/}
| FINE [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:28,747][sun.rmi.loader] Log.java(212): ha-jms-queue-processor@199aa4e: name = "java.rmi.server.UID", codebase = "http://172.16.77.70:8083/", defaultLoader = BaseClassLoader@1015293{vfszip:/usr/local/jboss-5.1.0.GA/server/app/deploy/app.ear/}
| FINE [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:28,749][sun.rmi.client.ref] Log.java(212): ha-jms-queue-processor@199aa4e: free connection (reuse = true)
| FINE [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:28,751][sun.rmi.transport.tcp] Log.java(212): ha-jms-queue-processor@199aa4e: reuse connection
| FINE [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:28,753][sun.rmi.transport.tcp] Log.java(212): ha-jms-queue-processor@199aa4e: create reaper
| FINE [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:28,755][sun.rmi.loader] Log.java(212): ha-jms-queue-processor@199aa4e: name = "org.jboss.ha.framework.interfaces.RoundRobin", codebase = "http://172.16.77.70:8083/", defaultLoader = BaseClassLoader@1015293{vfszip:/usr/local/jboss-5.1.0.GA/server/app/deploy/app.ear/}
| FINE [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:28,777][sun.rmi.transport.tcp] Log.java(212): ha-jms-queue-processor@199aa4e: reuse connection
| FINE [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:28,802][sun.rmi.loader] Log.java(212): ha-jms-queue-processor@199aa4e: name = "org.jboss.ha.framework.interfaces.HARMIResponse", codebase = "http://172.16.77.70:8083/", defaultLoader = BaseClassLoader@1015293{vfszip:/usr/local/jboss-5.1.0.GA/server/app/deploy/app.ear/}
| FINE [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:28,808][sun.rmi.loader] Log.java(212): ha-jms-queue-processor@199aa4e: name = "org.jnp.interfaces.MarshalledValuePair", codebase = "http://172.16.77.70:8083/", defaultLoader = BaseClassLoader@1015293{vfszip:/usr/local/jboss-5.1.0.GA/server/app/deploy/app.ear/}
| FINE [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:28,811][sun.rmi.loader] Log.java(212): ha-jms-queue-processor@199aa4e: name = "java.rmi.MarshalledObject", codebase = "http://172.16.77.70:8083/", defaultLoader = BaseClassLoader@1015293{vfszip:/usr/local/jboss-5.1.0.GA/server/app/deploy/app.ear/}
| FINE [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:28,813][sun.rmi.loader] Log.java(212): ha-jms-queue-processor@199aa4e: name = "[B", codebase = "", defaultLoader = BaseClassLoader@1015293{vfszip:/usr/local/jboss-5.1.0.GA/server/app/deploy/app.ear/}
| FINE [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:28,815][sun.rmi.client.ref] Log.java(212): ha-jms-queue-processor@199aa4e: free connection (reuse = true)
| FINE [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:28,816][sun.rmi.transport.tcp] Log.java(212): ha-jms-queue-processor@199aa4e: reuse connection
| FINE [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:28,817][sun.rmi.loader] Log.java(212): ha-jms-queue-processor@199aa4e: name = "org.jboss.jms.destination.JBossQueue", codebase = "http://172.16.77.70:8083/", defaultLoader = BaseClassLoader@1015293{vfszip:/usr/local/jboss-5.1.0.GA/server/app/deploy/app.ear/}
| FINE [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:28,837][sun.rmi.loader] Log.java(212): ha-jms-queue-processor@199aa4e: name = "org.jboss.jms.destination.JBossDestination", codebase = "http://172.16.77.70:8083/", defaultLoader = BaseClassLoader@1015293{vfszip:/usr/local/jboss-5.1.0.GA/server/app/deploy/app.ear/}
| INFO [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:28,912][com.squaretrade.locator.Locator] Locator.java(240): ADDING JMS RESOURCE TO CACHE: queue/DataReplication
| DEBUG [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:28,912][com.squaretrade.jms.MessageDeliveryDelegate] MessageDeliveryDelegate.java(132): Retrieving connection from pool
| DEBUG [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:28,913][com.squaretrade.jms.JMSConnectionFactory] JMSConnectionPool.java(105): Requesting JMS connection from pool.
| INFO [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:28,913][resourcePool.ResourcePool] ResourcePool.java(384): Pool = [] Growing pool currentSize = 0 maximumCapacity = 5
| INFO [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:28,917][com.squaretrade.locator.Locator] Locator.java(238): LOOKING UP JMS RESOURCE: ConnectionFactory
| FINE [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:28,919][sun.rmi.transport.tcp] Log.java(212): ha-jms-queue-processor@199aa4e: reuse connection
| FINE [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:28,930][sun.rmi.loader] Log.java(212): ha-jms-queue-processor@199aa4e: name = "org.jboss.ha.framework.interfaces.HARMIResponse", codebase = "http://172.16.77.70:8083/", defaultLoader = BaseClassLoader@1015293{vfszip:/usr/local/jboss-5.1.0.GA/server/app/deploy/app.ear/}
| FINE [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:28,932][sun.rmi.loader] Log.java(212): ha-jms-queue-processor@199aa4e: name = "org.jnp.interfaces.MarshalledValuePair", codebase = "http://172.16.77.70:8083/", defaultLoader = BaseClassLoader@1015293{vfszip:/usr/local/jboss-5.1.0.GA/server/app/deploy/app.ear/}
| FINE [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:28,933][sun.rmi.loader] Log.java(212): ha-jms-queue-processor@199aa4e: name = "java.rmi.MarshalledObject", codebase = "http://172.16.77.70:8083/", defaultLoader = BaseClassLoader@1015293{vfszip:/usr/local/jboss-5.1.0.GA/server/app/deploy/app.ear/}
| FINE [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:28,935][sun.rmi.loader] Log.java(212): ha-jms-queue-processor@199aa4e: name = "[B", codebase = "", defaultLoader = BaseClassLoader@1015293{vfszip:/usr/local/jboss-5.1.0.GA/server/app/deploy/app.ear/}
| FINE [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:28,937][sun.rmi.client.ref] Log.java(212): ha-jms-queue-processor@199aa4e: free connection (reuse = true)
| FINE [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:28,938][sun.rmi.transport.tcp] Log.java(212): ha-jms-queue-processor@199aa4e: reuse connection
| FINE [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:28,940][sun.rmi.loader] Log.java(212): ha-jms-queue-processor@199aa4e: name = "org.jboss.jms.client.JBossConnectionFactory", codebase = "http://172.16.77.70:8083/", defaultLoader = BaseClassLoader@1015293{vfszip:/usr/local/jboss-5.1.0.GA/server/app/deploy/app.ear/}
| FINE [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:29,029][sun.rmi.loader] Log.java(212): ha-jms-queue-processor@199aa4e: name = "org.jboss.jms.client.delegate.ClientConnectionFactoryDelegate", codebase = "http://172.16.77.70:8083/", defaultLoader = BaseClassLoader@1015293{vfszip:/usr/local/jboss-5.1.0.GA/server/app/deploy/app.ear/}
| FINE [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:29,054][sun.rmi.loader] Log.java(212): ha-jms-queue-processor@199aa4e: name = "org.jboss.jms.client.delegate.DelegateSupport", codebase = "http://172.16.77.70:8083/", defaultLoader = BaseClassLoader@1015293{vfszip:/usr/local/jboss-5.1.0.GA/server/app/deploy/app.ear/}
| FINE [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:29,159][sun.rmi.loader] Log.java(212): ha-jms-queue-processor@199aa4e: name = "org.jboss.messaging.util.Version", codebase = "http://172.16.77.70:8083/", defaultLoader = BaseClassLoader@1015293{vfszip:/usr/local/jboss-5.1.0.GA/server/app/deploy/app.ear/}
| INFO [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:29,165][com.squaretrade.locator.Locator] Locator.java(240): ADDING JMS RESOURCE TO CACHE: ConnectionFactory
| DEBUG [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:29,354][org.jboss.remoting.transport.socket.MicroSocketClientInvoker] Logger.java(228): SocketClientInvoker[500f8a, bisocket://172.16.77.70:4457] setting client socket wrapper class name to org.jboss.jms.client.remoting.ClientSocketWrapper
| DEBUG [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:29,355][org.jboss.remoting.transport.socket.MicroSocketClientInvoker] Logger.java(228): SocketClientInvoker[500f8a, bisocket://172.16.77.70:4457] setting shouldCheckConnection to false
| DEBUG [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:29,357][org.jboss.remoting.transport.socket.SocketClientInvoker] Logger.java(228): SocketClientInvoker[500f8a, bisocket://172.16.77.70:4457] setting timeout to 0
| DEBUG [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:29,359][org.jboss.remoting.transport.socket.MicroSocketClientInvoker] Logger.java(228): SocketClientInvoker[500f8a, bisocket://172.16.77.70:4457] constructed
| DEBUG [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:29,360][org.jboss.remoting.transport.socket.MicroSocketClientInvoker] Logger.java(228): SocketClientInvoker[500f8a, bisocket://172.16.77.70:4457] setting client socket wrapper class name to org.jboss.jms.client.remoting.ClientSocketWrapper
| DEBUG [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:29,361][org.jboss.remoting.transport.socket.MicroSocketClientInvoker] Logger.java(228): SocketClientInvoker[500f8a, bisocket://172.16.77.70:4457] setting shouldCheckConnection to false
| DEBUG [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:29,362][org.jboss.remoting.transport.socket.SocketClientInvoker] Logger.java(228): SocketClientInvoker[500f8a, bisocket://172.16.77.70:4457] setting timeout to 0
| DEBUG [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:29,373][org.jboss.remoting.transport.bisocket.BisocketClientInvoker] Logger.java(228): Setting ping frequency to: 214748364
| DEBUG [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:29,375][org.jboss.remoting.MicroRemoteClientInvoker] Logger.java(228): SocketClientInvoker[500f8a, bisocket://172.16.77.70:4457] connecting
| DEBUG [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:29,376][org.jboss.remoting.transport.socket.MicroSocketClientInvoker] Logger.java(228): Creating semaphore with size 50
| DEBUG [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:29,379][org.jboss.remoting.MicroRemoteClientInvoker] Logger.java(228): SocketClientInvoker[500f8a, bisocket://172.16.77.70:4457] connected
| DEBUG [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:30,679][org.jboss.remoting.transport.socket.MicroSocketClientInvoker] Logger.java(228): SocketClientInvoker[47054, bisocket://172.16.77.70:4457] setting maxPoolSize to 200
| DEBUG [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:30,681][org.jboss.remoting.transport.socket.MicroSocketClientInvoker] Logger.java(228): SocketClientInvoker[47054, bisocket://172.16.77.70:4457] setting client socket wrapper class name to org.jboss.jms.client.remoting.ClientSocketWrapper
| DEBUG [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:30,682][org.jboss.remoting.transport.socket.MicroSocketClientInvoker] Logger.java(228): SocketClientInvoker[47054, bisocket://172.16.77.70:4457] setting shouldCheckConnection to false
| DEBUG [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:30,684][org.jboss.remoting.transport.socket.SocketClientInvoker] Logger.java(228): SocketClientInvoker[47054, bisocket://172.16.77.70:4457] setting timeout to 0
| DEBUG [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:30,685][org.jboss.remoting.transport.socket.MicroSocketClientInvoker] Logger.java(228): SocketClientInvoker[47054, bisocket://172.16.77.70:4457] constructed
| DEBUG [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:30,686][org.jboss.remoting.transport.socket.MicroSocketClientInvoker] Logger.java(228): SocketClientInvoker[47054, bisocket://172.16.77.70:4457] setting maxPoolSize to 200
| DEBUG [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:30,688][org.jboss.remoting.transport.socket.MicroSocketClientInvoker] Logger.java(228): SocketClientInvoker[47054, bisocket://172.16.77.70:4457] setting client socket wrapper class name to org.jboss.jms.client.remoting.ClientSocketWrapper
| DEBUG [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:30,689][org.jboss.remoting.transport.socket.MicroSocketClientInvoker] Logger.java(228): SocketClientInvoker[47054, bisocket://172.16.77.70:4457] setting shouldCheckConnection to false
| DEBUG [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:30,690][org.jboss.remoting.transport.socket.SocketClientInvoker] Logger.java(228): SocketClientInvoker[47054, bisocket://172.16.77.70:4457] setting timeout to 0
| DEBUG [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:30,691][org.jboss.remoting.transport.bisocket.BisocketClientInvoker] Logger.java(228): Setting ping frequency to: 214748364
| DEBUG [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:30,693][org.jboss.remoting.MicroRemoteClientInvoker] Logger.java(228): SocketClientInvoker[47054, bisocket://172.16.77.70:4457] connecting
| DEBUG [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:30,694][org.jboss.remoting.transport.socket.MicroSocketClientInvoker] Logger.java(228): Creating semaphore with size 200
| DEBUG [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:30,695][org.jboss.remoting.MicroRemoteClientInvoker] Logger.java(228): SocketClientInvoker[47054, bisocket://172.16.77.70:4457] connected
| DEBUG [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:30,762][org.jboss.remoting.transport.socket.MicroSocketClientInvoker] Logger.java(228): SocketClientInvoker[19f4dcb, bisocket://172.16.77.70:4457] setting maxPoolSize to 1
| DEBUG [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:30,763][org.jboss.remoting.transport.socket.MicroSocketClientInvoker] Logger.java(228): SocketClientInvoker[19f4dcb, bisocket://172.16.77.70:4457] setting client socket wrapper class name to org.jboss.jms.client.remoting.ClientSocketWrapper
| DEBUG [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:30,765][org.jboss.remoting.transport.socket.MicroSocketClientInvoker] Logger.java(228): SocketClientInvoker[19f4dcb, bisocket://172.16.77.70:4457] setting shouldCheckConnection to false
| DEBUG [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:30,766][org.jboss.remoting.transport.socket.SocketClientInvoker] Logger.java(228): SocketClientInvoker[19f4dcb, bisocket://172.16.77.70:4457] setting timeout to 0
| DEBUG [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:30,768][org.jboss.remoting.transport.socket.MicroSocketClientInvoker] Logger.java(228): SocketClientInvoker[19f4dcb, bisocket://172.16.77.70:4457] constructed
| DEBUG [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:30,769][org.jboss.remoting.transport.socket.MicroSocketClientInvoker] Logger.java(228): SocketClientInvoker[19f4dcb, bisocket://172.16.77.70:4457] setting maxPoolSize to 1
| DEBUG [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:30,770][org.jboss.remoting.transport.socket.MicroSocketClientInvoker] Logger.java(228): SocketClientInvoker[19f4dcb, bisocket://172.16.77.70:4457] setting client socket wrapper class name to org.jboss.jms.client.remoting.ClientSocketWrapper
| DEBUG [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:30,771][org.jboss.remoting.transport.socket.MicroSocketClientInvoker] Logger.java(228): SocketClientInvoker[19f4dcb, bisocket://172.16.77.70:4457] setting shouldCheckConnection to false
| DEBUG [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:30,773][org.jboss.remoting.transport.socket.SocketClientInvoker] Logger.java(228): SocketClientInvoker[19f4dcb, bisocket://172.16.77.70:4457] setting timeout to 0
| DEBUG [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:30,774][org.jboss.remoting.transport.bisocket.BisocketClientInvoker] Logger.java(228): Setting ping frequency to: 214748364
| DEBUG [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:30,775][org.jboss.remoting.MicroRemoteClientInvoker] Logger.java(228): SocketClientInvoker[19f4dcb, bisocket://172.16.77.70:4457] connecting
| DEBUG [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:30,776][org.jboss.remoting.transport.socket.MicroSocketClientInvoker] Logger.java(228): Creating semaphore with size 1
| DEBUG [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:30,777][org.jboss.remoting.MicroRemoteClientInvoker] Logger.java(228): SocketClientInvoker[19f4dcb, bisocket://172.16.77.70:4457] connected
| DEBUG [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:30,781][org.jboss.remoting.Client] Logger.java(228): starting callback Connector: InvokerLocator [bisocket://172.16.77.2:1199077074/callback?callbackServerHost=172.16.77.2&callbackServerPort=1199077074&callbackServerProtocol=bisocket&clientMaxPoolSize=1&clientSocketClass=org.jboss.jms.client.remoting.ClientSocketWrapper&datatype=jms&guid=4sg252-dnh4pm-fv7825so-1-fv79osuy-aa&isCallbackServer=true&onewayThreadPool=org.jboss.jms.server.remoting.DirectThreadPool&serverSocketClass=org.jboss.jms.server.remoting.ServerSocketWrapper]
| DEBUG [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:30,861][org.jboss.remoting.ServerInvoker] Logger.java(228): SocketServerInvoker[172.16.77.2:1199077074] did not find server socket factory configuration as mbean service or classname. Creating default server socket factory.
| DEBUG [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:30,862][org.jboss.remoting.ServerInvoker] Logger.java(228): SocketServerInvoker[172.16.77.2:1199077074] created server socket factory javax.net.DefaultServerSocketFactory@80a54a
| DEBUG [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:30,863][org.jboss.remoting.transport.bisocket.BisocketServerInvoker] Logger.java(228): SocketServerInvoker[172.16.77.2:1199077074] setting pingFrequency to 214748364
| DEBUG [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:30,864][org.jboss.remoting.transport.bisocket.BisocketServerInvoker] Logger.java(228): SocketServerInvoker[172.16.77.2:1199077074] setting pingWindowFactor to 10
| DEBUG [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:30,874][org.jboss.remoting.transport.Connector] Logger.java(228): org.jboss.remoting.transport.Connector@1eb91e1 started
| DEBUG [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:30,942][org.jboss.remoting.ServerInvoker] Logger.java(228): ServerInvoker (SocketServerInvoker[172.16.77.2:1199077074]) added client callback handler CallbackManager[1ac7f93] with session id of 4sg252-dnh4pm-fv7825so-1-fv79osra-a6+4sg252-dnh4pm-fv7825so-1-fv79osxu-ab and callback handle object of null.
| DEBUG [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:30,944][org.jboss.remoting.InvokerRegistry] Logger.java(228): removed org.jboss.remoting.transport.local.LocalClientInvoker@1c057b9 from registry
| DEBUG [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:30,945][org.jboss.remoting.transport.bisocket.BisocketClientInvoker] Logger.java(228): getting secondary locator
| DEBUG [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:30,957][org.jboss.remoting.transport.bisocket.BisocketClientInvoker] Logger.java(228): secondary locator: InvokerLocator [null://172.16.77.70:59551/?]
| DEBUG [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:30,959][org.jboss.remoting.transport.bisocket.BisocketServerInvoker] Logger.java(228): creating control connection: InvokerLocator [null://172.16.77.70:59551/?]
| DEBUG [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:30,969][org.jboss.remoting.transport.bisocket.BisocketServerInvoker] Logger.java(228): SocketServerInvoker[172.16.77.2:1199077074] created control connection (4sg252-dnh4pm-fv7825so-1-fv79osxu-ab): Socket[addr=/172.16.77.70,port=59551,localport=38139]
| DEBUG [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:31,504][com.squaretrade.jms.MessageDeliveryDelegate] MessageDeliveryDelegate.java(136): Creating the session; transacted = false
| DEBUG [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:31,574][com.squaretrade.jms.MessageDeliveryDelegate] MessageDeliveryDelegate.java(186): Closing the session
| DEBUG [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:31,575][com.squaretrade.jms.MessageDeliveryDelegate] MessageDeliveryDelegate.java(196): Returning the connection
| DEBUG [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:31,576][com.squaretrade.jms.JMSConnectionFactory] JMSConnectionPool.java(120): Freeing connection JBossConnection->ConnectionDelegate[29364281, ID=181-zdio97vf-1-1fr087vf-006j51-y152gs4, SID=1]
| ERROR [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:31,576][STDERR] LoggerStream.java(156): Exception in thread "ha-jms-queue-processor@199aa4e"
| ERROR [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:31,578][STDERR] LoggerStream.java(156): java.lang.NullPointerException
| ERROR [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:31,578][STDERR] LoggerStream.java(156): at org.jboss.jms.client.container.FailoverValveInterceptor.invoke(FailoverValveInterceptor.java:87)
| ERROR [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:31,579][STDERR] LoggerStream.java(156): at org.jboss.aop.advice.PerInstanceInterceptor.invoke(PerInstanceInterceptor.java:86)
| ERROR [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:31,580][STDERR] LoggerStream.java(156): at org.jboss.aop.joinpoint.MethodInvocation.invokeNext(MethodInvocation.java:102)
| ERROR [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:31,580][STDERR] LoggerStream.java(156): at org.jboss.jms.client.container.ClosedInterceptor.invoke(ClosedInterceptor.java:170)
| ERROR [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:31,581][STDERR] LoggerStream.java(156): at org.jboss.aop.advice.PerInstanceInterceptor.invoke(PerInstanceInterceptor.java:86)
| ERROR [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:31,582][STDERR] LoggerStream.java(156): at org.jboss.aop.joinpoint.MethodInvocation.invokeNext(MethodInvocation.java:102)
| ERROR [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:31,582][STDERR] LoggerStream.java(156): at org.jboss.jms.client.delegate.ClientConnectionDelegate.createSessionDelegate(ClientConnectionDelegate.java)
| ERROR [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:31,583][STDERR] LoggerStream.java(156): at org.jboss.jms.client.JBossConnection.createSessionInternal(JBossConnection.java:269)
| ERROR [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:31,584][STDERR] LoggerStream.java(156): at org.jboss.jms.client.JBossConnection.createSession(JBossConnection.java:91)
| ERROR [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:31,584][STDERR] LoggerStream.java(156): at com.squaretrade.jms.MessageDeliveryDelegate.send(MessageDeliveryDelegate.java:137)
| ERROR [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:31,585][STDERR] LoggerStream.java(156): at com.squaretrade.jms.AbstractMessagingFacade.sendAndNotify(AbstractMessagingFacade.java:41)
| ERROR [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:31,586][STDERR] LoggerStream.java(156): at com.squaretrade.jms.PersistentQueueProcessingThread.process(PersistentQueueProcessingThread.java:95)
| ERROR [ha-jms-queue-processor@199aa4e][2009-05-26 16:57:31,586][STDERR] LoggerStream.java(156): at com.squaretrade.jms.PersistentQueueProcessingThread.run(PersistentQueueProcessingThread.java:73)
|
Thanks.
View the original post : http://www.jboss.org/index.html?module=bb&op=viewtopic&p=4233447#4233447
Reply to the post : http://www.jboss.org/index.html?module=bb&op=posting&mode=reply&p=4233447
17 years, 3 months
[Management, JMX/JBoss] - UserTransaction not working inside jboss service
by elgabo
Hi everyone,
I'm heavily using JMX based services inside a JBoss 4.2.3 application server (.sar project).
But I am not able to manage a JDBC transaction through UserTransaction. The statements get executed before I commit the transaction and when I rollback the changes are not undone. I use a local-tx-datasource MySQL JDBC datasource
| <local-tx-datasource>
| <jndi-name>myDs</jndi-name>
| <connection-url>jdbc:mysql://myserver:3306/opensips</connection-url>
| <driver-class>com.mysql.jdbc.Driver</driver-class>
| <user-name>myuser</user-name>
| <password>mypwd</password>
| <exception-sorter-class-name>org.jboss.resource.adapter.jdbc.vendor.MySQLExceptionSorter</exception-sorter-class-name>
|
| <metadata>
| <type-mapping>mySQL</type-mapping>
| </metadata>
| </local-tx-datasource>
|
and I think I'm correctly using the JTA API
| Connection conn = null;
| UserTransaction tx=null;
| try {
| DataSource ds=(DataSource) this.getResource(this.opensipsDs);
| tx=(UserTransaction) this.getResource("UserTransaction");
| tx.begin();
| conn=ds.getConnection();
| String activateSql="insert into grp (username, grp) values (?, 'active')";
| String deactivateSql="delete from grp where username=?";
|
| PreparedStatement ps;
| Set<String> lineas=estados.keySet();
| for(String linea:lineas) {
| if(estados.get(linea)) {
| //activar
| ps=conn.prepareStatement(activateSql);
| } else {
| //desactivar
| ps=conn.prepareStatement(deactivateSql);
| }
|
| ps.setString(1, linea);
| ps.executeUpdate();
| }
|
| tx.commit();
| } catch (Exception e) {
| this.log.error("error al realizar modificacion en opensips", e);
| if(tx!=null)
| try {
| tx.rollback();
| } catch (Exception ex) {
| this.log.info("no se pudo realizar rollback");
| }
| } finally {
| try {
| if(conn!=null&&!conn.isClosed()) {
| conn.close();
| }
| } catch (SQLException e) {
| this.log.debug("la coneccion ya esta cerrada");
| }
| }
|
Can I use the JTA API inside an MBean? Thank for you help
View the original post : http://www.jboss.org/index.html?module=bb&op=viewtopic&p=4233444#4233444
Reply to the post : http://www.jboss.org/index.html?module=bb&op=posting&mode=reply&p=4233444
17 years, 3 months
[JBoss Messaging] - Configuring the JMS Bridge
by cpslo1999
I've got two JBoss 5.0.1.GA instances. Server A has a topic and I would like to have bridged to a Queue on Server B.
I've added the following to Server B's deploy/messaging/jms-ds.xml
| <!-- Remote JMS Provider -->
| <mbean
| code="org.jboss.jms.jndi.JMSProviderLoader"
| name="jboss.messaging:service=JMSProviderLoader,name=MyRemoteJMSProvider,server=remotehost">
| <attribute name="ProviderName">RemoteXAConnectionFactory</attribute>
| <attribute name="ProviderAdapterClass">org.jboss.jms.jndi.JNDIProviderAdapter</attribute>
|
| <!-- The combined connection factory -->
| <attribute name="FactoryRef">XAConnectionFactory</attribute>
| <!-- The queue connection factory -->
| <attribute name="QueueFactoryRef">XAConnectionFactory</attribute>
| <!-- The topic factory -->
| <attribute name="TopicFactoryRef">XAConnectionFactory</attribute>
| <attribute name="Properties">
| java.naming.factory.initial=org.jnp.interfaces.NamingContextFactory
| java.naming.factory.url.pkgs=org.jboss.naming:org.jnp.interfaces
| java.naming.provider.url=localhost:1199
| </attribute>
| </mbean>
|
I then created a file {Server B}/deploy/messaging/dfm-bridge-service.xml
| <?xml version="1.0" encoding="UTF-8"?>
| <server>
|
| <mbean
| code="org.jboss.jms.server.bridge.BridgeService"
| name="jboss.jms:service=Bridge,name=DFMBrdige"
| xmbean-dd="xmdesc/Bridge-xmbean.xml">
| <depends optional-attribute-name="SourceProviderLoader">
| jboss.messaging:service=JMSProviderLoader,name=MyRemoteJMSProvider,server=remotehost
| </depends>
| <depends optional-attribute-name="TargetProviderLoader">
| jboss.messaging:service=JMSProviderLoader,name=JMSProvider
| </depends>
|
| <attribute name="SourceDestinationLookup">/topic/noticeTopic</attribute>
| <attribute name="TargetDestinationLookup">/queue/ingestRemote</attribute>
| <attribute name="QualityOfServiceMode">2</attribute>
| <attribute name="MaxBatchSize">5</attribute>
| <attribute name="MaxBatchTime">-1</attribute>
| <attribute name="FailureRetryInterval">5000</attribute>
| <attribute name="MaxRetries">-1</attribute>
| <attribute name="AddMessageIDInHeader">false</attribute>
| </mbean>
| </server>
|
I start up both servers and everything seems happy, including a message on
I've connected a very simple MDB to the queue on Server B
| @MessageDriven(activationConfig = {
| @ActivationConfigProperty(
| propertyName = "destinationType",
| propertyValue = "javax.jms.Queue"),
| @ActivationConfigProperty(
| propertyName = "destination",
| propertyValue = "queue/ingestRemote"),
| @ActivationConfigProperty(
| propertyName = "maxSession",
| propertyValue = "1")
| })
| public class IngestDFMMDB implements MessageListener {
| private final Log log = LogFactory.getLog(getClass());
|
| public void onMessage(Message msg) {
| log.fatal("DFM message received: " + msg);
| }
| }
|
I send messages to Server A's topic and detect that they have been sent via a JUnit test, but no message ever makes it to Server B's queue.
I've been following the instructions from here: http://www.jboss.org/community/wiki/JBMBridgeConfiguration
Any ideas why my MDB never gets called?
View the original post : http://www.jboss.org/index.html?module=bb&op=viewtopic&p=4233439#4233439
Reply to the post : http://www.jboss.org/index.html?module=bb&op=posting&mode=reply&p=4233439
17 years, 3 months