RabbitMQ, обмен темами

У меня есть обмен темами на моем RabbitMQ. Ошибка при отправке сообщения.

EXCHANGE_NAME = "EX_TEST";

Раздел получения:

ConnectionFactory connectionFactory = new ConnectionFactory();
connectionFactory.setHost(mServer);
mConnection = connectionFactory.newConnection();
mModel = mConnection.createChannel();
mModel.exchangeDeclare(EXCHANGE_NAME, MyExchangeType, true);
mQueue = mModel.queueDeclare().getQueue();
MySubscription = new QueueingConsumer(mModel);
mModel.queueBind(mQueue, EXCHANGE_NAME, routingKey);
mModel.basicConsume(mQueue, true, MySubscription);

Раздел отправки:

ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("localhost");
        Connection connection = factory.newConnection();
        Channel channel = connection.createChannel();
        channel.exchangeDeclare(EXCHANGE_NAME, "topic");

ошибка в строке: channel.exchangeDeclare(EXCHANGE_NAME, "topic"); Исключения: невозможно повторно объявить обмен 'EX_TEST' в vhost '/' с другим типом, постоянным, внутренним или автоматически удаленным значением, class-id = 40, method-id = 10

Как решить эту проблему? спасибо: D


android java rabbitmq rabbitmq-exchange
person Tugsbayar Buyadaa    schedule 01.11.2013    source источник

Ответы (1)


arrow_upward
1
arrow_downward

Аргументы метода в

mModel.exchangeDeclare(EXCHANGE_NAME, MyExchangeType, true);

а также

channel.exchangeDeclare(EXCHANGE_NAME, "topic");

должны быть идентичны.

person pinepain    schedule 01.11.2013