http://blog.gmane.org/gmane.comp.networking.rabbitmq.general hourly 1 1901-01-01T00:00+00:00 http://gmane.org/img/gmane-25t.png http://gmane.org http://permalink.gmane.org/gmane.comp.networking.rabbitmq.general/23360 <pre>Hi all, Is anyone successfully using PHP STOMP extension or library to connect and send/consume messages over RabbitMQ with STOMP adapter? Thanks, Nikola </pre> Nikola Savic 2013-05-24T22:28:02 http://permalink.gmane.org/gmane.comp.networking.rabbitmq.general/23359 <pre>Simon, Again, thank you for your continued help. I have made progress, but I'm hitting another problem. I'm trying to establish federation between two brokers (one happens to be clustered, but the second cluster node is currently down) using passwordless-SSH using a LDAP authentication backend. If I disable external auth, I can get the federation clients to connect. Once I enable external auth, I get the following error. Any ideas? =ERROR REPORT==== 24-May-2013::16:34:44 === ** Generic server &lt;0.2696.0&gt; terminating ** Last message in was {'$gen_cast',maybe_go} ** When Server state == {not_started, {{upstream, {amqp_params_network,&lt;&lt;"guest"&gt;&gt;,&lt;&lt;"guest"&gt;&gt;, &lt;&lt;"/"&gt;&gt;,"ecozzi-02",undefined,0,0,0,infinity, [{fail_if_no_peer_cert,true}, {verify,verify_peer}, {keyfile,"/opt/cray/ssl/client-01/key.pem"}, {certfile,"/opt/cray/ssl/client-01/cert.pem"}, {cacertfile,"/opt/cray/ssl/testca/cacert.pem"}], [#Fun&lt;amqp_uri.7.123484526&gt;, #Fun&lt;amqp_uri.7.123484526&gt;], [],[]}, &lt;&lt;"amqps://ecozzi-02?cacertfile=/opt/cray/ssl/testca/cacert.pem&amp;certfile=/opt/cray/ssl/client-01/cert.pem&amp;keyfile=/opt/cray/ssl/client-01/key.pem&amp;verify=verify_peer&amp;fail_if_no_peer_cert=true"&gt;&gt;, {exchange, {resource,&lt;&lt;"/"&gt;&gt;,exchange,&lt;&lt;"cray.topic"&gt;&gt;}, topic,true,false,false,[], [{federation, [{{&lt;&lt;"ecozzi-02"&gt;&gt;,&lt;&lt;"cray.topic"&gt;&gt;},&lt;&lt;"A"&gt;&gt;}]}], [{vhost,&lt;&lt;"/"&gt;&gt;}, {name,&lt;&lt;"federate-me"&gt;&gt;}, {pattern,&lt;&lt;"^cray."&gt;&gt;}, {definition, [{&lt;&lt;"federation-upstream-set"&gt;&gt;,&lt;&lt;"all"&gt;&gt;}]}, {priority,0}]}, 1000,1,1,none,none,true,none,&lt;&lt;"ecozzi-02"&gt;&gt;}, {resource,&lt;&lt;"/"&gt;&gt;,exchange,&lt;&lt;"cray.topic"&gt;&gt;}}} ** Reason for termination == ** {{{case_clause, {badrpc, {'EXIT', {{badarg,{error,noSuchObject}}, [{rabbit_access_control,'-check_vhost_access/2-fun-0-',3,[]}, {rabbit_access_control,check_access,5,[]}, {rabbit_direct,connect,5,[]}, {rpc,local_call,3,[{file,"rpc.erl"},{line,327}]}, {amqp_direct_connection,connect,4,[]}, {amqp_gen_connection,handle_call,3,[]}, {gen_server,handle_msg,5, [{file,"gen_server.erl"},{line,588}]}, {proc_lib,init_p_do_apply,3, [{file,"proc_lib.erl"},{line,227}]}]}}}}, [{amqp_direct_connection,connect,4,[]}, {amqp_gen_connection,handle_call,3,[]}, {gen_server,handle_msg,5,[{file,"gen_server.erl"},{line,588}]}, {proc_lib,init_p_do_apply,3,[{file,"proc_lib.erl"},{line,227}]}]}, {gen_server,call,[&lt;0.2699.0&gt;,connect,infinity]}} Eric On 05/24/2013 08:51 AM, Eric Cozzi wrote: </pre> Eric Cozzi 2013-05-24T21:55:07 http://permalink.gmane.org/gmane.comp.networking.rabbitmq.general/23358 <pre>Hello, I'm writing unit tests for the various components in my application, some of which interface with a RabbitMQ broker. I've managed to successfully implement reading from a mocked call to IModel.BasicConsume() and acknowledging with IModel.BasicAck() but am stuck on IModel.BasicPublish(), in particular mocking the ack/nack mechanism with IModel as I need to test my component in both those scenarios. How does the ack/nack mechanism work with IModel.WaitForConfirms() and how would I go about sending an ack/nack when the publisher calls IModel.BasicPublish()? I'm using NSubstitute as my mocking library but I imagine the solution is translatable across mocking frameworks. Thanks, Mark </pre> Mark Snelling 2013-05-24T16:02:12 http://permalink.gmane.org/gmane.comp.networking.rabbitmq.general/23357 <pre>I have created several plugin applications that run under RabbitMQ and when they produce an issue, sometimes the ERROR REPORT is logged in a very short/incomplete manner that does not allow me to identify where ( which module and line of code ) the error occurred. Here is an example: =ERROR REPORT==== 24-May-2013::08:23:35 === Error in process &lt;0.489.0&gt; on node 'rabbit&lt; at &gt;guidomacbookpro2' with exit value: {function_clause,[{orddict,fetch,["rxLBslwAswwgRz6RMtmDYenC8",[{"rxlbslwaswwgrz6rmtmdyenc8",[[{"BRANCH_ID","B8UpVlS40csA6v246IsYeTGYB"},{"DTTM_VERSION",2.013032e+16},{"HEADER_ID","B8UpVlS40csA6v246IsYeTGYB"},{"MODEL_ID","rxLBslwAsw... Notice above the last "..." characters, that's where it all ends. The interesting stuff is certainly at the end of that Strangely, other times, the report shows complete. I can't also understand what is the difference. Question: How to get a full / complete report ? Thanks Guido </pre> Guido Extra 2013-05-24T13:35:21 http://permalink.gmane.org/gmane.comp.networking.rabbitmq.general/23356 <pre> Sorry for taking so long, been busy on other things = ) I've patched this and created a PR on Github (see &lt;https://github.com/rabbitmq/rabbitmq-management/pull/6&gt;) Please tell me if you prefer patches some other way. Have a great weekend! Br, - Simon </pre> Simon Lundström 2013-05-24T14:43:09 http://permalink.gmane.org/gmane.comp.networking.rabbitmq.general/23355 <pre>Hi Simon, Tim, Thanks for your replies and effort analysing my query. On Riak we have experienced stability issues when large data is being transferred. I am not too sure the exact root cause, but we see busy_dist_port messages then one of the Riak nodes crashes and has to be restarted by Chef. Increasing "+zdbbl 18432" resolved this issue. This contains more information about Riak and this setting http://boundary.com/blog/2012/09/26/incuriosity-killed-the-infrastructur/ We have not seen any stability issues with our use of RabbitMQ to date. After our Riak experience I was concerned if our RabbitMQ usage pattern changes over time (for example message sizes increase), we could experience similar stability issues too. If there is a chance of this I would like to be warned before its a problem. Iain. On 21 May 2013 15:38, Simon MacMullen &lt;simon-mQ7lE4MOPXtWk0Htik3J/w&lt; at &gt;public.gmane.org&gt; wrote: </pre> Iain Hull 2013-05-24T14:35:07 http://permalink.gmane.org/gmane.comp.networking.rabbitmq.general/23354 <pre>A-ha! That's exactly what I was missing. Thanks! Eric On 05/24/2013 05:02 AM, Simon MacMullen wrote: </pre> Eric Cozzi 2013-05-24T13:51:14 http://permalink.gmane.org/gmane.comp.networking.rabbitmq.general/23353 <pre>While I'm biased by being the maintainer of php-amqplib, one thing I like from that library is the ability to have multiple consumers on the same PHP script. On Fri, May 24, 2013 at 3:31 PM, Colleen Mirabello &lt; colleen-LjP1WaoGRhZ8oCxkSR+xewC/G2K4zDHf&lt; at &gt;public.gmane.org&gt; wrote: </pre> Alvaro Videla 2013-05-24T13:40:23 http://permalink.gmane.org/gmane.comp.networking.rabbitmq.general/23352 <pre>Hi, I have an understanding problem because of the user permissions. My senario: I have a cluster, I have queues, ... I have users who should have there own queues, which only they and I should can see AND all of them should have permissions to send msg to a special queue and only one user (me) should have the permission to receive. Can someone help me to create this permissions in the web UI or console? I tried it a few times but no matter what I try my test user could see everything he couldn't change the conf but... not like I wanted. (Perhaps I have to create vhosts, but I don't know.) -- View this message in context: http://rabbitmq.1065348.n5.nabble.com/User-permission-tp26987.html Sent from the RabbitMQ mailing list archive at Nabble.com. </pre> Slyth 2013-05-24T13:33:46 http://permalink.gmane.org/gmane.comp.networking.rabbitmq.general/23351 <pre>Alvaro, Using that library, I don't believe there's a way to get the same script to consume from multiple queues using consume(). Once you call consume(), the script blocks waiting for messages from that queue. Thanks. - Colleen On 5/23/2013 5:41 PM, Alvaro Videla wrote: </pre> Colleen Mirabello 2013-05-24T13:31:22 http://permalink.gmane.org/gmane.comp.networking.rabbitmq.general/23350 <pre>Hi. I'm afraid the management logs are just what's available from Webmachine, which offers very little configurability. We've got a bug open to do our own HTTP logging, but I don't know how many people care. Does anyone else want to speak up? Cheers, Simon On 24/05/13 08:15, Simon Lundström wrote: </pre> Simon MacMullen 2013-05-24T10:04:58 http://permalink.gmane.org/gmane.comp.networking.rabbitmq.general/23349 <pre>Hi. Are you setting the various SSL options in the URIs? See http://www.rabbitmq.com/shovel.html#uris for the URI format. Federation uses the AMQP client, which doesn't get its SSL options from the configuration file. Cheers, Simon On 23/05/13 21:28, Eric Cozzi wrote: </pre> Simon MacMullen 2013-05-24T10:02:25 http://permalink.gmane.org/gmane.comp.networking.rabbitmq.general/23348 <pre> That benchmark didn't test your specific usage pattern, namely connect-send-disconnect-repeat. It also didn't run PHP on the client side. Hence it really isn't a good basis of comparison for your workload. Matthias. </pre> Matthias Radestock 2013-05-24T08:36:25 http://permalink.gmane.org/gmane.comp.networking.rabbitmq.general/23347 <pre> I found one benchmark of different MQ servers, which included STOMP and AMQP on RabbitMQ. STOMP was much slower :( http://x-aeon.com/wp/2013/04/10/a-quick-message-queue-benchmark-activemq-rabbitmq-hornetq-qpid-apollo/ Will try to implement STOMP on producers and will let you know if it works better from client and server point of view :) On 05/23/2013 03:23 PM, Matthias Radestock wrote: </pre> Nikola Savic 2013-05-24T08:29:41 http://permalink.gmane.org/gmane.comp.networking.rabbitmq.general/23346 <pre>Morning, Would it possible to get the managements access log to write itself to one file like &lt;nodename&gt;{,-sasl}.log so that it can more easily be rotated and compress with logrotate(1)? I'd rather not have to cron a find to compress and delete files. Br, - Simon ____________________________________ Simon Lundström Section for Infrastructure IT Services Stockholm University SE-106 91 Stockholm, Sweden www.su.se/it ____________________________________ </pre> Simon Lundström 2013-05-24T07:15:51 http://permalink.gmane.org/gmane.comp.networking.rabbitmq.general/23345 <pre>Hi there.....I know this is old thread, but I'm having the same problem.....the thing is that I'm trying to build a cluster on amazon ec2. there, there is no domain and the machines only have a hostname of the form ip-0-0-0-0. everything works fine for one node (and erlang starts with -name rabbit&lt; at &gt;ip-x-x-x-x), but when i try to join cluster to another node, there is no name resolution happening between both machines (other than specifying mutually on respectives ec/hosts). those machines does recognize the name *ip-x-x-x-x.ec2.internal*....but I'm just failing to configure this name. When i tried specifying this long name in NODENAME in env file, it's when erlang (or rabbitmq, don't know) complains with "can't get short name whatever". and maybe it's because the newer version, but I can't find where to change the -sname by -name in any scripts.....could you please have any advice for me ?? Thanks ! Santiago. On Saturday, February 19, 2011 7:52:21 PM UTC-3, Matthias Radestock wrote: &gt;</pre> Santiago Ezcurra 2013-05-23T23:37:17 http://permalink.gmane.org/gmane.comp.networking.rabbitmq.general/23344 <pre>Hi Matt! I haven’t looked at RabbitMQ for a while, so my answers might be outdated and/or wrong, but since I gave the original answers I’m going to give it a shot :). The improvements consist in the fact that the operations are safer now. It goes more or less like this: when the node starts up it asks the other nodes (‘other nodes’ in this case being the ones in the config file) for the cluster they are in, and then joins it if the other nodes are consistent in terms of Erlang and RabbitMQ versions. This opens up a race condition if the clusters start together: in the startup sequence they all ask each other out for the cluster, but since they’re still not fully started that they might all (or some) get inconclusive replies. Thus the cluster might not form fully. There surely are other negative outcomes that I am misremembering, but since RabbitMQ 3 it should be fairly hard (or at least harder) to get catastrophic results (e.g. mnesia panics). This is because in the past RabbitMQ blindly clustered with the other nodes without really bothering to check if it made sense to do so. The situation is a tricky one to solve with an interface similar to the one that we have now, and within the constraints of mnesia. One can probably devise ad-hoc solution if your assumptions are stronger than the ones we make in the code, e.g. you might check after a bit if the nodes are really clustered and take action if they are not. Hopefully the above was helpful, you might want to wait for others for more precise answers :). Francesco _______________________________________________ rabbitmq-discuss mailing list rabbitmq-discuss&lt; at &gt;lists.rabbitmq.com https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss </pre> Francesco Mazzoli 2013-05-23T23:34:05 http://permalink.gmane.org/gmane.comp.networking.rabbitmq.general/23343 <pre>Thanks. I found that that there was a previously not closed consumer for the same queue and that was consuming the message. Everything works now. -Vikram On 05/23/2013 08:20 AM, Matthias Radestock wrote: </pre> Vikram Viswanathan 2013-05-23T21:44:19 http://permalink.gmane.org/gmane.comp.networking.rabbitmq.general/23342 <pre>Hi, Using that library, can you consume from more than one queue? If yes, then you could send control messages to the script and make it stop. With php-amqplib since the while loop is part of user land code, you can control all the consuming parts on your own so this wouldn't be a problem. Regards, Alvaro On Thu, May 23, 2013 at 10:45 PM, Colleen Mirabello &lt; colleen-LjP1WaoGRhZ8oCxkSR+xewC/G2K4zDHf&lt; at &gt;public.gmane.org&gt; wrote: </pre> Alvaro Videla 2013-05-23T21:41:28 http://permalink.gmane.org/gmane.comp.networking.rabbitmq.general/23341 <pre>Thanks Matthias - You cleared up my point of confusion. Specifically, that because messages are written to an exchange rather than a queue, the publisher doesn't "touch" the queue. This is an important but subtle point. I may have overlooked it, but I don't recall it being highlighted anywhere in the docs. Matt On Thu, May 23, 2013 at 2:18 PM, Matthias Radestock &lt;matthias-mQ7lE4MOPXtWk0Htik3J/w&lt; at &gt;public.gmane.org&gt;wrote: </pre> Matt Pietrek 2013-05-23T21:23:59 http://permalink.gmane.org/gmane.comp.networking.rabbitmq.general/23340 <pre> More specifically, any queue.* method in AMQP. Note that publishers never 'write' to queues but publish messages to exchanges. So they are not affected by a queue's exclusivity. Matthias. </pre> Matthias Radestock 2013-05-23T21:18:56 Search the mailing list at Gmane query http://search.gmane.org/?group=$group=gmane.comp.networking.rabbitmq.general