Multi-database JMS Queues

[Steven Landers]

Hello-

JBoss version = 4.0.4

I have an odd requirement to use Hypersonic for some Queues, and PostgreSQL for other queues. This is a different requirement from simply 'switching from Hypersonic' because some queues will still use hypersonic. Essentially the client wants to have a 'local queue' (hypersonic) and a 'global queue' (ha-jndi singleton, postgres).

Is this possible? I've tried simply creating a 2nd Destination Manager and pointing to it, but it doesn't seem to work. When I do this, the uil2 service streams debug messages startup, and jboss never loads.

Global Q /deploy-hasingleton/jms/globalqueue-service.xml (postgres)

  
<mbean code="org.jboss.mq.server.jmx.Queue"
        name="jboss.mq.destination:service=Queue,name=globalQueue">
        <depends optional-attribute-name="DestinationManager">
            jboss.mq:service=PostgresDestinationManager
        </depends>
        <attribute name="RedeliveryLimit">10</attribute>
        <attribute name="RedeliveryDelay">60000</attribute>
    </mbean>
  

Local Q /deploy/jms/localqueue-service.xml (hypersonic)

<mbean code="org.jboss.mq.server.jmx.Queue" 
        name="jboss.mq.destination:service=Queue,name=localQueue">
        <depends optional-attribute-name="DestinationManager">
            jboss.mq:service=DestinationManager
        </depends>
        <attribute name="RedeliveryDelay">5000</attribute>
    </mbean>

I also have the postgres-jdbc-state-service.xml and postgres-jdbc2-service.xml in the /deploy-hasingleton/jms directory, and left the HSQL ones in the /deploy/jms directory. I can get everything working on ALL postgres or ALL hypersonic, just not both currently.

Additionally, this is constantly spilled into the server.log

2010-07-08 17:51:18,700 DEBUG [org.jboss.mq.il.uil2.SocketManager] Failed to handle: org.jboss.mq.il.uil2.msgs.CloseMsg25378186[msgType: m_connectionClosing, msgID: -2147481029, error: null]
java.io.IOException: Client is not connected
        at org.jboss.mq.il.uil2.SocketManager.internalSendMessage(SocketManager.java:265)
        at org.jboss.mq.il.uil2.SocketManager.sendReply(SocketManager.java:239)
        at org.jboss.mq.il.uil2.ServerSocketManagerHandler.handleMsg(ServerSocketManagerHandler.java:128)
        at org.jboss.mq.il.uil2.SocketManager$ReadTask.handleMsg(SocketManager.java:396)
        at org.jboss.mq.il.uil2.msgs.BaseMsg.run(BaseMsg.java:392)
        at EDU.oswego.cs.dl.util.concurrent.PooledExecutor$Worker.run(PooledExecutor.java:748)
        at java.lang.Thread.run(Thread.java:619)
2010-07-08 17:51:18,708 DEBUG [org.jboss.mq.il.uil2.SocketManager] End WriteTask.run
2010-07-08 17:51:18,708 DEBUG [org.jboss.mq.il.uil2.ServerSocketManagerHandler] Exiting on IOE
java.net.SocketException: Socket closed
        at java.net.SocketInputStream.read(SocketInputStream.java:162)
        at java.io.BufferedInputStream.fill(BufferedInputStream.java:218)
        at java.io.BufferedInputStream.read(BufferedInputStream.java:237)
        at org.jboss.util.stream.NotifyingBufferedInputStream.read(NotifyingBufferedInputStream.java:79)
        at java.io.ObjectInputStream$PeekInputStream.peek(ObjectInputStream.java:2249)
        at java.io.ObjectInputStream$BlockDataInputStream.readBlockHeader(ObjectInputStream.java:2429)
        at java.io.ObjectInputStream$BlockDataInputStream.refill(ObjectInputStream.java:2499)
        at java.io.ObjectInputStream$BlockDataInputStream.read(ObjectInputStream.java:2571)
        at java.io.ObjectInputStream$BlockDataInputStream.readByte(ObjectInputStream.java:2720)
        at java.io.ObjectInputStream.readByte(ObjectInputStream.java:895)
        at org.jboss.mq.il.uil2.SocketManager$ReadTask.run(SocketManager.java:317)
        at java.lang.Thread.run(Thread.java:619)

If I change DestinationManager to point at PostgresSql, or change PostgresDestinationManager to DestinationManager, everything works...just on one database, however.

Any thoughts? Things to try? It would be nice if I could affirmatively say "JMS Queues on a JBoss server CANNOT be split amongst 2 databases via configuration" - but at this point, it seems like it may still be possible.

Thanks,
Steven

[Steven Landers]

Correction: JBoss does load, but I get this in my application log:

org.springframework.jms.listener.adapter.ListenerExecutionFailedException: Listener method 'handleMessage' threw exception; nested exception is org.springframework.jms.UncategorizedJmsException: Uncategorized exception occured during JMS processing; nested exception is javax.jms.JMSException: This destination does not exist !

When I point the DestinationManager to Postgres or Hypersonic only, then it works. Thoughts?

[Steven Landers]

If this is ridiculous - If I could have a few key reasons so I can explain away this issue and avoid this multi-db-Q nonsense, I'd be very appreciative.

[Peter Johnson]

As far as I know, you can set up JBoss Messaging to use only one database. Messaging stores more than just messages in the database.