Class QuickfixjEngine
- java.lang.Object
-
- org.apache.camel.support.service.BaseService
-
- org.apache.camel.support.service.ServiceSupport
-
- org.apache.camel.component.quickfixj.QuickfixjEngine
-
- All Implemented Interfaces:
AutoCloseable
,org.apache.camel.Service
,org.apache.camel.ShutdownableService
,org.apache.camel.StatefulService
,org.apache.camel.SuspendableService
public class QuickfixjEngine extends org.apache.camel.support.service.ServiceSupport
This is a wrapper class that provided QuickFIX/J initialization capabilities beyond those supported in the core QuickFIX/J distribution. Specifically, it infers dependencies on specific implementations of message stores and logs. It also supports extended QuickFIX/J settings properties to specify threading models, custom store and log implementations, etc. The wrapper will create an initiator or acceptor or both depending on the roles of sessions described in the settings file.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
QuickfixjEngine.ThreadModel
-
Field Summary
Fields Modifier and Type Field Description static String
DEFAULT_END_TIME
static long
DEFAULT_HEARTBTINT
static String
DEFAULT_START_TIME
static String
SETTING_THREAD_MODEL
static String
SETTING_USE_JMX
-
Constructor Summary
Constructors Constructor Description QuickfixjEngine(org.apache.camel.CamelContext camelContext, String uri, String settingsResourceName)
QuickfixjEngine(org.apache.camel.CamelContext camelContext, String uri, String settingsResourceName, quickfix.MessageStoreFactory messageStoreFactoryOverride, quickfix.LogFactory sessionLogFactoryOverride, quickfix.MessageFactory messageFactoryOverride)
QuickfixjEngine(org.apache.camel.CamelContext camelContext, String uri, quickfix.SessionSettings settings, quickfix.MessageStoreFactory messageStoreFactoryOverride, quickfix.LogFactory sessionLogFactoryOverride, quickfix.MessageFactory messageFactoryOverride)
QuickfixjEngine(org.apache.camel.CamelContext camelContext, String uri, quickfix.SessionSettings settings, quickfix.MessageStoreFactory messageStoreFactoryOverride, quickfix.LogFactory sessionLogFactoryOverride, quickfix.MessageFactory messageFactoryOverride, boolean lazy)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description void
addEventListener(QuickfixjEventListener listener)
protected void
doShutdown()
protected void
doStart()
protected void
doStop()
MessageCorrelator
getMessageCorrelator()
String
getUri()
boolean
isInitialized()
boolean
isLazy()
protected static quickfix.SessionSettings
loadSettings(org.apache.camel.CamelContext camelContext, String settingsResourceName)
void
removeEventListener(QuickfixjEventListener listener)
-
Methods inherited from class org.apache.camel.support.service.BaseService
build, doBuild, doFail, doInit, doLifecycleChange, doResume, doSuspend, fail, getStatus, init, isBuild, isInit, isNew, isRunAllowed, isShutdown, isStarted, isStarting, isStartingOrStarted, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
-
-
-
Field Detail
-
DEFAULT_START_TIME
public static final String DEFAULT_START_TIME
- See Also:
- Constant Field Values
-
DEFAULT_END_TIME
public static final String DEFAULT_END_TIME
- See Also:
- Constant Field Values
-
DEFAULT_HEARTBTINT
public static final long DEFAULT_HEARTBTINT
- See Also:
- Constant Field Values
-
SETTING_THREAD_MODEL
public static final String SETTING_THREAD_MODEL
- See Also:
- Constant Field Values
-
SETTING_USE_JMX
public static final String SETTING_USE_JMX
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
QuickfixjEngine
public QuickfixjEngine(org.apache.camel.CamelContext camelContext, String uri, String settingsResourceName) throws Exception
- Throws:
Exception
-
QuickfixjEngine
public QuickfixjEngine(org.apache.camel.CamelContext camelContext, String uri, String settingsResourceName, quickfix.MessageStoreFactory messageStoreFactoryOverride, quickfix.LogFactory sessionLogFactoryOverride, quickfix.MessageFactory messageFactoryOverride) throws Exception
- Throws:
Exception
-
QuickfixjEngine
public QuickfixjEngine(org.apache.camel.CamelContext camelContext, String uri, quickfix.SessionSettings settings, quickfix.MessageStoreFactory messageStoreFactoryOverride, quickfix.LogFactory sessionLogFactoryOverride, quickfix.MessageFactory messageFactoryOverride) throws Exception
- Throws:
Exception
-
QuickfixjEngine
public QuickfixjEngine(org.apache.camel.CamelContext camelContext, String uri, quickfix.SessionSettings settings, quickfix.MessageStoreFactory messageStoreFactoryOverride, quickfix.LogFactory sessionLogFactoryOverride, quickfix.MessageFactory messageFactoryOverride, boolean lazy) throws Exception
- Throws:
Exception
-
-
Method Detail
-
loadSettings
protected static quickfix.SessionSettings loadSettings(org.apache.camel.CamelContext camelContext, String settingsResourceName) throws Exception
- Throws:
Exception
-
doStart
protected void doStart() throws Exception
- Overrides:
doStart
in classorg.apache.camel.support.service.BaseService
- Throws:
Exception
-
doStop
protected void doStop() throws Exception
- Overrides:
doStop
in classorg.apache.camel.support.service.BaseService
- Throws:
Exception
-
doShutdown
protected void doShutdown() throws Exception
- Overrides:
doShutdown
in classorg.apache.camel.support.service.BaseService
- Throws:
Exception
-
addEventListener
public void addEventListener(QuickfixjEventListener listener)
-
removeEventListener
public void removeEventListener(QuickfixjEventListener listener)
-
getUri
public String getUri()
-
getMessageCorrelator
public MessageCorrelator getMessageCorrelator()
-
isInitialized
public boolean isInitialized()
-
isLazy
public boolean isLazy()
-
-