use correct method to send the message to rabbitMQ, exchange was not

used from parameter

Signed-off-by: Michael Hirsch <michael.hirsch@bosch-si.com>
This commit is contained in:
Michael Hirsch
2016-03-05 17:43:39 +01:00
parent 6cfde5f32c
commit da9124cecd

View File

@@ -34,7 +34,7 @@ public class DefaultAmqpSenderService implements AmqpSenderService {
@Override
public void sendMessage(final Message message, final URI uri) {
internalAmqpTemplate.send(extractExchange(uri), message);
internalAmqpTemplate.send(extractExchange(uri), null, message);
}
}