org.apache.synapse.transport.fix
Class FIXOutgoingMessageHandler
java.lang.Object
org.apache.synapse.transport.fix.FIXOutgoingMessageHandler
public class FIXOutgoingMessageHandler
- extends Object
FIXOutgoingMessageHandler makes sure that messages are delivered in the order they were received by
a FIX acceptor. In case the message arrived over a different transport still this class will try to
put the messages in correct order based on the counter value of the message.
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
FIXOutgoingMessageHandler
public FIXOutgoingMessageHandler()
setSessionFactory
public void setSessionFactory(FIXSessionFactory sessionFactory)
sendMessage
public void sendMessage(quickfix.Message message,
quickfix.SessionID targetSession,
String sourceSession,
int counter,
MessageContext msgCtx,
String targetEPR)
throws quickfix.SessionNotFound
- Performs the actual send operation on the message. Tries to send the messages in the order they
arrived over the FIX transport
- Parameters:
message
- the FIX message to be senttargetSession
- ID of the target FIXSessionsourceSession
- String that uniquely identifies the incoming sessioncounter
- application level sequence number of the messagemsgCtx
- Axis2 MessageContext for the outgoing messagetargetEPR
- the target EPR to forward the message
- Throws:
quickfix.SessionNotFound
- on error
cleanUpMessages
public void cleanUpMessages(String session)
Copyright © 2005-2012 Apache Software Foundation. All Rights Reserved.