com.epam.fixengine.session

Class InitiatorFIXSession

java.lang.Object

com.epam.fixengine.session.AbstractFIXSession

com.epam.fixengine.session.InitiatorFIXSession

All Implemented Interfaces:

FIXSession, ExtendedFIXSession, com.epam.fixengine.session.SessionStateListenSupport

Direct Known Subclasses:

AutoreconnectFIXSession

public class InitiatorFIXSession
extends AbstractFIXSession

Nested Class Summary

Nested classes/interfaces inherited from class com.epam.fixengine.session.AbstractFIXSession

AbstractFIXSession.ConsumingControlTransportWrapper

Field Summary

Fields

Modifier and Type	Field and Description
protected static Log	log

Fields inherited from class com.epam.fixengine.session.AbstractFIXSession

configuration, DEBUG_ENABLED, graceful, listener, messageFactory, preferredSendingMode, queue, runtimeState, sentTRNum, sequenceManager, sessionLock, sessionParameters, testRequestTime, TRACE_ENABLED, transport

Fields inherited from interface com.epam.fixengine.FIXSession

DEFAULT_SENDING_OPTIONS, SEND_ASYNC, SEND_SYNC

Constructor Summary

Constructors

Constructor and Description
InitiatorFIXSession(FIXMessageFactory factory, SessionParameters sessionParameters, HandlerChain fixSessionListener) Creates the InitiatorFIXSession.

Method Summary

Modifier and Type	Method and Description
void	connect() Connects to remote counterparty, if initiator or accepts incoming connection if acceptor.
protected void	connectInternal()
void	disconnect(String reason) Disconnect the session.
void	dispose() Disposes current session, removes its reference from GlobalSessionManager and frees all allocated resources.
protected FIXTransport	getTransport(SessionParameters sessionParameters, String host, int port) Gets transport.
void	init() Initialize FIX session.
protected void	initTransport()
void	reject(String reason) Unsupported for InitiatorFIXSession.
void	setSessionState(SessionState sessionState) Sets session state.

Methods inherited from class com.epam.fixengine.session.AbstractFIXSession

addInSessionLevelMessageListener, addOutSessionLevelMessageListener, addSessionStateListener, addUserGlobalMessageHandler, backupStorages, checkHasSessionSendOrReceivedTestRequest, checkSessionInactiveAndSendHbt, clearQueue, disconnect, disconnect, disconnect, disconnect, disconnectTestRequestIsLost, equals, forcedDisconnect, getAttribute, getAttribute, getAttributeAsBool, getAttributeAsLong, getBytesRead, getBytesSent, getConfiguration, getEncryption, getErrorHandler, getEstablished, getExtendedFIXSessionListener, getFIXSessionOutOfSyncListener, getIncomingMessageStorage, getInSeqNum, getLastDisconnectReason, getLastInMessageTimestamp, getLastOutMessageTimestamp, getMessageFactory, getMessageHandlers, getMessageQueue, getMessageValidator, getNoOfInMessages, getNoOfOutMessages, getOutgoingMessageStorage, getOutSeqNum, getQueuedMessagesCount, getRejectMessageListener, getRuntimeState, getSequenceManager, getSessionParameters, getSessionParametersInstance, getSessionState, getSlowConsumerListener, getStorageFactory, hashCode, initSessionInternal, initSessionRuntimeState, isHbtControlInPumper, isResetSeqNumFlagRequiredForInitLogon, isStatisticEnabled, lockSending, markShutdownAsGraceful, onDisconnect, prepareForConnect, prepareMessage, prepareMessage, prepareMessage, prepareMessageFromString, prepareMessageFromString, reinit, removeAttribute, removeAttribute, removeLongAttribute, removeSessionStateListener, resetInitialization, resetSequenceNumbers, resetSequenceNumbers, resetTestRequestFlags, restoreSessionAfterReceivedTestRequest, saveSessionParameters, sendAsIs, sendAsIs, sendMessage, sendMessage, sendMessage, sendMessage, sendMessageAndGetQueueSize, sendMessageAndGetQueueSize, sendMessageOutOfTurn, sendTestRequest, sendWithChanges, sendWithChanges, sendWithChangesAndGetQueueSize, sendWithChangesAndGetQueueSize, setAttribute, setAttribute, setAttribute, setAttribute, setErrorHandler, setFIXSessionListener, setFIXSessionOutOfSyncListener, setInSeqNum, setLastDisconnectReason, setOutOfTurnMode, setOutSeqNum, setPreLogoffSessionState, setRejectMessageListener, setSequenceNumbers, setSlowConsumerListener, shutdown, shutdown, startSession, subscribeForAttributeChanges, toString, unlockSending

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.epam.fixengine.session.ExtendedFIXSession

getAndRemoveAttribute

Field Detail

log

protected static final Log log

Constructor Detail

InitiatorFIXSession

public InitiatorFIXSession(FIXMessageFactory factory,
                           SessionParameters sessionParameters,
                           HandlerChain fixSessionListener)

Creates the InitiatorFIXSession.

Method Detail

getTransport

protected FIXTransport getTransport(SessionParameters sessionParameters,
                                    String host,
                                    int port)

Gets transport.

Parameters:

sessionParameters - the session parameters

host - the host

port - the port

init

public void init()
          throws IOException

Description copied from interface: FIXSession

Initialize FIX session. This allows to put messages to session. These messages will be send after connect.

Specified by:

init in interface FIXSession

Overrides:

init in class AbstractFIXSession

Throws:

IOException - I/O exception if error occurred

connect

public void connect()
             throws IOException

Description copied from interface: FIXSession

Connects to remote counterparty, if initiator or accepts incoming connection if acceptor.

Specified by:

connect in interface FIXSession

Specified by:

connect in class AbstractFIXSession

Throws:

IOException - I/O exception if error occurred

See Also:

FIXSession.reject(String)

setSessionState

public void setSessionState(SessionState sessionState)

Description copied from interface: ExtendedFIXSession

Sets session state.

Specified by:

setSessionState in interface ExtendedFIXSession

Overrides:

setSessionState in class AbstractFIXSession

Parameters:

sessionState - the new session state

See Also:

ExtendedFIXSession.setSessionState(com.epam.fixengine.SessionState)

reject

public void reject(String reason)
            throws IOException

Unsupported for InitiatorFIXSession. Always throws IllegalStateException.

Specified by:

reject in interface FIXSession

Specified by:

reject in class AbstractFIXSession

Throws:

IllegalStateException

IOException - I/O exception if error occurred

See Also:

FIXSession.reject(String)

connectInternal

protected void connectInternal()
                        throws IOException

Throws:

IOException

initTransport

protected void initTransport()

disconnect

public void disconnect(String reason)

Description copied from class: AbstractFIXSession

Disconnect the session.

The method sends the logof message, if response is not received during the HBI, shutdown the session.

Specified by:

disconnect in interface FIXSession

Overrides:

disconnect in class AbstractFIXSession

Parameters:

reason - the reason, if parameter is not null, the logof message will be send with 58=reason.

See Also:

FIXSession.disconnect(String)

dispose

public void dispose()

Description copied from interface: FIXSession

Disposes current session, removes its reference from GlobalSessionManager and frees all allocated resources. Normally should be called after disconnect(). However it is possible to call this method for active session without previous disconnect() that will abnormally terminate fix session by closing fix connection (without logon exchange). This is useful to terminate stuck sessions if standard FIX logoff procedure doesn't work.

Specified by:

dispose in interface FIXSession

Overrides:

dispose in class AbstractFIXSession

See Also:

FIXSession.dispose()