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 and Description
protected org.slf4j.Logger	log

Constructor Summary

Constructors

Constructor and Description
JmsAsyncProducerEventHandler(JmsProducer producer)

Method Summary

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

Field Detail

log

protected transient org.slf4j.Logger log

Constructor Detail

JmsAsyncProducerEventHandler

public JmsAsyncProducerEventHandler(JmsProducer producer)

Method Detail

onCompletion

public void onCompletion(javax.jms.Message message)

Specified by:

onCompletion in interface javax.jms.CompletionListener

onException

public void onException(javax.jms.Message message,
                        java.lang.Exception exception)

Specified by:

onException in interface javax.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 interface ComponentLifecycle

Throws:

CoreException - wrapping any underlying Exceptions

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)