Hi, Please provide more details for this?
Fro which point are you going to inject the message? Did you create the endpoint used in the send mediator? On Mon, Jan 12, 2015 at 9:56 AM, Chanaka Cooray <[email protected]> wrote: > Hi, > I need to inject a message to a esb sequence, I already wrote a java code > to implement that. When I created a sequence to send message to an > endpoint, the console indicates the following error. But when I tried to > inject the message to a sequence with log mediator, it works fine. > > [2015-01-12 09:37:26,679] ERROR - Axis2SynapseEnvironment Unexpected error >>> executing task/async inject >> >> java.lang.IllegalStateException: not initialized, endpoint must be in >>> initialized state >> >> at >>> org.apache.synapse.endpoints.AbstractEndpoint.readyToSend(AbstractEndpoint.java:244) >> >> at >>> org.apache.synapse.endpoints.AddressEndpoint.send(AddressEndpoint.java:54) >> >> at >>> org.apache.synapse.mediators.builtin.SendMediator.mediate(SendMediator.java:97) >> >> at >>> org.apache.synapse.mediators.AbstractListMediator.mediate(AbstractListMediator.java:80) >> >> at >>> org.apache.synapse.mediators.AbstractListMediator.mediate(AbstractListMediator.java:47) >> >> at >>> org.apache.synapse.mediators.filters.InMediator.mediate(InMediator.java:61) >> >> at >>> org.apache.synapse.mediators.AbstractListMediator.mediate(AbstractListMediator.java:80) >> >> at >>> org.apache.synapse.mediators.AbstractListMediator.mediate(AbstractListMediator.java:47) >> >> at >>> org.apache.synapse.mediators.base.SequenceMediator.mediate(SequenceMediator.java:135) >> >> at >>> org.apache.synapse.core.axis2.Axis2SynapseEnvironment.injectInbound(Axis2SynapseEnvironment.java:324) >> >> at >>> org.wso2.carbon.inbound.endpoint.protocol.mqtt.MQTTInjectHandler.invoke(MQTTInjectHandler.java:94) >> >> at >>> org.wso2.carbon.inbound.endpoint.protocol.mqtt.MqttListenerCallback.messageArrived(MqttListenerCallback.java:30) >> >> at >>> org.eclipse.paho.client.mqttv3.internal.CommsCallback.handleMessage(CommsCallback.java:332) >> >> at >>> org.eclipse.paho.client.mqttv3.internal.CommsCallback.run(CommsCallback.java:144) >> >> at java.lang.Thread.run(Thread.java:745) >> >> [2015-01-12 09:37:26,683] WARN - Axis2SynapseEnvironment Executing fault >>> handler due to exception encountered >> >> [2015-01-12 09:37:26,683] WARN - FaultHandler ERROR_CODE : 0 >> >> [2015-01-12 09:37:26,683] WARN - FaultHandler ERROR_MESSAGE : not >>> initialized, endpoint must be in initialized state >> >> [2015-01-12 09:37:26,684] WARN - FaultHandler ERROR_DETAIL : >>> java.lang.IllegalStateException: not initialized, endpoint must be in >>> initialized state >> >> at >>> org.apache.synapse.endpoints.AbstractEndpoint.readyToSend(AbstractEndpoint.java:244) >> >> at >>> org.apache.synapse.endpoints.AddressEndpoint.send(AddressEndpoint.java:54) >> >> at >>> org.apache.synapse.mediators.builtin.SendMediator.mediate(SendMediator.java:97) >> >> at >>> org.apache.synapse.mediators.AbstractListMediator.mediate(AbstractListMediator.java:80) >> >> at >>> org.apache.synapse.mediators.AbstractListMediator.mediate(AbstractListMediator.java:47) >> >> at >>> org.apache.synapse.mediators.filters.InMediator.mediate(InMediator.java:61) >> >> at >>> org.apache.synapse.mediators.AbstractListMediator.mediate(AbstractListMediator.java:80) >> >> at >>> org.apache.synapse.mediators.AbstractListMediator.mediate(AbstractListMediator.java:47) >> >> at >>> org.apache.synapse.mediators.base.SequenceMediator.mediate(SequenceMediator.java:135) >> >> at >>> org.apache.synapse.core.axis2.Axis2SynapseEnvironment.injectInbound(Axis2SynapseEnvironment.java:324) >> >> at >>> org.wso2.carbon.inbound.endpoint.protocol.mqtt.MQTTInjectHandler.invoke(MQTTInjectHandler.java:94) >> >> at >>> org.wso2.carbon.inbound.endpoint.protocol.mqtt.MqttListenerCallback.messageArrived(MqttListenerCallback.java:30) >> >> at >>> org.eclipse.paho.client.mqttv3.internal.CommsCallback.handleMessage(CommsCallback.java:332) >> >> at >>> org.eclipse.paho.client.mqttv3.internal.CommsCallback.run(CommsCallback.java:144) >> >> at java.lang.Thread.run(Thread.java:745) >> >> >>> [2015-01-12 09:37:26,684] WARN - FaultHandler ERROR_EXCEPTION : >>> java.lang.IllegalStateException: not initialized, endpoint must be in >>> initialized state >> >> >> > The java code attached below is the code that I implemented to inject the > message into the sequence. > > >> *OMElement documentElement = null;* >> * InputStream in = new AutoCloseInputStream(new >> ByteArrayInputStream(* >> * message.getBytes()));** >> documentElement = builder.processDocument(in, contentType, axis2MsgCtx);* >> >> * // Inject the message to the sequence.* >> * >> msgCtx.setEnvelope(TransportUtils.createSOAPEnvelope(documentElement));* >> * if (injectingSeq == null || injectingSeq.equals("")) {* >> * log.error("Sequence name not specified. Sequence : " + >> injectingSeq);* >> * return false;* >> * }* >> * SequenceMediator seq = (SequenceMediator) >> synapseEnvironment.getSynapseConfiguration()* >> * .getSequence(injectingSeq);* >> * seq.setErrorHandler(onErrorSeq);* >> * if (seq != null) {* >> * if (log.isDebugEnabled()) {* >> * log.debug("injecting message to sequence : " + >> injectingSeq);* >> * }* >> * if(!synapseEnvironment.injectInbound(msgCtx, seq, >> sequential)){* >> * return false;* >> * }* >> * } else {* >> * log.error("Sequence: " + injectingSeq + " not found");** >> }* > > > Is there are any way to fix this error? > Thank You > -- > *Chanaka Sampath Cooray* > Software Engineering Intern, > WSO2 Lanka (pvt) Ltd. > Mobile:+94713614884 > -- Best Regards, Malaka Silva Senior Tech Lead M: +94 777 219 791 Tel : 94 11 214 5345 Fax :94 11 2145300 Skype : malaka.sampath.silva LinkedIn : http://www.linkedin.com/pub/malaka-silva/6/33/77 Blog : http://mrmalakasilva.blogspot.com/ WSO2, Inc. lean . enterprise . middleware http://www.wso2.com/ http://www.wso2.com/about/team/malaka-silva/ <http://wso2.com/about/team/malaka-silva/> Save a tree -Conserve nature & Save the world for your future. Print this email only if it is absolutely necessary.
_______________________________________________ Dev mailing list [email protected] http://wso2.org/cgi-bin/mailman/listinfo/dev
