Hi,

I'm trying to connect to Qpid Java 0.32 using Pika but I can't seem to
get this working. I have a default Qpid install but when I try to
connect I get the following error from the Pika client:

  File "/usr/lib/python2.7/dist-packages/pika/connection.py", line
1012, in _get_credentials
    raise exceptions.AuthenticationError(self.params.credentials.TYPE)
pika.exceptions.AuthenticationError: PLAIN

I can't find any clear documentation on how to correct this problem.
The Pika code is:

---

import pika

# Establish a connection to our local AMQP server.
hostname = 'localhost'
username = 'guest'
password = 'guest'
parameters = 
pika.ConnectionParameters(hostname,credentials=pika.credentials.PlainCredentials(username,password))
connection = pika.BlockingConnection(parameters)
channel = connection.channel()

channel.exchange_declare(exchange='readings',
                         exchange_type='fanout',
                         durable=True)

---

The same client works fine with RabbitMQ. Any ideas on how to get this
working with Qpid Java?

Thanks,

Rowan

---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to