I wonder if this createDynamicProxy call is correct?

[wpdebruin]

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!!!