Skip to content

Instantly share code, notes, and snippets.

@kjnilsson
Created June 14, 2017 09:14
Show Gist options
  • Save kjnilsson/2666d0205a52c766e43f1ab14c6d48b4 to your computer and use it in GitHub Desktop.
Save kjnilsson/2666d0205a52c766e43f1ab14c6d48b4 to your computer and use it in GitHub Desktop.
include/amqp_client.hrl: connection_timeout = infinity,
src/amqp_channel.erl: gen_server:call(Channel, {call, Method, none, self()}, infinity).
src/amqp_channel.erl: gen_server:call(Channel, {call, Method, Content, self()}, infinity).
src/amqp_channel.erl: gen_server:call(Channel, {close, Code, Text}, infinity).
src/amqp_channel.erl: gen_server:call(Channel, next_publish_seqno, infinity).
src/amqp_channel.erl: wait_for_confirms(Channel, infinity).
src/amqp_channel.erl:%% Timeout = non_neg_integer() | 'infinity'
src/amqp_channel.erl: case gen_server:call(Channel, {wait_for_confirms, Timeout}, infinity) of
src/amqp_channel.erl: wait_for_confirms_or_die(Channel, infinity).
src/amqp_channel.erl:%% Timeout = non_neg_integer() | 'infinity'
src/amqp_channel.erl: gen_server:call(Channel, {call_consumer, Msg}, infinity).
src/amqp_channel.erl: gen_server:call(Channel, {subscribe, BasicConsume, Subscriber}, infinity).
src/amqp_channel.erl: gen_server:call(Pid, open, infinity).
src/amqp_channel.erl: infinity -> undefined;
src/amqp_channels_manager.erl: infinity).
src/amqp_channels_manager.erl: gen_server:call(ChMgr, is_empty, infinity).
src/amqp_channels_manager.erl: gen_server:call(ChMgr, num_channels, infinity).
src/amqp_connection.erl:%% <li>connection_timeout :: non_neg_integer() | 'infinity'
src/amqp_connection.erl:%% defaults to 'infinity' (network only)</li>
src/amqp_connection.erl: close(ConnectionPid, Code, Text, infinity).
src/amqp_connection_sup.erl: transient, infinity, supervisor,
src/amqp_connection_type_sup.erl: intrinsic, infinity, supervisor,
src/amqp_gen_connection.erl: gen_server:call(Pid, connect, infinity).
src/amqp_gen_connection.erl: infinity) of
src/amqp_gen_connection.erl: gen_server:call(Pid, {command, {close, Close, Timeout}}, infinity).
src/amqp_gen_connection.erl: gen_server:call(Pid, {info, Items}, infinity).
src/amqp_gen_connection.erl: gen_server:call(Pid, info_keys, infinity).
src/amqp_gen_connection.erl: infinity -> ok;
src/amqp_gen_consumer.erl: gen_server2:call(Pid, {consumer_call, Msg}, infinity).
src/amqp_gen_consumer.erl: gen_server2:call(Pid, {consumer_call, Method, Args}, infinity).
src/amqp_gen_consumer.erl: gen_server2:call(Pid, {consumer_call, Method, Args, DeliveryCtx}, infinity).
src/amqp_main_reader.erl: case rabbit_net:async_recv(Sock, 0, infinity) of
src/amqp_main_reader.erl: case rabbit_net:async_recv(Sock, 0, infinity) of
src/amqp_rpc_client.erl: gen_server:call(Pid, stop, infinity).
src/amqp_rpc_client.erl: gen_server:call(RpcClient, {call, Payload}, infinity).
src/amqp_rpc_server.erl: gen_server:call(Pid, stop, infinity).
src/amqp_sup.erl: temporary, infinity, supervisor, [amqp_connection_sup]}]}}.
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment