public class FIXSessionFactory extends Object
Modifier and Type | Method and Description |
---|---|
boolean |
createFIXAcceptor(org.apache.axis2.description.AxisService service)
Get the FIX configuration settings and initialize a new FIX session for the specified
service.
|
boolean |
createFIXInitiator(org.apache.axis2.description.AxisService service) |
void |
createFIXInitiator(String fixEPR,
org.apache.axis2.description.AxisService service,
quickfix.SessionID sessionID)
Extract the parameters embedded in the given EPR and initialize a new FIX session.
|
void |
disposeFIXAcceptor(org.apache.axis2.description.AxisService service)
Get the FIX Acceptor for the specified service from the sessionStore Map and
stop it.
|
void |
disposeFIXInitiators()
Stops all the FIX initiators created so far and cleans up all the mappings
related to them
|
quickfix.Acceptor |
getAcceptor(String serviceName)
Finds a FIX Acceptor for the specified service from the acceptorStore
|
quickfix.Application |
getApplication(String fixEPR) |
quickfix.Initiator |
getInitiator(String fixEPR)
Finds a FIX initiator for the specified EPR from the initiatorStore
|
static FIXSessionFactory |
getInstance(FIXApplicationFactory af) |
String[] |
getServiceEPRs(String serviceName,
String ip)
Returns an array of Strings representing EPRs for the specified service
|
void |
setListenerThreadPool(org.apache.axis2.transport.base.threads.WorkerPool listenerThreadPool) |
void |
setSenderThreadPool(org.apache.axis2.transport.base.threads.WorkerPool senderThreadPool) |
public static FIXSessionFactory getInstance(FIXApplicationFactory af)
public boolean createFIXAcceptor(org.apache.axis2.description.AxisService service) throws org.apache.axis2.AxisFault
service
- the AxisServiceorg.apache.axis2.AxisFault
- if the acceptor cannot be createdpublic void createFIXInitiator(String fixEPR, org.apache.axis2.description.AxisService service, quickfix.SessionID sessionID) throws org.apache.axis2.AxisFault
fixEPR
- the EPR to send FIX messagesservice
- the AxisServicesessionID
- the SessionID of the session createdorg.apache.axis2.AxisFault
- Exception thrownpublic boolean createFIXInitiator(org.apache.axis2.description.AxisService service) throws org.apache.axis2.AxisFault
org.apache.axis2.AxisFault
public void disposeFIXAcceptor(org.apache.axis2.description.AxisService service)
service
- the AxisServicepublic void disposeFIXInitiators()
public String[] getServiceEPRs(String serviceName, String ip)
serviceName
- the name of the serviceip
- the IP address of the hostpublic quickfix.Acceptor getAcceptor(String serviceName)
serviceName
- the name of the AxisServicepublic quickfix.Initiator getInitiator(String fixEPR)
fixEPR
- a valid FIX EPRpublic quickfix.Application getApplication(String fixEPR)
public void setListenerThreadPool(org.apache.axis2.transport.base.threads.WorkerPool listenerThreadPool)
public void setSenderThreadPool(org.apache.axis2.transport.base.threads.WorkerPool senderThreadPool)
Copyright © 2005-2017 Apache Software Foundation. All Rights Reserved.