|
||||||||||
PREV CLASS NEXT CLASS (src) | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.jboss.mx.util.JBossNotificationBroadcasterSupport (src)
org.jboss.system.ServiceMBeanSupport (src)
org.jboss.ejb.plugins.jms.DLQHandler
Places redeliveded messages on a Dead Letter Queue.
The Dead Letter Queue handler is used to not set JBoss in an endles loop when a message is resent on and on due to transaction rollback for message receipt.
It sends message to a dead letter queue (configurable, defaults to queue/DLQ) when the message has been resent a configurable amount of times, defaults to 10.
The handler is configured through the element MDBConfig in container-invoker-conf.
The JMS property JBOSS_ORIG_DESTINATION in the resent message is set to the name of the original destination (Destination.toString()) if it is present.
The JMS property JBOSS_ORIG_MESSAGEID in the resent message is set to the id of the original message. Created: Thu Aug 23 21:17:26 2001
Nested Class Summary | |
protected class |
DLQHandler.DLQSynchronization (src)
Remove a redelivered message from the DLQ's buffer when it is acknowledged |
Field Summary | |
static java.lang.String |
JBOSS_ORIG_DESTINATION
JMS property name holding original destination. |
static java.lang.String |
JBOSS_ORIG_MESSAGEID
JMS property name holding original JMS message id. |
Fields inherited from class org.jboss.system.ServiceMBeanSupport (src) |
log, server, SERVICE_CONTROLLER_SIG, serviceName |
Fields inherited from interface org.jboss.system.ServiceMBean (src) |
CREATE_EVENT, CREATED, DESTROY_EVENT, DESTROYED, FAILED, REGISTERED, START_EVENT, STARTED, STARTING, states, STOP_EVENT, STOPPED, STOPPING, UNREGISTERED |
Constructor Summary | |
DLQHandler(JMSProviderAdapter (src) providerAdapter)
|
Method Summary | |
protected void |
createService()
Initalize the service. |
protected void |
deleteFromBuffer(java.lang.String id)
Delete the entry in the message counter buffer for specifyed JMS id. |
protected void |
destroyService()
Sub-classes should override this method to provide custum 'destroy' logic. |
boolean |
handleRedeliveredMessage(Message (src) msg,
Transaction (src) tx)
Check if a message has been redelivered to many times. |
void |
importXml(org.w3c.dom.Element element)
Takes an MDBConfig Element |
protected int |
incrementResentCount(java.lang.String id)
Increment the counter for the specific JMS message id. |
protected Message (src) |
makeWritable(Message (src) msg,
boolean trace)
Make the Message properties writable. |
protected void |
sendMessage(Message (src) msg)
Send message to the configured dead letter queue, defaults to queue/DLQ. |
protected void |
startService()
Sub-classes should override this method to provide custum 'start' logic. |
protected void |
stopService()
Sub-classes should override this method to provide custum 'stop' logic. |
java.lang.String |
toString()
|
Methods inherited from class org.jboss.system.ServiceMBeanSupport (src) |
create, destroy, getLog, getName, getNextNotificationSequenceNumber, getObjectName, getServer, getServiceName, getState, getStateString, jbossInternalCreate, jbossInternalDescription, jbossInternalDestroy, jbossInternalLifecycle, jbossInternalStart, jbossInternalStop, postDeregister, postRegister, preDeregister, preRegister, start, stop |
Methods inherited from class org.jboss.mx.util.JBossNotificationBroadcasterSupport (src) |
addNotificationListener, getNotificationInfo, handleNotification, removeNotificationListener, removeNotificationListener, sendNotification |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Field Detail |
public static final java.lang.String JBOSS_ORIG_DESTINATION
public static final java.lang.String JBOSS_ORIG_MESSAGEID
Constructor Detail |
public DLQHandler(JMSProviderAdapter (src) providerAdapter)
Method Detail |
protected void createService() throws java.lang.Exception
createService
in class ServiceMBeanSupport (src)
java.lang.Exception
- Service failed to initalize.protected void startService() throws java.lang.Exception
ServiceMBeanSupport (src)
This method is empty, and is provided for convenience when concrete service classes do not need to perform anything specific for this state change.
startService
in class ServiceMBeanSupport (src)
java.lang.Exception
protected void stopService() throws java.lang.Exception
ServiceMBeanSupport (src)
This method is empty, and is provided for convenience when concrete service classes do not need to perform anything specific for this state change.
stopService
in class ServiceMBeanSupport (src)
java.lang.Exception
protected void destroyService() throws java.lang.Exception
ServiceMBeanSupport (src)
This method is empty, and is provided for convenience when concrete service classes do not need to perform anything specific for this state change.
destroyService
in class ServiceMBeanSupport (src)
java.lang.Exception
public boolean handleRedeliveredMessage(Message (src) msg, Transaction (src) tx)
protected void sendMessage(Message (src) msg) throws JMSException (src)
JMSException (src)
protected int incrementResentCount(java.lang.String id)
protected void deleteFromBuffer(java.lang.String id)
protected Message (src) makeWritable(Message (src) msg, boolean trace) throws JMSException (src)
JMSException (src)
public void importXml(org.w3c.dom.Element element) throws DeploymentException (src)
DeploymentException (src)
public java.lang.String toString()
|
||||||||||
PREV CLASS NEXT CLASS (src) | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |