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 java.lang.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 and 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 com.espertech.esper.runtime.client.util.AdapterStateManager	stateManager Manages adapter state.

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

ESPERIO_MAP_EVENT_TYPE

Constructor Summary

Constructors

Constructor and Description
JMSInputAdapter()

Method Summary

Modifier and Type	Method and 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 Detail

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 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

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