Spring Integration with JMS backed channels - "Dispatcher has no subscribers" -

-

i newbie spring integration , trying execute basic producer/consumer application si , activemq.

i see messages being produced , stored on queue, when consumer ( service activator in case) processes message , tries returning new message output channel, keep getting below warning messages :

11:28:14.425 warn [defaultmessagelistenercontainer-1][org.springframework.jms.listener.defaultmessagelis tenercontainer] execution of jms message listener failed, , no errorhandler has been set. org.springframework.integration.messagedeliveryexc eption: dispatcher has no subscribers jms-channel jsonresponsechannel. @ org.springframework.integration.jms.subscribablejm schannel$dispatchingmessagelistener.onmessage(subs cribablejmschannel.java:159)  below snapshot of context xmls :  common-context.xml --------------------- .............. <bean id="requestqueue" class="org.apache.activemq.command.activemqqueue"> <constructor-arg value="input_msg_queue" /> </bean> <bean id="responsequeue" class="org.apache.activemq.command.activemqqueue"> <constructor-arg value="output_msg_queue" /> </bean> <int-jms:channel id="jsongreetingrequests" queue-name="input_msg_queue" message-driven="true"/> <int-jms:channel id="jsonresponsechannel" queue-name="output_msg_queue" message-driven="true"/> <bean name="connectionfactory" class="org.apache.activemq.activemqconnectionfacto ry"> <property name="brokerurl" value="tcp://localhost:61616" /> </bean> ..............  consumer-context.xml --------------------- .............  <int-jms:message-driven-channel-adapter id="newrequestsinchanneladapter" destination="requestqueue" channel="jsongreetingrequests"/> <!-- <int-jms:inbound-gateway request-channel="jsongreetingrequests" reply-channel="jsonresponsechannel" request-destination="requestqueue" />-->  <int:chain input-channel="jsongreetingrequests" output-channel="jsonresponsechannel"> <int:json-to-object-transformer type="com.periscope.samples.service.message"/> <int:service-activator method="greethello"> <bean class="com.periscope.samples.service.impl.hellowor ldserviceimpl"/> </int:service-activator> <int:object-to-json-transformer /> </int:chain>  <stream:stdout-channel-adapter id="greetingsstdout" channel="jsonresponsechannel"/> .....................  producer-context.xml ----------------------- ..... <int:gateway id="greetings" default-request-channel="greetingrequests" service-interface="com.periscope.samples.service.greetings "/> <int:channel id="greetingrequests"/>  <int:chain input-channel="greetingrequests" output-channel="jsongreetingrequests"> <int:object-to-json-transformer /> </int:chain>  <int-jms:outbound-channel-adapter id="jmsgreetingsoutchanneladapter" channel="jsongreetingrequests" destination="requestqueue"/> .......

this msg string being wrapped in user defined object , sent on input_msg_queue. consumer reads msg , processes , returns new message on output_msg_queue. these activemq backed channels , queues.

can please throw light how rid of these warnings since in particular use case, not expect other subscriber listening on output_msg_queue ?

thanks.

you don't need both jms channel adapters , jms-backed queues.

with current config have 2 consumers on input_msg_queue (the channel , channel adapter).

jms-backed channels needed message persistence. sending messages different application, use adapters.

simply change these

<int-jms:channel id="jsongreetingrequests" queue-name="input_msg_queue" message-   driven="true"/> <int-jms:channel id="jsonresponsechannel" queue-name="output_msg_queue" message-driven="true"/>

to simple <int:channel/>s.

also, given using request/response semantics, starting <gateway/> need use jms in/out gateways, not adapters (which one-way integration).


Comments

Post a Comment

Popular posts from this blog

ios - RestKit 0.20 — CoreData: error: Failed to call designated initializer on NSManagedObject class (again) -

-
this error has shown on many times, seems. prominent answer issue seems restkit 0.20 — coredata: error: failed call designated initializer on nsmanagedobject class however, solution posted doesn't work me. let's start beginning: i want upload file server. want parse response make sure uploaded. if not, try again later. model has boolean variable called nsnumber *senttoserver purpose (in coredata, bool saved nsnumber ) . because don't know whether sending going successful, save entity coredata model first before sending via restkit. when post request successful, server returns json string this: {"id":14,"created":true} notice that, of course, id not set on coredata model yet, both id , created new informations model. here's model: @interface recording : nsmanagedobject @property (nonatomic, retain) nsstring * audiofilepath; @property (nonatomic, retain) nsdate * createdat; @property (nonatomic, retain) nsstring * deviceid; @...
Read more

java - Digest auth with Spring Security using javaconfig -

-
so i'm trying create digest authentication spring following documentation trying translate xml "requirements" in java requirements. let's have xml in docs: <bean id="digestfilter" class= "org.springframework.security.web.authentication.www.digestauthenticationfilter"> <property name="userdetailsservice" ref="jdbcdaoimpl"/> <property name="authenticationentrypoint" ref="digestentrypoint"/> <property name="usercache" ref="usercache"/> </bean> <bean id="digestentrypoint" class= "org.springframework.security.web.authentication.www.digestauthenticationentrypoint"> <property name="realmname" value="contacts realm via digest authentication"/> <property name="key" value="acegi"/> <property name="noncevalidityseconds" value="10"/> </b...
Read more

laravel - PDOException in Connector.php line 55: SQLSTATE[HY000] [1045] Access denied for user 'root'@'localhost' (using password: YES) -

-
my .env: app_env=local app_debug=true app_key=myappkey app_url=http://localhost db_connection=mysql db_host=localhost db_port=3306 db_database=gestiontaller db_username=root db_password='root' cache_driver=file session_driver=file queue_driver=sync redis_host=127.0.0.1 redis_password=null redis_port=6379 mail_driver=smtp mail_host=mailtrap.io mail_port=2525 mail_username=null mail_password=null mail_encryption=null i've tried password ", ' , without, restarting server every time. i've tried changing localhost 172.0.0.1. yes, password correct, running mysql -u root -p introducing password root in prompt can go mysql. users table: +------------------+-----------+ | user | host | +------------------+-----------+ | debian-sys-maint | localhost | | mysql.sys | localhost | | root | localhost | | root1 | localhost | +------------------+-----------+ i've added homestead.yaml this: database_port: 3306 ...
Read more