com.espertech.esperio.jms
Class JMSInputAdapter

java.lang.Object
  extended by com.espertech.esperio.jms.JMSInputAdapter
All Implemented Interfaces:
Adapter, AdapterSPI, InputAdapter
Direct Known Subclasses:
SpringJMSTemplateInputAdapter

public abstract class JMSInputAdapter
extends java.lang.Object
implements InputAdapter, AdapterSPI

Created for ESPER.


Field Summary
protected  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 com.espertech.esper.adapter.InputAdapter
ESPERIO_MAP_EVENT_TYPE
 
Constructor Summary
JMSInputAdapter()
           
 
Method Summary
 void destroy()
           
 EPServiceProvider getEPServiceProvider()
           
 JMSMessageUnmarshaller getJmsMessageUnmarshaller()
          Returns the unmarshaller.
 AdapterState getState()
           
 void pause()
           
 void resume()
           
 void setEPServiceProvider(EPServiceProvider epService)
           
 void setJmsMessageUnmarshaller(JMSMessageUnmarshaller jmsMessageUnmarshaller)
          Sets the unmarshaller to use.
 void start()
           
 void stop()
           
 
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 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 EPServiceProvider getEPServiceProvider()
Specified by:
getEPServiceProvider in interface AdapterSPI

setEPServiceProvider

public void setEPServiceProvider(EPServiceProvider epService)
Specified by:
setEPServiceProvider in interface AdapterSPI

start

public void start()
           throws EPException
Specified by:
start in interface Adapter
Throws:
EPException

pause

public void pause()
           throws EPException
Specified by:
pause in interface Adapter
Throws:
EPException

resume

public void resume()
            throws EPException
Specified by:
resume in interface Adapter
Throws:
EPException

stop

public void stop()
          throws EPException
Specified by:
stop in interface Adapter
Throws:
EPException

destroy

public void destroy()
             throws EPException
Specified by:
destroy in interface Adapter
Throws:
EPException

getState

public AdapterState getState()
Specified by:
getState in interface Adapter

© 2006-2011 EsperTech Inc.
All rights reserved.
Visit us at espertech.com