[rabbitmq-discuss] Message receive error

Wed Jul 6 08:50:46 BST 2011

Hello,

I have code

-module(send).
-export([main/0]).

-include_lib("amqp_client/include/amqp_client.hrl").

main() ->
    io:format("Connect \n"),
    {ok, Connection} =
        amqp_connection:start(#amqp_params_network{host = "localhost",
						   password = <<"password">>}),

    io:format("Open channel \n"),
    {ok, Channel} = amqp_connection:open_channel(Connection),
    amqp_channel:call(Channel, #'queue.declare'{queue = <<"test1">>}),
    amqp_channel:subscribe(Channel, #'basic.consume'{queue =
<<"test2">>}, self()),

   io:format("send message \n"),

    Message = <<"test message">>,
    amqp_channel:cast(Channel, #'basic.publish'{exchange = <<"">>,
routing_key = <<"test1">>},
		      #amqp_msg{payload = Message}),

    io:format("message sended \n"),

    receive
        #'basic.consume_ok'{} -> ok
    end,
    loop(Channel).

loop(Channel) ->
    io:format("Loop start"),
    receive
	{#'basic.deliver'{delivery_tag = Tag}, Content} ->
	    io:format("Message receive"),
	    amqp_channel:cast(Channel, #'basic.ack'{delivery_tag = Tag}),
	    loop(Channel);
	_ ->
	    loop(Channel)
    end.

I get error when run it:

Eshell V5.8.1  (abort with ^G)
1> send:main().
Connect
Open channel
** exception exit: {{shutdown,{server_initiated_close,404,
                                                      <<"NOT_FOUND -
no queue 'test2' in vhost '/'">>}},
                    {gen_server,call,
                                [<0.48.0>,

{subscribe,{'basic.consume',0,<<"test2">>,<<>>,false,

false,false,false,[]},
                                            <0.32.0>},
                                 infinity]}}
     in function  gen_server:call/3
     in call from send:main/0

How can i send and receive message?

Thank you.