Guest User

Untitled

a guest
Dec 21st, 2017
132
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 4.67 KB | None | 0 0
  1. 1. List item
  2.  
  3. <rabbit:annotation-driven container-factory="rabbitListenerContainerFactory" />
  4. <!-- CREATE Queues -->
  5. <rabbit:queue name="queue.email" durable="true" auto-delete="false"/>
  6. <rabbit:queue name="queue.sms" durable="true" auto-delete="false"/>
  7. <rabbit:queue name="queue.newstatus" durable="true" auto-delete="false"/>
  8. <rabbit:queue name="queue.smsnew" durable="true" auto-delete="false" />
  9. <rabbit:topic-exchange name="exchange">
  10. <!-- <rabbit:bindings>
  11. <rabbit:binding pattern="topic" queue="queue.newstatus"/>
  12. </rabbit:bindings> -->
  13. </rabbit:topic-exchange>
  14. <rabbit:connection-factory
  15. id="connectionFactory"
  16. host="192.168.2.31"
  17. username="guest"
  18. password="guest"
  19. port="5672"
  20. channel-cache-size="100"
  21. requested-heartbeat="30"/>
  22. <rabbit:admin connection-factory="connectionFactory"/>
  23. <!-- Template Creation -->
  24. <rabbit:template id="amqpTemplate" connection-factory="connectionFactory" exchange="exchange"/>
  25. <!-- Listener Creation -->
  26. <bean id="rabbitListenerContainerFactory" class="org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory">
  27. <property name="connectionFactory" ref="connectionFactory" />
  28. <property name="concurrentConsumers" value="30"/>
  29. <property name="maxConcurrentConsumers" value="50"/>
  30. <property name="prefetchCount" value="30"/>
  31. <property name="defaultRequeueRejected" value="false"/>
  32. <property name="autoStartup" value="true"/>
  33. </bean>
  34.  
  35. <rabbit:listener-container connection-factory="connectionFactory" recovery-interval="50000" acknowledge="none" requeue-rejected="false">
  36. <rabbit:listener ref="rabbitListenerContainerFactory" queue-names="queue.email" />
  37. <rabbit:listener ref="rabbitListenerContainerFactory" queue-names="queue.sms" />
  38. </rabbit:listener-container>
  39. Iam getting following exception
  40.  
  41. org.springframework.amqp.AmqpConnectException: java.net.ConnectException: Connection refused: connect
  42. at org.springframework.amqp.rabbit.support.RabbitExceptionTranslator.convertRabbitAccessException(RabbitExceptionTranslator.java:62)
  43. at org.springframework.amqp.rabbit.connection.AbstractConnectionFactory.createBareConnection(AbstractConnectionFactory.java:376)
  44. at org.springframework.amqp.rabbit.connection.CachingConnectionFactory.createConnection(CachingConnectionFactory.java:573)
  45. at org.springframework.amqp.rabbit.core.RabbitTemplate.doExecute(RabbitTemplate.java:1430)
  46. at org.springframework.amqp.rabbit.core.RabbitTemplate.execute(RabbitTemplate.java:1411)
  47. at org.springframework.amqp.rabbit.core.RabbitTemplate.execute(RabbitTemplate.java:1387)
  48. at org.springframework.amqp.rabbit.core.RabbitAdmin.getQueueProperties(RabbitAdmin.java:336)
  49. at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.redeclareElementsIfNecessary(SimpleMessageListenerContainer.java:1209)
  50. at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer$AsyncMessageProcessingConsumer.run(SimpleMessageListenerContainer.java:1470)
  51. at java.lang.Thread.run(Thread.java:745)
  52. Caused by: java.net.ConnectException: Connection refused: connect
  53. at java.net.DualStackPlainSocketImpl.waitForConnect(Native Method)
  54. at java.net.DualStackPlainSocketImpl.socketConnect(DualStackPlainSocketImpl.java:85)
  55. at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:339)
  56. at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:200)
  57. at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:182)
  58. at java.net.PlainSocketImpl.connect(PlainSocketImpl.java:172)
  59. at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
  60. at java.net.Socket.connect(Socket.java:579)
  61. at com.rabbitmq.client.impl.SocketFrameHandlerFactory.create(SocketFrameHandlerFactory.java:50)
  62. at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:907)
  63. at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:859)
  64. at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1000)
  65. at org.springframework.amqp.rabbit.connection.AbstractConnectionFactory.createBareConnection(AbstractConnectionFactory.java:364)
  66. can anyone help me to resolve this problem,thanks in Advance.
Add Comment
Please, Sign In to add comment