Hi All
I have a situation where I would like to wiretap communications going
through to a service which allows communication via a jms queue
Currently this application simply requires one to start up activemq as a
broker and then every thing works OK.
Now I would like to, (instead of starting up ActiveMQ) start up SMX4 and
allow for queses to be registered etc. This part also works fine, the
consumer service finds the registered queue in the underlying activemq
instance of SMX4 and communication takes place between the consumer service
and the producer service....
The problem start when I actually create a service assembly which contains a
jms-su with the following endpoint defined
<jms:endpoint service="test:jms"
endpoint="consumer"
role="consumer"
destinationStyle="queue"
jmsProviderDestinationName="test-check_queue"
connectionFactory="#connectionFactory" />
I also have a Camel RouteBuilder in which I would like to pick up messages
from the above jms endpoint and log some information at that point.
But as soon as communication takes place i get the following exception.
08:34:02,171 | ERROR | mix-jms-thread-2 | MultiplexingConsumerProcessor |
.MultiplexingConsumerProcessor$1 101 | Error while handling jms message
java.lang.UnsupportedOperationException: Can not handle objects of type
org.springframework.remoting.support.RemoteInvocation
at
org.apache.servicemix.jms.DefaultJmsMarshaler.toXmlInputStream(DefaultJmsMarshaler.java:150)
at
org.apache.servicemix.jms.DefaultJmsMarshaler.toSOAP(DefaultJmsMarshaler.java:178)
at
org.apache.servicemix.jms.AbstractJmsProcessor.toNMS(AbstractJmsProcessor.java:220)
at
org.apache.servicemix.jms.multiplexing.MultiplexingConsumerProcessor.access$300(MultiplexingConsumerProcessor.java:37)
at
org.apache.servicemix.jms.multiplexing.MultiplexingConsumerProcessor$1.run(MultiplexingConsumerProcessor.java:95)
at
java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:650)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:675)
The communication on the external services side uses spring remoting so the
consumer service communicates with the producer service via the queue and
uses normal rpc-like calls on a java interface/impl which is exported using
spring
JmsInvokerServiceExporter and JmsInvokerProxyFactoryBean etc. etc....
What I would like to know is what I should do/configure to be able to
consume and produce jms messages coming in for a service that uses Spring
remoting technology.
Note: that the external services' (both the client and server) have already
been coded and we cannot change the way they communicate?
Thank you in advance
ICA
