ravib777 commented on issue #3470: NIFI-5639 PublishAMQP Processor URL: https://github.com/apache/nifi/pull/3470#issuecomment-491482253 Even if the exchange name is incorrect PublishAMQP processor sends the flowfile to success relationship. The message is however not send to RabbitMQ and the connection is closed. All the subsequent flowfiles are now sent to failure relationship as the connection is closed. Adding channel.exchangeDeclarePassive() [1] will double check if the exchange exists in RabbitMQ before publishing the message. [1] https://rabbitmq.github.io/rabbitmq-java-client/api/current/com/rabbitmq/client/Channel.html#exchangeDeclarePassive(java.lang.String)
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services
