com.espertech.esperio.jms

Class JMSOutputAdapter

java.lang.Object

com.espertech.esperio.jms.JMSOutputAdapter

All Implemented Interfaces:

com.espertech.esper.adapter.Adapter, com.espertech.esper.adapter.AdapterSPI, com.espertech.esper.adapter.OutputAdapter

Direct Known Subclasses:

SpringJMSTemplateOutputAdapter

public abstract class JMSOutputAdapter
extends java.lang.Object
implements com.espertech.esper.adapter.OutputAdapter, com.espertech.esper.adapter.AdapterSPI

Implements a JMS output adapter.

Field Summary

Fields

Modifier and Type	Field and Description
protected javax.jms.Destination	destination JMS Destination.
protected JMSMessageMarshaller	jmsMessageMarshaller Marshaller to use.

Constructor Summary

Constructors

Constructor and Description
JMSOutputAdapter()

Method Summary

Modifier and Type	Method and Description
void	destroy()
com.espertech.esper.client.EPServiceProvider	getEPServiceProvider()
JMSMessageMarshaller	getJmsMessageMarshaller() Returns the JMS message marshaller.
com.espertech.esper.adapter.AdapterState	getState()
com.espertech.esper.adapter.Subscription	getSubscription(java.lang.String subscriptionName)
java.util.Map<java.lang.String,com.espertech.esper.adapter.Subscription>	getSubscriptionMap()
void	pause()
void	resume()
abstract void	send(com.espertech.esper.client.EventBean eventBean, JMSMessageMarshaller jmsAdapterMarshaller) Abstract send methods for marshalling and sending an event of to JMS care.
void	setDestination(javax.jms.Destination destination) Sets the JMS destination.
void	setEPServiceProvider(com.espertech.esper.client.EPServiceProvider epService)
void	setJmsMessageMarshaller(JMSMessageMarshaller jmsMessageMarshaller) Sets the JMS message marshaller.
void	setSubscriptionMap(java.util.Map<java.lang.String,com.espertech.esper.adapter.Subscription> subscriptionMap)
void	start()
void	stop()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

jmsMessageMarshaller

protected JMSMessageMarshaller jmsMessageMarshaller

Marshaller to use.

destination

protected javax.jms.Destination destination

JMS Destination.

Constructor Detail

JMSOutputAdapter

public JMSOutputAdapter()

Method Detail

send

public abstract void send(com.espertech.esper.client.EventBean eventBean,
                          JMSMessageMarshaller jmsAdapterMarshaller)
                   throws com.espertech.esper.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.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(javax.jms.Destination destination)

Sets the JMS destination.

Parameters:

destination - is the queue or topic

getSubscriptionMap

public java.util.Map<java.lang.String,com.espertech.esper.adapter.Subscription> getSubscriptionMap()

Specified by:

getSubscriptionMap in interface com.espertech.esper.adapter.OutputAdapter

setSubscriptionMap

public void setSubscriptionMap(java.util.Map<java.lang.String,com.espertech.esper.adapter.Subscription> subscriptionMap)

Specified by:

setSubscriptionMap in interface com.espertech.esper.adapter.OutputAdapter

getSubscription

public com.espertech.esper.adapter.Subscription getSubscription(java.lang.String subscriptionName)

Specified by:

getSubscription in interface com.espertech.esper.adapter.OutputAdapter

getEPServiceProvider

public com.espertech.esper.client.EPServiceProvider getEPServiceProvider()

Specified by:

getEPServiceProvider in interface com.espertech.esper.adapter.AdapterSPI

setEPServiceProvider

public void setEPServiceProvider(com.espertech.esper.client.EPServiceProvider epService)

Specified by:

setEPServiceProvider in interface com.espertech.esper.adapter.AdapterSPI

start

public void start()
           throws com.espertech.esper.client.EPException

Specified by:

start in interface com.espertech.esper.adapter.Adapter

Throws:

com.espertech.esper.client.EPException

pause

public void pause()
           throws com.espertech.esper.client.EPException

Specified by:

pause in interface com.espertech.esper.adapter.Adapter

Throws:

com.espertech.esper.client.EPException

resume

public void resume()
            throws com.espertech.esper.client.EPException

Specified by:

resume in interface com.espertech.esper.adapter.Adapter

Throws:

com.espertech.esper.client.EPException

stop

public void stop()
          throws com.espertech.esper.client.EPException

Specified by:

stop in interface com.espertech.esper.adapter.Adapter

Throws:

com.espertech.esper.client.EPException

destroy

public void destroy()
             throws com.espertech.esper.client.EPException

Specified by:

destroy in interface com.espertech.esper.adapter.Adapter

Throws:

com.espertech.esper.client.EPException

getState

public com.espertech.esper.adapter.AdapterState getState()

Specified by:

getState in interface com.espertech.esper.adapter.Adapter