ActiveMQ: Проблема с поиском очереди

Очевидно, что Solarc прав, но у меня недостаточно представителей, чтобы комментировать, поэтому я добавляю немного здесь.

Если у вас возникли проблемы с чтением файла json (или простого текстового файла json), попробуйте поместить данные или образцы данных через валидатор json (например, https: // jsonlint.com/). Это может сэкономить вам время на отладку.

6
задан MrG 12 January 2009 в 15:05
поделиться

2 ответа

Во-первых Вы не должны явно создавать очереди в брокере, хотя это не причиняет вреда.

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

Можно сделать это явно, как описано здесь. Если Вы хотите автоволшебное население JNDI, затем используют соглашение о присвоении имен JNDI dynamicQueues/DUMMY как имя JNDI Вы поиск (как описано в Динамично создающих местах назначения)

8
ответ дан 16 December 2019 в 21:47
поделиться

Хм.. хорошо, когда я хочу слушать Очередь, я обычно делаю что-то вроде этого. (Импорт от javax.jms)

Очередь очереди;

    // Connect to ActiveMQ
    ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory(messageBrokerURL);
    connection = factory.createConnection();
    session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

    // List to Dummy Queue
    queue = session.createQueue("DUMMY");
    messageConsumer = session.createConsumer(queue);
    messageConsumer.setMessageListener(queueHandler);

    // Start the connection
    connection.start();

И удостоверьтесь, что Ваш Обработчик реализует MessageListener.

0
ответ дан 16 December 2019 в 21:47
поделиться
Другие вопросы по тегам:

Похожие вопросы: