Package 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.
-
-
Constructor Summary
Constructors Constructor Description FIXOutgoingMessageHandler()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
cleanUpMessages(String session)
void
sendMessage(quickfix.Message message, quickfix.SessionID targetSession, String sourceSession, int counter, org.apache.axis2.context.MessageContext msgCtx, String targetEPR)
Performs the actual send operation on the message.void
setSessionFactory(FIXSessionFactory sessionFactory)
-
-
-
Method Detail
-
setSessionFactory
public void setSessionFactory(FIXSessionFactory sessionFactory)
-
sendMessage
public void sendMessage(quickfix.Message message, quickfix.SessionID targetSession, String sourceSession, int counter, org.apache.axis2.context.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)
-
-