Hi Piriya, I don't see any issue with what you have done here. You can't see messages in the store, may be due to message processor consume that message and trying to send to the endpoint. You can do following things to troubleshoot this issue.
1. Remove messageprocessor temporarily and execute the curl command, then the message should be there in the store. If the message is still not there, then there should be something wrong with message queue configurations. 2. If you can see the message in store in step #1, there can be something wrong with the endpoint you provided. You can enable wire log and troubleshoot that. Thanks Godwin On Thu, Dec 28, 2017 at 10:47 PM, Piriya Sivalingam <[email protected]> wrote: > Hi, > > I am trying to implement guaranteed delivery EIP using WSO2ESB and > WSO2DSS. My endpoint for this scenario is a dataservice in WSO2DSS. In this > scenario, I am using RabbitMQ as the message broker. > > I followed the below steps to implement the guaranteed delivery scenario. > > - I installed RabbitMQ and Erlang OTP. > - Then I added RabbitMQ message store according to the instructions in > this [1] document. > - I created an API with store mediator to stores messages using the > above message store. > - Then I created a Message-processor that consumes messages from the > message-store and sends it to an endpoint. > > Below are the configurations of the Message-Store, API and > Message-Processor. > > Message-Store: > > <messageStore name="RabbitMS" class="org.apache.synapse. > message.store.impl.rabbitmq.RabbitMQStore" xmlns="http://ws.apache.org/ > ns/synapse"> > <parameter name="store.rabbitmq.host.name">localhost</parameter> > <parameter name="store.rabbitmq.host.port">5672</parameter> > <parameter name="store.rabbitmq.queue.name">RabbitMS_Queue</parameter> > <parameter name="store.producer.guaranteed.delivery.enable"> > true</parameter> > <parameter name="store.failover.message.store.name">InMemoryStore</ > parameter> > </messageStore> > > API: > > <api xmlns="http://ws.apache.org/ns/synapse"; name="API1" > context="/details"> > <resource methods="GET" url-mapping="/test"> > <inSequence> > <payloadFactory media-type="xml"> > <format> > <p:select_with_key_CHASSIS_operation xmlns:p=" > https://car.data.wso2.com";> > <xs:CHASSIS_ID xmlns:xs="https://car.data.wso2.com > ">1009</xs:CHASSIS_ID> > </p:select_with_key_CHASSIS_operation> > </format> > <args/> > </payloadFactory> > <property name="FORCE_SC_ACCEPTED" value="true" scope="axis2" > type="STRING"/> > <property name="OUT_ONLY" value="true" scope="default" > type="STRING"></property> > <log level="full"/> > <store messageStore="RabbitMS"/> > </inSequence> > </resource> > </api> > > Message-Processor: > > <messageProcessor name="Forwarder" class="org.apache.synapse. > message.processor.impl.forwarder.ScheduledMessageForwardingProcessor" > targetEndpoint="sampleEndPoint" messageStore="RabbitMS" xmlns=" > http://ws.apache.org/ns/synapse";> > <parameter name="interval">1000</parameter> > <parameter name="client.retry.interval">1000</parameter> > <parameter name="max.delivery.attempts">4</parameter> > <parameter name="is.active">true</parameter> > <parameter name="max.delivery.drop">Disabled</parameter> > <parameter name="member.count">1</parameter> > </messageProcessor> > > End-point: > > <endpoint xmlns="http://ws.apache.org/ns/synapse"; name="sampleEndPoint"> > <address uri="https://192.168.8.100:9453/services/ChassisService/ > select_with_key_CHASSIS_operation"> > </address> > </endpoint> > > > But when I invoke the API with the below curl command I could not see any > messages stored in the message-store/queue or any logs in the console of > ESB. > > curl command: > curl -X GET -H "Content-Type:application/json" 'http://192.168.8.100:8280/ > details' > > Could you please suggest whether what I have done is correct or correct me > if I have done something wrong. > > [1] https://docs.wso2.com/display/ESB500/RabbitMQ+Message+Store > > Thanks. > Piriya > > -- > Regards, > > *Piriya Sivalingam* > > *Software Engineer - Support Team* > > *WSO2* > *Mobile : +94 77 8462039 <+94%2077%20846%202039>* > > [image: http://wso2.com/signature] <http://wso2.com/signature> > > > _______________________________________________ > Dev mailing list > [email protected] > http://wso2.org/cgi-bin/mailman/listinfo/dev > > -- *Godwin Amila Shrimal* Associate Technical Lead WSO2 Inc.; http://wso2.com lean.enterprise.middleware mobile: *+94772264165* linkedin: *https://www.linkedin.com/in/godwin-amila-2ba26844/ <https://www.linkedin.com/in/godwin-amila-2ba26844/>* twitter: https://twitter.com/godwinamila <http://wso2.com/signature>
_______________________________________________ Dev mailing list [email protected] http://wso2.org/cgi-bin/mailman/listinfo/dev
