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
[EMAIL PROTECTED]
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
