Exqpid is the wrapper for qpidpn.
Exqpid depends on qpidpn. Follow the below steps:-
- install Apache Qpid Proton 0.7
- Set the
ERLANG_HOME
, If you have installed in a location other than such as '/usr', '/usr/local'. Set theQPID_PROTON_HOME
, If you have installed in a location other than such as '/usr', '/usr/local'. mix deps.get
mix deps.compile
iex -S mix
Exqpid.start() :: {:ok, pid} | {:error, :not_started}
Exqpid.publish(:topic, 'mytopic', 'hello') :: :ok | {:error, :not_published}
Exqpid.publish(:queue, 'myqueue', 'hello') :: :ok | {:error, :not_published}
Exqpid.subscribe(:topic, 'mytopic') :: :ok | {:error, :not_subscribed}
Exqpid.subscribe(:queue, 'myqueue') :: :ok | {:error, :not_subscribed}