MessageDispatchingException: Dispatcher has no subscribers bad message cause = null

2022-07-30T05:51:41

I'm implementing an MQ producer which will send messages via an OUT Queue. I have the channel, bridge, outbound bean, and the JMS outbound-channel-adapter setup. When I run my test case by sending the message, I see this error-> bad message cause=org.springframework.integration.MessageDispatchingException: Dispatcher has no subscribersbad message cause=null

Message config.xml

    <?xml version="1.0" encoing="utf-8"?>
      <beans
        
      <int:channel id="inbound.rawjms">
         <int: interceptors>
            <int ref bean="jmsTransportHeaderEnricher"/>
         </int: interceptors>
      </int:channel>
    
    <int:bridge input-channel="inbound.rawjms" output-channel="inbound.endpoint"/>

<channel id="inbound.endpoint">
    <dispatcher task-executor="preDatabaseChannelExecutor"/>
</channel>

<bridge input-channel="inbound.endpoint" output-channel="inbound.endpoint.xml"/>

<channel id="inbound.endpoint.xml" datatype="java.lang.String"/>
<chain input-channel="inbound.endpoint.xml" output-channel="inbound.xml.database">
</chain>


<channel id="inbound.xml.database">
    <dispatcher task-executor="postDatabaseChannelExecutor"/>
</channel>
            
    <bean id="jms.queue" class="com.ibm.mq.jms.MQQueue">
      <constructir-arg index="0" value="${txbus.mq.destination.outbound.queue}"/>
    </bean>
    
<channel id="outbound.f.queue" datatype="java.lang.String"/>

    <int-jms:outbound-channel-adapter
           id="jms.outbound.adapter.queue"
           channel="outbound.f.queue"
           connection-factory="connectionFactory"
           destination="jms.queue"
           auto-startup="true"/>
    </beans>

Config Class

@Configuration
@ImportResource("classpath:/META-INF/spring/message-config.xml")
public class Config{


   @Bean
   public Queue focusIn(@Value("${txbus.mq.destination}") String destinationIn){
     return new MQQueue(destinationIn);
  }

}

NOTE: I have removed the xmlns, xmlns:xsi, xsi:schema location from the .xml file as I couldn't copy them over.

Copyright License:
Author:「Santosh Ravi Teja」,Reproduced under the CC 4.0 BY-SA copyright license with link to original source & disclaimer.
Link to:https://stackoverflow.com/questions/73171307/messagedispatchingexception-dispatcher-has-no-subscribers-bad-message-cause-n

About “MessageDispatchingException: Dispatcher has no subscribers bad message cause = null” questions

I'm implementing an MQ producer which will send messages via an OUT Queue. I have the channel, bridge, outbound bean, and the JMS outbound-channel-adapter setup. When I run my test case by sending ...
Having a simple Spring Cloud Stream setup. The interface public interface MyKafkaBinding { @Output(PUBLISHER) MessageChannel publisher(); @Input(&quot;subscriber&quot;)
I am using Spring-XD to read a topic from kafka, filter the data using spark- streaming-processor and sink the data into the spark. The command i used to deploy stream is: stream create spark-str...
my configuration is as below , i am getting no subscriber exception , how can i resolve ? &lt;bean id="Beani" class="org.util.Beani" init-method="init" /&gt; &lt;int:gateway id="configHelper"
Spring Cloud Stream Dispatcher has no subscribers Error. After a successful spring boot container start up we need to put few notification messages on a Kafka topic and several of our microservice...
I am trying to use Spring Cloud Stream Kafka Binding to send and receive messages with a local zookeeper and kafka server. However, when starting up Spring MVC server, I am seeing the following exc...
I'm creating a microservice using JHipster and I'm facing an strange problem when trying receive a message from kafka. I'm using 3 computer on internal LAN to make this test: Kafka server in 192.1...
I am trying to use Spring integration to connect to JMS client , but i am getting :- [WARN ] 2018-08-22 10:57:20.378 [DispatchThread: [com.ibm.mq.jmqi.remote.impl.RemoteSession[connectionId=
I'm using spring-integration-sftp and my goal is to push local file to SFTP (just that for now, without confirmation or anything else). My configuration is as follows: @EnableIntegration @
While trying to run the below mentioned spring integration flow, I am getting an error :- org.springframework.jms.listener.DefaultMessageListenerContainer [consumeTradeJSONChannelAdapter.containe...

Copyright License:Reproduced under the CC 4.0 BY-SA copyright license with link to original source & disclaimer.