Package com.espertech.esperio.jms

Class SpringJMSTemplateInputAdapter

java.lang.Object

com.espertech.esperio.jms.JMSInputAdapter

com.espertech.esperio.jms.SpringJMSTemplateInputAdapter

All Implemented Interfaces:

com.espertech.esper.runtime.client.util.Adapter, com.espertech.esper.runtime.client.util.AdapterSPI, com.espertech.esper.runtime.client.util.InputAdapter, jakarta.jms.MessageListener

public class SpringJMSTemplateInputAdapter
extends JMSInputAdapter
implements jakarta.jms.MessageListener

Input adapter for receiving runtime from the JMS world using Spring JMS templates and sending these to an runtime.

Field Summary

Fields inherited from class com.espertech.esperio.jms.JMSInputAdapter

jmsMessageUnmarshaller, runtime, startTime, stateManager

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

ESPERIO_JSON_EVENT_TYPE, ESPERIO_MAP_EVENT_TYPE

Constructor Summary

Constructors

Constructor	Description
SpringJMSTemplateInputAdapter()

Method Summary

Modifier and Type	Method	Description
org.springframework.jms.core.JmsTemplate	getJmsTemplate()	Returns the jms template.
void	onMessage(jakarta.jms.Message message)
void	setJmsTemplate(org.springframework.jms.core.JmsTemplate jmsTemplate)	Sets the Spring JMS template

Methods inherited from class com.espertech.esperio.jms.JMSInputAdapter

destroy, getJmsMessageUnmarshaller, getRuntime, getState, pause, resume, setJmsMessageUnmarshaller, setRuntime, start, stop

Methods inherited from class java.lang.Object

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

Constructor Details

SpringJMSTemplateInputAdapter

public SpringJMSTemplateInputAdapter()

Method Details

getJmsTemplate

public org.springframework.jms.core.JmsTemplate getJmsTemplate()

Returns the jms template.

Returns:

Spring JMS template

setJmsTemplate

public void setJmsTemplate(org.springframework.jms.core.JmsTemplate jmsTemplate)

Sets the Spring JMS template

Parameters:

jmsTemplate - is the jms template

onMessage

public void onMessage(jakarta.jms.Message message)

Specified by:

onMessage in interface jakarta.jms.MessageListener