Eventmachine talk - Mar 2009 - Integration with Message Queue

I''ve got an EventMachine that will manage a handful (anywhere from
100-1000) outbound TCP connections to a variety of devices around our
network. I''d like the EM to accept requests from various management
processes, relay the request on to the TCP stream, then return the
result.

I think it would be fairly simple to implement a periodic timer that
looks for new requests, but I''d like this to happen on the fly. In
some instances, there may be a user waiting for the result.

So it''s pretty easy to whip up an EM that connects to all the devices.
But what''s the best way to "accept" requests from a job
queue? I''ve
seen rumblings of some sort of AMQP integration, but am not sure
exactly what it does. Ideally, EM could handle some sort of IO object
from the message queue just like any other IO?

Or would it be better to implement the queuing in a separate thread?

Thanks for any advice,

Norman

The amqp library uses EM to connect to a rabbitmq server. You can also
use the EM memcache client to connect to starling or memcacheQ.

  Aman

On Mon, Mar 2, 2009 at 6:52 PM, Norman Elton <normelton at gmail.com>
wrote:
> I''ve got an EventMachine that will manage a handful (anywhere from
> 100-1000) outbound TCP connections to a variety of devices around our
> network. I''d like the EM to accept requests from various
management
> processes, relay the request on to the TCP stream, then return the
> result.
>
> I think it would be fairly simple to implement a periodic timer that
> looks for new requests, but I''d like this to happen on the fly. In
> some instances, there may be a user waiting for the result.
>
> So it''s pretty easy to whip up an EM that connects to all the
devices.
> But what''s the best way to "accept" requests from a job
queue? I''ve
> seen rumblings of some sort of AMQP integration, but am not sure
> exactly what it does. Ideally, EM could handle some sort of IO object
> from the message queue just like any other IO?
>
> Or would it be better to implement the queuing in a separate thread?
>
> Thanks for any advice,
>
> Norman
> _______________________________________________
> Eventmachine-talk mailing list
> Eventmachine-talk at rubyforge.org
> http://rubyforge.org/mailman/listinfo/eventmachine-talk
>