Registering endpoint directly with ApplicationContext instead of MessageBus.
This commit is contained in:
@@ -104,7 +104,8 @@ public class DirectChannelSubscriptionTests {
|
||||
};
|
||||
consumer.setOutputChannel(targetChannel);
|
||||
SubscribingConsumerEndpoint endpoint = new SubscribingConsumerEndpoint(consumer, sourceChannel);
|
||||
bus.registerEndpoint(endpoint);
|
||||
context.getBeanFactory().registerSingleton("testEndpoint", endpoint);
|
||||
bus.setApplicationContext(context);
|
||||
context.refresh();
|
||||
bus.start();
|
||||
this.sourceChannel.send(new StringMessage("foo"));
|
||||
|
||||
Reference in New Issue
Block a user