Apache Cassandra integration with RabbitMQ

[Zakaria Hili]

Hi,

I want to use MQTT as a protocol communication with RabbitMQ Message Broker, but from rabbitmq website I found this paragraph:

These implementations are suitable for development but sometimes won't be for production needs. MQTT 3.1 specification does not define consistency or replication requirements for retained message stores, therefore RabbitMQ allows for custom ones to meet the consistency and availability needs of a particular environment. For example, stores based on Riak and Cassandra would be suitable for most production environments as those data stores provide tunable consistency.

https://www.rabbitmq.com/mqtt.html

So, from this paragraph, I should to use Cassandra as a database for RabbitMQ, but I didn't find anything about integration Cassandra as a database for rabbitmq.

can you help me by giving me something to make it possible.

NB:I'm newbie in RabbitMQ.

[dfed...@pivotal.io]

Retained message stores are pluggable and should be an erlang module implementing rabbit_mqtt_retained_msg_store behaviour. Only rabbit_mqtt_retained_msg_store_ets and rabbit_mqtt_retained_msg_store_dets modules are provided by RabbitMQ. Maybe there are some plugin implementing Cassandra store.

You can implement such plugin yourself. rabbit_mqtt_retained_msg_store behaviour is pretty straight forward.