Spring integration error:- org.springframework.messaging.MessageDeliveryException: Dispatcher has no subscribers for channel while connecting to MQ
Spring integration error:- org.springframework.messaging.MessageDeliveryException: Dispatcher has no subscribers for channel while connecting to MQ
我正在尝试使用 Spring 集成来连接到 JMS 客户端,但我得到:-
[WARN] 2018-08-22 10:57:20.378 [DispatchThread: [com.ibm.mq.jmqi.remote.impl.RemoteSession[connectionId=414D514353414D5030303144202020206CF77A5B9E4A5E21]]] SimpleMessageListenerContainer - JMS 消息侦听器的执行失败,并且没有错误处理程序放。
org.springframework.messaging.MessageDeliveryException: Dispatcher 没有频道 'app-name:local:9010.inputChannel' 的订阅者。嵌套异常是 org.springframework.integration.MessageDispatchingException:调度程序没有订阅者,failedMessage=GenericMessage
下面是我的 spring 集成配置 class
知道我为什么会收到此异常。
非常感谢
问题正是消息所说的。
Dispatcher has no subscribers for channel 'app-name:local:9010.inputChannel'.
您没有订阅此 bean
@Bean
public MessageChannel inputChannel() {
return new DirectChannel();
}
编辑
@ServiceActivator(inputChannel = "inputChannel")
public void handle(String in) {
...
}
或
@Transformer(inputChannel = "inputChannel", outputChannel = "transformed")
public String handle(String in) {
retur in.toUpperCase();
}
@ServiceActivator(inputChannel = "transformed")
public void handle(String in) {
...
}
我正在尝试使用 Spring 集成来连接到 JMS 客户端,但我得到:-
[WARN] 2018-08-22 10:57:20.378 [DispatchThread: [com.ibm.mq.jmqi.remote.impl.RemoteSession[connectionId=414D514353414D5030303144202020206CF77A5B9E4A5E21]]] SimpleMessageListenerContainer - JMS 消息侦听器的执行失败,并且没有错误处理程序放。 org.springframework.messaging.MessageDeliveryException: Dispatcher 没有频道 'app-name:local:9010.inputChannel' 的订阅者。嵌套异常是 org.springframework.integration.MessageDispatchingException:调度程序没有订阅者,failedMessage=GenericMessage
下面是我的 spring 集成配置 class
知道我为什么会收到此异常。
非常感谢
问题正是消息所说的。
Dispatcher has no subscribers for channel 'app-name:local:9010.inputChannel'.
您没有订阅此 bean
@Bean
public MessageChannel inputChannel() {
return new DirectChannel();
}
编辑
@ServiceActivator(inputChannel = "inputChannel")
public void handle(String in) {
...
}
或
@Transformer(inputChannel = "inputChannel", outputChannel = "transformed")
public String handle(String in) {
retur in.toUpperCase();
}
@ServiceActivator(inputChannel = "transformed")
public void handle(String in) {
...
}