Fix rocketMQ test case

pull/2985/head
ruansheng 2 years ago
parent ee8cbc8f40
commit 42e6fa4cd9

@ -70,6 +70,7 @@ public class RocketMQMessageChannelBinderTest {
ExtendedConsumerProperties<RocketMQConsumerProperties> extendedConsumerProperties
= new ExtendedConsumerProperties<>(new RocketMQConsumerProperties());
extendedConsumerProperties.populateBindingName("input1");
TestConsumerDestination destination = new TestConsumerDestination("test");
MessageProducer consumerEndpoint = binder.createConsumerEndpoint(destination, null,
extendedConsumerProperties);

Loading…
Cancel
Save