Class 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.
    • 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)  
    • 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 class org.apache.camel.support.service.BaseService
        Throws:
        Exception
      • doStop

        protected void doStop()
                       throws Exception
        Overrides:
        doStop in class org.apache.camel.support.service.BaseService
        Throws:
        Exception
      • doShutdown

        protected void doShutdown()
                           throws Exception
        Overrides:
        doShutdown in class org.apache.camel.support.service.BaseService
        Throws:
        Exception
      • getUri

        public String getUri()
      • isInitialized

        public boolean isInitialized()
      • isLazy

        public boolean isLazy()