Hi,
I'm trying to send a FIX message through synapse to a JMS consumer and get a
response back.
Messages successfully deliver to the JMS endpoint and response(s) are coming
back to Synapse layer, but they are not delivering to the message initiator
(FIX endpoint).
I'm using ActiveMQ 5.1.0 as my JMS message broker.
Synapse logs the following exception
2008-06-23 10:03:02,704 [127.0.1.1-asankaa-laptop] [Axis2 Task] DEBUG
SendMediator Start : Send mediator
2008-06-23 10:03:02,704 [127.0.1.1-asankaa-laptop] [Axis2 Task] DEBUG
SendMediator Sending response message using implicit message properties..
Sending To: http://www.w3.org/2005/08/addressing/anonymous
SOAPAction: null
2008-06-23 10:03:02,704 [127.0.1.1-asankaa-laptop] [Axis2 Task] DEBUG
FIXTransportSender Attempting to send a FIX message, Message
ID:urn:uuid:1E7F3734ED3D0F88921214195582704641005166278414
2008-06-23 10:03:02,704 [127.0.1.1-asankaa-laptop] [Axis2 Task] ERROR
Axis2Sender Unexpected error sending message back
org.apache.axis2.AxisFault: Unable to find a valid service for the message
at
org.apache.synapse.transport.fix.FIXUtils.getServiceName(FIXUtils.java:442)
at
org.apache.synapse.transport.fix.FIXTransportSender.sendMessage(FIXTransportSender.java:91)
at
org.apache.synapse.transport.base.AbstractTransportSender.invoke(AbstractTransportSender.java:127)
at org.apache.axis2.engine.AxisEngine.send(AxisEngine.java:448)
at
org.apache.synapse.core.axis2.Axis2Sender.sendBack(Axis2Sender.java:138)
at
org.apache.synapse.core.axis2.Axis2SynapseEnvironment.send(Axis2SynapseEnvironment.java:219)
at
org.apache.synapse.mediators.builtin.SendMediator.mediate(SendMediator.java:154)
at
org.apache.synapse.mediators.AbstractListMediator.mediate(AbstractListMediator.java:58)
2008-06-23 10:03:02,705 [127.0.1.1-asankaa-laptop] [Axis2 Task] WARN
FaultHandler Fault handler - setting ERROR_MESSAGE : Unexpected error sending
message back
2008-06-23 10:03:02,706 [127.0.1.1-asankaa-laptop] [Axis2 Task] WARN
FaultHandler Fault handler - setting ERROR_DETAIL :
org.apache.synapse.SynapseException: Unexpected error sending message back
The synapse log display the response message by converting <> to < and >.
Original message generated from JMS :
8Mon Jun 23 10:03:02 GMT+05:30 20081223331100011MSFT0
Message inside synapse :
8Mon Jun 23 10:03:02 GMT+05:30 20081223331100011MSFT0
Any clue to find a solution for the problem.
Asanka A.
_________________________________________________________________
Discover the new Windows Vista
http://search.msn.com/results.aspx?q=windows+vista&mkt=en-US&form=QBRE<!--
~ Licensed to the Apache Software Foundation (ASF) under one
~ or more contributor license agreements. See the NOTICE file
~ distributed with this work for additional information
~ regarding copyright ownership. The ASF licenses this file
~ to you under the Apache License, Version 2.0 (the
~ "License"); you may not use this file except in compliance
~ with the License. You may obtain a copy of the License at
~
~ http://www.apache.org/licenses/LICENSE-2.0
~
~ Unless required by applicable law or agreed to in writing,
~ software distributed under the License is distributed on an
~ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
~ KIND, either express or implied. See the License for the
~ specific language governing permissions and limitations
~ under the License.
-->
<!-- Send FIX messages using JMS (ActiveMQ) -->
<definitions xmlns="http://ws.apache.org/ns/synapse";>
<proxy name="FIXProxy" transports="fix">
<target>
<endpoint>
<address
uri="jms:/fix.inqueue?transport.jms.ConnectionFactoryJNDIName=QueueConnectionFactory&java.naming.factory.initial=org.apache.activemq.jndi.ActiveMQInitialContextFactory&java.naming.provider.url=tcp://localhost:61616&transport.jms.DestinationType=queue&transport.jms.ReplyDestination=replyQueue" />
</endpoint>
<inSequence>
<log level="full" />
</inSequence>
<outSequence>
<log level="full" />
<send />
<log level="full" />
</outSequence>
</target>
<parameter name="transport.fix.AcceptorConfigURL">
file:repository/conf/fix-synapse.cfg
</parameter>
<parameter name="transport.fix.AcceptorMessageStore">
/home/asankaa/var/data/store
</parameter>
<parameter name="transport.fix.InitiatorConfigURL">
file:repository/conf/synapse-sender.cfg
</parameter>
<parameter name="transport.fix.InitiatorMessageStore">
/home/asankaa/var/data/store
</parameter>
</proxy>
</definitions>
