java - SpringBoot rabbit connection timeout issue -


my spring boot application throws connection timeout error, , never able connect. other interesting problem see is, never picking connection timeout property defined in spring app properties.

  org.springframework.amqp.amqptimeoutexception: java.util.concurrent.timeoutexception     @ org.springframework.amqp.rabbit.support.rabbitexceptiontranslator.convertrabbitaccessexception(rabbitexceptiontranslator.java:74) ~[spring-rabbit-1.6.7.release.jar:na]     @ org.springframework.amqp.rabbit.connection.abstractconnectionfactory.createbareconnection(abstractconnectionfactory.java:309) ~[spring-rabbit-1.6.7.release.jar:na]     @ org.springframework.amqp.rabbit.connection.cachingconnectionfactory.createconnection(cachingconnectionfactory.java:577) ~[spring-rabbit-1.6.7.release.jar:na]     @ org.springframework.amqp.rabbit.core.rabbittemplate.doexecute(rabbittemplate.java:1431) ~[spring-rabbit-1.6.7.release.jar:na]     @ org.springframework.amqp.rabbit.core.rabbittemplate.execute(rabbittemplate.java:1412) ~[spring-rabbit-1.6.7.release.jar:na]     @ org.springframework.amqp.rabbit.core.rabbittemplate.execute(rabbittemplate.java:1388) ~[spring-rabbit-1.6.7.release.jar:na]     @ org.springframework.amqp.rabbit.core.rabbitadmin.getqueueproperties(rabbitadmin.java:336) ~[spring-rabbit-1.6.7.release.jar:na]     @ org.springframework.amqp.rabbit.listener.simplemessagelistenercontainer.redeclareelementsifnecessary(simplemessagelistenercontainer.java:1123) [spring-rabbit-1.6.7.release.jar:na]     @ org.springframework.amqp.rabbit.listener.simplemessagelistenercontainer.access$800(simplemessagelistenercontainer.java:98) [spring-rabbit-1.6.7.release.jar:na]     @ org.springframework.amqp.rabbit.listener.simplemessagelistenercontainer$asyncmessageprocessingconsumer.run(simplemessagelistenercontainer.java:1329) [spring-rabbit-1.6.7.release.jar:na]     @ java.lang.thread.run(thread.java:745) [na:1.8.0_91] caused by: java.util.concurrent.timeoutexception: null     @ com.rabbitmq.utility.blockingcell.get(blockingcell.java:76) ~[amqp-client-3.6.5.jar:na]     @ com.rabbitmq.utility.blockingcell.uninterruptibleget(blockingcell.java:110) ~[amqp-client-3.6.5.jar:na]     @ com.rabbitmq.utility.blockingvalueorexception.uninterruptiblegetvalue(blockingvalueorexception.java:36) ~[amqp-client-3.6.5.jar:na]     @ com.rabbitmq.client.impl.amqchannel$blockingrpccontinuation.getreply(amqchannel.java:366) ~[amqp-client-3.6.5.jar:na]     @ com.rabbitmq.client.impl.amqconnection.start(amqconnection.java:292) ~[amqp-client-3.6.5.jar:na]     @ com.rabbitmq.client.connectionfactory.newconnection(connectionfactory.java:824) ~[amqp-client-3.6.5.jar:na]     @ com.rabbitmq.client.connectionfactory.newconnection(connectionfactory.java:736) ~[amqp-client-3.6.5.jar:na]     @ org.springframework.amqp.rabbit.connection.abstractconnectionfactory.createbareconnection(abstractconnectionfactory.java:293) ~[spring-rabbit-1.6.7.release.jar:na]     ... 9 common frames omitted

here java config,

    @configuration @enablerabbit public class rabbitconfig {      private final string exchange;     private final string queuename;       public rabbitconfig(             @value("${exchange.name}") string exchange,             @value("${queue.name}") string queue) {          this.exchange= exchange;         this.queuename=queue; }  @bean queue queue() {     return new queue(queuename, true); }  @bean directexchange exchange() {     return new directexchange(queuename); }  @bean binding binding(queue queue, directexchange exchange) {     return bindingbuilder.bind(queue).to(exchange).with(queuename); }  @bean simplemessagelistenercontainer container(rabbitadmin admin,cachingconnectionfactory connectionfactory) {     simplemessagelistenercontainer container = new simplemessagelistenercontainer();     connectionfactory.setclosetimeout(10000);     container.setqueuenames(queuename);     container.setconnectionfactory(connectionfactory);     //container.setmessagelistener(listeneradapter);     return container; }  //    @bean //    messagelisteneradapter listeneradapter(receiver receiver) { //        return new messagelisteneradapter(receiver, "receivemessage"); //    }      @bean     public rabbitadmin admin(connectionfactory connectionfactory) {         return new rabbitadmin(connectionfactory);     }   }

and spring application properties like,

spring.rabbitmq.host = 127.0.0.1 spring.rabbitmq.port = 15672 spring.rabbitmq.username = guest spring.rabbitmq.password = guest  exchange.name=myexchange queue.name=myqueue  spring.rabbitmq.cache.connection.mode=connection spring.rabbitmq.cache.channel.size=50 spring.rabbitmq.cache.channel.checkout-timeout= 10000

rabbit , running on 127.0.0.1 on port 15672, app never able connect.

by default, amqp port 5672. port 15672 shows web ui (admin console). if you're using default setup, adjust

spring.rabbitmq.port = 5672

rabbitmq networking configuration reference


Comments

Post a Comment

Popular posts from this blog

php - Vagrant up error - Uncaught Reflection Exception: Class DOMDocument does not exist -

i've set bento/ubuntu-16.04 vagrant box using php 5.6, , getting following error quite few times when try , run shell script: "uncaught reflection exception: class domdocument not exist". i've tried adding following top of script (not together), each no success: "sudo apt-get install php5.6-xml", "sudo apt-get install php5-xml", "sudo apt-get install php-dom" i've tried resetting server "sudo service apache2 restart". does have suggestions?
Read more

vue.js - Create hooks for automated testing -

Image
qa guys complained can't automate frontend testing. because our html looks same outside. lazy hack did this <template> <div :role="$options.name"> ... </div> </template> <script> export default { name: 'vmcomponentname' } </script> which takes name script , applies html. in browser get: <div role="vmcomponentname"> ... </div> line :role="$options.name" goes in every component. is there dry er solutions? please share. additional details i'll explain in details looking for. imagine have vmusercreate form creates user. test case can create user . to automatically test without role, have use following selector: .wrapper > .wrapper > .wrapper > .submit-button the test extremely brittle (will break lot). if use roles can use [role="vmusercreateform"] .submit-button selector. many folds less brittle. so basically, i'm ...
Read more

Add new key value to json node in java -

i have json file : { "id":1, "name":"abc", "addressdetails": { "city":"newyork" } } i wanted add 1 more key-value ("pincode" : "414141") node 'addressdetails'. i tried using : objectmapper mapper = new objectmapper(); jsonnode root = mapper.readtree(new file("d://test.json")); objectnode node = mapper.createobjectnode(); node.with("addressdetails").put("pincode", "414141"); but it's not getting added, there way can ? you can try you should modify file path objectmapper mapper = new objectmapper(); objectnode nodes = mapper.readvalue(new file("d:\\test.txt"), objectnode.class); nodes.with("addressdetails").put("pincode", "414141"); mapper.writer().writevalue(new file("d:\\test.txt"), nodes);
Read more