2009/9/14 Scott Parkerson <scott.parker...@ateb.com>:
> Hello,
>
> I'm trying to use Camel 1.6.1 in SMX 4.1.0.2 (FUSE) and the POJO
> Producing / Consuming annotations as described in the online
> documentation.
>
> In one class (a CXF-based RESTful webservice), I have the following set
> up:
>
> // OutboundFooRequestHandler is an interface (see below)
> �...@produce(uri="activemq:queue:outbound_foo_req")
> private OutboundFooRequestHandler outboundFooRequestHandler;
>
> �...@post
> �...@path("/sendfoo")
> public Response sendFoo(OutboundFooRequest sendFooRequest)
> {
> // (a bunch of web-specific code deleted)
>
> // send this sendFooReqest object on the queue
> outboundFooRequestHandler.handle(sendFooRequest);
>
> // Return HTTP response 202 Accepted
> return Response.status(202).build();
> }
>
>
> The interface that is annotated with Produce is shown below:
>
> @InOnly
> public interface OutboundFooRequestHandler
> {
> public void handle(OutboundFooRequest outboundFooRequest);
> }
>
> Here is the implementation of the interface:
>
> public class OutboundFooRequestHandlerImpl implements
> OutboundFooRequestHandler, InitializingBean, DisposableBean
> {
>
> private static final Logger logger =
> LoggerFactory.getLogger(OutboundFooRequestHandlerImpl.class);
>
> �...@override
> �...@consume(uri="activemq:queue:outbound_foo_req")
> public void handle(@Body OutboundFooRequest outboundFooRequest)
> {
> logger.debug("got it");
>
> // TODO: actually *do* something
> }
>
> The producer and the consumer's bundle-context.xml has this:
>
> <camelContext
> xmlns="http://activemq.apache.org/camel/schema/spring"; />
>
> <bean name="activemq"
> class="org.apache.camel.component.jms.JmsComponent">
> <property name="connectionFactory">
> <bean class="org.apache.activemq.ActiveMQConnectionFactory">
> <property name="brokerURL" value="vm://default" />
> </bean>
> </property>
> </bean>
>
> I can send a message, but the consumer doesn't wake up and pick up the
> message.
>
> It's worth noting that the producer and the consumer are in two
> different bundles.
>
> What am I missing?
Are you creating your OutboundFooRequestHandlerImpl class by
configuring it in Spring XML? Or are you using the Spring 3 component
scan stuff?
--
James
-------
http://macstrac.blogspot.com/
Open Source Integration
http://fusesource.com/
