com.espertech.esperio.jms

Class JMSInputAdapter

java.lang.Object

com.espertech.esperio.jms.JMSInputAdapter

All Implemented Interfaces:

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

Direct Known Subclasses:

SpringJMSTemplateInputAdapter

public abstract class JMSInputAdapter
extends java.lang.Object
implements com.espertech.esper.adapter.InputAdapter, com.espertech.esper.adapter.AdapterSPI

Created for ESPER.

Field Summary

Fields

Modifier and Type	Field and Description
protected com.espertech.esper.core.service.EPServiceProviderSPI	epServiceProviderSPI Engine services.
protected JMSMessageUnmarshaller	jmsMessageUnmarshaller Unmarshaller for JMS messages.
protected long	startTime Start time.
protected com.espertech.esper.adapter.AdapterStateManager	stateManager Manages adapter state.

Fields inherited from interface com.espertech.esper.adapter.InputAdapter

ESPERIO_MAP_EVENT_TYPE

Constructor Summary

Constructors

Constructor and Description
JMSInputAdapter()

Method Summary

Modifier and Type	Method and Description
void	destroy()
com.espertech.esper.client.EPServiceProvider	getEPServiceProvider()
JMSMessageUnmarshaller	getJmsMessageUnmarshaller() Returns the unmarshaller.
com.espertech.esper.adapter.AdapterState	getState()
void	pause()
void	resume()
void	setEPServiceProvider(com.espertech.esper.client.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 com.espertech.esper.adapter.AdapterStateManager stateManager

Manages adapter state.

epServiceProviderSPI

protected com.espertech.esper.core.service.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 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