I got it working by replacing: synapseEnvironment.injectMessage(mc);
with this code: EndpointDefinition endpointDef = new EndpointDefinition(); endpointDef.setAddress(to); synapseEnvironment.send(endpointDef, mc); I don't know if "mc.setTo(new EndpointReference(to))" has any effect at all... now it does what i want ! Remsy -----Original Message----- From: [EMAIL PROTECTED] [mailto:[EMAIL PROTECTED] Behalf Of Paul Fremantle Sent: September 18, 2008 4:45 PM To: [email protected] Subject: Re: [esb-java-user] invoking proxy service from task Remsy We are looking at that right now, but the usual pattern is to specify a filter in the main sequence: For example: <task class="org.apache.synapse.startup.tasks.MessageInjector" name="test-task"> <property name="to" value="urn:something"/> <property name="message"> <m0:test xmlns:m0="http://services.samples/xsd"/> </property> <trigger interval="5"/> </task> <sequence name="main"> <!-- find the newly injected messages --> <filter source="get-property('To')" regex="urn:something"> <sequence key="sequence-to-call"/> </filter> </sequence> </definitions> Schmilinsky, Remsy wrote: > Hi. How can I specify a proxy address for a task ? I created a simple task, > but it just calls the main sequence instead of the proxy URL passed in the > "to" parameter. > > For instance, I want to choose the proxy service for the task, each proxy has > a different sequence. It just keeps calling the main sequence... > > Here is the task class I created: > > import org.apache.axis2.addressing.EndpointReference; > import org.apache.commons.logging.Log; > import org.apache.commons.logging.LogFactory; > import org.apache.synapse.ManagedLifecycle; > import org.apache.synapse.MessageContext; > import org.apache.synapse.core.SynapseEnvironment; > import org.apache.synapse.startup.Task; > import org.apache.synapse.util.PayloadHelper; > > /** > * Injects a Message in to the Synapse environment > */ > public class MessageInjector implements Task, ManagedLifecycle { > > /** > * Holds the logger for logging purposes > */ > private Log log = LogFactory.getLog(MessageInjector.class); > > /** > * Holds the to address for the message to be injected > */ > private String to = null; > > /** > * Holds the SynapseEnv to which the message will be injected > */ > private SynapseEnvironment synapseEnvironment; > > /** > * Initializes the Injector > * > * @param se > * SynapseEnvironment of synapse > */ > public void init(SynapseEnvironment se) { > synapseEnvironment = se; > } > > /** > * Set the to address of the message to be injected > * > * @param url > * String containing the to address > */ > public void setTo(String url) { > to = url; > } > > /** > * This will be invoked by the schedular to inject the message > * in to the SynapseEnvironment > */ > public void execute() { > String message = "Hello world !"; > > log.debug("execute"); > if (synapseEnvironment == null) { > log.error("Synapse Environment not set"); > return; > } > if (message == null) { > log.error("message not set"); > return; > > } > if (to == null) { > log.error("to address not set"); > return; > > } > > MessageContext mc = synapseEnvironment.createMessageContext(); > mc.setTo(new EndpointReference(to)); > PayloadHelper.setTextPayload(mc, message); > synapseEnvironment.injectMessage(mc); > > } > > /** > * Destroys the Injector > */ > public void destroy() { > } > } > > Here is the config file: > > <?xml version="1.0" encoding="UTF-8"?> > <syn:definitions xmlns:syn="http://ws.apache.org/ns/synapse";> > <syn:registry provider="org.wso2.esb.registry.ESBRegistry"> > <syn:parameter name="root">file:registry</syn:parameter> > <syn:parameter name="cachableDuration">15000</syn:parameter> > </syn:registry> > <syn:proxy name="AnotherProxy" transports="http" startOnLoad="true" > statistics="enable" trace="enable"> > <syn:target inSequence="main2"> > <syn:endpoint> > <syn:address uri="vfs:file:///home/remsy/test/out"/> > </syn:endpoint> > <syn:outSequence> > <syn:send> > <syn:endpoint> > <syn:address uri="vfs:file:///home/remsy/test/out"/> > </syn:endpoint> > </syn:send> > </syn:outSequence> > </syn:target> > </syn:proxy> > <syn:proxy name="Transformer" transports="http vfs" startOnLoad="true" > statistics="enable" trace="enable"> > <syn:target inSequence="main"> > <syn:endpoint> > <syn:address uri="vfs:file:///home/remsy/test/out"/> > </syn:endpoint> > <syn:outSequence> > <syn:send> > <syn:endpoint> > <syn:address uri="vfs:file:///home/remsy/test/out"/> > </syn:endpoint> > </syn:send> > </syn:outSequence> > </syn:target> > <syn:parameter > name="transport.vfs.ContentType">text/plain</syn:parameter> > <syn:parameter > name="transport.vfs.ActionAfterFailure">MOVE</syn:parameter> > <syn:parameter > name="transport.vfs.MoveAfterProcess">file:///home/remsy/test/original</syn:parameter> > <syn:parameter > name="transport.vfs.MoveAfterFailure">file:///home/remsy/test/original</syn:parameter> > <syn:parameter > name="transport.vfs.ActionAfterProcess">MOVE</syn:parameter> > <syn:parameter > name="transport.vfs.FileNamePattern">.*\.txt</syn:parameter> > <syn:parameter > name="transport.vfs.FileURI">file:///home/remsy/test/in</syn:parameter> > <syn:parameter name="transport.PollInterval">15</syn:parameter> > </syn:proxy> > <syn:sequence statistics="enable" name="main" trace="enable"> > <syn:log level="full" separator=","/> > <syn:class name="MediatorTest"/> > </syn:sequence> > <syn:sequence name="fault"> > <syn:log level="full"> > <syn:property name="MESSAGE" value="Executing default > "fault" sequence"/> > <syn:property name="ERROR_CODE" > expression="get-property('ERROR_CODE')"/> > <syn:property name="ERROR_MESSAGE" > expression="get-property('ERROR_MESSAGE')"/> > </syn:log> > <syn:drop/> > </syn:sequence> > <syn:sequence statistics="enable" name="main2" trace="enable"> > <syn:log level="full" separator=","/> > </syn:sequence> > <syn:task name="TestInjector" class="MessageInjector"> > <syn:trigger once="true"/> > <syn:property name="to" > value="http://localhost:8280/soap/AnotherProxy"/> > </syn:task> > </syn:definitions> > > thanks > > Remsy > > -----Original Message----- > From: [EMAIL PROTECTED] > [mailto:[EMAIL PROTECTED] Behalf Of Paul Fremantle > Sent: September 18, 2008 11:50 AM > To: [email protected] > Subject: Re: [esb-java-user] MQ series message listener > > > Yes, Indika has got this working. > > Indika - can you please post some instructions? > > Thanks > Paul > > Schmilinsky, Remsy wrote: >> Hi. Esb uses Active MQ for message listening, is it possible to adapt it for >> IBM MQ ? Our current infrastructure only supports this method. >> >> thanks >> >> Remsy >> >> _______________________________________________ >> Esb-java-user mailing list >> [email protected] >> http://mailman.wso2.org/cgi-bin/mailman/listinfo/esb-java-user >> > -- Paul Fremantle CTO and Co-Founder, WSO2 OASIS WS-RX TC Co-chair VP, Apache Synapse Office: +44 844 484 8143 Cell: +44 798 447 4618 blog: http://pzf.fremantle.org [EMAIL PROTECTED] "Oxygenating the Web Service Platform", www.wso2.com _______________________________________________ Esb-java-user mailing list [email protected] http://mailman.wso2.org/cgi-bin/mailman/listinfo/esb-java-user _______________________________________________ Esb-java-user mailing list [email protected] http://mailman.wso2.org/cgi-bin/mailman/listinfo/esb-java-user
