Mix.install([
{:amqp, "~> 3.3"}
])
options = [host: "localhost", port: 5675, virtual_host: "/", username: "guest", password: "guest"]
{:ok, connection} = AMQP.Connection.open(options)
{:ok, channel} = AMQP.Channel.open(connection)
AMQP.Queue.declare(channel, "sneakers")
AMQP.Basic.publish(channel, "", "sneakers", "Setec Astronomy")