Hi ESB Team,
When I am configuring Store mediator, I created an On Store Sequence.
*<sequence name="onstoreSeq" xmlns="http://ws.apache.org/ns/synapse
<http://ws.apache.org/ns/synapse>"> <axis2ns17:store messageStore="reg"
sequence="conf:/registrySeq"
xmlns:axis2ns17="http://ws.apache.org/ns/synapse
<http://ws.apache.org/ns/synapse>"/></sequence>*
Then I created another sequence with a store mediator (Store mediator used
On Store Sequence)
*<sequence name="onstoreSeq"> <store messageStore="reg"
sequence="conf:/registrySeq"/> </sequence> *
Created a proxy and invoked it using axis2Client.
*<proxy name="regProxy" startOnLoad="true" trace="disable" transports="http
https"> <description/> <target inSequence="onstoreSeq"/>
</proxy>*
Then I tried to add a Scheduled Message Forwarding Processor to send
messages in the message store. As I used Store mediator through On Store
Sequence, processor will automatically deactivate:
*ForwardingService Deactivating the message processor
[storeProce]java.lang.NullPointerException at
org.apache.synapse.message.processor.impl.forwarder.ForwardingService.dispatch(ForwardingService.java:431)
at
org.apache.synapse.message.processor.impl.forwarder.ForwardingService.execute(ForwardingService.java:204)
at
org.wso2.carbon.mediation.ntask.NTaskAdapter.execute(NTaskAdapter.java:90)
at
org.wso2.carbon.ntask.core.impl.TaskQuartzJobAdapter.execute(TaskQuartzJobAdapter.java:67)
at org.quartz.core.JobRunShell.run(JobRunShell.java:213) at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266) at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)[2016-03-09 23:58:51,712] WARN -
ForwardingService Failed to send the message through the deactivate
sequence. Sequence name does not Exist.*
*Issue*: Can we implement message processor which have connection to On
Store Sequence as it not including in synapse ? Why message processor do
not identify On Store Sequence?
Any clarification on this ? Any help will be highly appreciated.
PS: Attached Synapse Configuration XML.
Thank you.
--
Best Regards,
Dilshani Subasinghe
Software Engineer - QA
WSO2, Inc.;http://wso2.com/
<http://www.google.com/url?q=http%3A%2F%2Fwso2.com%2F&sa=D&sntz=1&usg=AFQjCNGJuLRux6KkJwXKVUCYOtEsNCmIAQ>
lean.enterprise.middleware
Mobile: +94773375185
<?xml version="1.0" encoding="UTF-8"?>
<definitions xmlns="http://ws.apache.org/ns/synapse";>
<registry provider="org.wso2.carbon.mediation.registry.WSO2Registry">
<parameter name="cachableDuration">15000</parameter>
</registry>
<taskManager provider="org.wso2.carbon.mediation.ntask.NTaskTaskManager"/>
<proxy name="regProxy" startOnLoad="true" trace="disable" transports="http https">
<description/>
<target inSequence="onstoreSeq"/>
</proxy>
<sequence name="onstoreSeq">
<store messageStore="reg" sequence="conf:/registrySeq"/>
</sequence>
<sequence name="fault">
<!-- Log the message at the full log level with the ERROR_MESSAGE and the ERROR_CODE-->
<log level="full">
<property name="MESSAGE" value="Executing default 'fault' sequence"/>
<property expression="get-property('ERROR_CODE')" name="ERROR_CODE"/>
<property expression="get-property('ERROR_MESSAGE')" name="ERROR_MESSAGE"/>
</log>
<!-- Drops the messages by default if there is a fault -->
<drop/>
</sequence>
<sequence name="main">
<in>
<!-- Log all messages passing through -->
<log level="full"/>
<filter regex="http://localhost:9000.*"; source="get-property('To')">
<!-- Send the messages where they have been sent (i.e. implicit "To" EPR) -->
<send/>
</filter>
</in>
<out>
<send/>
</out>
<description>The main sequence for the message mediation</description>
</sequence>
<messageStore name="reg"/>
<messageProcessor
class="org.apache.synapse.message.processor.impl.forwarder.ScheduledMessageForwardingProcessor"
messageStore="reg" name="storeProce" targetEndpoint="http://127.0.0.1:9000/services/SimpleStockQuoteService";>
<parameter name="client.retry.interval">1000</parameter>
<parameter name="throttle">false</parameter>
<parameter name="max.delivery.attempts">4</parameter>
<parameter name="member.count">1</parameter>
<parameter name="max.delivery.drop">Disabled</parameter>
<parameter name="interval">1000</parameter>
<parameter name="is.active">true</parameter>
<parameter name="target.endpoint">http://127.0.0.1:9000/services/SimpleStockQuoteService</parameter>
</messageProcessor>
<!-- You can add any flat sequences, endpoints, etc.. to this synapse.xml file if you do
*not* want to keep the artifacts in several files -->
</definitions>_______________________________________________
Dev mailing list
[email protected]
http://wso2.org/cgi-bin/mailman/listinfo/dev
