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

Fixed compiler warnings

This commit is contained in:
Ben Hood 2008-12-07 01:19:04 +00:00
parent ce36c34f77
commit a4e103eb97
1 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
deps/amqp_client/src/test_util.erl vendored
View File

@ -228,14 +228,14 @@ basic_qos_test(Connection) ->
Parent = self(),
lib_amqp:declare_queue(lib_amqp:start_channel(Connection), Q),
%Channel = lib_amqp:start_channel(Connection),
Consumers = [spawn(fun() -> Channel = lib_amqp:start_channel(Connection),
amqp_channel:call(Channel,
#'basic.qos'{prefetch_count = 1}),
lib_amqp:subscribe(Channel, Q, self(), false),
amqp_channel:call(Channel,
#'basic.qos'{prefetch_count = 1}),
sleeping_consumer(Channel, Sleep, Parent) end)
|| Sleep <- lists:seq(1, Workers)],
[spawn(fun() -> Channel = lib_amqp:start_channel(Connection),
amqp_channel:call(Channel,
#'basic.qos'{prefetch_count = 1}),
lib_amqp:subscribe(Channel, Q, self(), false),
amqp_channel:call(Channel,
#'basic.qos'{prefetch_count = 1}),
sleeping_consumer(Channel, Sleep, Parent) end)
|| Sleep <- lists:seq(1, Workers)],
latch_loop(Workers),
producer_loop(lib_amqp:start_channel(Connection), Q, Messages),
latch_loop(Messages),
@ -255,7 +255,7 @@ sleeping_consumer(Channel, Sleep, Parent) ->
sleeping_consumer(Channel, Sleep, Parent)
end.
producer_loop(Channel, RoutingKey, 0) ->
producer_loop(_Channel, _RoutingKey, 0) ->
ok;
producer_loop(Channel, RoutingKey, N) ->