Package com.espertech.esperio.jms

Class JMSOutputAdapter

java.lang.Object
com.espertech.esperio.jms.JMSOutputAdapter
All Implemented Interfaces:
com.espertech.esper.runtime.client.util.Adapter, com.espertech.esper.runtime.client.util.AdapterSPI
Direct Known Subclasses:
SpringJMSTemplateOutputAdapter
public abstract class JMSOutputAdapter extends Object implements com.espertech.esper.runtime.client.util.AdapterSPI
Implements a JMS output adapter.

  • Field Details

    • jmsMessageMarshaller

      protected JMSMessageMarshaller jmsMessageMarshaller
      Marshaller to use.

    • destination

      protected jakarta.jms.Destination destination
      JMS Destination.

  • Constructor Details

    • JMSOutputAdapter

      public JMSOutputAdapter()

  • Method Details

    • send

      public abstract void send(com.espertech.esper.common.client.EventBean eventBean, JMSMessageMarshaller jmsAdapterMarshaller) throws com.espertech.esper.common.client.EPException
      Abstract send methods for marshalling and sending an event of to JMS care.
      Parameters:
      eventBean - is the event
      jmsAdapterMarshaller - is the marshaller
      Throws:
      com.espertech.esper.common.client.EPException - when the send failed

    • getJmsMessageMarshaller

      public JMSMessageMarshaller getJmsMessageMarshaller()
      Returns the JMS message marshaller.
      Returns:
      marshaller

    • setJmsMessageMarshaller

      public void setJmsMessageMarshaller(JMSMessageMarshaller jmsMessageMarshaller)
      Sets the JMS message marshaller.
      Parameters:
      jmsMessageMarshaller - is the marshaller

    • setDestination

      public void setDestination(jakarta.jms.Destination destination)
      Sets the JMS destination.
      Parameters:
      destination - is the queue or topic

    • setSubscriptionMap

      public void setSubscriptionMap(Map<String,JMSSubscription> subscriptionMap)

    • getRuntime

      public com.espertech.esper.runtime.client.EPRuntime getRuntime()
      Specified by:
      getRuntime in interface com.espertech.esper.runtime.client.util.AdapterSPI

    • setRuntime

      public void setRuntime(com.espertech.esper.runtime.client.EPRuntime runtime)
      Specified by:
      setRuntime in interface com.espertech.esper.runtime.client.util.AdapterSPI

    • start

      public void start() throws com.espertech.esper.common.client.EPException
      Specified by:
      start in interface com.espertech.esper.runtime.client.util.Adapter
      Throws:
      com.espertech.esper.common.client.EPException

    • pause

      public void pause() throws com.espertech.esper.common.client.EPException
      Specified by:
      pause in interface com.espertech.esper.runtime.client.util.Adapter
      Throws:
      com.espertech.esper.common.client.EPException

    • resume

      public void resume() throws com.espertech.esper.common.client.EPException
      Specified by:
      resume in interface com.espertech.esper.runtime.client.util.Adapter
      Throws:
      com.espertech.esper.common.client.EPException

    • stop

      public void stop() throws com.espertech.esper.common.client.EPException
      Specified by:
      stop in interface com.espertech.esper.runtime.client.util.Adapter
      Throws:
      com.espertech.esper.common.client.EPException

    • destroy

      public void destroy() throws com.espertech.esper.common.client.EPException
      Specified by:
      destroy in interface com.espertech.esper.runtime.client.util.Adapter
      Throws:
      com.espertech.esper.common.client.EPException

    • getState

      public com.espertech.esper.runtime.client.util.AdapterState getState()
      Specified by:
      getState in interface com.espertech.esper.runtime.client.util.Adapter