[rabbitmq-users] Issue when using rabbitMQ MQTT

[shriyansh jain]

Hi,

I am sending data to a particular topic("Test") using user details(UserNAme:*
userA* Password: *UserApwd*) but at then time of receiving I am using
different user credentials (UserNAme:* userB* Password: *UserBpwd*) he is
also receiving the data from topic(* "Test"*).
How i can set the authentication Please let me know.

*Sender Code:*

MqttClient client = new MqttClient("Rabbit MQ VM IP");
client.Connect(*"ClientName1", "userA", "UserApwd"*);
string[] topic = {* "Test"* };
byte[] qoslevels = { MqttMsgBase.QOS_LEVEL_AT_MOST_ONCE };
client.Subscribe(topic, qoslevels);
client.MqttMsgPublished += new
MqttClient.MqttMsgPublishedEventHandler(client_MqttMsgPublished);

for (int i = 0; i < 10; i++)
{
ushort t = client.Publish("/queue/test",
Encoding.UTF8.GetBytes("testmessage" + i),
MqttMsgBase.QOS_LEVEL_AT_LEAST_ONCE, true);
Console.WriteLine("Sending: " + "testmessage" + i);
Console.WriteLine();
}

*Receiver Code*

static void Main(string[] args)
{
MqttClient client = new MqttClient("Rabbit MQ VM IP");
client.Connect(*"ClientName2", "userB", "UserBpwd"*);
string[] topic = {* "**Test**"* };
byte[] qoslevels = { MqttMsgBase.QOS_LEVEL_AT_MOST_ONCE };
client.Subscribe(topic, qoslevels);
client.MqttMsgPublishReceived += new
MqttClient.MqttMsgPublishEventHandler(client_PublishArrived);

Console.ReadLine();
}

private static void client_PublishArrived(object sender,
MqttMsgPublishEventArgs e)
{
Console.WriteLine("Message Received " +
Encoding.UTF8.GetString(e.Message));
Console.WriteLine();
}

Thanks

[Michael Klishin]

userA Password: UserApwd) but at then time of receiving I am using
different user credentials (UserNAme: userB Password: UserBpwd)
he is also receiving the data from topic( "Test").
How i can set the authentication Please let me know.

Authentication or authorisation? What's your end goal? 
--
MK

Staff Software Engineer, Pivotal/RabbitMQ

[shriyansh jain]

I don't want to receive message of one topic to other user so we need to
implement authorisation here at Topic level. We will authenticate with the
help of username and password.

Post by Michael Klishin

Post by shriyansh jain
I am sending data to a particular topic("Test") using user
userA Password: UserApwd) but at then time of receiving I am using
different user credentials (UserNAme: userB Password: UserBpwd)
he is also receiving the data from topic( "Test").
How i can set the authentication Please let me know.

Authentication or authorisation? What's your end goal?
--
MK
Staff Software Engineer, Pivotal/RabbitMQ

[Michael Klishin]

Post by shriyansh jain
I don't want to receive message of one topic to other user so we
need to implement authorisation here at Topic level. We will
authenticate with the help of username and password.

MQTT (the protocol) doesn't have a concept of authorisation
and RabbitMQ's authorisation concepts are originally built for a single
(and fairly different) protocol [1].

RabbitMQ MQTT plugin will have support for it in 3.6.0 [2].
You'll  be able to restrict clients from subscribing to specific topics.

1. http://www.rabbitmq.com/access-control.html
2. https://github.com/rabbitmq/rabbitmq-mqtt/pull/28
--
MK

Staff Software Engineer, Pivotal/RabbitMQ