com.teraspaces.qwfix
Class FIXSession
java.lang.Object
com.teraspaces.qwfix.FIXSession
public final class FIXSession
- extends Object
getEngine
public FIXEngine getEngine()
getSettings
public FIXSessionSettings getSettings()
getEngineSessionSettings
public FIXEngineSessionSettings getEngineSessionSettings()
getEndPoint
public FIXEngineSessionEndPoint getEndPoint()
getConnectionStatus
public FIXSessionConnectionStatus getConnectionStatus()
getDefaultSchema
public FIXSchema getDefaultSchema()
getSchemas
public List<FIXSchema> getSchemas()
disconnect
public void disconnect()
logout
public void logout(String text)
resume
public void resume()
getPersistences
public List<FIXSessionPersistence> getPersistences()
createMessage
public FIXMessage createMessage(String msgType)
createMessage
public FIXMessage createMessage(String msgType,
int schemaIndex)
sendMessage
public long sendMessage(FIXMessage message)
throws IOException,
FIXSessionRejectException
- Throws:
IOException
FIXSessionRejectException
sendMessage
public long sendMessage(FIXMessage message,
boolean alwaysQueue)
throws IOException,
FIXSessionRejectException
- Throws:
IOException
FIXSessionRejectException
getSentMessageInfo
public long getSentMessageInfo(long token)
- Gets the actual MsgSeqNum from the token of an outgoing message.
- Parameters:
token - The message token returned from sendMessage method.
- Returns:
- A token indicating the actual MsgSeqNum. Use FIXMessageTokenHelper.getMsgSeqNum to get the actual sequence number. If the
message has not been sent yet, FIXMessageTokenHelper.INVALID_TOKEN will be returned.
getLastSentAppMessage
public long getLastSentAppMessage()
getLastOutgoingAppMessage
public long getLastOutgoingAppMessage()
getPerfQueueOutgoing
public int getPerfQueueOutgoing()
getPerfQueueIncoming
public int getPerfQueueIncoming()
getPerfMessagesSent
public int getPerfMessagesSent()
getPerfMessagesReceived
public int getPerfMessagesReceived()
isActive
public boolean isActive()
getCurrentActivePersistence
public FIXSessionPersistence getCurrentActivePersistence()
getServiceStatus
public FIXServiceStatus getServiceStatus()
addSessionMessageListener
public void addSessionMessageListener(FIXSessionMessageListener listener)
removeSessionMessageListener
public void removeSessionMessageListener(FIXSessionMessageListener listener)
addSessionStatusListener
public void addSessionStatusListener(FIXSessionStatusListener listener)
removeSessionStatusListener
public void removeSessionStatusListener(FIXSessionStatusListener listener)
getEngineSessionID
public int getEngineSessionID()
getGlobalSessionID
public int getGlobalSessionID()
getSupportsRecovery
public boolean getSupportsRecovery()
setSupportsRecovery
public void setSupportsRecovery(boolean value)