[rabbitmq-discuss] rabbitmq server to server communication

Wed Jan 13 12:48:52 GMT 2010

Here is a quick n dirty amqp replicator that we've been using for a while.
Modified it a bit to remove some project specific stuff. You may use it
while you wait for the new release.

Ruby code:

require 'rubygems'
require 'mq'

EM.run do
  def replicate source, destination, topic
    source_q = MQ::Queue.new(source, "replicator for #{topic}")
    source_q.bind(MQ::Exchange.new(source, :topic, topic))
    destination_ex = MQ::Exchange.new(destination, :topic, topic)

    source_q.subscribe do |headers, msg|
      destination_ex.publish(msg)
    end
  end

  local, remote = %w{one two}, %w{three}
  localhost, remotehost = 'localhost', '192.168.0.26'

  local_channel = MQ.new(AMQP.connect(:host => localhost, :logging =>
false))
  remote_channel = MQ.new(AMQP.connect(:host => remotehost, :logging =>
false))

  local.each  { |t| replicate local_channel, remote_channel, t }
  remote.each { |t| replicate remote_channel, local_channel, t }
end

Regards,
Pradeep

On Wed, Jan 13, 2010 at 5:42 PM, Alexis Richardson <
alexis.richardson at gmail.com> wrote:

> Seema
>
> It's been imminent for some time - QA in underway currently.  We hit
> the usual slowdowns due to the holiday season.
>
> We'll be sure to let you know.
>
> alexis
>
>
> On Wed, Jan 13, 2010 at 12:09 PM, Seema Biradar <seemasbiradar at gmail.com>
> wrote:
> > Ok Thanks for the information!
> >
> > Please let me know when the next release is? and
> > The link from where we can download the same ?
> >
> > Thanks again!
> > Regards
> > Seema
> >
> >
> > On Wed, Jan 13, 2010 at 5:22 PM, Alexis Richardson
> > <alexis.richardson at gmail.com> wrote:
> >>
> >> Seema
> >>
> >> I have just asked the team about this and learnt that Shovel was taken
> >> offline for a few weeks pending our next server release.  This is
> >> because we wanted to make some changes to the plugin to align with
> >> server changes.  Would you mind waiting a few weeks?  If you need to
> >> do something quickly, then please let us know.
> >>
> >> Best wishes
> >>
> >> alexis
> >>
> >>
> >>
> >>
> >>
> >>
> >>
> >> On Wed, Jan 13, 2010 at 9:17 AM, Seema Biradar <seemasbiradar at gmail.com
> >
> >> wrote:
> >> > Can you please let me know where can i download or get src for the
> Shove
> >> > pluggin.
> >> >
> >> >
> >> > On Tue, Jan 12, 2010 at 11:22 PM, Alexis Richardson
> >> > <alexis.richardson at gmail.com> wrote:
> >> >>
> >> >> Seema,
> >> >>
> >> >> I am not the best person to answer your question in full, but:  In
> >> >> addition to what Pradeep said, you need to be aware that Shovel is a
> >> >> RabbitMQ plugin.  The plugins are described here:
> >> >> http://www.rabbitmq.com/admin-guide.html#plugins
> >> >>
> >> >> The following talk describes a use case involving Shovel -
> >> >>
> >> >>
> >> >>
> >> >>
> http://qconsf.com/sf2009/presentation/Open+Source+at+Unibet.com+-+10x+Scalability+at+Half+the+Cost
> >> >>
> >> >> And Stefan's slides are here:
> >> >>
> >> >> http://qconsf.com/sf2009/tracks/show_track.jsp?trackOID=301
> >> >>
> >> >> alexis
> >> >>
> >> >>
> >> >> On Tue, Jan 12, 2010 at 7:18 AM, Pradeep Gatram
> >> >> <pradeep.gatram at gmail.com> wrote:
> >> >> > Seema,
> >> >> >
> >> >> > You dont have to interact with Shovel directly. Look at it this way
> >> >> >
> >> >> > p1-->R1 --> Shovel (or amqp-relay) -->R2-->C2
> >> >> >
> >> >> > p1 & c2 can be in any programming language. You just have to
> >> >> > "configure"
> >> >> > the
> >> >> > Shovel/amqp-relay appropriately.
> >> >> >
> >> >> > Pradeep
> >> >> >
> >> >> > On Tue, Jan 12, 2010 at 12:30 PM, Seema Biradar
> >> >> > <seemasbiradar at gmail.com>
> >> >> > wrote:
> >> >> >>
> >> >> >> Hi,
> >> >> >> Thanks for the information.
> >> >> >>
> >> >> >> I need one more help .
> >> >> >>
> >> >> >> Can you please suggest me how can we use Shovel component and
> >> >> >> RabbitMQ
> >> >> >> using in JAVA Programming language.
> >> >> >>
> >> >> >> Using JAVA as programming language (RabbitMQ Java API), how can we
> >> >> >> make
> >> >> >> use of shovel component?
> >> >> >> (I am using RabbitMQ bundle for Windows )
> >> >> >>
> >> >> >> If any examples are there ( RabbitMQ Java API + Shovel Application
> )
> >> >> >> .please let me know.
> >> >> >>
> >> >> >> Thanksin adavance.
> >> >> >> Seema
> >> >> >>
> >> >> >>
> >> >> >>
> >> >> >> On Mon, Jan 11, 2010 at 4:30 PM, Alexis Richardson
> >> >> >> <alexis.richardson at gmail.com> wrote:
> >> >> >>>
> >> >> >>> Seema
> >> >> >>>
> >> >> >>> We have a component called Shovel that does this.  Have a look
> at:
> >> >> >>>
> >> >> >>>
> >> >> >>>
> >> >> >>>
> >> >> >>>
> http://www.google.com/custom?hl=en&client=google-coop&cof=FORID%3A13%3BAH%3Aleft%3BCX%3ASearch%2520rabbitmq%252Ecom%3BL%3Ahttp%3A%2F%2Fwww.google.com%2Fintl%2Fen%2Fimages%2Flogos%2Fcustom_search_logo_sm.gif%3BLH%3A30%3BLP%3A1%3BVLC%3A%23551a8b%3BDIV%3A%23cccccc%3B&adkw=AELymgUM4bEBKZRWHklce-FzQ07Y_Ty_1vnaPtrQ8r-mfG-h02gaVCQWhzccmyx_IeDaFY9Tk26r8LoVr4kPf-qF5JYWjXQjBG5fUe-P7g5bl1eaF1uKRUU&boostcse=0&q=shovel+rabbitmq&btnG=Search&cx=!009922129631189805192%3Akpd1zoym_hq<http://www.google.com/custom?hl=en&client=google-coop&cof=FORID%3A13%3BAH%3Aleft%3BCX%3ASearch%2520rabbitmq%252Ecom%3BL%3Ahttp%3A%2F%2Fwww.google.com%2Fintl%2Fen%2Fimages%2Flogos%2Fcustom_search_logo_sm.gif%3BLH%3A30%3BLP%3A1%3BVLC%3A%23551a8b%3BDIV%3A%23cccccc%3B&adkw=AELymgUM4bEBKZRWHklce-FzQ07Y_Ty_1vnaPtrQ8r-mfG-h02gaVCQWhzccmyx_IeDaFY9Tk26r8LoVr4kPf-qF5JYWjXQjBG5fUe-P7g5bl1eaF1uKRUU&boostcse=0&q=shovel+rabbitmq&btnG=Search&cx=%21009922129631189805192%3Akpd1zoym_hq>
> >> >> >>>
> >> >> >>> Also, some has created a 'relay' project on Github:
> >> >> >>> http://github.com/slider/amqp-relay
> >> >> >>>
> >> >> >>> Does this answer your question?
> >> >> >>>
> >> >> >>> alexis
> >> >> >>>
> >> >> >>>
> >> >> >>> On Mon, Jan 11, 2010 at 7:21 AM, Seema Biradar
> >> >> >>> <seemasbiradar at gmail.com>
> >> >> >>> wrote:
> >> >> >>> > Hi
> >> >> >>> >
> >> >> >>> > My requirement is like this
> >> >> >>> >
> >> >> >>> > Two instance of RabbitMQ server are running at different IP.say
> >> >> >>> > assume
> >> >> >>> > P1 is a producer of rabitmq1 R1(which is in one mechine)
> >> >> >>> > C2 is a cosumer of rabittmq2 R2 (which is running in another
> >> >> >>> > mechine),i
> >> >> >>> > Is it possible  the communication flow in the following manner,
> >> >> >>> > p1-->R1-->R2-->C2
> >> >> >>> >
> >> >> >>> > If there small example please mail me back
> >> >> >>> >
> >> >> >>> > Thanks in advance
> >> >> >>> > Seema
> >> >> >>> >
> >> >> >>> > _______________________________________________
> >> >> >>> > rabbitmq-discuss mailing list
> >> >> >>> > rabbitmq-discuss at lists.rabbitmq.com
> >> >> >>> >
> >> >> >>> >
> http://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
> >> >> >>> >
> >> >> >>> >
> >> >> >>
> >> >> >>
> >> >> >> _______________________________________________
> >> >> >> rabbitmq-discuss mailing list
> >> >> >> rabbitmq-discuss at lists.rabbitmq.com
> >> >> >>
> http://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
> >> >> >>
> >> >> >
> >> >> >
> >> >> > _______________________________________________
> >> >> > rabbitmq-discuss mailing list
> >> >> > rabbitmq-discuss at lists.rabbitmq.com
> >> >> >
> http://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
> >> >> >
> >> >> >
> >> >
> >> >
> >
> >
>
> _______________________________________________
> rabbitmq-discuss mailing list
> rabbitmq-discuss at lists.rabbitmq.com
> http://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/20100113/636f83f4/attachment.htm 