JMS over JCA and JCA Flow

[Terry Cox <te...@meta-concepts.com>]

Hi,

Having an odd problem switching across to the JCA Flow:

As a test, we are binding to a JMS queue and then routing any messages 
to a trace component.

Using a plain JMS in-binding, the unit test successfully instantiates a 
container and sends a message through the queue.

Switching to the JCA in-binding, the container seems to set up the 
activeMQ queues required by the flow, but then shuts down activeMQ 
before handling the message, resulting in a string of IO exceptions.

TCP consumer thread starting
13:53:52,999 | DEBUG | eMQ Session Task | WireFormatNegotiator 
    | q.transport.WireFormatNegotiator   62 | Sending: WireFormatInfo { 
version=1, properties={TightEncodingEnabled=true, 
TcpNoDelayEnabled=true, SizePrefixDisabled=false, 
StackTraceEnabled=true, MaxInactivityDuration=30000, CacheEnabled=true}, 
magic=[A,c,t,i,v,e,M,Q]}
13:53:53,135 | DEBUG | /127.0.0.1:34306 | WireFormatNegotiator 
    | q.transport.WireFormatNegotiator   85 | Received WireFormat: 
WireFormatInfo { version=1, properties={StackTraceEnabled=true, 
TightEncodingEnabled=true, TcpNoDelayEnabled=true, 
SizePrefixDisabled=false, MaxInactivityDuration=30000, 
CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]}
13:53:53,146 | DEBUG | /127.0.0.1:34306 | WireFormatNegotiator 
    | q.transport.WireFormatNegotiator   92 | tcp:///127.0.0.1:34306 
before negotiation: OpenWireFormat{version=1, cacheEnabled=false, 
stackTraceEnabled=false, tightEncodingEnabled=false, 
sizePrefixDisabled=false}
13:53:53,146 | DEBUG | /127.0.0.1:34306 | WireFormatNegotiator 
    | q.transport.WireFormatNegotiator  103 | tcp:///127.0.0.1:34306 
after negotiation: OpenWireFormat{version=1, cacheEnabled=true, 
stackTraceEnabled=true, tightEncodingEnabled=true, sizePrefixDisabled=false}
13:53:53,149 | DEBUG | /127.0.0.1:34301 | AbstractRegion 
    | emq.broker.region.AbstractRegion   76 | Adding destination: 
topic://productUpdateInputTopic
13:53:53,145 | DEBUG | eMQ Session Task | 
SinglePoolConnectionInterceptor  | oolMatchAllConnectionInterceptor   92 
| Returning new connection 
org.apache.geronimo.connector.outbound.ManagedConnectionInfo@1f7708
13:53:53,136 | DEBUG | /127.0.0.1:61616 | TcpTransport 
    | ivemq.transport.tcp.TcpTransport  139 | TCP consumer thread starting
13:53:53,165 | DEBUG | /127.0.0.1:61616 | WireFormatNegotiator 
    | q.transport.WireFormatNegotiator   85 | Received WireFormat: 
WireFormatInfo { version=1, properties={StackTraceEnabled=true, 
TightEncodingEnabled=true, TcpNoDelayEnabled=true, 
SizePrefixDisabled=false, MaxInactivityDuration=30000, 
CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]}
13:53:53,136 | DEBUG | /127.0.0.1:61616 | TcpTransport 
    | ivemq.transport.tcp.TcpTransport  139 | TCP consumer thread starting
13:53:53,166 | DEBUG | /127.0.0.1:61616 | WireFormatNegotiator 
    | q.transport.WireFormatNegotiator   85 | Received WireFormat: 
WireFormatInfo { version=1, properties={StackTraceEnabled=true, 
TightEncodingEnabled=true, TcpNoDelayEnabled=true, 
SizePrefixDisabled=false, MaxInactivityDuration=30000, 
CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]}
13:53:53,167 | DEBUG | /127.0.0.1:61616 | WireFormatNegotiator 
    | q.transport.WireFormatNegotiator   92 | 
tcp://localhost/127.0.0.1:61616 before negotiation: 
OpenWireFormat{version=1, cacheEnabled=false, stackTraceEnabled=false, 
tightEncodingEnabled=false, sizePrefixDisabled=false}
13:53:53,168 | DEBUG | /127.0.0.1:61616 | WireFormatNegotiator 
    | q.transport.WireFormatNegotiator   92 | 
tcp://localhost/127.0.0.1:61616 before negotiation: 
OpenWireFormat{version=1, cacheEnabled=false, stackTraceEnabled=false, 
tightEncodingEnabled=false, sizePrefixDisabled=false}
13:53:53,175 | DEBUG | /127.0.0.1:61616 | WireFormatNegotiator 
    | q.transport.WireFormatNegotiator  103 | 
tcp://localhost/127.0.0.1:61616 after negotiation: 
OpenWireFormat{version=1, cacheEnabled=true, stackTraceEnabled=true, 
tightEncodingEnabled=true, sizePrefixDisabled=false}
13:53:53,177 | DEBUG | /127.0.0.1:61616 | WireFormatNegotiator 
    | q.transport.WireFormatNegotiator  103 | 
tcp://localhost/127.0.0.1:61616 after negotiation: 
OpenWireFormat{version=1, cacheEnabled=true, stackTraceEnabled=true, 
tightEncodingEnabled=true, sizePrefixDisabled=false}
13:53:53,215 | INFO  | eMQ ShutdownHook | BrokerService 
    | he.activemq.broker.BrokerService  384 | ActiveMQ Message Broker 
(broker, 
ID:workstation22155.capital.uk.specsavers.com-34289-1156942429089-1:0) 
is shutting down
13:53:53,216 | DEBUG | eMQ ShutdownHook | BrokerService 
    | he.activemq.broker.BrokerService 1029 | Caught exception, must be 
shutting down: java.lang.IllegalStateException: Shutdown in progress