Package com.adaptris.core.jms
Class JmsAsyncProducerEventHandler
- java.lang.Object
-
- com.adaptris.core.jms.JmsAsyncProducerEventHandler
-
- All Implemented Interfaces:
ComponentLifecycle
,javax.jms.CompletionListener
public class JmsAsyncProducerEventHandler extends java.lang.Object implements javax.jms.CompletionListener, ComponentLifecycle
-
-
Field Summary
Fields Modifier and Type Field Description protected org.slf4j.Logger
log
-
Constructor Summary
Constructors Constructor Description JmsAsyncProducerEventHandler(JmsProducer producer)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
addUnAckedMessage(java.lang.String messageId, AdaptrisMessage message)
boolean
getAcceptSuccessCallbacks()
java.util.Map<java.lang.String,com.adaptris.core.jms.JmsAsyncProducerEventHandler.CallbackConsumers>
getUnAckedMessages()
void
init()
Initialises the component.void
onCompletion(javax.jms.Message message)
void
onException(javax.jms.Message message, java.lang.Exception exception)
JmsProducer
registeredProducer()
void
registerProducer(JmsProducer producer)
void
setAcceptSuccessCallbacks(boolean acceptSuccessCallbacks)
void
setUnAckedMessages(java.util.Map<java.lang.String,com.adaptris.core.jms.JmsAsyncProducerEventHandler.CallbackConsumers> unAckedMessages)
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface com.adaptris.core.ComponentLifecycle
close, start, stop
-
-
-
-
Constructor Detail
-
JmsAsyncProducerEventHandler
public JmsAsyncProducerEventHandler(JmsProducer producer)
-
-
Method Detail
-
onCompletion
public void onCompletion(javax.jms.Message message)
- Specified by:
onCompletion
in interfacejavax.jms.CompletionListener
-
onException
public void onException(javax.jms.Message message, java.lang.Exception exception)
- Specified by:
onException
in interfacejavax.jms.CompletionListener
-
addUnAckedMessage
public void addUnAckedMessage(java.lang.String messageId, AdaptrisMessage message)
-
init
public void init() throws CoreException
Description copied from interface:ComponentLifecycle
Initialises the component.Component initialisation includes config verification, creation of connections etc.
- Specified by:
init
in interfaceComponentLifecycle
- Throws:
CoreException
- wrapping any underlyingException
s
-
registeredProducer
public JmsProducer registeredProducer()
-
registerProducer
public void registerProducer(JmsProducer producer)
-
getUnAckedMessages
public java.util.Map<java.lang.String,com.adaptris.core.jms.JmsAsyncProducerEventHandler.CallbackConsumers> getUnAckedMessages()
-
setUnAckedMessages
public void setUnAckedMessages(java.util.Map<java.lang.String,com.adaptris.core.jms.JmsAsyncProducerEventHandler.CallbackConsumers> unAckedMessages)
-
getAcceptSuccessCallbacks
public boolean getAcceptSuccessCallbacks()
-
setAcceptSuccessCallbacks
public void setAcceptSuccessCallbacks(boolean acceptSuccessCallbacks)
-
-