I have some problems with implement a simple publiser-subscriber patter using and ActiveMq topic.
I want to implement a producer which sends a message ( in fire-and-forget style) and some consumers which consumes these messages.
I've managed to implement both the producer and the consumer, but I cannot configure my producer be able to send one-way ( anych ) message without waiting for the response.
The message sent by the producer arrives to the consumer, but the problem is that I get an ungly exception on producer side because the reply has timed out.
INFO 2009-06-04 10:30:52,464 org.springframework.integration.gateway.SimpleMess agingGateway:87 [main] - started org.springframework.integration.gateway.SimpleMess agingGateway@16c9867
Exception in thread "main" org.springframework.integration.message.MessageTim eoutException: failed to receive JMS response within timeout of: 5000ms
Here is my client configuration:
<amq:connectionFactory id="connectionFactory" brokerURL="tcp://localhost:61616"></amq:connectionFactory>
<amq:topic id="testTopic" physicalName="testTopic"/>
<siublish-subscribe-channel id="myChannel" />
<jms:outbound-gateway id="jmsGateway" request-destination="testTopic"
<si:gateway id="client" service-interface="com.test.pubsub.Producer" />
The problem is in "<jms:outbound-gateway" which can handle only synchronouse calls.
What else I can try, except using the low level progrmatic JMS api.
I guess spring should have some support for handling this problem, because it is a common use case ?