net.esper.adapter.jms
Class JMSInputAdapter

java.lang.Object
  net.esper.adapter.jms.JMSInputAdapter

All Implemented Interfaces:

Adapter, AdapterSPI, InputAdapter

Direct Known Subclasses:

SpringJMSTemplateInputAdapter

public abstract class JMSInputAdapter
extends Object
implements InputAdapter, AdapterSPI

Created for ESPER.

Field Summary

protected net.esper.core.EPServiceProviderSPI	epServiceProviderSPI Engine services.
protected JMSMessageUnmarshaller	jmsMessageUnmarshaller Unmarshaller for JMS messages.
protected long	startTime Start time.
protected AdapterStateManager	stateManager Manages adapter state.

Fields inherited from interface net.esper.adapter.InputAdapter

ESPERIO_MAP_EVENT_TYPE

Constructor Summary

JMSInputAdapter()

Method Summary

void	destroy() Destroy the Adapter, stopping the sending of all events and releasing all the resources, and disallowing any further state changes on the Adapter.
net.esper.client.EPServiceProvider	getEPServiceProvider() Returns the engine instance.
JMSMessageUnmarshaller	getJmsMessageUnmarshaller() Returns the unmarshaller.
AdapterState	getState() Get the state of this Adapter.
void	pause() Pause the sending of events after a Adapter has been started.
void	resume() Resume sending events after the Adapter has been paused.
void	setEPServiceProvider(net.esper.client.EPServiceProvider epService) An adapter takes an engine instance to process events.
void	setJmsMessageUnmarshaller(JMSMessageUnmarshaller jmsMessageUnmarshaller) Sets the unmarshaller to use.
void	start() Start the sending of events into the runtime egine.
void	stop() Stop sending events and return the Adapter to the OPENED state, ready to be started once again.

Methods inherited from class java.lang.Object

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

Field Detail

stateManager

protected final AdapterStateManager stateManager

Manages adapter state.

epServiceProviderSPI

protected net.esper.core.EPServiceProviderSPI epServiceProviderSPI

Engine services.

startTime

protected long startTime

Start time.

jmsMessageUnmarshaller

protected JMSMessageUnmarshaller jmsMessageUnmarshaller

Unmarshaller for JMS messages.

Constructor Detail

JMSInputAdapter

public JMSInputAdapter()

Method Detail

getJmsMessageUnmarshaller

public JMSMessageUnmarshaller getJmsMessageUnmarshaller()

Returns the unmarshaller.

Returns:

unmarshaller

setJmsMessageUnmarshaller

public void setJmsMessageUnmarshaller(JMSMessageUnmarshaller jmsMessageUnmarshaller)

Sets the unmarshaller to use.

Parameters:

jmsMessageUnmarshaller - is the unmarshaller to use

getEPServiceProvider

public net.esper.client.EPServiceProvider getEPServiceProvider()

Description copied from interface: AdapterSPI

Returns the engine instance.

Specified by:

getEPServiceProvider in interface AdapterSPI

Returns:

engine

setEPServiceProvider

public void setEPServiceProvider(net.esper.client.EPServiceProvider epService)

Description copied from interface: AdapterSPI

An adapter takes an engine instance to process events.

Specified by:

setEPServiceProvider in interface AdapterSPI

Parameters:

epService - is the service instance for the adapter.

start

public void start()
           throws net.esper.client.EPException

Description copied from interface: Adapter

Start the sending of events into the runtime egine.

Specified by:

start in interface Adapter

Throws:

net.esper.client.EPException - in case of errors processing the events

pause

public void pause()
           throws net.esper.client.EPException

Description copied from interface: Adapter

Pause the sending of events after a Adapter has been started.

Specified by:

pause in interface Adapter

Throws:

net.esper.client.EPException - if this Adapter has already been stopped

resume

public void resume()
            throws net.esper.client.EPException

Description copied from interface: Adapter

Resume sending events after the Adapter has been paused.

Specified by:

resume in interface Adapter

Throws:

net.esper.client.EPException - in case of errors processing the events

stop

public void stop()
          throws net.esper.client.EPException

Description copied from interface: Adapter

Stop sending events and return the Adapter to the OPENED state, ready to be started once again.

Specified by:

stop in interface Adapter

Throws:

net.esper.client.EPException - in case of errors releasing resources

destroy

public void destroy()
             throws net.esper.client.EPException

Description copied from interface: Adapter

Destroy the Adapter, stopping the sending of all events and releasing all the resources, and disallowing any further state changes on the Adapter.

Specified by:

destroy in interface Adapter

Throws:

net.esper.client.EPException - to indicate errors during destroy

getState

public AdapterState getState()

Description copied from interface: Adapter

Get the state of this Adapter.

Specified by:

getState in interface Adapter

Returns:

state