|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.apache.synapse.transport.fix.FIXIncomingMessageHandler
public class FIXIncomingMessageHandler
FIXIncomingMessageHandler is responsible for handling all incoming FIX messages. This is where the Quickfix/J engine meets Synapse core. Admin level FIX messages are handled by Quickfix/J itself. All the application level messages are handed over to the Synapse core.
Constructor Summary | |
---|---|
FIXIncomingMessageHandler(ConfigurationContext cfgCtx,
org.apache.axis2.transport.base.threads.WorkerPool workerPool,
AxisService service,
boolean acceptor)
|
Method Summary | |
---|---|
void |
acquire()
|
void |
fromAdmin(quickfix.Message message,
quickfix.SessionID sessionID)
This callback notifies when an administrative message is sent from a counterparty to the FIX engine. |
void |
fromApp(quickfix.Message message,
quickfix.SessionID sessionID)
This callback receives messages for the application. |
void |
onCreate(quickfix.SessionID sessionID)
This method is called when quickfix creates a new session. |
void |
onLogon(quickfix.SessionID sessionID)
This callback notifies when a valid logon has been established with a counter party. |
void |
onLogout(quickfix.SessionID sessionID)
This callback notifies when a FIX session is no longer online. |
void |
setOutgoingMessageContext(MessageContext msgCtx)
|
void |
toAdmin(quickfix.Message message,
quickfix.SessionID sessionID)
This callback provides Synapse with a peek at the administrative messages that are being sent from your FIX engine to the counter party. |
void |
toApp(quickfix.Message message,
quickfix.SessionID sessionID)
This is a callback for application messages that are being sent to a counter party. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public FIXIncomingMessageHandler(ConfigurationContext cfgCtx, org.apache.axis2.transport.base.threads.WorkerPool workerPool, AxisService service, boolean acceptor)
Method Detail |
---|
public void setOutgoingMessageContext(MessageContext msgCtx)
public void acquire() throws InterruptedException
InterruptedException
public void onCreate(quickfix.SessionID sessionID)
onCreate
in interface quickfix.Application
sessionID
- QuickFIX session IDpublic void onLogon(quickfix.SessionID sessionID)
onLogon
in interface quickfix.Application
sessionID
- QuickFIX session IDpublic void onLogout(quickfix.SessionID sessionID)
onLogout
in interface quickfix.Application
sessionID
- QuickFIX session IDpublic void toAdmin(quickfix.Message message, quickfix.SessionID sessionID)
toAdmin
in interface quickfix.Application
message
- QuickFIX messagesessionID
- QuickFIX session IDpublic void fromAdmin(quickfix.Message message, quickfix.SessionID sessionID) throws quickfix.FieldNotFound, quickfix.IncorrectDataFormat, quickfix.IncorrectTagValue, quickfix.RejectLogon
fromAdmin
in interface quickfix.Application
message
- QuickFIX messagesessionID
- QuickFIX session ID
quickfix.FieldNotFound
quickfix.IncorrectDataFormat
quickfix.IncorrectTagValue
quickfix.RejectLogon
- causes a logon rejectpublic void toApp(quickfix.Message message, quickfix.SessionID sessionID) throws quickfix.DoNotSend
toApp
in interface quickfix.Application
message
- QuickFIX messagesessionID
- QuickFIX session ID
quickfix.DoNotSend
- This exception aborts message transmissionpublic void fromApp(quickfix.Message message, quickfix.SessionID sessionID) throws quickfix.FieldNotFound, quickfix.IncorrectDataFormat, quickfix.IncorrectTagValue, quickfix.UnsupportedMessageType
fromApp
in interface quickfix.Application
message
- QuickFIX messagesessionID
- QuickFIX session ID
quickfix.FieldNotFound
quickfix.IncorrectDataFormat
quickfix.IncorrectTagValue
quickfix.UnsupportedMessageType
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |