Лучший способ добавления/извлечения данных в/из очередей RabbitMQ ⇐ JAVA

[Anonymous]

Рассмотрим следующий сценарий:

Непрерывное создание и заполнение различных очередей в RabbitMQ, и каждая очередь должна использоваться не более чем с ОДНИМ поток за раз

Обратите внимание, что это все еще находится на стадии разработки, но будет закодировано на Java (хотя это не должно иметь никакого значения) .
Я мог бы придумать два способа сделать это:
Писатель:

Код: Выделить всё

 for each incoming info do:
create a new channel with a given queue name then write  data MQ using this channel

Читатель:

Код: Выделить всё

for each Thread t do:
create a new Channel for a next queue name and pass the Channel to t

или

Код: Выделить всё

create one channel

Писатель:

Код: Выделить всё

for each incoming data do:
get the queue name for data and write to mq using already defined channel

Читатель:

Код: Выделить всё

for each Thread t do:
assign next queue name to t , so it uses one single channel to retrieve data.

• Итак, каковы плюсы и минусы каждой реализации?
• Может быть, мне здесь что-то не хватает?

Подробнее здесь: https://stackoverflow.com/questions/320 ... tmq-queues