You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
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!!!
The text was updated successfully, but these errors were encountered:
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!!!
The text was updated successfully, but these errors were encountered: