RpcServer shouldn't be uisng QueueingConsumer since it is deprecated

[chanan]

RpcServer uses the blocking QueueingConsumer which has been deprecated. This makes it hard to use within a multi threaded environment such as in Play/Akka.

[michaelklishin]

That's not a fair description of how the queueing consumer works. Queueing consumer does use a linked blocking queue to hold delivered messages in but you can dispatch them to an executor in a loop, or send messages to actors that
do the actual work.

When specifically is this implementation a bottleneck?

[chanan]

Sorry, its not the QueueingConsumer itself, it is more correct to say that the mainloop (infinite while loop) that is causing the problem.

If RpcServer were to take an instance of DefaultConsumer for example, this will allow the implementer to handle the call in an event driven environment. Although of course I see that this can be an issue to handle the reply envelope.

[michaelklishin]

QueueingConsumer is no longer marked as deprecated.