ACCESS_REFUSED - Login was refused using authentication mechanism PLAIN

Question

I have installed "erlang" and "rabbitmq" in my windows 7 machine. But when I am trying to run this code I am getting One exception.

package com.rabbitmq;

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
public class SendMessage {
  private final static String QUEUE_NAME = "hello";
  public static void main(String[] argv) throws Exception { 
    ConnectionFactory factory = new ConnectionFactory();
    factory.setHost("localhost");
    Connection connection = factory.newConnection();
    Channel channel = connection.createChannel();
    channel.queueDeclare(QUEUE_NAME, false, false, false, null);
    String message = "Hello World!";
    channel.basicPublish("", QUEUE_NAME, null, message.getBytes("UTF-8"));
    System.out.println(" [x] Sent '" + message + "'");
    channel.close();
    connection.close();
  }
}

I am getting this Exception.

Exception in thread "main" com.rabbitmq.client.AuthenticationFailureException: ACCESS_REFUSED - Login was refused using authentication mechanism PLAIN. For details see the broker logfile.

This is the log:

11-Apr-2016::12:45:06 === Adding vhost 'localhost'

=INFO REPORT==== 11-Apr-2016::14:08:52 === accepting AMQP connection <0.360.0> (127.0.0.1:55327 -> 127.0.0.1:5672)

=ERROR REPORT==== 11-Apr-2016::14:08:52 === Error on AMQP connection <0.360.0> (127.0.0.1:55327 -> 127.0.0.1:5672, state: starting):

=INFO REPORT==== 11-Apr-2016::14:08:52 === closing AMQP connection <0.360.0> (127.0.0.1:55327 -> 127.0.0.1:5672)

When I am trying to list the users I am not getting any existing user and add_user is also not working in cmd link

Answer 1

In your ConnectionFactory you need to set your username and password, if your have created any or you can use the default user "guest" with password "guest", which can be accessible only from localhost.

Answer 2

you can create new user (userA) and password (userA123).
And set

factory.setHost("your_pc_ip");
factory.setUsername("userA");
factory.setPassword("userA123");

in sender and receiver classes.

Answer 3

It's a bit vexing to come across this error message while following the official helloworld guide exactly.

With some research, here's what works for me:

ConnectionFactory factory = new ConnectionFactory();
factory.setHost("10.0.0.2");   // * default rabbitmq port: 5672
factory.setUsername("myUsr");  // ensure a new user is created on the server
factory.setPassword("p@ssword");
factory.setVirtualHost("vh1"); // ensure a new virtual host is created on the server
                               // and the user has granted the access right to it

try (Connection connection = factory.newConnection();
     Channel channel = connection.createChannel()) {

    // create a queue
    String queueName = "myQueueName";
    Boolean durable = false;    // if ture, messages will be retained even after server is restarted
    Boolean exclusive = false;  // if true, other connections will not be able to access this queue
    Boolean autoDelete = false; // if true, queue is deleted when all consumers have finished using it
    Map<String, Object> arguments = null;
    channel.queueDeclare(queueName, durable, exclusive, autoDelete, arguments);

    String message = "Hello World!";
    channel.basicPublish("", queueName, null, message.getBytes());
    System.out.println(" [x] Sent '" + message + "'");
}

To add a new virtual host from web management UI:

To add a new user from web management UI:

To grant user the access right to virtual host:

(click the user name to enter the detail page)