Package com.epam.fixengine.jms.adaptor

Class FIXJMSAdaptor

java.lang.Object
com.epam.fixengine.jms.adaptor.FIXJMSAdaptor
All Implemented Interfaces:
com.epam.fixengine.jms.JMSAdaptor
public class FIXJMSAdaptor extends Object implements com.epam.fixengine.jms.JMSAdaptor
This class helps to send and receive FIX Messages to/from JMS service.
Author:
Mykhailo_Sereda

  • Constructor Details

    • FIXJMSAdaptor

      public FIXJMSAdaptor(com.epam.fixengine.jms.client.consumer.IJMSConsumer consumer, com.epam.fixengine.jms.client.producer.IJMSProducer producer)

  • Method Details

    • init

      public void init() throws jakarta.jms.JMSException
      Specified by:
      init in interface com.epam.fixengine.jms.JMSAdaptor
      Throws:
      jakarta.jms.JMSException
      See Also:
      • JMSAdaptor

    • sendMessage

      public void sendMessage(FIXFieldList fixMsg) throws jakarta.jms.JMSException
      Specified by:
      sendMessage in interface com.epam.fixengine.jms.JMSAdaptor
      Throws:
      jakarta.jms.JMSException
      See Also:
      • JMSAdaptor

    • connect

      public void connect() throws jakarta.jms.JMSException
      Specified by:
      connect in interface com.epam.fixengine.jms.JMSAdaptor
      Throws:
      jakarta.jms.JMSException
      See Also:
      • JMSAdaptor

    • close

      public void close() throws jakarta.jms.JMSException
      Close MessageProducer and MessageConsumer
      Specified by:
      close in interface com.epam.fixengine.jms.JMSAdaptor
      Throws:
      jakarta.jms.JMSException - if can't close MessageProducer or MessageConsumer
      See Also:
      • MessageProducer.close()
      • MessageConsumer.close()

    • setMessageListener

      public void setMessageListener(com.epam.fixengine.jms.FIXAdaptorMsgListener messageListener)
      Specified by:
      setMessageListener in interface com.epam.fixengine.jms.JMSAdaptor