Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- <rabbit:connection-factory id="RabbitMQConnectionFactory" virtual-host="${rabbitmq.vhost}" host="${rabbitmq.host}" port="${rabbitmq.port}" username="${rabbitmq.username}" password="${rabbitmq.password}"/>
- <rabbit:listener-container missing-queues-fatal="false" declaration-retries="0" error-handler="errorHandlinginRabbitMQ" recovery-interval="10000" auto-startup="${rabbitmq.apc.autostartup}" max-concurrency="1" prefetch="1" concurrency="1" connection-factory="RabbitMQConnectionFactory" acknowledge="manual">
- <rabbit:listener ref="apcRabbitMQListener" queue-names="${queue.tpg.rabbitmq.destination.apc}" exclusive="true" />
- </rabbit:listener-container>
- <bean id="errorHandlinginRabbitMQ" class="RabbitMQErrorHandler"/>
- public class RabbitMQErrorHandler implements ErrorHandler
- {
- @Override
- public void handleError(final Throwable exception)
- {
- System.out.println("error occurred in message listener and handled in error handler" + exception.toString());
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement