ch.algotrader.adapter.fix

Class DefaultFixAdapter

java.lang.Object

ch.algotrader.adapter.fix.DefaultFixAdapter

All Implemented Interfaces:

FixAdapter

Direct Known Subclasses:

ManagedFixAdapter

public class DefaultFixAdapter
extends java.lang.Object
implements FixAdapter

Default Implementation of $FixAdapter

Author:

Andy Flury

Constructor Summary

Constructors

Constructor and Description
DefaultFixAdapter(quickfix.SocketInitiator socketInitiator, LookupService lookupService, FixEventScheduler eventScheduler, OrderIdGenerator orderIdGenerator)

Method Summary

Modifier and Type	Method and Description
void	closeSession(java.lang.String sessionQualifier) Closes session with the given identifier if open.
void	createSession(java.lang.String sessionQualifier) creates an individual session with the given qualifier
void	createSessionForService(java.lang.String orderServiceType) creates an individual session
java.lang.String	getNextOrderId(Account account) Gets the next orderId for the specified account
quickfix.Session	getSession(java.lang.String sessionQualifier) Returns session with the given identifier.
void	openSession(java.lang.String sessionQualifier) Makes sure there is an existing session with the given qualifier.
void	openSessionForService(java.lang.String orderServiceType) Makes sure there is an existing session with the given qualifier.
void	sendMessage(quickfix.Message message, Account account) sends a message to the designated session for the given account
void	sendMessage(quickfix.Message message, java.lang.String sessionQualifier) sends a message to the designated session
void	setOrderId(java.lang.String sessionQualifier, int orderId) Sets the current order count for the given session qualifier.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DefaultFixAdapter

public DefaultFixAdapter(quickfix.SocketInitiator socketInitiator,
                         LookupService lookupService,
                         FixEventScheduler eventScheduler,
                         OrderIdGenerator orderIdGenerator)

Method Detail

getSession

public quickfix.Session getSession(java.lang.String sessionQualifier)
                            throws BrokerAdapterException

Description copied from interface: FixAdapter

Returns session with the given identifier.

Specified by:

getSession in interface FixAdapter

Throws:

BrokerAdapterException

createSessionForService

public void createSessionForService(java.lang.String orderServiceType)
                             throws BrokerAdapterException

creates an individual session

Specified by:

createSessionForService in interface FixAdapter

Throws:

BrokerAdapterException

openSessionForService

public void openSessionForService(java.lang.String orderServiceType)
                           throws BrokerAdapterException

Description copied from interface: FixAdapter

Makes sure there is an existing session with the given qualifier. New session will be created if there is no session with the given qualifier.

Specified by:

openSessionForService in interface FixAdapter

Throws:

BrokerAdapterException

createSession

public void createSession(java.lang.String sessionQualifier)
                   throws BrokerAdapterException

Description copied from interface: FixAdapter

creates an individual session with the given qualifier

Specified by:

createSession in interface FixAdapter

Throws:

BrokerAdapterException

openSession

public void openSession(java.lang.String sessionQualifier)
                 throws BrokerAdapterException

Description copied from interface: FixAdapter

Makes sure there is an existing session with the given qualifier. New session will be created if there is no session with the given qualifier.

Specified by:

openSession in interface FixAdapter

Throws:

BrokerAdapterException

closeSession

public void closeSession(java.lang.String sessionQualifier)
                  throws BrokerAdapterException

Description copied from interface: FixAdapter

Closes session with the given identifier if open.

Specified by:

closeSession in interface FixAdapter

Throws:

BrokerAdapterException

sendMessage

public void sendMessage(quickfix.Message message,
                        Account account)
                 throws BrokerAdapterException

sends a message to the designated session for the given account

Specified by:

sendMessage in interface FixAdapter

Throws:

BrokerAdapterException

sendMessage

public void sendMessage(quickfix.Message message,
                        java.lang.String sessionQualifier)
                 throws BrokerAdapterException

sends a message to the designated session

Specified by:

sendMessage in interface FixAdapter

Throws:

BrokerAdapterException

getNextOrderId

public java.lang.String getNextOrderId(Account account)

Gets the next orderId for the specified account

Specified by:

getNextOrderId in interface FixAdapter

setOrderId

public void setOrderId(java.lang.String sessionQualifier,
                       int orderId)

Description copied from interface: FixAdapter

Sets the current order count for the given session qualifier.

Specified by:

setOrderId in interface FixAdapter