Package com.espertech.esperio.jms

Class JMSInputAdapter

java.lang.Object

com.espertech.esperio.jms.JMSInputAdapter

All Implemented Interfaces:

com.espertech.esper.runtime.client.util.Adapter, com.espertech.esper.runtime.client.util.AdapterSPI, com.espertech.esper.runtime.client.util.InputAdapter

Direct Known Subclasses:

SpringJMSTemplateInputAdapter

public abstract class JMSInputAdapter
extends Object
implements com.espertech.esper.runtime.client.util.InputAdapter, com.espertech.esper.runtime.client.util.AdapterSPI

Created for ESPER.

Field Summary

Fields

Modifier and Type	Field	Description
protected JMSMessageUnmarshaller	jmsMessageUnmarshaller	Unmarshaller for JMS messages.
protected com.espertech.esper.runtime.internal.kernel.service.EPRuntimeSPI	runtime	Engine services.
protected long	startTime	Start time.
protected final com.espertech.esper.runtime.client.util.AdapterStateManager	stateManager	Manages adapter state.

Fields inherited from interface com.espertech.esper.runtime.client.util.InputAdapter

ESPERIO_JSON_EVENT_TYPE, ESPERIO_MAP_EVENT_TYPE

Constructor Summary

Constructors

Constructor	Description
JMSInputAdapter()

Method Summary

Modifier and Type	Method	Description
void	destroy()
JMSMessageUnmarshaller	getJmsMessageUnmarshaller()	Returns the unmarshaller.
com.espertech.esper.runtime.client.EPRuntime	getRuntime()
com.espertech.esper.runtime.client.util.AdapterState	getState()
void	pause()
void	resume()
void	setJmsMessageUnmarshaller(JMSMessageUnmarshaller jmsMessageUnmarshaller)	Sets the unmarshaller to use.
void	setRuntime(com.espertech.esper.runtime.client.EPRuntime runtime)
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Field Details

stateManager

protected final com.espertech.esper.runtime.client.util.AdapterStateManager stateManager

Manages adapter state.

runtime

protected com.espertech.esper.runtime.internal.kernel.service.EPRuntimeSPI runtime

Engine services.

startTime

protected long startTime

Start time.

jmsMessageUnmarshaller

protected JMSMessageUnmarshaller jmsMessageUnmarshaller

Unmarshaller for JMS messages.

Constructor Details

JMSInputAdapter

public JMSInputAdapter()

Method Details

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

getRuntime

public com.espertech.esper.runtime.client.EPRuntime getRuntime()

Specified by:

getRuntime in interface com.espertech.esper.runtime.client.util.AdapterSPI

setRuntime

public void setRuntime(com.espertech.esper.runtime.client.EPRuntime runtime)

Specified by:

setRuntime in interface com.espertech.esper.runtime.client.util.AdapterSPI

start

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

Specified by:

start in interface com.espertech.esper.runtime.client.util.Adapter

Throws:

com.espertech.esper.common.client.EPException

pause

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

Specified by:

pause in interface com.espertech.esper.runtime.client.util.Adapter

Throws:

com.espertech.esper.common.client.EPException

resume

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

Specified by:

resume in interface com.espertech.esper.runtime.client.util.Adapter

Throws:

com.espertech.esper.common.client.EPException

stop

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

Specified by:

stop in interface com.espertech.esper.runtime.client.util.Adapter

Throws:

com.espertech.esper.common.client.EPException

destroy

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

Specified by:

destroy in interface com.espertech.esper.runtime.client.util.Adapter

Throws:

com.espertech.esper.common.client.EPException

getState

public com.espertech.esper.runtime.client.util.AdapterState getState()

Specified by:

getState in interface com.espertech.esper.runtime.client.util.Adapter