public class DefaultFixAdapter extends java.lang.Object implements FixAdapter
FixAdapter
Constructor and Description |
---|
DefaultFixAdapter(quickfix.SocketInitiator socketInitiator,
LookupService lookupService,
FixEventScheduler eventScheduler,
OrderIdGenerator orderIdGenerator) |
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.
|
public DefaultFixAdapter(quickfix.SocketInitiator socketInitiator, LookupService lookupService, FixEventScheduler eventScheduler, OrderIdGenerator orderIdGenerator)
public quickfix.Session getSession(java.lang.String sessionQualifier) throws BrokerAdapterException
FixAdapter
getSession
in interface FixAdapter
BrokerAdapterException
public void createSessionForService(java.lang.String orderServiceType) throws BrokerAdapterException
createSessionForService
in interface FixAdapter
BrokerAdapterException
public void openSessionForService(java.lang.String orderServiceType) throws BrokerAdapterException
FixAdapter
openSessionForService
in interface FixAdapter
BrokerAdapterException
public void createSession(java.lang.String sessionQualifier) throws BrokerAdapterException
FixAdapter
createSession
in interface FixAdapter
BrokerAdapterException
public void openSession(java.lang.String sessionQualifier) throws BrokerAdapterException
FixAdapter
openSession
in interface FixAdapter
BrokerAdapterException
public void closeSession(java.lang.String sessionQualifier) throws BrokerAdapterException
FixAdapter
closeSession
in interface FixAdapter
BrokerAdapterException
public void sendMessage(quickfix.Message message, Account account) throws BrokerAdapterException
sendMessage
in interface FixAdapter
BrokerAdapterException
public void sendMessage(quickfix.Message message, java.lang.String sessionQualifier) throws BrokerAdapterException
sendMessage
in interface FixAdapter
BrokerAdapterException
public java.lang.String getNextOrderId(Account account)
orderId
for the specified account
getNextOrderId
in interface FixAdapter
public void setOrderId(java.lang.String sessionQualifier, int orderId)
FixAdapter
setOrderId
in interface FixAdapter