root
/
rabbitmq-server
mirror of https://github.com/rabbitmq/rabbitmq-server.git
1
0
Fork 0
Code Issues Actions Packages Projects Releases Wiki Activity

RPC client starts channel in init/1

This commit is contained in:
Ben Hood 2008-12-23 14:14:52 +00:00
parent ae742ea9fc
commit 53485d6c06
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
deps/amqp_client/src/amqp_rpc_client.erl vendored
View File

@ -41,8 +41,7 @@
%---------------------------------------------------------------------------
start(Connection, Queue) ->
Channel = lib_amqp:start_channel(Connection),
{ok, Pid} = gen_server:start(?MODULE, [Channel, Queue], []),
{ok, Pid} = gen_server:start(?MODULE, [Connection, Queue], []),
Pid.
stop(Pid) ->
@ -89,7 +88,8 @@ publish(Payload, From,
%---------------------------------------------------------------------------
% Sets up a reply queue and consumer within an existing channel
init([Channel, RoutingKey]) ->
init([Connection, RoutingKey]) ->
Channel = lib_amqp:start_channel(Connection),
InitialState = #rpc_client_state{channel = Channel,
exchange = <<>>,
routing_key = RoutingKey},