|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.apache.axis2.handlers.AbstractHandler org.apache.axis2.transport.base.AbstractTransportSender org.apache.synapse.transport.fix.FIXTransportSender
public class FIXTransportSender
The FIX transport sender implementation. This implementation looks at the SOAPBody of the message context to identify how the message was first received by Axis2 engine and also looks at some FIX header fields to make the optimum routing decision.
This transport sender implementation does not support forwarding FIX messages to sessions with different BeginString values.When it performs a message forwarding it makes sure the forwarding takes place according to the conditions specified in the 'Third Party Routing' section in the FIX protocol specification.
Nested Class Summary |
---|
Nested classes/interfaces inherited from interface org.apache.axis2.engine.Handler |
---|
Handler.InvocationResponse |
Field Summary |
---|
Fields inherited from class org.apache.axis2.transport.base.AbstractTransportSender |
---|
cfgCtx, log, metrics |
Fields inherited from class org.apache.axis2.handlers.AbstractHandler |
---|
handlerDesc |
Constructor Summary | |
---|---|
FIXTransportSender()
|
Method Summary | |
---|---|
void |
init(ConfigurationContext cfgCtx,
TransportOutDescription transportOut)
|
void |
logOutIncomingSession(quickfix.SessionID sessionID)
|
void |
sendMessage(MessageContext msgCtx,
String targetEPR,
OutTransportInfo outTransportInfo)
Performs the actual sending of the message. |
void |
stop()
|
Methods inherited from class org.apache.axis2.transport.base.AbstractTransportSender |
---|
cleanup, createResponseMessageContext, getActiveThreadCount, getAvgSizeReceived, getAvgSizeSent, getBytesReceived, getBytesSent, getFaultsReceiving, getFaultsSending, getLastResetTime, getMaxSizeReceived, getMaxSizeSent, getMessagesReceived, getMessagesSent, getMetricsWindow, getMinSizeReceived, getMinSizeSent, getQueueSize, getResponseCodeTable, getTimeoutsReceiving, getTimeoutsSending, getTransportName, handleException, handleException, handleIncomingMessage, invoke, logException, maintenenceShutdown, pause, resetStatistics, resume, waitForSynchronousResponse |
Methods inherited from class org.apache.axis2.handlers.AbstractHandler |
---|
cleanup, flowComplete, getHandlerDesc, getName, getParameter, init, toString |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Methods inherited from interface org.apache.axis2.engine.Handler |
---|
cleanup, flowComplete, getHandlerDesc, getName, getParameter, init |
Constructor Detail |
---|
public FIXTransportSender()
Method Detail |
---|
public void init(ConfigurationContext cfgCtx, TransportOutDescription transportOut) throws AxisFault
init
in interface TransportSender
init
in class org.apache.axis2.transport.base.AbstractTransportSender
cfgCtx
- the axis2 configuration contexttransportOut
- the Out Transport description
AxisFault
- on errorpublic void stop()
stop
in interface TransportSender
stop
in class org.apache.axis2.transport.base.AbstractTransportSender
public void sendMessage(MessageContext msgCtx, String targetEPR, OutTransportInfo outTransportInfo) throws AxisFault
sendMessage
in class org.apache.axis2.transport.base.AbstractTransportSender
msgCtx
- the axis2 message context of the message to be senttargetEPR
- the EPR for which the message is to be sentoutTransportInfo
- the OutTransportInfo for the message
AxisFault
- on errorpublic void logOutIncomingSession(quickfix.SessionID sessionID)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |