net.esper.adapter.jms
Class JMSInputAdapter

java.lang.Object
  extended by 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