AF
Size: a a a
AF
ŹR
D
defmodule AMQP.Receiver do
def wait_for_messages do
queue_name = "message_to_chat"
{:ok, connection} = AMQP.Connection.open(host: 'rabbitmq')
{:ok, channel} = AMQP.Channel.open(connection)
AMQP.Queue.declare(channel, queue_name)
AMQP.Basic.consume(channel, queue_name, nil, no_ack: true)
_wait_for_messages()
end
defp _wait_for_messages do
receive do
{:basic_deliver, payload, _meta} ->
IO.puts payload
_wait_for_messages()
end
end
end
AF
D
ŹR
D
jc
jc
VS
jc
jc
FM
jc
jc
PS
jc
ПК
ПК
к