|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.espertech.esperio.jms.JMSOutputAdapter
public abstract class JMSOutputAdapter
Implements a JMS output adapter.
Field Summary | |
---|---|
protected javax.jms.Destination |
destination
JMS Destination. |
protected JMSMessageMarshaller |
jmsMessageMarshaller
Marshaller to use. |
Constructor Summary | |
---|---|
JMSOutputAdapter()
|
Method Summary | |
---|---|
void |
destroy()
Destroy the Adapter, stopping the sending of all events and releasing all the resources, and disallowing any further state changes on the Adapter. |
com.espertech.esper.client.EPServiceProvider |
getEPServiceProvider()
Returns the engine instance. |
JMSMessageMarshaller |
getJmsMessageMarshaller()
Returns the JMS message marshaller. |
AdapterState |
getState()
Get the state of this Adapter. |
Subscription |
getSubscription(String subscriptionAlias)
Returns a given subscription by it's name, or null if not found |
Map<String,Subscription> |
getSubscriptionMap()
Returns the subscriptions. |
void |
pause()
Pause the sending of events after a Adapter has been started. |
void |
resume()
Resume sending events after the Adapter has been paused. |
abstract void |
send(com.espertech.esper.event.EventBean eventBean,
JMSMessageMarshaller jmsAdapterMarshaller)
Abstract send methods for marshalling and sending an event of to JMS care. |
void |
setDestination(javax.jms.Destination destination)
Sets the JMS destination. |
void |
setEPServiceProvider(com.espertech.esper.client.EPServiceProvider epService)
An adapter takes an engine instance to process events. |
void |
setJmsMessageMarshaller(JMSMessageMarshaller jmsMessageMarshaller)
Sets the JMS message marshaller. |
void |
setSubscriptionMap(Map<String,Subscription> subscriptionMap)
Sets the subscriptions for the output adapter. |
void |
start()
Start the sending of events into the runtime egine. |
void |
stop()
Stop sending events and return the Adapter to the OPENED state, ready to be started once again. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected JMSMessageMarshaller jmsMessageMarshaller
protected javax.jms.Destination destination
Constructor Detail |
---|
public JMSOutputAdapter()
Method Detail |
---|
public abstract void send(com.espertech.esper.event.EventBean eventBean, JMSMessageMarshaller jmsAdapterMarshaller) throws com.espertech.esper.client.EPException
eventBean
- is the eventjmsAdapterMarshaller
- is the marshaller
com.espertech.esper.client.EPException
- when the send failedpublic JMSMessageMarshaller getJmsMessageMarshaller()
public void setJmsMessageMarshaller(JMSMessageMarshaller jmsMessageMarshaller)
jmsMessageMarshaller
- is the marshallerpublic void setDestination(javax.jms.Destination destination)
destination
- is the queue or topicpublic Map<String,Subscription> getSubscriptionMap()
OutputAdapter
getSubscriptionMap
in interface OutputAdapter
public void setSubscriptionMap(Map<String,Subscription> subscriptionMap)
OutputAdapter
setSubscriptionMap
in interface OutputAdapter
subscriptionMap
- is the active subscriptions.public Subscription getSubscription(String subscriptionAlias)
OutputAdapter
getSubscription
in interface OutputAdapter
subscriptionAlias
- is the subscription
public com.espertech.esper.client.EPServiceProvider getEPServiceProvider()
AdapterSPI
getEPServiceProvider
in interface AdapterSPI
public void setEPServiceProvider(com.espertech.esper.client.EPServiceProvider epService)
AdapterSPI
setEPServiceProvider
in interface AdapterSPI
epService
- is the service instance for the adapter.public void start() throws com.espertech.esper.client.EPException
Adapter
start
in interface Adapter
com.espertech.esper.client.EPException
- in case of errors processing the eventspublic void pause() throws com.espertech.esper.client.EPException
Adapter
pause
in interface Adapter
com.espertech.esper.client.EPException
- if this Adapter has already been stoppedpublic void resume() throws com.espertech.esper.client.EPException
Adapter
resume
in interface Adapter
com.espertech.esper.client.EPException
- in case of errors processing the eventspublic void stop() throws com.espertech.esper.client.EPException
Adapter
stop
in interface Adapter
com.espertech.esper.client.EPException
- in case of errors releasing resourcespublic void destroy() throws com.espertech.esper.client.EPException
Adapter
destroy
in interface Adapter
com.espertech.esper.client.EPException
- to indicate errors during destroypublic AdapterState getState()
Adapter
getState
in interface Adapter
|
© 2007 EsperTech Inc. All rights reserved. Visit us at espertech.com |
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |