Advertisement
Guest User

Untitled

a guest
Apr 4th, 2017
127
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.97 KB | None | 0 0
  1. <rabbit:connection-factory id="RabbitMQConnectionFactory" virtual-host="${rabbitmq.vhost}" host="${rabbitmq.host}" port="${rabbitmq.port}" username="${rabbitmq.username}" password="${rabbitmq.password}"/>
  2. <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">
  3. <rabbit:listener ref="apcRabbitMQListener" queue-names="${queue.tpg.rabbitmq.destination.apc}" exclusive="true" />
  4. </rabbit:listener-container>
  5. <bean id="errorHandlinginRabbitMQ" class="RabbitMQErrorHandler"/>
  6.  
  7. public class RabbitMQErrorHandler implements ErrorHandler
  8. {
  9. @Override
  10. public void handleError(final Throwable exception)
  11. {
  12. System.out.println("error occurred in message listener and handled in error handler" + exception.toString());
  13. }
  14. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement