I Think your original code was actually all good, this was the bit that
was throwing me off.
> qname,_,_ = chan.queue_declare(auto_delete=True, durable=True)
> > chan.queue_bind(qname, exchange="myexchange", routing_key="users." + user)
I did'nt get that each listener needs their own queue
(using morbid gave me some very bad habits and ways of thinking),
once I did not realize the importance of queue_declare
not being passed a name, so it gives you back a unique queue.
So it was me messing it up, not your code samples.
I solved my problem in the end with a combination of stomppy,
amqplib and the stomp library that comes with orbited.
If you create the queue on the server side with amqplib, then
all javascript stomp library had to do was connect to that queue.
Thanks again for your help
Sean
On Mon, 2009-07-06 at 23:30 +0100, Rory Geoghegan wrote:
> Seeing as there's no talks this week, I can procrastinate a tad bit
> more on my presentation. However, I just wanted to show these two
> samples of code, which don't use stomp and which I am pretty sure was
> working on my machine (WOMM(tm)).
>
> cahoon.py:
>
> import amqplib.client_0_8 as amqp
>
> connection = amqp.Connection()
> channel = amqp.channel.Channel(connection)
> try:
> channel.exchange_declare('rory.topic', 'topic', passive=True)
> except amqp.AMQPChannelException:
> print "Declating exchange"
> channel = amqp.channel.Channel(connection)
> channel.exchange_declare('rory.topic', 'topic', auto_delete=False)
>
>
> channel.basic_publish(
> amqp.basic_message.Message("{'rory': 'cool'}"),
> exchange='rory.topic'
> )
>
> calvillo.py:
>
> import amqplib.client_0_8 as amqp
>
> connection = amqp.Connection()
> channel = amqp.channel.Channel(connection)
> channel.basic_publish(
> amqp.basic_message.Message("Billy Mays Here"),
> exchange='rory.topic'
> )
>
> I had this working with a rabbitmq server running on the same machine.
> For the record, rabbitmq is pretty easy to get up and running once
> you've installed erlang.
>
> --Rory Geoghegan
>
> On Fri, Jun 12, 2009 at 5:31 PM, <[email protected]> wrote:
> >
> > With a little more experimentation, creating a new exchange is not
> > neccessary, they key part is to create a new queue for each reciever,
> > heres the same effect using a routing key and just one exchange.
> >
> > Sending.
> >
> > conn.send(str(i), exchange="myexchange", destination='users.'+ user)
> >
> >
> > Recieving
> >
> >
> > import stomp
> > from amqplib import client_0_8 as amqp
> > import sys
> >
> >
> > conn = amqp.Connection(host="localhost:5672", userid="guest",
> > password="guest",
> > virtual_host="/", insist=False)
> >
> >
> > user = sys.argv[1]
> > chan = conn.channel()
> >
> > chan.exchange_declare("myexchange", 'topic', durable=True)
> > qname,_,_ = chan.queue_declare(auto_delete=True, durable=True)
> > chan.queue_bind(qname, exchange="myexchange", routing_key="users." + user)
> > chan.close()
> > conn.close()
> >
> > class MyListener(object):
> > def on_error(self, headers, message):
> > print 'recieved an error %s' % message
> >
> > def on_message(self, headers, message):
> > print 'recieved a message %s' % message
> >
> > conn = stomp.Connection([('0.0.0.0', 61613), ('127.0.0.1', 61613)],
> > 'browser', 'browser')
> > conn.set_listener('', MyListener())
> > conn.start()
> > conn.connect(username="guest", password="guest")
> > headers = {}
> >
> > conn.subscribe(destination=qname, ack='auto')
> >
> > while True:
> > pass
> > conn.disconnect()
> >
> >
> >
> >
> >
> >
> >
> > >
> >
>
> >
--~--~---------~--~----~------------~-------~--~----~
You received this message because you are subscribed to the Google Groups
"Python Ireland" group.
To post to this group, send email to [email protected]
To unsubscribe from this group, send email to
[email protected]
For more options, visit this group at
http://groups.google.ie/group/pythonireland?hl=en
-~----------~----~----~----~------~----~------~--~---
