| java.lang.Object
 org.jboss.resource.adapter.jms.inflow.dlq.AbstractDLQHandler
All known Subclasses: org.jboss.resource.adapter.jms.inflow.dlq.JBossMQDLQHandler,
| AbstractDLQHandler | | abstract public class AbstractDLQHandler implements DLQHandler,ExceptionListener(Code) | | An abstract DLQ handler.
author:
Adrian Brock
version:
$Revision: 57189 $ |
| connection | | protected QueueConnection connection(Code) | | The DLQ Connection
|
| dlq | | protected Queue dlq(Code) | | The DLQ
|
| log | | final protected static Logger log(Code) | | The logger
|
| doSend | | protected void doSend(Message msg, int deliveryMode, int priority, long timeToLive)(Code) | | Do the message send
Parameters:
msg - the message |
| getDeliveryMode | | protected int getDeliveryMode(Message msg)(Code) | | Get the delivery mode for the DLQ message
Parameters:
msg - the message the delivery mode |
| getPriority | | protected int getPriority(Message msg)(Code) | | Get the priority for the DLQ message
Parameters:
msg - the message the priority |
| getTimeToLive | | protected long getTimeToLive(Message msg)(Code) | | Get the time to live for the DLQ message
Parameters:
msg - the message the time to live |
| handleDelivery | | abstract protected boolean handleDelivery(Message msg)(Code) | | Do we handle the message?
Parameters:
msg - the message to handle true when we handle it |
| handleRedeliveredMessage | | public boolean handleRedeliveredMessage(Message msg)(Code) | | |
| handleSendError | | protected void handleSendError(Message msg, Throwable t)(Code) | | Handle a failure to send the message to the dlq
Parameters:
msg - the message
Parameters:
t - the error |
| makeWritable | | protected Message makeWritable(Message msg)(Code) | | Make a writable copy of the message
Parameters:
msg - the message the copied message |
| messageDelivered | | public void messageDelivered(Message msg)(Code) | | |
| onException | | public void onException(JMSException exception)(Code) | | |
| sendToDLQ | | protected void sendToDLQ(Message msg)(Code) | | Send the message to the dlq
Parameters:
msg - message to send |
| setupDLQConnection | | protected void setupDLQConnection(Context ctx) throws Exception(Code) | | Setup the DLQ Connection
Parameters:
ctx - the naming context
throws:
Exception - for any error |
| setupDLQDestination | | protected void setupDLQDestination(Context ctx) throws Exception(Code) | | Setup the DLQ Destination
Parameters:
ctx - the naming context
throws:
Exception - for any error |
| teardown | | public void teardown()(Code) | | |
| teardownDLQConnection | | protected void teardownDLQConnection()(Code) | | Teardown the DLQ Connection
|
| teardownDLQDestination | | protected void teardownDLQDestination()(Code) | | Teardown the DLQ Destination
|
| warnDLQ | | protected void warnDLQ(Message msg, int count, int max)(Code) | | Warn that a message is being handled by the DLQ
Parameters:
msg -
Parameters:
count - the number of redelivers
Parameters:
max - the maximum number of redeliveries |
|
|