Package com.adaptris.core.jms.solace
Class SolaceConsumerConnectionErrorHandler
- java.lang.Object
-
- com.adaptris.core.ConnectionErrorHandlerImp
-
- com.adaptris.core.jms.JmsConnectionErrorHandlerImpl
-
- com.adaptris.core.jms.JmsConnectionErrorHandler
-
- com.adaptris.core.jms.solace.SolaceConsumerConnectionErrorHandler
-
- All Implemented Interfaces:
ComponentLifecycle
,ConnectionErrorHandler
,com.solacesystems.jms.SolConsumerEventListener
,javax.jms.ExceptionListener
@ComponentProfile(summary="A connection error handler that listens for Solace queue shutdown events.", tag="consumer,jms,error-handler") public class SolaceConsumerConnectionErrorHandler extends JmsConnectionErrorHandler implements com.solacesystems.jms.SolConsumerEventListener
A custom connection error handler that can be configured on your Solace consumers.
This connection error handler uses the same standard JMSException listener, but additionally will listen for queue shutdown events, therefore triggering the exception handler.
If you use this error handler and a
JmsConsumer
(rather thanPtpConsumer
orPasConsumer
) then you will also need to set the advanced property of deferConsumerCreationToVendor to true on yourJmsConsumer
. This will allow us to continue to try to create the consumer on restart until the queue has been bought back up again.
-
-
Field Summary
-
Fields inherited from class com.adaptris.core.jms.JmsConnectionErrorHandlerImpl
idForLogging
-
Fields inherited from class com.adaptris.core.ConnectionErrorHandlerImp
log
-
-
Constructor Summary
Constructors Constructor Description SolaceConsumerConnectionErrorHandler()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
onEvent(com.solacesystems.jms.events.SolConsumerEvent event)
void
start()
-
Methods inherited from class com.adaptris.core.jms.JmsConnectionErrorHandler
close, getSingleExecution, init, onException, setSingleExecution, stop
-
Methods inherited from class com.adaptris.core.jms.JmsConnectionErrorHandlerImpl
allowedInConjunctionWith, equals, handleConnectionException, hashCode
-
Methods inherited from class com.adaptris.core.ConnectionErrorHandlerImp
getRegisteredChannels, registerConnection, restartAffectedComponents, retrieveConnection, retryWaitTimeMs
-
-
-
-
Method Detail
-
onEvent
public void onEvent(com.solacesystems.jms.events.SolConsumerEvent event)
- Specified by:
onEvent
in interfacecom.solacesystems.jms.SolConsumerEventListener
-
start
public void start() throws CoreException
- Specified by:
start
in interfaceComponentLifecycle
- Overrides:
start
in classJmsConnectionErrorHandler
- Throws:
CoreException
-
-