[rabbitmq-discuss] Exchanges and queues for a social design system

Tue Sep 24 11:10:24 BST 2013

Thanks Michael for your response , however I have another question , rabbit is best for propagation and routing and is not a database  , I am designing a social based system and I have my users in the database .
e.g Jack follows john , john follows jack
So when jack makes a post I write the post to my db and deliver the message to john by writing to johns exchange .John gets the message by waiting on a queue based on any message written to his exchange.is this the right approach to designing a social system with rabbitmq ?, thanks.

----- Reply message -----
From: rabbitmq-discuss-request at lists.rabbitmq.com
To: <rabbitmq-discuss at lists.rabbitmq.com>
Subject: rabbitmq-discuss Digest, Vol 76, Issue 25
Date: Tue, Sep 24, 2013 12:00 PM

Send rabbitmq-discuss mailing list submissions to
	rabbitmq-discuss at lists.rabbitmq.com

To subscribe or unsubscribe via the World Wide Web, visit
	https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
or, via email, send a message with subject or body 'help' to
	rabbitmq-discuss-request at lists.rabbitmq.com

You can reach the person managing the list at
	rabbitmq-discuss-owner at lists.rabbitmq.com

When replying, please edit your Subject line so it is more specific
than "Re: Contents of rabbitmq-discuss digest..."

Today's Topics:

   1. Re: Problems with RabbitMQ installlation and	startup
      (Simon MacMullen)
   2. Re: consumer in background ( tyger2007 at yahoo.com )
   3. Re: consumer in background (Michael Klishin)
   4. Many consumers on 1 queue. What algorithm RabbitMQ use to
      send messages? (Haster)
   5. Re: Many consumers on 1 queue. What algorithm RabbitMQ use to
      send messages? (Michael Klishin)
   6. Channel best practices (Mike Hadlow)
   7. Re: Rabbitmq 3.1.5 version facing issues. urgent issue ..
      (Simon MacMullen)
   8. Re: Channel best practices (Michael Klishin)
   9. Re: clustered ram node loosing its membership without being
      reset (Simon MacMullen)
  10. Re: Channel best practices (Tim Watson)
  11. Re: Fine-grained LDAP access to resources (Simon MacMullen)
  12. Re: Channel best practices (Mike Hadlow)
  13. Re: Channel best practices (Michael Klishin)
  14. ANN QDB 0.5.0 released (David Tinker)
  15. Re: Questiong about plugins and clustering (Alvaro Videla)
  16. Re: Fine-grained LDAP access to resources (James M.)
  17. Re: Channel best practices (Mike Hadlow)
  18. AMQP URIs do not support connection_timeout? (Fred Dushin)
  19. Re: AMQP URIs do not support connection_timeout? (Simon MacMullen)
  20. Re: Troubleshooting RabbitMQ (Simon MacMullen)
  21. Re: Can't Bind After Upgrading from 3.1.1 to	3.1.5 (Chris)
  22. Re: Fine-grained LDAP access to resources (Simon MacMullen)
  23. Re: Fine-grained LDAP access to resources (Simon MacMullen)
  24. Generated Message-ID in AMQP Header (Ingo Knito)
  25. Re: Fine-grained LDAP access to resources (James M.)
  26. Re: Generated Message-ID in AMQP Header (Alvaro Videla)
  27. Determining home node for queue (Paul Bowsher)
  28. Re: Many consumers on 1 queue. What algorithm RabbitMQ use to
      send messages? (Haster)
  29. Cluster Recovery Modes (Cordell, Ron)
  30. rabbitpy 0.5.0 released (Gavin M. Roy)
  31. Re: Cluster Recovery Modes (Cordell, Ron)
  32. What's difference between vFabric RabbitMQ and the open
      source RabbitMQ? (Huang Tonglang)
  33. Re: Cluster Recovery Modes (Tim Watson)
  34. Re: What's difference between vFabric RabbitMQ	and the open
      source RabbitMQ? (Michael Klishin)
  35. Re: Determining home node for queue (Michael Klishin)
  36. Re: Many consumers on 1 queue. What algorithm	RabbitMQ use to
      send messages? (Michael Klishin)
  37. Clustring not working in rabbit MQ (dilip.aim11)
  38.  What's difference between vFabric RabbitMQ and the open
      source RabbitMQ? (jim)
  39. Re: Clustring not working in rabbit MQ (Emile Joubert)
  40. Re: Clustring not working in rabbit MQ (dilip.aim11)
  41. Re: Clustring not working in rabbit MQ (Emile Joubert)
  42. Re: Many consumers on 1 queue. What algorithm RabbitMQ use to
      send messages? (Haster)
  43. Re: Clustring not working in rabbit MQ (dilip.aim11)

----------------------------------------------------------------------

Message: 1
Date: Mon, 23 Sep 2013 10:35:25 +0100
From: Simon MacMullen <simon at rabbitmq.com>
Subject: Re: [rabbitmq-discuss] Problems with RabbitMQ installlation
	and	startup
To: Discussions about RabbitMQ <rabbitmq-discuss at lists.rabbitmq.com>
Message-ID: <52400B5D.4050402 at rabbitmq.com>
Content-Type: text/plain; charset=ISO-8859-1; format=flowed

On 20/09/2013 23:20, Allan Baker wrote:
> One thing to mention is that the scripts /etc/init.d/rabbit-mqserver and
> /usr/sbin/rabbit-mqserver give the same error.
> However, interestingly enough, if you run
> /usr/lib/rabbitmq/bin/rabbitmq-server:

<snip>

> It works! What could be wrong with the startup scripts? I attach them
> also to see
> if there's something there that could be useful.

The main difference in starting in these two ways is that the server is 
run as root in the latter case, rather than the "rabbitmq" user. The 
failed startup also failed due to "undef" - i.e. the Erlang VM could not 
find the definition for a module.

I therefore wonder if the permissions of the server code have been 
changed somehow so that the "rabbitmq" user can't read it. If so, the 
easiest way to fix the permissions is probably to remove the deb and 
reinstall it.

Cheers, Simon

------------------------------

Message: 2
Date: Mon, 23 Sep 2013 10:53:06 +0100
From: " tyger2007 at yahoo.com " <tyger2007 at yahoo.com>
Subject: Re: [rabbitmq-discuss] consumer in background
To: rabbitmq-discuss at lists.rabbitmq.com
Message-ID: <443920.47598.bm at smtp206.mail.gq1.yahoo.com>
Content-Type: text/plain; charset="utf-8"

Thanks alvaro like I said this concept is totally new to me , however I would like to know if the consumers would run stand alone , that is apart from the web server ? , if that is the case does it mean I would have to keep my command line open always on my servers?

----- Reply message -----
From: rabbitmq-discuss-request at lists.rabbitmq.com
To: <rabbitmq-discuss at lists.rabbitmq.com>
Subject: rabbitmq-discuss Digest, Vol 76, Issue 24
Date: Mon, Sep 23, 2013 12:00 PM

Send rabbitmq-discuss mailing list submissions to
	rabbitmq-discuss at lists.rabbitmq.com

To subscribe or unsubscribe via the World Wide Web, visit
	https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
or, via email, send a message with subject or body 'help' to
	rabbitmq-discuss-request at lists.rabbitmq.com

You can reach the person managing the list at
	rabbitmq-discuss-owner at lists.rabbitmq.com

When replying, please edit your Subject line so it is more specific
than "Re: Contents of rabbitmq-discuss digest..."

Today's Topics:

   1. Troubleshooting RabbitMQ (Sukhjeet Singh)
   2. federate the unnamed queue? (Greg Roy)
   3. Re: Troubleshooting RabbitMQ (Michael Klishin)
   4. Re: federate the unnamed queue? (Michael Klishin)
   5. Re: federate the unnamed queue? (Alvaro Videla)
   6. Re: Producer consumer in background on a web	server
      (Alvaro Videla)
   7. Re: Federation setup query (Jain, Punit)
   8. Re: Questiong about plugins and clustering (Simon MacMullen)
   9. Re: federate the unnamed queue? (Simon MacMullen)
  10. Re: Troubleshooting RabbitMQ (Simon MacMullen)
  11. Re: Questiong about plugins and clustering (Emile Joubert)
  12. Re: How do the Producer gets response from the subscribers
      (Matthias Radestock)

----------------------------------------------------------------------

Message: 1
Date: Sun, 22 Sep 2013 07:39:55 -0400
From: Sukhjeet Singh <princu.chana at gmail.com>
Subject: [rabbitmq-discuss] Troubleshooting RabbitMQ
To: rabbitmq-discuss at lists.rabbitmq.com
Message-ID:
	<CAB9W+YKEJ6qNX89Cj2SfEO7d85cweod-XYKS=uMGr_VhDmAYBQ at mail.gmail.com>
Content-Type: text/plain; charset="iso-8859-1"

Sir/Madam,
                 This is for first time I am using RabbitMQ. After
searching, I come to know that first I have to install RabbitMq sever and
after doing that I used a code sample given in rabbitMq's official site.I
am pasting that code here also. I also tried to search the resolution of
this error but I am not able to get it's solution. This is a request to
please help me as soon as it can br possible.

Actually, the problem is that createConnection() method is throwing an
exception and the exception is "BrokerUnreachableException was Unhandled".

Please HELP ASAP.

Thanks.
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20130922/734cd42a/attachment.html>

------------------------------

Message: 2
Date: Sun, 22 Sep 2013 10:47:13 -0400
From: Greg Roy <gj.roy75 at gmail.com>
Subject: [rabbitmq-discuss] federate the unnamed queue?
To: rabbitmq-discuss at lists.rabbitmq.com
Message-ID:
	<CAKAqKjuD_5=59Yb4m55UUk+PdeWHu0VRLb8H0-TczarUnA2FWA at mail.gmail.com>
Content-Type: text/plain; charset="iso-8859-1"

Hello All,

I would like to federate all messages to the default unnamed queue - is
this possible?  I have tried variations of pattern matching nothing, but
believe I'll need to alter my publishing behaviour.  True or false?

Thanks in advance,

Greg
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20130922/960fa966/attachment-0001.htm>

------------------------------

Message: 3
Date: Sun, 22 Sep 2013 19:31:17 +0100
From: Michael Klishin <michael at rabbitmq.com>
Subject: Re: [rabbitmq-discuss] Troubleshooting RabbitMQ
To: Discussions about RabbitMQ <rabbitmq-discuss at lists.rabbitmq.com>
Message-ID: <BCD3D9F4-D067-4352-B546-9D2F20CDA81E at rabbitmq.com>
Content-Type: text/plain; charset="iso-8859-1"

On sep 22, 2013, at 12:39 p.m., Sukhjeet Singh <princu.chana at gmail.com> wrote:

> Actually, the problem is that createConnection() method is throwing an exception and the exception is "BrokerUnreachableException was Unhandled". 

Sukhjeet,

Can you please be a bit more specific about

 * What the stack trace look like
 * How did you install RabbitMQ
 * If it is running
 * If there's anything in the log
 * What tutorial are you following and for what language

Then it will be much easier to provide specific advice.

MK

-------------- next part --------------
A non-text attachment was scrubbed...
Name: signature.asc
Type: application/pgp-signature
Size: 495 bytes
Desc: Message signed with OpenPGP using GPGMail
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20130922/7b2dd9a8/attachment-0001.pgp>

------------------------------

Message: 4
Date: Sun, 22 Sep 2013 19:33:20 +0100
From: Michael Klishin <michael at rabbitmq.com>
Subject: Re: [rabbitmq-discuss] federate the unnamed queue?
To: Discussions about RabbitMQ <rabbitmq-discuss at lists.rabbitmq.com>
Message-ID: <3E151093-B43C-4B67-91B8-B5DC40A66711 at rabbitmq.com>
Content-Type: text/plain; charset="iso-8859-1"

Greg,

On sep 22, 2013, at 3:47 p.m., Greg Roy <gj.roy75 at gmail.com> wrote:

> I would like to federate all messages to the default unnamed queue - is this possible?

It's the default exchange that is "unnamed" (clients specify an empty string to refer to it).
Queue federation will be supposed in the next release (3.2). Are you talking about
exchanges?

>  I have tried variations of pattern matching nothing, but believe I'll need to alter my publishing behaviour.

It should be possible to federate any exchange, as far as I know. Can you post some specific
federation configuration examples and you code, and explain what your queues and bindings
setup is?

MK

-------------- next part --------------
A non-text attachment was scrubbed...
Name: signature.asc
Type: application/pgp-signature
Size: 495 bytes
Desc: Message signed with OpenPGP using GPGMail
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20130922/c4af5071/attachment-0001.pgp>

------------------------------

Message: 5
Date: Sun, 22 Sep 2013 14:47:50 -0500
From: Alvaro Videla <videlalvaro at gmail.com>
Subject: Re: [rabbitmq-discuss] federate the unnamed queue?
To: Discussions about RabbitMQ <rabbitmq-discuss at lists.rabbitmq.com>
Message-ID:
	<CAMcAHLXy=RSE9=L=8rr9HS4sGJtZj4eGwDqSOwFpTXLtVq_87A at mail.gmail.com>
Content-Type: text/plain; charset="iso-8859-1"

Hi,

If by "unnamed queue" you mean the default exchange with no name, then no,
you can't federate that exchange.

Regards,

Alvaro

On Sun, Sep 22, 2013 at 9:47 AM, Greg Roy <gj.roy75 at gmail.com> wrote:

> Hello All,
>
> I would like to federate all messages to the default unnamed queue - is
> this possible?  I have tried variations of pattern matching nothing, but
> believe I'll need to alter my publishing behaviour.  True or false?
>
> Thanks in advance,
>
> Greg
>
> _______________________________________________
> rabbitmq-discuss mailing list
> rabbitmq-discuss at lists.rabbitmq.com
> https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
>
>
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20130922/9f82ec8f/attachment-0001.htm>

------------------------------

Message: 6
Date: Sun, 22 Sep 2013 14:59:19 -0500
From: Alvaro Videla <videlalvaro at gmail.com>
Subject: Re: [rabbitmq-discuss] Producer consumer in background on a
	web	server
To: Discussions about RabbitMQ <rabbitmq-discuss at lists.rabbitmq.com>
Message-ID:
	<CAMcAHLVv+65CpZ_eZwLn1b=fd_+dfawHXOB_gWERnkfURu6TXg at mail.gmail.com>
Content-Type: text/plain; charset="iso-8859-1"

Hi

On Sun, Sep 22, 2013 at 6:34 AM, tyger2007 at yahoo.com <tyger2007 at yahoo.com>wrote:

> how do I make my php consumers work without running them on a command-line
> to listen to producer messages ?

What do you mean by this? You can just run the PHP consumer directly on the
webserver process, although I wouldn't recommend doing that since you would
end up blocking all the server threads.

Is there a reason why you don't want to run the consumer from the command
line directly?

Regards,

Alvaro
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20130922/1934f66e/attachment-0001.htm>

------------------------------

Message: 7
Date: Mon, 23 Sep 2013 02:23:27 -0400
From: "Jain, Punit" <Punit.Jain at emc.com>
Subject: Re: [rabbitmq-discuss] Federation setup query
To: Simon MacMullen <simon at rabbitmq.com>
Cc: Discussions about RabbitMQ <rabbitmq-discuss at lists.rabbitmq.com>
Message-ID:
	<DB14E94115BBC84E8960C12C176D06760127ECAD05 at MX25A.corp.emc.com>
Content-Type: text/plain; charset="us-ascii"

> -----Original Message-----
> From: Simon MacMullen [mailto:simon at rabbitmq.com]
> Sent: Friday, September 20, 2013 9:22 PM
> To: Jain, Punit
> Cc: Discussions about RabbitMQ
> Subject: Re: [rabbitmq-discuss] Federation setup query
> 
> On 20/09/2013 1:26PM, Jain, Punit wrote:
> > Hi, We are using federation setup with two URIs defined in an
> > upstream, as suggested by you. I simulated link failure by closing one
> > of the Ethernet port. I observed that it takes around 15-20 minutes to
> > switch link. Why is it taking this much time? Is there a way I can
> > decrease the switch time?
> 
> It should switch as soon as the "old" AMQP connection goes down - so check
> your heartbeat settings.
> 

I think it was set to default value which is 600. I changed it to 30 seconds on upstream.
Now it detects the failure in around a minute and changes the link.

> > One more question: on the same setup, I stopped RabbitMQ server on
> > downstream and started it after few seconds. Sometimes the messages
> > published to upstream exchange during that duration are lost. Though,
> > they were present in the upstream queue during that period, but lost
> > after the downstream broker was started.
> 
> Hmm.
> 
> Of course that shouldn't be happening. How do you know they are lost? In
> particular, it's possible for the downstream bindings to change while a link is
> down, in which case messages can be queued on the upstream, then when the
> link comes back they get transferred over and then dropped.
> Could something like that be happening? The tracer might be helpful to see if
> these messages are indeed getting published downstream.
>

This behavior was observed when both links were up, but we just stopped and started the downstream broker. 
Bindings were not changed, there was only one queue listening to downstream stream with '#' routing key.
I will use tracer when I observe this next time.

Thank you, Simon.

> Cheers, Simon
> 
> --
> Simon MacMullen
> RabbitMQ, Pivotal

------------------------------

Message: 8
Date: Mon, 23 Sep 2013 09:41:23 +0100
From: Simon MacMullen <simon at rabbitmq.com>
Subject: Re: [rabbitmq-discuss] Questiong about plugins and clustering
To: Discussions about RabbitMQ <rabbitmq-discuss at lists.rabbitmq.com>
Message-ID: <523FFEB3.9050109 at rabbitmq.com>
Content-Type: text/plain; charset=ISO-8859-1; format=flowed

On 21/09/2013 02:53, Alvaro Videla wrote:
> Is there a way for a plugin to know when a node joins or leaves the
> cluster?

No, not at the moment. Currently we just ask Mnesia whenever we need to 
know.

> Is there any notification that can be received by my plugin about this
> event happening or I need to poll Mnesia once in a while?

Well, you can invoke rabbit_mnesia:cluster_nodes(running) or 
rabbit_mnesia:cluster_nodes(all) or whatever.

> I see there's rabbit_node_monitor:notify_joined_cluster/0 but that's
> doesn't seem to help me.

No, that's the other way round - used to tell the node monitor that a 
node has joined.

What are you trying to do?

Cheers, Simon

------------------------------

Message: 9
Date: Mon, 23 Sep 2013 10:01:39 +0100
From: Simon MacMullen <simon at rabbitmq.com>
Subject: Re: [rabbitmq-discuss] federate the unnamed queue?
To: Discussions about RabbitMQ <rabbitmq-discuss at lists.rabbitmq.com>
Cc: Greg Roy <gj.roy75 at gmail.com>
Message-ID: <52400373.5080005 at rabbitmq.com>
Content-Type: text/plain; charset=ISO-8859-1; format=flowed

On 22/09/2013 19:33, Michael Klishin wrote:
> It should be possible to federate any exchange, as far as I know.

As Alvaro pointed out, it's any exchange other than the default exchange 
(since the "default exchange" really just means "publish to queue").

I'll update the documentation to make this clearer.

Cheers, Simon

------------------------------

Message: 10
Date: Mon, 23 Sep 2013 10:04:51 +0100
From: Simon MacMullen <simon at rabbitmq.com>
Subject: Re: [rabbitmq-discuss] Troubleshooting RabbitMQ
To: Discussions about RabbitMQ <rabbitmq-discuss at lists.rabbitmq.com>
Cc: Sukhjeet Singh <princu.chana at gmail.com>
Message-ID: <52400433.1060904 at rabbitmq.com>
Content-Type: text/plain; charset=ISO-8859-1; format=flowed

On 22/09/2013 12:39, Sukhjeet Singh wrote:
> Actually, the problem is that createConnection() method is throwing an
> exception and the exception is "BrokerUnreachableException was Unhandled".

The clue's in the name. The broker was not reachable. Catch the 
exception to find out more, but I would bet that you haven't pointed the 
ConnectionFactory at the broker.

Cheers, Simon

------------------------------

Message: 11
Date: Mon, 23 Sep 2013 10:06:36 +0100
From: Emile Joubert <emile at rabbitmq.com>
Subject: Re: [rabbitmq-discuss] Questiong about plugins and clustering
To: Discussions about RabbitMQ <rabbitmq-discuss at lists.rabbitmq.com>
Message-ID: <5240049C.4060204 at rabbitmq.com>
Content-Type: text/plain; charset=ISO-8859-1

Hi Alvaro,

On 21/09/13 02:53, Alvaro Videla wrote:

> Is there a way for a plugin to know when a node joins or leaves the
> cluster? 

A plugin could subscribe to Mnesia system events that will report when
Mnesia stops and starts on nodes:
 http://www.erlang.org/doc/apps/mnesia/Mnesia_chap5.html#id76679

Depending on the kind of plugin you are writing you could use the
information sent to the log exchange (amq.rabbitmq.log) to determine
when nodes leave and join.

-Emile

------------------------------

Message: 12
Date: Mon, 23 Sep 2013 10:16:53 +0100
From: Matthias Radestock <matthias at rabbitmq.com>
Subject: Re: [rabbitmq-discuss] How do the Producer gets response from
	the subscribers
To: Discussions about RabbitMQ <rabbitmq-discuss at lists.rabbitmq.com>
Cc: ramkkk <mramu789 at gmail.com>
Message-ID: <52400705.3000600 at rabbitmq.com>
Content-Type: text/plain; charset=ISO-8859-1; format=flowed

On 19/09/13 13:15, ramkkk wrote:
> Producer the sends a command to the consumer  to spawn the process . so each
> consumer has to give the response back to the Producer ..
>
>   but i am not getting the response back to the Producer, consumer is going
> on the infinite loop...
> [...]
> consumer code
> [...]
>      def on_request(self,ch, method, props, body):
>          self.spawn_processes(2)
>          self.response = [process.pid for process in self.spawned_processes]
>          ch.basic_publish(exchange='logs',
>                       routing_key='',
>                       properties=pika.BasicProperties(correlation_id = \
>                                                       props.correlation_id,
>                                                       delivery_mode=2 ,
>                                                       ),
>
>                       body=str(self.response))
>          ch.basic_ack(delivery_tag = method.delivery_tag)

The consumer is publishing the response to the 'logs' exchange with a '' 
routing key, whereas...

> Producer
> [...]
>      def __init__(self):
>          self.connection = pika.BlockingConnection(pika.ConnectionParameters(
>                  host='localhost'))
>          self.channel = self.connection.channel()
>          self.channel.exchange_declare(exchange='logs',
>                           type='fanout')
>          result = self.channel.queue_declare(exclusive=True)
>          self.callback_queue = result.method.queue
>
>          self.channel.basic_qos(prefetch_count=1)
>          self.channel.basic_consume(self.on_response, no_ack=True,
>                                     queue=self.callback_queue)

...the producer is expecting replies on an exclusive, server-named queue.

Clearly that isn't going to work. And because the 'logs' exchange is 
also the exchange on which the consumer queue is bound you end up with 
the 'infinite loop' at the consumer since the response published by the 
consumer will be consumed by the consumer!

You need to change your consumer to publish the response to the default 
exchange ('') with the routing_key taken from props.reply_to of the request.

Matthias.

------------------------------

_______________________________________________
rabbitmq-discuss mailing list
rabbitmq-discuss at lists.rabbitmq.com
https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss

End of rabbitmq-discuss Digest, Vol 76, Issue 24
************************************************
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20130923/16da1935/attachment.html>

------------------------------

Message: 3
Date: Mon, 23 Sep 2013 10:56:39 +0100
From: Michael Klishin <michael.s.klishin at gmail.com>
Subject: Re: [rabbitmq-discuss] consumer in background
To: Discussions about RabbitMQ <rabbitmq-discuss at lists.rabbitmq.com>
Message-ID:
	<CAE3HoVTd6rw8t0y9EwqxaNftLCno_4ZtSHRCDuYfOB+1QwO=Pw at mail.gmail.com>
Content-Type: text/plain; charset="utf-8"

2013/9/23 tyger2007 at yahoo.com <tyger2007 at yahoo.com>

> Thanks alvaro like I said this concept is totally new to me , however I
> would like to know if the consumers would run stand alone , that is apart
> from the web server ? ,

Yes. PHP environment is reset between requests, this does not work very
well with
long-running network connections.

> if that is the case does it mean I would have to keep my command line open
> always on my servers?

Just run the process in the background (daemonized).
-- 
MK

http://github.com/michaelklishin
http://twitter.com/michaelklishin
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20130923/c2f11c8a/attachment-0001.htm>

------------------------------

Message: 4
Date: Mon, 23 Sep 2013 03:00:05 -0700 (PDT)
From: Haster <haster2004 at yandex.ru>
Subject: [rabbitmq-discuss] Many consumers on 1 queue. What algorithm
	RabbitMQ use to send messages?
To: rabbitmq-discuss at lists.rabbitmq.com
Message-ID: <1379930405578-29831.post at n5.nabble.com>
Content-Type: text/plain; charset=us-ascii

Hi there!

For example, I have 3 consumers on 1 queue.
If I set prefetch_count = 1, then server will use round-robin algorithm:
1st message to consumer1
2nd message to consumer2
3rd message to consumer3
4th message to consumer1 and so on.

But how does strategy changes when prefetch_count !=1? (for example 10)
Will server push 10 messages to consumer1, next 10 to 2 and so on?

And if prefetch_count = 1 but 1st consumer has already processed his
message? Will server send new message again to consumer1? Or in any cases
next message will be sent to consumer2?

--
View this message in context: http://rabbitmq.1065348.n5.nabble.com/Many-consumers-on-1-queue-What-algorithm-RabbitMQ-use-to-send-messages-tp29831.html
Sent from the RabbitMQ mailing list archive at Nabble.com.

------------------------------

Message: 5
Date: Mon, 23 Sep 2013 11:05:23 +0100
From: Michael Klishin <michael.s.klishin at gmail.com>
Subject: Re: [rabbitmq-discuss] Many consumers on 1 queue. What
	algorithm RabbitMQ use to send messages?
To: Discussions about RabbitMQ <rabbitmq-discuss at lists.rabbitmq.com>
Message-ID:
	<CAE3HoVQJwwDw_rgCiyQpK2+OKyyAcWdM5=fZFD26NA-5aZ5zJA at mail.gmail.com>
Content-Type: text/plain; charset="utf-8"

2013/9/23 Haster <haster2004 at yandex.ru>

>
> And if prefetch_count = 1 but 1st consumer has already processed his
> message? Will server send new message again to consumer1? Or in any cases
> next message will be sent to consumer2?

It's round robin between consumers that haven't gone above the basic.qos
setting
for their channel. With prefetch > 1 it's just harder to see because you
have more
messages in flight.
-- 
MK

http://github.com/michaelklishin
http://twitter.com/michaelklishin
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20130923/af6240a6/attachment-0001.htm>

------------------------------

Message: 6
Date: Mon, 23 Sep 2013 11:20:42 +0100
From: Mike Hadlow <mike at suteki.co.uk>
Subject: [rabbitmq-discuss] Channel best practices
To: RabbitMQ Discuss <rabbitmq-discuss at lists.rabbitmq.com>
Message-ID:
	<CAAc6ZR-WMup1miiMuLQTEsCLpe+v3Nzc8yZfYQNi+N0vuMdTfA at mail.gmail.com>
Content-Type: text/plain; charset="iso-8859-1"

Hi All,

Are channel best practices for connected RabbitMQ clients published
anywhere? I understand the threading limitations, that channels should not
be shared between threads. Does the channel concept exist only to support
multi-threaded applications, or does it have some other purpose?

If I marshal all calls to a channel onto a single thread in my application
code, is there any problem with simply maintaining a single channel for all
declares, publishes and consumes?

Additional questions:

1. Should each basic consume be invoked on a dedicated channel?

2. Do I need to basic.ack on the same channel on which I invoked
basic.consume?

Many thanks
Mike
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20130923/a05cd176/attachment-0001.htm>

------------------------------

Message: 7
Date: Mon, 23 Sep 2013 11:24:33 +0100
From: Simon MacMullen <simon at rabbitmq.com>
Subject: Re: [rabbitmq-discuss] Rabbitmq 3.1.5 version facing issues.
	urgent issue ..
To: Discussions about RabbitMQ <rabbitmq-discuss at lists.rabbitmq.com>
Cc: sagu prf <sagu.prf1 at gmail.com>
Message-ID: <524016E1.50205 at rabbitmq.com>
Content-Type: text/plain; charset=ISO-8859-1; format=flowed

On 22/09/13 02:46, sagu prf wrote:
> I am getting following error ..please correct me what is wrong with
> above file and it was created while enabling rabbitmq-plugins enable
> plugin-name,

Yes, rabbitmq_jsonrpc_channel is broken in 3.1.5 I'm afraid. It will be 
fixed in the next release.

Cheers, Simon

-- 
Simon MacMullen
RabbitMQ, Pivotal

------------------------------

Message: 8
Date: Mon, 23 Sep 2013 11:33:00 +0100
From: Michael Klishin <michael.s.klishin at gmail.com>
Subject: Re: [rabbitmq-discuss] Channel best practices
To: Discussions about RabbitMQ <rabbitmq-discuss at lists.rabbitmq.com>
Message-ID:
	<CAE3HoVSCtkQ3BGS6mZQeykVFZ+kGxAsEA79kh1WjonaBg-DJ=g at mail.gmail.com>
Content-Type: text/plain; charset="utf-8"

2013/9/23 Mike Hadlow <mike at suteki.co.uk>

> Does the channel concept exist only to support multi-threaded
> applications, or does it have some other purpose?
>

It was added to avoid having N TCP connections from the same client in case
it needs to have multiple logical connections.

> If I marshal all calls to a channel onto a single thread in my application
> code, is there any problem with simply maintaining a single channel for all
> declares, publishes and consumes?
>

Should be fine.

>
> Additional questions:
>
> 1. Should each basic consume be invoked on a dedicated channel?
>

If you want to have N consumers from the same OS process, it's not strictly
necessary.

> 2. Do I need to basic.ack on the same channel on which I invoked
> basic.consume?
>

You must ack/nack/reject on the same channel the delivery was on because
delivery_tag is
scoped per channel.

A good reason to use more than one channel is error handling, which in many
cases is per-channel.
For example, if you expect an exception for one operation that you can
recover from, you can use
a separate channel to make sure the connection closure caused by the
exception does not affect other operations in the same VM.
-- 
MK

http://github.com/michaelklishin
http://twitter.com/michaelklishin
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20130923/af810d83/attachment-0001.htm>

------------------------------

Message: 9
Date: Mon, 23 Sep 2013 11:33:56 +0100
From: Simon MacMullen <simon at rabbitmq.com>
Subject: Re: [rabbitmq-discuss] clustered ram node loosing its
	membership without being reset
To: Discussions about RabbitMQ <rabbitmq-discuss at lists.rabbitmq.com>
Message-ID: <52401914.2030206 at rabbitmq.com>
Content-Type: text/plain; charset=ISO-8859-1; format=flowed

On 20/09/13 18:24, Sigismondo Boschi wrote:
> IMHO a more reasonable behavior would be that node02, when started with
> node01 being down, not being able to find any reference peer, and being
> ram based, should just fail.

> Can you confirm this is a bug, or if the intended behavior, what is the
> rationale?

No, it's a bug. I'm sure it used to work the way you describe.

Cheers, Simon

-- 
Simon MacMullen
RabbitMQ, Pivotal

------------------------------

Message: 10
Date: Mon, 23 Sep 2013 11:40:06 +0100
From: Tim Watson <tim at rabbitmq.com>
Subject: Re: [rabbitmq-discuss] Channel best practices
To: Discussions about RabbitMQ <rabbitmq-discuss at lists.rabbitmq.com>
Message-ID: <3CB93AD8-8875-4E45-BAB9-2F3F348E8730 at rabbitmq.com>
Content-Type: text/plain; charset=iso-8859-1

On 23 Sep 2013, at 11:20, Mike Hadlow wrote:

> Hi All,
> 
> Are channel best practices for connected RabbitMQ clients published anywhere? I understand the threading limitations, that channels should not be shared between threads. Does the channel concept exist only to support multi-threaded applications, or does it have some other purpose?
> 

The channel concept exists (in AMQP) to provide a lightweight alternative to having one TCP connection per client, since the latter are resource intensive (to both client and server's detriment). Multiplexing multiple "clients" over a single TCP connection turns out to be a fairly common approach amongst network intensive applications. Channels also provide a unit of atomicity with regards message ordering, i.e., messages are always fully (FIFO) ordered from client to server over a single channel, whereas there are no ordering guarantees regarding messages concurrently sent (or delivered) over multiple channels.

> If I marshal all calls to a channel onto a single thread in my application code, is there any problem with simply maintaining a single channel for all declares, publishes and consumes?
> 

One problem you might run into relates to the answer I've given below about correlating ACKs with the correct channel.

> Additional questions:
> 
> 1. Should each basic consume be invoked on a dedicated channel?
> 

That's not strictly necessary, though neither is it wrong. Depending on your application logic, you might find that introduces unnecessary overhead (in terms of threads and associated synchronisation primitives used in the client and/or additional resource use on the server), so if I were you I would only do it if it is (a) necessary or (b) significantly simplifies your client code. Remember that a channel provides a FIFO ordering guarantee, so having multiple consumers on a single channel means that you're potentially dealing with messages from more than one source queue, in which case you might inadvertently introduce a serial bottleneck. 

> 2. Do I need to basic.ack on the same channel on which I invoked basic.consume?
> 

Yes, that is absolutely necessary. An ACK sent on another channel to the one on which the delivery was received will be treated as a channel error.

Cheers,
Tim

------------------------------

Message: 11
Date: Mon, 23 Sep 2013 11:55:55 +0100
From: Simon MacMullen <simon at rabbitmq.com>
Subject: Re: [rabbitmq-discuss] Fine-grained LDAP access to resources
To: Discussions about RabbitMQ <rabbitmq-discuss at lists.rabbitmq.com>
Message-ID: <52401E3B.6060906 at rabbitmq.com>
Content-Type: text/plain; charset=ISO-8859-1; format=flowed

On 20/09/13 22:35, James McClelland wrote:
> I'm wondering if there's some way I could get functionality similar to
> {in_group, CN=rmq-${vhost}-${prefix}-queue} where ${prefix} is the first
> token in a period delimited string.

That doesn't exist at the moment, no.

Hmm, we almost want some equivalent of the JSP-EL there. Oh god, another 
mini-language...

Cheers, Simon

-- 
Simon MacMullen
RabbitMQ, Pivotal

------------------------------

Message: 12
Date: Mon, 23 Sep 2013 12:18:55 +0100
From: Mike Hadlow <mike at suteki.co.uk>
Subject: Re: [rabbitmq-discuss] Channel best practices
To: Discussions about RabbitMQ <rabbitmq-discuss at lists.rabbitmq.com>
Message-ID:
	<CAAc6ZR_EPYZVDSpxND2qMy2Rqdi=q_6kHMm_qZRLrUzo1Hc_oA at mail.gmail.com>
Content-Type: text/plain; charset="iso-8859-1"

Thanks Michael, Tim. great answers.

One more channel question:

You shouldn't share a channel between multiple threads, but given that an
ACK should be sent on the same channel that the delivery is received mean
that one _must_ violate this rule? I call basic.consume on my application
thread, but basic.deliver will be called on the client library's internal
message loop thread and then the ACK will no doubt be called on a separate
application thread (where I de-queue the message from my queuing consumer).
Is this violation of the do-not-use-channels-on-multiple-threads rule OK?

Thanks
Mike

On Mon, Sep 23, 2013 at 11:40 AM, Tim Watson <tim at rabbitmq.com> wrote:

>
> On 23 Sep 2013, at 11:20, Mike Hadlow wrote:
>
> > Hi All,
> >
> > Are channel best practices for connected RabbitMQ clients published
> anywhere? I understand the threading limitations, that channels should not
> be shared between threads. Does the channel concept exist only to support
> multi-threaded applications, or does it have some other purpose?
> >
>
> The channel concept exists (in AMQP) to provide a lightweight alternative
> to having one TCP connection per client, since the latter are resource
> intensive (to both client and server's detriment). Multiplexing multiple
> "clients" over a single TCP connection turns out to be a fairly common
> approach amongst network intensive applications. Channels also provide a
> unit of atomicity with regards message ordering, i.e., messages are always
> fully (FIFO) ordered from client to server over a single channel, whereas
> there are no ordering guarantees regarding messages concurrently sent (or
> delivered) over multiple channels.
>
> > If I marshal all calls to a channel onto a single thread in my
> application code, is there any problem with simply maintaining a single
> channel for all declares, publishes and consumes?
> >
>
> One problem you might run into relates to the answer I've given below
> about correlating ACKs with the correct channel.
>
> > Additional questions:
> >
> > 1. Should each basic consume be invoked on a dedicated channel?
> >
>
> That's not strictly necessary, though neither is it wrong. Depending on
> your application logic, you might find that introduces unnecessary overhead
> (in terms of threads and associated synchronisation primitives used in the
> client and/or additional resource use on the server), so if I were you I
> would only do it if it is (a) necessary or (b) significantly simplifies
> your client code. Remember that a channel provides a FIFO ordering
> guarantee, so having multiple consumers on a single channel means that
> you're potentially dealing with messages from more than one source queue,
> in which case you might inadvertently introduce a serial bottleneck.
>
> > 2. Do I need to basic.ack on the same channel on which I invoked
> basic.consume?
> >
>
> Yes, that is absolutely necessary. An ACK sent on another channel to the
> one on which the delivery was received will be treated as a channel error.
>
> Cheers,
> Tim
> _______________________________________________
> rabbitmq-discuss mailing list
> rabbitmq-discuss at lists.rabbitmq.com
> https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
>
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20130923/3bc0b6ca/attachment-0001.htm>

------------------------------

Message: 13
Date: Mon, 23 Sep 2013 12:35:32 +0100
From: Michael Klishin <michael.s.klishin at gmail.com>
Subject: Re: [rabbitmq-discuss] Channel best practices
To: Discussions about RabbitMQ <rabbitmq-discuss at lists.rabbitmq.com>
Message-ID:
	<CAE3HoVSNBRsN_Tv+kASYFMRgf178wo-ZwjJP2i_DaZ-P=TK2Zg at mail.gmail.com>
Content-Type: text/plain; charset="utf-8"

2013/9/23 Mike Hadlow <mike at suteki.co.uk>

> You shouldn't share a channel between multiple threads, but given that an
> ACK should be sent on the same channel that the delivery is received mean
> that one _must_ violate this rule?

If you run one consumer per thread, use a new channel for every one of them.
-- 
MK

http://github.com/michaelklishin
http://twitter.com/michaelklishin
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20130923/0422f41f/attachment-0001.htm>

------------------------------

Message: 14
Date: Mon, 23 Sep 2013 14:26:51 +0200
From: David Tinker <david.tinker at gmail.com>
Subject: [rabbitmq-discuss] ANN QDB 0.5.0 released
To: Discussions about RabbitMQ <rabbitmq-discuss at lists.rabbitmq.com>
Message-ID:
	<CA+O6_FdJXD2vWk3tLN+AnVnxg6ZL=1=GyH2y8B4_Zn9m_HOWqg at mail.gmail.com>
Content-Type: text/plain; charset=ISO-8859-1

http://qdb.io/

This version adds filtering on routing key and/or grep on the message
body. Filtering is available on the list messages endpoint and
outputs.

# Fetch messages containing a line starting with a number
# The -g option to curl stops it from messing with [] and {}
# The %2b is the + character url encoded
$ curl -g "http://127.0.0.1:9554/q/incoming/messages?grep=^[0-9]%2b"

# Fetch messages with routingKey matching a RabbitMQ expression
# The hash (#) must be url encoded as %23
$ curl "http://127.0.0.1:9554/q/incoming/messages?routingKey=foo.*.%23"

# Fetch messages with routingKey matching a Java regular expression
$ curl -g "http://127.0.0.1:9554/q/incoming/messages?routingKey=/^[0-9]%2b/"

Some output examples:

# Output messages from 10h20 today containing a line starting with a number
# The %2b is the + character url encoded
$ curl http://127.0.0.1:9554/q/foo/out/rabbit -d from=10:20 -d grep=^[0-9]%2b

# Output messages with routingKey matching a RabbitMQ expression
$ curl http://127.0.0.1:9554/q/foo/out/rabbit -d "routingKey=foo.*"

# Fetch messages with routingKey matching a Java regular expression
$ curl http://127.0.0.1:9554/q/foo/out/rabbit -d "routingKey=/^[0-9]%2b/"

Cheers
David

http://qdb.io/ Persistent Message Queues With Replay and #RabbitMQ Integration

------------------------------

Message: 15
Date: Mon, 23 Sep 2013 07:56:26 -0500
From: Alvaro Videla <videlalvaro at gmail.com>
Subject: Re: [rabbitmq-discuss] Questiong about plugins and clustering
To: Simon MacMullen <simon at rabbitmq.com>
Cc: Discussions about RabbitMQ <rabbitmq-discuss at lists.rabbitmq.com>
Message-ID:
	<CAMcAHLUiks7r0geYjpAGMX7D6FRNUpSzv7qBVoEk3pFOX9FRiw at mail.gmail.com>
Content-Type: text/plain; charset="iso-8859-1"

On Mon, Sep 23, 2013 at 3:41 AM, Simon MacMullen <simon at rabbitmq.com> wrote:

> What are you trying to do?
>

I want to have a plugin that works with a concept of topics and partitioned
queues. What does this mean?

I want to create a topic called "my_topic" which implies having a
consistent hash exchange (CHE) called "my_topic" + one queue called
"node_name.my_topic" bound to the my_topic exchange. The queue message
contents should live in the "node_name" node.

Whenever a node joins the cluster, I want to automatically declare a queue
called "new_node.my_topic" and bind it to the "my_topic" CHE. That queue
will be declared on new_node, so the message contents would end up in that
node.

With this I want to achieve some sort of "partitioned queues".

I plan this plugin to be an extension to the management plugin, so one
would create one of these topics via an HTTP call.

Also when connecting to a broker, one could ask this plugin via HTTP to
send the proper queue name for a particular topic, in order to consume from
it.

Does this makes sense?
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20130923/011dcd5f/attachment-0001.htm>

------------------------------

Message: 16
Date: Mon, 23 Sep 2013 07:18:08 -0700
From: "James M." <jamesmcc at gmail.com>
Subject: Re: [rabbitmq-discuss] Fine-grained LDAP access to resources
To: rabbitmq-discuss at lists.rabbitmq.com
Message-ID:
	<CAPDfD5E2+6D0W-NtQ8Xa7rooO-wze+ZAh2ECzG9SF=WF=jO9Pg at mail.gmail.com>
Content-Type: text/plain; charset="iso-8859-1"

On Mon, Sep 23, 2013 at 3:55 AM, Simon MacMullen <simon at rabbitmq.com> wrote:

> That doesn't exist at the moment, no.
>
> Hmm, we almost want some equivalent of the JSP-EL there. Oh god, another
> mini-language...
>

Thanks for the clarification Simon. This feature would be a huge benefit
for us. The way it stands now, if someone wants access isolation within a
vhost, we have to spin up a new vhost and then create shovels if they need
to intercommunicate.

I took a shot at modifying and compiling the ldap plugin and came up with a
seemingly working solution. I'm just getting my feet wet with Erlang but
does this have any glaring issues at first glance? I'm basically adding a
new derived value to the Args list so that when it's sent to fill()
${prefix} is properly expanded.

https://gist.github.com/jmcle/2b91d991c9a163ec9d37/revisions

My follow up question would be, what are the chances of getting something
similar to this added to the official code base?

Thanks,
James
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20130923/0840e2f9/attachment-0001.htm>

------------------------------

Message: 17
Date: Mon, 23 Sep 2013 15:52:09 +0100
From: Mike Hadlow <mike at suteki.co.uk>
Subject: Re: [rabbitmq-discuss] Channel best practices
To: Discussions about RabbitMQ <rabbitmq-discuss at lists.rabbitmq.com>
Message-ID:
	<CAAc6ZR9fWofRsS9oh1-tjiWXJrY_KiHbBdqh3vcEDxZT=X0Pyw at mail.gmail.com>
Content-Type: text/plain; charset="iso-8859-1"

Hi Michael, Tim,

I've put your comments into a blog post:
http://mikehadlow.blogspot.co.uk/2013/09/rabbitmq-amqp-channel-best-practices.html
.

Let me know if there's anything you'd like to add/change/remove.

Many thanks
Mike

On Mon, Sep 23, 2013 at 12:35 PM, Michael Klishin <
michael.s.klishin at gmail.com> wrote:

>
> 2013/9/23 Mike Hadlow <mike at suteki.co.uk>
>
>> You shouldn't share a channel between multiple threads, but given that an
>> ACK should be sent on the same channel that the delivery is received mean
>> that one _must_ violate this rule?
>
>
> If you run one consumer per thread, use a new channel for every one of
> them.
> --
> MK
>
> http://github.com/michaelklishin
> http://twitter.com/michaelklishin
>
> _______________________________________________
> rabbitmq-discuss mailing list
> rabbitmq-discuss at lists.rabbitmq.com
> https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
>
>
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20130923/19510527/attachment-0001.htm>

------------------------------

Message: 18
Date: Mon, 23 Sep 2013 10:59:49 -0400
From: Fred Dushin <fred at dushin.net>
Subject: [rabbitmq-discuss] AMQP URIs do not support
	connection_timeout?
To: "rabbitmq-discuss at lists.rabbitmq.com"
	<rabbitmq-discuss at lists.rabbitmq.com>
Message-ID: <2C43E142-1836-48A4-BA00-273643BB1133 at dushin.net>
Content-Type: text/plain;	charset=us-ascii

Hi folks,

I was wondering why we don't support the connection_timeout amqp_params_network parameter in the amqp_uri:parse functions.

It seems to boil down to:

parse_amqp_param(Field, String) when Field =:= channel_max orelse
                                  Field =:= frame_max   orelse
                                  Field =:= heartbeat   ->
 try return(list_to_integer(String))
 catch error:badarg -> fail({not_an_integer, String})
 end;
parse_amqp_param(Field, String) ->
 fail({parameter_unconfigurable_in_query, Field, String}).

Would it be possible to add connection_timeout to the guard expression?

Thanks!

-Fred

------------------------------

Message: 19
Date: Mon, 23 Sep 2013 16:03:54 +0100
From: Simon MacMullen <simon at rabbitmq.com>
Subject: Re: [rabbitmq-discuss] AMQP URIs do not support
	connection_timeout?
To: Discussions about RabbitMQ <rabbitmq-discuss at lists.rabbitmq.com>
Message-ID: <5240585A.8040008 at rabbitmq.com>
Content-Type: text/plain; charset=ISO-8859-1; format=flowed

On 23/09/13 15:59, Fred Dushin wrote:
> Hi folks,
>
> I was wondering why we don't support the connection_timeout
> amqp_params_network parameter in the amqp_uri:parse functions.

Probably an oversight, good point. Will fix...

Cheers, Simon

-- 
Simon MacMullen
RabbitMQ, Pivotal

------------------------------

Message: 20
Date: Mon, 23 Sep 2013 16:06:17 +0100
From: Simon MacMullen <simon at rabbitmq.com>
Subject: Re: [rabbitmq-discuss] Troubleshooting RabbitMQ
To: Sukhjeet Singh <princu.chana at gmail.com>
Cc: rabbitmq-discuss <rabbitmq-discuss at lists.rabbitmq.com>
Message-ID: <524058E9.1090404 at rabbitmq.com>
Content-Type: text/plain; charset=ISO-8859-1; format=flowed

Please keep rabbitmq-discuss on CC.

On 23/09/13 15:59, Sukhjeet Singh wrote:
> that problem has been solved . I was using user name and password from
> my side which were not required. Now, I have an another problem. How can
> we use rabbitmq in multiple users ? I mean to say what approach I should
> take to solve the multiple users problem . I want to use rabbitmq to
> send and receive messsges in my website.

What do you mean by "use rabbitmq in multiple users"? You could have 
your application connect to the RabbitMQ broker with a single user and 
enforce permissions itself; many applications do this.

Or you could use RabbitMQ access control: see 
http://www.rabbitmq.com/access-control.html

Cheers, Simon

> On Mon, Sep 23, 2013 at 5:04 AM, Simon MacMullen <simon at rabbitmq.com
> <mailto:simon at rabbitmq.com>> wrote:
>
>     On 22/09/2013 12:39, Sukhjeet Singh wrote:
>
>         Actually, the problem is that createConnection() method is
>         throwing an
>         exception and the exception is "BrokerUnreachableException was
>         Unhandled".
>
>
>     The clue's in the name. The broker was not reachable. Catch the
>     exception to find out more, but I would bet that you haven't pointed
>     the ConnectionFactory at the broker.
>
>     Cheers, Simon
>
>

-- 
Simon MacMullen
RabbitMQ, Pivotal

------------------------------

Message: 21
Date: Mon, 23 Sep 2013 11:12:49 -0400
From: Chris <stuff at moesel.net>
Subject: Re: [rabbitmq-discuss] Can't Bind After Upgrading from 3.1.1
	to	3.1.5
To: Matthias Radestock <matthias at rabbitmq.com>
Cc: Discussions about RabbitMQ <rabbitmq-discuss at lists.rabbitmq.com>
Message-ID:
	<CAHEpgBAES6nuN2sZo0SvAFC1EE8G82veHLEhXRkwW+dtnaRgRQ at mail.gmail.com>
Content-Type: text/plain; charset="iso-8859-1"

Hi Matthias,

Thank you for your help!  I will send you the logs, screenshot, and report
privately in the next couple of hours.  If there are any other pivotal
folks who want me to send it to them too, please let me know!

-Chris

On Fri, Sep 20, 2013 at 5:23 PM, Matthias Radestock
<matthias at rabbitmq.com>wrote:

> Chris,
>
>
> On 20/09/13 22:00, Chris wrote:
>
>> I can try to get the logs.  Of course, during the upgrade nodes went up
>> and down...  So there could have been a time when the nodes the queue
>> was on were both down.  But this continued even after all nodes were
>> back up and the queue was recreated.
>>
>
> Right. I want to check the logs for anything unusual.
>
>
>  It is very reproducible now on this specific customer system (we haven't
>> yet resolved it there since I was hoping for an option that doesn't
>> include clearing mnesia or resetting the nodes).  So, yes, I can make
>> the binding fail all I want on that system.
>>
>
> In which case please post the output of 'rabbitmqctl report' from one of
> the nodes, and a screenshot of the management UI when you get the NOT_FOUND
> error.
>
> Regards,
>
> Matthias.
>
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20130923/543fb351/attachment-0001.htm>

------------------------------

Message: 22
Date: Mon, 23 Sep 2013 16:56:35 +0100
From: Simon MacMullen <simon at rabbitmq.com>
Subject: Re: [rabbitmq-discuss] Fine-grained LDAP access to resources
To: "James M." <jamesmcc at gmail.com>
Cc: rabbitmq-discuss at lists.rabbitmq.com
Message-ID: <524064B3.4040208 at rabbitmq.com>
Content-Type: text/plain; charset=ISO-8859-1; format=flowed

On 23/09/13 15:18, James M. wrote:
> I took a shot at modifying and compiling the ldap plugin and came up
> with a seemingly working solution. I'm just getting my feet wet with
> Erlang but does this have any glaring issues at first glance? I'm
> basically adding a new derived value to the Args list so that when it's
> sent to fill() ${prefix} is properly expanded.

Based on a quick look at the code, nothing is too wrong from a low level 
point of view. However, this is wrong:

case Predicate of
     true  -> Var = Something;
     false -> Var = SomethingElse
end,

since although Var happens to escape the inner scope in all cases, it's 
not very clear and modern Erlang compilers will complain. Instead you want:

Var = case Predicate of
           true  -> Something;
           false -> SomethingElse
       end,

> My follow up question would be, what are the chances of getting
> something similar to this added to the official code base?

However, I'd be reluctant to merge this; conceptually it's very specific 
to your use case - what if you want to match something other than up to 
the first '.'? What if you want to do that on something other than the 
resource name?

Really you want to be able to write something like ${name.prefix('.')}. 
That is (obviously) much more complicated though.

It's possible some half-way house could exist between these two 
extremes; if so I can't immediately think of it.

Cheers, Simon

-- 
Simon MacMullen
RabbitMQ, Pivotal

------------------------------

Message: 23
Date: Mon, 23 Sep 2013 17:01:56 +0100
From: Simon MacMullen <simon at rabbitmq.com>
Subject: Re: [rabbitmq-discuss] Fine-grained LDAP access to resources
To: Discussions about RabbitMQ <rabbitmq-discuss at lists.rabbitmq.com>
Message-ID: <524065F4.1050404 at rabbitmq.com>
Content-Type: text/plain; charset=ISO-8859-1; format=flowed

On 23/09/13 16:56, Simon MacMullen wrote:
> modern Erlang compilers will complain

No, I imagined that. They should though :-)

Cheers, Simon

-- 
Simon MacMullen
RabbitMQ, Pivotal

------------------------------

Message: 24
Date: Mon, 23 Sep 2013 18:46:21 +0200 (CEST)
From: "Ingo Knito" <Ingo.Knito79 at gmx.de>
Subject: [rabbitmq-discuss] Generated Message-ID in AMQP Header
To: rabbitmq-discuss at lists.rabbitmq.com
Message-ID:
	<trinity-aac81bd3-c891-43e0-badc-7c91cda13a21-1379954781345 at 3capp-gmx-bs56>

Content-Type: text/plain; charset="us-ascii"

An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20130923/47685113/attachment-0001.htm>

------------------------------

Message: 25
Date: Mon, 23 Sep 2013 10:17:06 -0700
From: "James M." <jamesmcc at gmail.com>
Subject: Re: [rabbitmq-discuss] Fine-grained LDAP access to resources
To: rabbitmq-discuss at lists.rabbitmq.com
Message-ID:
	<CAPDfD5HDnjZ2uV16ONQXVp9gqjrwzCer4zH4=LDaCqsA3qOYAA at mail.gmail.com>
Content-Type: text/plain; charset="iso-8859-1"

On Mon, Sep 23, 2013 at 8:58 AM, Simon MacMullen wrote:

> However, I'd be reluctant to merge this; conceptually it's very specific
to your use case - what if you want to match something other than up to the
first '.'? What if you want to do that on something other than the resource
name?

> No, I imagined that. They should though :-)
Thanks for the feedback. You're right, the compiler didn't complain but
your way does makes more sense. I've updated the gist to reflect the
changes if anyone is following along.

As for use case specificity, I can see your point. Although, I'm struggling
to come up with a case where you would want to use a tokenized version of
anything other than name. Assuming name is the only thing that makes sense
you could potentially have a new attribute called 'prefix_delimiter' which
would be sent to the tokens function. If you wanted to add more
customization there could be 'prefix_depth' as well which controlled how
many tokens were returned.

These would be global settings but they do have a parallel to the native
user permission regex matching which I think makes sense. Going inline with
the logic like you mentioned would be flexible but I'm not sure how helpful
it would be to have individual delimiters for different resource types.
Delimiters seem like they would be more of a global decision for the entire
broker once a proper group name convention was decided on.
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20130923/6c5995fc/attachment-0001.htm>

------------------------------

Message: 26
Date: Mon, 23 Sep 2013 12:59:00 -0500
From: Alvaro Videla <videlalvaro at gmail.com>
Subject: Re: [rabbitmq-discuss] Generated Message-ID in AMQP Header
To: Discussions about RabbitMQ <rabbitmq-discuss at lists.rabbitmq.com>
Message-ID:
	<CAMcAHLW3UU7qTgnvc=L7OHAMfvN+LmWqaU20mw7W8QsHgTSCTA at mail.gmail.com>
Content-Type: text/plain; charset="iso-8859-1"

Hi,

On Mon, Sep 23, 2013 at 11:46 AM, Ingo Knito <Ingo.Knito79 at gmx.de> wrote:

> So what I want is, that the rabbitMQ broker autogenerates and sets a
> (global) unique message-id for an incoming message at a certain exchange,
> but only if it is missing.
>

This is not possible at the moment. Also it will make RabbitMQ violate the
assumption that the broker is not modifying messages at all.

Regards,

Alvaro
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20130923/58da098a/attachment-0001.htm>

------------------------------

Message: 27
Date: Mon, 23 Sep 2013 12:12:57 -0700 (PDT)
From: Paul Bowsher <paul.bowsher at gmail.com>
Subject: [rabbitmq-discuss] Determining home node for queue
To: rabbitmq-discuss at googlegroups.com
Message-ID: <1073b2a0-3aa2-49a4-88b3-7e0b8ff2e463 at googlegroups.com>
Content-Type: text/plain; charset="utf-8"

Hi,

We currently run a two-node cluster with mirrored queues. We see a huge 
drop-off in throughput when our publishers or consumers connect to the 
non-home node for the queue. This was also confirmed outside of production 
with two fresh Vagrant VMs on both CentOS and Ubuntu, see 
gist https://gist.github.com/boffbowsh/6675281 and the Java Client 
MulticastMain example. Do others see this behaviour? We see this being 
easily mitigated by always connecting to the home node for the queue, and 
failing over if the home node goes down. However, we haven't yet been able 
to think of a nice clean way of ensuring clients always connect to this. We 
do have a dynamic LB at our disposal so we can create a sort of floating IP 
if that's easiest. 

Does anyone have any experience of this sort of setup in production, and 
can they provide any tips?

Many thanks,

Paul Bowsher
Senior Engineer
Globaldev
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20130923/5b377d1f/attachment-0001.htm>

------------------------------

Message: 28
Date: Mon, 23 Sep 2013 13:23:28 -0700 (PDT)
From: Haster <haster2004 at yandex.ru>
Subject: Re: [rabbitmq-discuss] Many consumers on 1 queue. What
	algorithm RabbitMQ use to send messages?
To: rabbitmq-discuss at lists.rabbitmq.com
Message-ID: <1379967808275-29855.post at n5.nabble.com>
Content-Type: text/plain; charset=us-ascii

michaelklishin, so there is no determine algorithm? 
And I can't found some formala for calculating which consumer will consume
n-message?

--
View this message in context: http://rabbitmq.1065348.n5.nabble.com/Many-consumers-on-1-queue-What-algorithm-RabbitMQ-use-to-send-messages-tp29831p29855.html
Sent from the RabbitMQ mailing list archive at Nabble.com.

------------------------------

Message: 29
Date: Mon, 23 Sep 2013 22:54:19 +0000
From: "Cordell, Ron" <Ron.Cordell at RelayHealth.com>
Subject: [rabbitmq-discuss] Cluster Recovery Modes
To: "rabbitmq-discuss at lists.rabbitmq.com"
	<rabbitmq-discuss at lists.rabbitmq.com>
Message-ID:
	<0B8CD6850421B745BE39BC5C760192327201D8CE at DDCEP50016.na.corp.mckesson.com>

Content-Type: text/plain; charset="us-ascii"

One of the cluster recovery configurations is "ignore":

  *   ignore - Your network really is reliable. All your nodes are in a rack, connected with a switch, and that switch is also the route to the outside world. You don't want to run any risk of any of your cluster shutting down if any other part of it fails (or you have a two node cluster).

Does this mode effectively turn off the heartbeat? Is a node detected as partitioned but nothing done?

Thanks,

Ron
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20130923/592f0c81/attachment-0001.htm>

------------------------------

Message: 30
Date: Mon, 23 Sep 2013 19:11:25 -0400
From: "Gavin M. Roy" <gavinmroy at gmail.com>
Subject: [rabbitmq-discuss] rabbitpy 0.5.0 released
To: rabbitmq-discuss <rabbitmq-discuss at lists.rabbitmq.com>
Message-ID:
	<CAPnH5kqhxEGF3jwXPZCBuCsN-6DoCmJvYb4UhARjZb6fEfLhCg at mail.gmail.com>
Content-Type: text/plain; charset="iso-8859-1"

rabbitpy 0.5.0, a minimalistic, thread-safe, pythonic RabbitMQ client
library is now available on pypi:

https://pypi.python.org/pypi/rabbitpy

Documentation is available at http://rabbitpy.readthedocs.org

*Highlights*

- Simple, blocking Pythonic API
- A thread-based connection and IO management system that properly supports
AMQP 0.9.1 server to client RPC semantics.
- Support for Python 2.6, 2.7, 3.2 and 3.3
- Support for the up-coming Connection.Blocked feature in RabbitMQ:
http://next.rabbitmq.com/connection-blocked.html

*Examples of Use*

A simple publisher for one-off message publishing:

    >>> rabbitpy.publish('amqp://guest:guest@localhost:5672/%2f',
                         exchange='test',
                         routing_key='example',
                         body='This is my test message',
                         properties={'content_type': 'text/plain'})

A simple consumer:

    >>> with rabbitpy.consume('amqp://guest:guest@localhost:5672/%2f',
'test') as c:
    ..    for message in c.next_message():
    ...         print message.properties['message_id']
    ...         print message.body
    ...         message.ack()
    ...
    856dfdc7-5ee3-4fc1-9635-977bf0043a9f
    {"foo": "bar"}

And a more complete consumer example:

    import rabbitpy
    with rabbitpy.Connection('amqp://guest:guest@localhost:5672/%2f') as
conn:
        with conn.channel() as channel:
            queue = rabbitpy.Queue(channel, 'example')
            with queue.consumer() as consumer:
                for message in consumer.next_message():
                    print('Message:')
                    print(' Time: %s' % message.properties['timestamp'])
                    print(' Body: %s' % message.body)
                    message.ack()

*Development Status*

This library is still considered experimental, but the API is set is not
expected to change. Barring any bug-fix releases, the next version (0.6.0)
will be move the library from alpha development status to beta. Testers are
needed!

Please report any bugs to https://github.com/gmr/rabbitpy/issues

Regards,

Gavin
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20130923/993ff45b/attachment-0001.htm>

------------------------------

Message: 31
Date: Mon, 23 Sep 2013 23:25:51 +0000
From: "Cordell, Ron" <Ron.Cordell at RelayHealth.com>
Subject: Re: [rabbitmq-discuss] Cluster Recovery Modes
To: Discussions about RabbitMQ <rabbitmq-discuss at lists.rabbitmq.com>
Message-ID:
	<0B8CD6850421B745BE39BC5C760192327201D95F at DDCEP50016.na.corp.mckesson.com>

Content-Type: text/plain; charset="us-ascii"

I meant to ask in this same message about the heartbeat interval set to 0 and how it is different for the cluster 'ignore' mode.

Cheers.

From: <Cordell>, Ronald Cordell <Ron.Cordell at RelayHealth.com<mailto:Ron.Cordell at RelayHealth.com>>
Reply-To: Discussions RabbitMQ <rabbitmq-discuss at lists.rabbitmq.com<mailto:rabbitmq-discuss at lists.rabbitmq.com>>
Date: Monday, September 23, 2013 3:54 PM
To: Discussions RabbitMQ <rabbitmq-discuss at lists.rabbitmq.com<mailto:rabbitmq-discuss at lists.rabbitmq.com>>
Subject: [rabbitmq-discuss] Cluster Recovery Modes

One of the cluster recovery configurations is "ignore":

  *   ignore - Your network really is reliable. All your nodes are in a rack, connected with a switch, and that switch is also the route to the outside world. You don't want to run any risk of any of your cluster shutting down if any other part of it fails (or you have a two node cluster).

Does this mode effectively turn off the heartbeat? Is a node detected as partitioned but nothing done?

Thanks,

Ron
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20130923/485e8c4f/attachment-0001.htm>

------------------------------

Message: 32
Date: Tue, 24 Sep 2013 09:25:36 +0800
From: Huang Tonglang <tlhuang at 800best.com>
Subject: [rabbitmq-discuss] What's difference between vFabric RabbitMQ
	and the open source RabbitMQ?
To: "rabbitmq-discuss at lists.rabbitmq.com"
	<rabbitmq-discuss at lists.rabbitmq.com>
Message-ID:
	<023CBAD52AC91842B08759362DE8396C0FD58019BA at bestex3.800best.net>
Content-Type: text/plain; charset="us-ascii"

Thanks in advance!

Tonglang Huang

-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20130924/5f04cc7c/attachment-0001.htm>

------------------------------

Message: 33
Date: Tue, 24 Sep 2013 07:06:23 +0100
From: Tim Watson <tim at rabbitmq.com>
Subject: Re: [rabbitmq-discuss] Cluster Recovery Modes
To: Discussions about RabbitMQ <rabbitmq-discuss at lists.rabbitmq.com>
Message-ID: <9DBF7119-71A9-4F53-A881-6F39B964E5C5 at rabbitmq.com>
Content-Type: text/plain; charset="us-ascii"

On 24 Sep 2013, at 00:25, Cordell, Ron wrote:
> I meant to ask in this same message about the heartbeat interval set to 0 and how it is different for the cluster 'ignore' mode.
> 

AMQP heartbeats are a feature to enable client and server to detect connection failures in a timely fashion), whereas clustering operates over a completely different network transport and uses a different protocol. So there's no connection between these two things.

> One of the cluster recovery configurations is "ignore":
[snip]
> Does this mode effectively turn off the heartbeat?

No - as mentioned above, AMQP heartbeats and clustering are orthogonal.

> Is a node detected as partitioned but nothing done?

Yes, that's pretty much what this recover mode does. The idea behind 'ignore' is to avoid any further loss of service. The other recovery modes can lead to one or more of the remaining (unpartitioned) nodes restarting in order to heal the cluster (see 'autoheal' mode) or total loss of service on some nodes if they reside in a minority island (see 'pause_minority' mode). 

Cheers,
Tim

-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20130924/b3a5009a/attachment-0001.htm>

------------------------------

Message: 34
Date: Tue, 24 Sep 2013 08:04:16 +0100
From: Michael Klishin <michael at rabbitmq.com>
Subject: Re: [rabbitmq-discuss] What's difference between vFabric
	RabbitMQ	and the open source RabbitMQ?
To: Discussions about RabbitMQ <rabbitmq-discuss at lists.rabbitmq.com>
Message-ID: <F0CDF731-7104-472B-8438-684EC6164B81 at rabbitmq.com>
Content-Type: text/plain; charset="us-ascii"

Huang Tonglang:

> Thanks in advance!

vFabric RabbitMQ is commercially supported.

MK

-------------- next part --------------
A non-text attachment was scrubbed...
Name: signature.asc
Type: application/pgp-signature
Size: 495 bytes
Desc: Message signed with OpenPGP using GPGMail
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20130924/9e78444b/attachment-0001.pgp>

------------------------------

Message: 35
Date: Tue, 24 Sep 2013 08:06:34 +0100
From: Michael Klishin <michael at rabbitmq.com>
Subject: Re: [rabbitmq-discuss] Determining home node for queue
To: Discussions about RabbitMQ <rabbitmq-discuss at lists.rabbitmq.com>
Cc: paul.bowsher at gmail.com
Message-ID: <6D2BC91A-1AD5-4A52-AB96-91E1D39663A1 at rabbitmq.com>
Content-Type: text/plain; charset="us-ascii"

On sep 23, 2013, at 8:12 p.m., Paul Bowsher <paul.bowsher at gmail.com> wrote:

> Do others see this behaviour?

Publishing to an arbitrary node increases intra-cluster traffic so this is expected.

> We see this being easily mitigated by always connecting to the home node for the queue, and failing over if the home node goes down. However, we haven't yet been able to think of a nice clean way of ensuring clients always connect to this.

RabbitMQ HTTP API should provide relevant information:
http://hg.rabbitmq.com/rabbitmq-management/raw-file/5be95aaf986f/priv/www/api/index.html

MK

-------------- next part --------------
A non-text attachment was scrubbed...
Name: signature.asc
Type: application/pgp-signature
Size: 495 bytes
Desc: Message signed with OpenPGP using GPGMail
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20130924/b611e373/attachment-0001.pgp>

------------------------------

Message: 36
Date: Tue, 24 Sep 2013 08:07:43 +0100
From: Michael Klishin <michael at rabbitmq.com>
Subject: Re: [rabbitmq-discuss] Many consumers on 1 queue. What
	algorithm	RabbitMQ use to send messages?
To: Discussions about RabbitMQ <rabbitmq-discuss at lists.rabbitmq.com>
Message-ID: <4F2B3AAF-422F-4368-9965-9440FFDE8CA7 at rabbitmq.com>
Content-Type: text/plain; charset="us-ascii"

On sep 23, 2013, at 9:23 p.m., Haster <haster2004 at yandex.ru> wrote:

> And I can't found some formala for calculating which consumer will consume
> n-message?

In theory you can but given that messages can be requeued and delivering and processing
them rarely takes a fixed amount of time, it will be pretty inaccurate.

MK

-------------- next part --------------
A non-text attachment was scrubbed...
Name: signature.asc
Type: application/pgp-signature
Size: 495 bytes
Desc: Message signed with OpenPGP using GPGMail
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20130924/bfb05af3/attachment-0001.pgp>

------------------------------

Message: 37
Date: Tue, 24 Sep 2013 00:43:30 -0700 (PDT)
From: "dilip.aim11" <dilip.aim11 at gmail.com>
Subject: [rabbitmq-discuss] Clustring not working in rabbit MQ
To: rabbitmq-discuss at lists.rabbitmq.com
Message-ID: <1380008610098-29866.post at n5.nabble.com>
Content-Type: text/plain; charset=us-ascii

Hi ,
I trying Clustring in two machine .

but after changing *.erlang.cookie* file of slave machine .
That slave machine node getting down
 after that if i am running any command on the slave machine - 
like -

rabbitmqctl stop_app
rabbitmqctl -n slave at host status

it always saying could not connect  node name node down 

but if i am running this command in slave machine -
rabbitmqctl -n master at host status

so its able to connect master machine .
but slave rabbitmq getting  down  

Please suggest solution on this .

--
View this message in context: http://rabbitmq.1065348.n5.nabble.com/Clustring-not-working-in-rabbit-MQ-tp29866.html
Sent from the RabbitMQ mailing list archive at Nabble.com.

------------------------------

Message: 38
Date: Tue, 24 Sep 2013 09:56:05 +0100
From: jim <jim at rabbitmq.com>
Subject: [rabbitmq-discuss]  What's difference between vFabric
	RabbitMQ and the open source RabbitMQ?
To: Discussions about RabbitMQ <rabbitmq-discuss at lists.rabbitmq.com>
Message-ID: <48019a6c9b554fad175443761849e0da at rabbitmq.com>
Content-Type: text/plain; charset=UTF-8; format=flowed

Not so.

Commercial support is available from Pivotal for both vFabric RabbitMQ 
and open source RabbitMQ. The terms do differ between them.

The main differences are:

- vFabric RabbitMQ has a commercial license [0] whereas open source 
RabbitMQ is licensed under the MPL1.1 [1]
- vFabric RabbitMQ support can be purchased under a perpetual license 
whereas open source RabbitMQ is annual subscription only [2]
- the support window for a particular release of vFabric RabbitMQ is 
substantially longer (3yrs) than open source RabbitMQ (1yr) [3]
- the vFabric RabbitMQ release comes with a JMS client that is not 
available as part of the open source distribution [4]

Jim

[0] http://www.vmware.com/uk/download/eula/universal_eula.html
[1] http://www.rabbitmq.com/mpl.html
[2] http://www.vmware.com/uk/products/vfabric-rabbitmq/buy.html
[3] 
http://www.vmware.com/support/policies/application-platform/eos.html
[4] 
http://pubs.vmware.com/vfabricRabbitMQ31/index.jsp?topic=/com.vmware.vfabric.rabbitmq.3.1/suppconfigsrabbit/about.html

On 24 September 2013 08:04, Michael Klishin <michael at rabbitmq.com> 
wrote:
Huang Tonglang:

> Thanks in advance!

vFabric RabbitMQ is commercially supported.

MK

_______________________________________________
rabbitmq-discuss mailing list
rabbitmq-discuss at lists.rabbitmq.com
https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss

------------------------------

Message: 39
Date: Tue, 24 Sep 2013 09:57:38 +0100
From: Emile Joubert <emile at rabbitmq.com>
Subject: Re: [rabbitmq-discuss] Clustring not working in rabbit MQ
To: Discussions about RabbitMQ <rabbitmq-discuss at lists.rabbitmq.com>
Cc: "dilip.aim11" <dilip.aim11 at gmail.com>
Message-ID: <52415402.5000606 at rabbitmq.com>
Content-Type: text/plain; charset=ISO-8859-1

On 24/09/13 08:43, dilip.aim11 wrote:

> so its able to connect master machine .
> but slave rabbitmq getting  down  

That suggests that the .erlang.cookie files are not the same on both
nodes. Check that the cookie hash is identical as reported in the
logfile when the broker starts up.

-Emile

------------------------------

Message: 40
Date: Tue, 24 Sep 2013 02:03:25 -0700 (PDT)
From: "dilip.aim11" <dilip.aim11 at gmail.com>
Subject: Re: [rabbitmq-discuss] Clustring not working in rabbit MQ
To: rabbitmq-discuss at lists.rabbitmq.com
Message-ID: <1380013405433-29869.post at n5.nabble.com>
Content-Type: text/plain; charset=us-ascii

Hi ,

Both Hash are same i checked .

--
View this message in context: http://rabbitmq.1065348.n5.nabble.com/Clustring-not-working-in-rabbit-MQ-tp29866p29869.html
Sent from the RabbitMQ mailing list archive at Nabble.com.

------------------------------

Message: 41
Date: Tue, 24 Sep 2013 10:13:04 +0100
From: Emile Joubert <emile at rabbitmq.com>
Subject: Re: [rabbitmq-discuss] Clustring not working in rabbit MQ
To: Discussions about RabbitMQ <rabbitmq-discuss at lists.rabbitmq.com>
Cc: "dilip.aim11" <dilip.aim11 at gmail.com>
Message-ID: <524157A0.4050302 at rabbitmq.com>
Content-Type: text/plain; charset=ISO-8859-1

On 24/09/13 10:03, dilip.aim11 wrote:

> Both Hash are same i checked .

Can you confirm that the slave is running when you experience these
failures? What does the slave logfile say?

-Emile

------------------------------

Message: 42
Date: Tue, 24 Sep 2013 02:14:08 -0700 (PDT)
From: Haster <haster2004 at yandex.ru>
Subject: Re: [rabbitmq-discuss] Many consumers on 1 queue. What
	algorithm RabbitMQ use to send messages?
To: rabbitmq-discuss at lists.rabbitmq.com
Message-ID: <1380014048655-29870.post at n5.nabble.com>
Content-Type: text/plain; charset=us-ascii

Thank for replies, guys

--
View this message in context: http://rabbitmq.1065348.n5.nabble.com/Many-consumers-on-1-queue-What-algorithm-RabbitMQ-use-to-send-messages-tp29831p29870.html
Sent from the RabbitMQ mailing list archive at Nabble.com.

------------------------------

Message: 43
Date: Tue, 24 Sep 2013 02:26:09 -0700 (PDT)
From: "dilip.aim11" <dilip.aim11 at gmail.com>
Subject: Re: [rabbitmq-discuss] Clustring not working in rabbit MQ
To: rabbitmq-discuss at lists.rabbitmq.com
Message-ID: <1380014769903-29872.post at n5.nabble.com>
Content-Type: text/plain; charset=us-ascii

Hi ,
Done , 
after change the cookie , i didn't restarted the service.
after restarted the service every thing is working fine .
Thanks for ur time .

--
View this message in context: http://rabbitmq.1065348.n5.nabble.com/Clustring-not-working-in-rabbit-MQ-tp29866p29872.html
Sent from the RabbitMQ mailing list archive at Nabble.com.

------------------------------

_______________________________________________
rabbitmq-discuss mailing list
rabbitmq-discuss at lists.rabbitmq.com
https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss

End of rabbitmq-discuss Digest, Vol 76, Issue 25
************************************************
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20130924/06231456/attachment.htm>