From 9f07fccaee55761c61509c116794f36fd1664912 Mon Sep 17 00:00:00 2001 From: Gary Russell Date: Thu, 26 Oct 2017 09:12:43 -0400 Subject: [PATCH] Fix test NPEs caused by previous commit --- .../stream/binder/rabbit/RabbitMessageChannelBinder.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/spring-cloud-stream-binder-rabbit/src/main/java/org/springframework/cloud/stream/binder/rabbit/RabbitMessageChannelBinder.java b/spring-cloud-stream-binder-rabbit/src/main/java/org/springframework/cloud/stream/binder/rabbit/RabbitMessageChannelBinder.java index b2cf5e642..27907c772 100644 --- a/spring-cloud-stream-binder-rabbit/src/main/java/org/springframework/cloud/stream/binder/rabbit/RabbitMessageChannelBinder.java +++ b/spring-cloud-stream-binder-rabbit/src/main/java/org/springframework/cloud/stream/binder/rabbit/RabbitMessageChannelBinder.java @@ -294,7 +294,7 @@ public class RabbitMessageChannelBinder protected MessageHandler createProducerMessageHandler(final ProducerDestination producerDestination, ExtendedProducerProperties producerProperties, MessageChannel errorChannel) throws Exception { - Assert.state(!producerProperties.getHeaderMode().equals(HeaderMode.embeddedHeaders), + Assert.state(!HeaderMode.embeddedHeaders.equals(producerProperties.getHeaderMode()), "the RabbitMQ binder does not support embedded headers since RabbitMQ supports headers natively"); String prefix = producerProperties.getExtension().getPrefix(); String exchangeName = producerDestination.getName(); @@ -373,7 +373,7 @@ public class RabbitMessageChannelBinder @Override protected MessageProducer createConsumerEndpoint(ConsumerDestination consumerDestination, String group, ExtendedConsumerProperties properties) { - Assert.state(!properties.getHeaderMode().equals(HeaderMode.embeddedHeaders), + Assert.state(!HeaderMode.embeddedHeaders.equals(properties.getHeaderMode()), "the RabbitMQ binder does not support embedded headers since RabbitMQ supports headers natively"); String destination = consumerDestination.getName(); SimpleMessageListenerContainer listenerContainer = new SimpleMessageListenerContainer(