создать список очереди activemq

Чтобы создать список очередей, вы должны создать этот список, а затем создать каждую очередь отдельно из объекта сеанса.

Queue q = session.createQueue("someQueueName")

Однако на самом деле это не «создает» очередь в этом смысле, поскольку очередь является постоянной «вещью» в процессе/сервере ActiveMQ. Это создаст только ссылку на очередь ActiveMQ с идентификатором/именем.

Я не уверен, зачем вам сразу десять очередей. Как правило, у вас есть одна очередь для каждого типа события или варианта использования (или аналогичного), а затем вы используете одновременных потребителей для параллельной обработки.

Но, конечно, вы всегда можете сделать что-то подобное с помощью простого цикла for, создавая одну очередь за раз и присоединяя их к массиву. Обратите внимание, что вы не можете получить безопасные очереди только с Event объектами в них.

Однако вы можете отправлять ObjectMessage с событиями. Просто создайте один:

Event event = createEvent(..); // Given "Event" is serializable (need to be able to persist it).
Message m = session.createObjectMessage(event);
// Send message as usual in ActiveMQ.

Возможно, вам нужно переосмыслить одну или несколько вещей в вашем коде при преобразовании из BlockingQueues в постоянные очереди ActiveMQ.

Вы можете получить список доступных очередей, используя DestinationSource из вашего соединения.

ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
ActiveMQConnection connection = (ActiveMQConnection)connectionFactory.createConnection();
DestinationSource ds = connection.getDestinationSource();
Set<ActiveMQQueue> queues = ds.getQueues();

редактировать: чтобы создать очередь, взгляните на пример ActiveMQ Hello world ссылка Что делает код создается подключение к activeMQ-брокеру, встроенному в jvm

// Create a ConnectionFactory
ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("vm://localhost");

// Create a Connection
Connection connection = connectionFactory.createConnection();
connection.start();

// Create a Session
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

// Create the destination (Topic or Queue)
Destination destination = session.createQueue("TEST.FOO");

Что может быть неочевидно в приведенном выше коде, так это то, что строка:

ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("vm://localhost");

не только установит соединение с брокером, но и внедрит брокера внутри соединения, если его еще нет. Объяснение внизу этой страницы

ActiveMQConnectionFactory cf = new ActiveMQConnectionFactory("vm://localhost?create=false");