cloudbees - Configuration of CloudAMQP Connection -

-

i'm having difficulty configuring connection cloudamqp in deployed grails application. can run application locally against locally installed rabbitmq instance can't figure out how correctly define application run on cloudbees using cloudamqp service.

in config.groovy, i'm defining connection info , queue:

rabbitmq {     connectionfactory {         username = 'username'         password = 'password'         hostname = 'lemur.cloudamqp.com'     }      queues = {         testqueue autodelete: false, durable: false, exclusive: false     } }

when application starts , tries connect, see following log messages:

2013-08-23 21:29:59,195 [main] debug listener.simplemessagelistenercontainer  - starting rabbit listener container. 2013-08-23 21:29:59,205 [simpleasynctaskexecutor-1] debug listener.blockingqueueconsumer  - starting consumer consumer: tag=[null], channel=null, acknowledgemode=auto local queue size=0 2013-08-23 21:30:08,405 [simpleasynctaskexecutor-1] warn  listener.simplemessagelistenercontainer  - consumer raised exception, processing can restart if connection factory supports org.springframework.amqp.amqpioexception: java.io.ioexception     @ org.springframework.amqp.rabbit.connection.rabbitutils.convertrabbitaccessexception(rabbitutils.java:112)     @ org.springframework.amqp.rabbit.connection.abstractconnectionfactory.createbareconnection(abstractconnectionfactory.java:163)     @ org.springframework.amqp.rabbit.connection.cachingconnectionfactory.createconnection(cachingconnectionfactory.java:228)     @ org.springframework.amqp.rabbit.connection.connectionfactoryutils$1.createconnection(connectionfactoryutils.java:119)     @ org.springframework.amqp.rabbit.connection.connectionfactoryutils.dogettransactionalresourceholder(connectionfactoryutils.java:163)     @ org.springframework.amqp.rabbit.connection.connectionfactoryutils.gettransactionalresourceholder(connectionfactoryutils.java:109)     @ org.springframework.amqp.rabbit.listener.blockingqueueconsumer.start(blockingqueueconsumer.java:199)     @ org.springframework.amqp.rabbit.listener.simplemessagelistenercontainer$asyncmessageprocessingconsumer.run(simplemessagelistenercontainer.java:524)     @ java.lang.thread.run(unknown source) caused by: java.io.ioexception     @ com.rabbitmq.client.impl.amqchannel.wrap(amqchannel.java:106)     @ com.rabbitmq.client.impl.amqchannel.wrap(amqchannel.java:102)     @ com.rabbitmq.client.impl.amqchannel.exnwrappingrpc(amqchannel.java:124)     @ com.rabbitmq.client.impl.amqconnection.start(amqconnection.java:381)     @ com.rabbitmq.client.connectionfactory.newconnection(connectionfactory.java:516)     @ com.rabbitmq.client.connectionfactory.newconnection(connectionfactory.java:545) caused by: com.rabbitmq.client.shutdownsignalexception: connection error; reason: java.net.socketexception: connection reset     @ com.rabbitmq.utility.valueorexception.getvalue(valueorexception.java:67)     @ com.rabbitmq.utility.blockingvalueorexception.uninterruptiblegetvalue(blockingvalueorexception.java:33)     @ com.rabbitmq.client.impl.amqchannel$blockingrpccontinuation.getreply(amqchannel.java:343)     @ com.rabbitmq.client.impl.amqchannel.privaterpc(amqchannel.java:216)     @ com.rabbitmq.client.impl.amqchannel.exnwrappingrpc(amqchannel.java:118)     ... 3 more caused by: java.net.socketexception: connection reset     @ com.rabbitmq.client.impl.frame.readfrom(frame.java:95)     @ com.rabbitmq.client.impl.socketframehandler.readframe(socketframehandler.java:131)     @ com.rabbitmq.client.impl.amqconnection$mainloop.run(amqconnection.java:508) 2013-08-23 21:30:08,406 [simpleasynctaskexecutor-1] info  listener.simplemessagelistenercontainer  - restarting consumer: tag=[null], channel=null, acknowledgemode=auto local queue size=0 2013-08-23 21:30:08,406 [simpleasynctaskexecutor-1] debug listener.blockingqueueconsumer  - closing rabbit channel: null 2013-08-23 21:30:08,407 [simpleasynctaskexecutor-2] debug listener.blockingqueueconsumer  - starting consumer consumer: tag=[null], channel=null, acknowledgemode=auto local queue size=0 aug 23, 2013 9:30:11 pm org.apache.catalina.core.applicationcontext log info: initializing spring frameworkservlet 'grails' aug 23, 2013 9:30:11 pm org.apache.coyote.http11.http11protocol init info: initializing coyote http/1.1 on http-8634 aug 23, 2013 9:30:11 pm org.apache.coyote.http11.http11protocol start info: starting coyote http/1.1 on http-8634

according https://developer.cloudbees.com/bin/view/run/cloudamqp

when bind cloudamqp service app - config params provided in pattern of cloudamqp_url_ - type of thing need put in config files can wired in when app launches.


Comments

Post a Comment

Popular posts from this blog

java - Run a .jar on Heroku -

-
i trying run .jar file on heroku, , can't find instructions anywhere on how this. have read wants me compile uploading heroku. possible, , if is, how this? if helps, trying run minecraft craftbukkit server, , don't have pom.xml file yet. you didn't provide details i'll try give , people reaches question way it. first of all, create heroku account , create heroku application (assumed have done that). second, need generate application jar , upload heroku. so, open terminal , install heroku cli (assuming unix terminal): $ sudo npm install -g heroku-cli you need have npm , nodejs installed, can check link: https://www.digitalocean.com/community/tutorials/how-to-install-node-js-on-ubuntu-16-04 once done that, can use npm update node version acceptable heroku-cli: $ sudo npm install -g n $ sudo n 7.10.0 and run: $ sudo npm install -g heroku-cli in order deploy jars, need install deploy plugin: $ sudo heroku plugins:install heroku-cli-deploy ...
Read more

java - Jtable duplicate Rows -

-
Image
when add new rows in jtable duplicate rows many times this method update jtable public final void tableaucomande(){ ((defaulttablemodel)tabcommande.getmodel()).getdatavector().clear(); session s=hibernateutil.getsessionfactory().opensession(); criteria cr1= s.createcriteria(commande.class); list <commande> lcs=cr1.list() ; criteria cr2= s.createcriteria(lignecommande.class); list <lignecommande> lck=cr2.list() ; if(lcs.size()!=0 && lck.size()!=0) { (commande lc:lcs) { for(lignecommande lig:lck){ ((defaulttablemodel)tabcommande.getmodel()).addrow(new object[]{ lc.getid_cmd(),lc.getnumcmd(),lc.getdate_cmd(),lc.getclient().getnomprenom(), lig.getproduit().getlib_prd(),lig.getquantite(),lig.getproduit().getid_prd() }); } } // tabcommande.setrowselectioninterval(tabcommande.getrowcount()-1,tabcommande.getrowcount()-1); } } this code add add data rows displaye...
Read more

validation - How to pass paramaters like unix into windows batch file -

-
i need pass various parameters .cmd file unix format file.cmd -configuration=value -source=value -flag but, try this: startlocal @echo off cls setlocal set cmdline=%* set configuration= set source= set badargs= set validation= goto main :splitargs echo splitargs(%*) if "%*" neq "" ( /f "tokens=1,2,* delims== " %%i in ("%*") call :assignkeyvalue %%i %%j & call :splitargs %%k ) goto :eof :assignkeyvalue echo assignkeyvalue(%1, %2) if /i %1==-configuration ( set configuration=%2 ) else if /i %1==-source ( set source=%2 ) else ( rem append unrecognised [key,value] badargs echo unknown key %1 set badargs=%badargs%[%1, %2] ) goto :eof :validate echo validating set validation=fail if defined configuration ( echo -configuration ok if defined source ( echo -source ok if not defined badargs ( set validation=success ) ) ) goto :eof :main cl...
Read more