org.apache.camel.component.quickfixj
Class QuickfixjEngine
java.lang.Object
org.apache.camel.support.ServiceSupport
org.apache.camel.component.quickfixj.QuickfixjEngine
- All Implemented Interfaces:
- org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.StatefulService, org.apache.camel.SuspendableService
public class QuickfixjEngine
- extends org.apache.camel.support.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.
Fields inherited from class org.apache.camel.support.ServiceSupport |
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending |
Constructor Summary |
QuickfixjEngine(String uri,
quickfix.SessionSettings settings,
boolean forcedShutdown,
quickfix.MessageStoreFactory messageStoreFactoryOverride,
quickfix.LogFactory sessionLogFactoryOverride,
quickfix.MessageFactory messageFactoryOverride)
Deprecated. Better make use of the QuickfixjEngine(String, SessionSettings, MessageStoreFactory, LogFactory, MessageFactory) constructor
as the forcedShutdown paramater had/has no effect. |
QuickfixjEngine(String uri,
quickfix.SessionSettings settings,
quickfix.MessageStoreFactory messageStoreFactoryOverride,
quickfix.LogFactory sessionLogFactoryOverride,
quickfix.MessageFactory messageFactoryOverride)
|
QuickfixjEngine(String uri,
quickfix.SessionSettings settings,
quickfix.MessageStoreFactory messageStoreFactoryOverride,
quickfix.LogFactory sessionLogFactoryOverride,
quickfix.MessageFactory messageFactoryOverride,
boolean lazy)
|
QuickfixjEngine(String uri,
String settingsResourceName)
|
QuickfixjEngine(String uri,
String settingsResourceName,
boolean forcedShutdown)
Deprecated. Better make use of the QuickfixjEngine(String, String) constructor
as the forcedShutdown paramater had/has no effect. |
QuickfixjEngine(String uri,
String settingsResourceName,
boolean forcedShutdown,
quickfix.MessageStoreFactory messageStoreFactoryOverride,
quickfix.LogFactory sessionLogFactoryOverride,
quickfix.MessageFactory messageFactoryOverride)
Deprecated. Better make use of the QuickfixjEngine(String, String, MessageStoreFactory, LogFactory, MessageFactory) constructor
as the forcedShutdown paramater had/has no effect. |
QuickfixjEngine(String uri,
String settingsResourceName,
quickfix.MessageStoreFactory messageStoreFactoryOverride,
quickfix.LogFactory sessionLogFactoryOverride,
quickfix.MessageFactory messageFactoryOverride)
|
Methods inherited from class org.apache.camel.support.ServiceSupport |
doResume, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, resume, shutdown, start, stop, suspend |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
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
QuickfixjEngine
@Deprecated
public QuickfixjEngine(String uri,
String settingsResourceName,
boolean forcedShutdown)
throws quickfix.ConfigError,
quickfix.FieldConvertError,
IOException,
JMException
- Deprecated. Better make use of the
QuickfixjEngine(String, String)
constructor
as the forcedShutdown
paramater had/has no effect.
- Throws:
quickfix.ConfigError
quickfix.FieldConvertError
IOException
JMException
QuickfixjEngine
public QuickfixjEngine(String uri,
String settingsResourceName)
throws quickfix.ConfigError,
quickfix.FieldConvertError,
IOException,
JMException
- Throws:
quickfix.ConfigError
quickfix.FieldConvertError
IOException
JMException
QuickfixjEngine
@Deprecated
public QuickfixjEngine(String uri,
String settingsResourceName,
boolean forcedShutdown,
quickfix.MessageStoreFactory messageStoreFactoryOverride,
quickfix.LogFactory sessionLogFactoryOverride,
quickfix.MessageFactory messageFactoryOverride)
throws quickfix.ConfigError,
quickfix.FieldConvertError,
IOException,
JMException
- Deprecated. Better make use of the
QuickfixjEngine(String, String, MessageStoreFactory, LogFactory, MessageFactory)
constructor
as the forcedShutdown
paramater had/has no effect.
- Throws:
quickfix.ConfigError
quickfix.FieldConvertError
IOException
JMException
QuickfixjEngine
public QuickfixjEngine(String uri,
String settingsResourceName,
quickfix.MessageStoreFactory messageStoreFactoryOverride,
quickfix.LogFactory sessionLogFactoryOverride,
quickfix.MessageFactory messageFactoryOverride)
throws quickfix.ConfigError,
quickfix.FieldConvertError,
IOException,
JMException
- Throws:
quickfix.ConfigError
quickfix.FieldConvertError
IOException
JMException
QuickfixjEngine
@Deprecated
public QuickfixjEngine(String uri,
quickfix.SessionSettings settings,
boolean forcedShutdown,
quickfix.MessageStoreFactory messageStoreFactoryOverride,
quickfix.LogFactory sessionLogFactoryOverride,
quickfix.MessageFactory messageFactoryOverride)
throws quickfix.ConfigError,
quickfix.FieldConvertError,
IOException,
JMException
- Deprecated. Better make use of the
QuickfixjEngine(String, SessionSettings, MessageStoreFactory, LogFactory, MessageFactory)
constructor
as the forcedShutdown
paramater had/has no effect.
- Throws:
quickfix.ConfigError
quickfix.FieldConvertError
IOException
JMException
QuickfixjEngine
public QuickfixjEngine(String uri,
quickfix.SessionSettings settings,
quickfix.MessageStoreFactory messageStoreFactoryOverride,
quickfix.LogFactory sessionLogFactoryOverride,
quickfix.MessageFactory messageFactoryOverride)
throws quickfix.ConfigError,
quickfix.FieldConvertError,
IOException,
JMException
- Throws:
quickfix.ConfigError
quickfix.FieldConvertError
IOException
JMException
QuickfixjEngine
public QuickfixjEngine(String uri,
quickfix.SessionSettings settings,
quickfix.MessageStoreFactory messageStoreFactoryOverride,
quickfix.LogFactory sessionLogFactoryOverride,
quickfix.MessageFactory messageFactoryOverride,
boolean lazy)
throws quickfix.ConfigError,
quickfix.FieldConvertError,
IOException,
JMException
- Throws:
quickfix.ConfigError
quickfix.FieldConvertError
IOException
JMException
doStart
protected void doStart()
throws Exception
- Specified by:
doStart
in class org.apache.camel.support.ServiceSupport
- Throws:
Exception
doStop
protected void doStop()
throws Exception
- Specified by:
doStop
in class org.apache.camel.support.ServiceSupport
- Throws:
Exception
doShutdown
protected void doShutdown()
throws Exception
- Overrides:
doShutdown
in class org.apache.camel.support.ServiceSupport
- 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()
Apache Camel