-
Notifications
You must be signed in to change notification settings - Fork 4
Description
https://github.com/lmajano/messaging-polyglot/blob/master/consumer/cfml/start.cfm
I wonder if the new lib.Consumer is correct? Since you placed the Consumer in models, should it not be
new models.Consumer? In your commandbox code Consumer is in the lib dir.
// Prepare a push consumer
consumerTask = createDynamicProxy(
new lib.Consumer( channel ),
[ "com.rabbitmq.client.Consumer" ]
);
And additionaly, I was wondering if I could integrate something like this in Coldbox.
I want to announce an interception directly in my consumer, so I can handle every incoming message in an interceptor. For this I need to inject my Consumer with the coldbox interceptor service.
So let's say
instead of new lib.Consumer(channel) a getInstance("Consumer").init(channel) or
better ?? without wirebox new lib.Consumer(channel, myInterceptorService) ??
By the way, nice work with RabbitMQ!!!