[rabbitmq-discuss] rabbitMQ-2.8.2 : problem with credentials

Thu May 17 06:26:49 BST 2012

Dear All ...
My System is RabitMQ 2.8.2 on Ubuntu-lucid.
Installed using apt-get from :
deb http://www.rabbitmq.com/debian/ testing main

I try to use credential, but got error msg.

Here it is :
==1.This is the sender01.py without credential=======
import pika
import sys

connection = 
pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
channel = connection.channel()

channel.queue_declare(queue='task_queue', durable=True)

message = ' '.join(sys.argv[1:]) or "Hello World!"
channel.basic_publish(exchange='',
     routing_key='task_queue',
     body=message,
     properties=pika.BasicProperties(delivery_mode = 2,))
print ' [x] Sent %r' % (message,)
connection.close()
==2. and the result is===============================
root at core /opt/oprekan# python ./sender01.py 'without credentials'
  [x] Sent 'without credentials'
==3. try to add 1 user===============================
root at core /opt/oprekan# rabbitmqctl add_user bino01 123456
Creating user "bino01" ...
...done.
==4. and this is sender02.py with credentials========
import pika
import sys

credentials = pika.PlainCredentials('bino01', '123456')
connection = 
pika.BlockingConnection(pika.ConnectionParameters(credentials=credentials,host='127.0.0.1'))
channel = connection.channel()
channel.queue_declare(queue='task_queue', durable=True)

message = ' '.join(sys.argv[1:]) or "Hello World!"
channel.basic_publish(exchange='',
     routing_key='task_queue',
     body=message,
     properties=pika.BasicProperties(delivery_mode = 2,))
print ' [x] Sent %r' % (message,)
connection.close()

==5. and here is the result============================
root at core /opt/oprekan# python ./sender02.py 'WITH credentials'
Traceback (most recent call last):
   File "./sender02.py", line 5, in <module>
     connection = 
pika.BlockingConnection(pika.ConnectionParameters(credentials=credentials,host='127.0.0.1'))
   File 
"/usr/local/lib/python2.6/dist-packages/pika/adapters/blocking_connection.py", 
line 32, in __init__
     BaseConnection.__init__(self, parameters, None, reconnection_strategy)
   File 
"/usr/local/lib/python2.6/dist-packages/pika/adapters/base_connection.py", 
line 50, in __init__
     reconnection_strategy)
   File "/usr/local/lib/python2.6/dist-packages/pika/connection.py", 
line 170, in __init__
     self._connect()
   File "/usr/local/lib/python2.6/dist-packages/pika/connection.py", 
line 228, in _connect
     self.parameters.port or  spec.PORT)
   File 
"/usr/local/lib/python2.6/dist-packages/pika/adapters/blocking_connection.py", 
line 44, in _adapter_connect
     self._handle_read()
   File 
"/usr/local/lib/python2.6/dist-packages/pika/adapters/base_connection.py", 
line 151, in _handle_read
     data = self.socket.recv(self._suggested_buffer_size)
socket.timeout: timed out
====================================

Kindly please tell me what to do to fix this problem

sincerely
-bino-