Hi again, works now (I should really reading the rabbitMQ logs before posting). It seems that the Ruby implementation use the OBS host IP address instead of localhost as own address, even if the server is 'localhost', so the rabbitmq server did not allow the connection without setting {loopback_users, []} in the /etc/rabbitmq/rabbitmq.config. Normally the senders address should be selected automatically based on the destination network address, I think. Sorry for the noise. Karsten Am 17.06.2018 um 22:39 schrieb Karsten Keil:
Hi,
I want to move a old notify plugin to the new RabbitMQ implementation. For this I added an rabbitMQ server on the OBS frontend host (running OBS 2.9.2). After some trouble with the epmd and rabbitMQ server setup I finally got it running and could test it with the rabbitMQ tutorials, so I'm sure that this part is working.
options.yml rabbitMQ stuff:
# Rabbitmq based message bus # # Prefix of the message bus rooting key amqp_namespace: 'opensuse.obs' # # Connection options -> http://rubybunny.info/articles/connecting.html amqp_options: host: localhost port: 5672 user: guest pass: guest vhost: / # # Exchange@options -> http://rubybunny.info/articles/exchanges.html amqp_exchange_name: pubsub amqp_exchange_options: type: :topic auto_delete: false arguments: persistent: true passive: true #end of options.yml
Then I used a simple python consumer:
#!/usr/bin/env python import pika
connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost')) channel = connection.channel()
channel.exchange_declare(exchange='pubsub', exchange_type='topic')
result = channel.queue_declare(exclusive=True) queue_name = result.method.queue
channel.queue_bind(exchange='pubsub', queue=queue_name, routing_key='opensuse.obs.#')
print(' [*] Waiting for pubsub. To exit press CTRL+C')
def callback(ch, method, properties, body): print(" [x] %r" % body)
channel.basic_consume(callback, queue=queue_name, no_ack=True)
channel.start_consuming() # end of consumer code
I tried '#' as routing_key as well, but neither did work. Do I need to config something more as the options.yml ?
Does my code or the configuration be wrong ? Of course I restarted apache after any change in option.yml.
Thanks Karsten
-- To unsubscribe, e-mail: opensuse-buildservice+unsubscribe@opensuse.org To contact the owner, e-mail: opensuse-buildservice+owner@opensuse.org