diff options
| author | Matthew Sackman <matthew@rabbitmq.com> | 2011-02-14 18:10:44 +0000 |
|---|---|---|
| committer | Matthew Sackman <matthew@rabbitmq.com> | 2011-02-14 18:10:44 +0000 |
| commit | 88651d6fc3d3f6bfcd9a94bceec465d9a5271865 (patch) | |
| tree | 42e01c371f0c83b5ee8d93f0ebf7031d81a46880 /src/rabbit_direct.erl | |
| parent | ab98fba181a2c34d81958bee8be72535bc2b7321 (diff) | |
| download | rabbitmq-server-88651d6fc3d3f6bfcd9a94bceec465d9a5271865.tar.gz | |
Pass client capabilities through to the channel
Diffstat (limited to 'src/rabbit_direct.erl')
| -rw-r--r-- | src/rabbit_direct.erl | 14 |
1 files changed, 8 insertions, 6 deletions
diff --git a/src/rabbit_direct.erl b/src/rabbit_direct.erl index 3b8c9fba..34f868cb 100644 --- a/src/rabbit_direct.erl +++ b/src/rabbit_direct.erl @@ -16,7 +16,7 @@ -module(rabbit_direct). --export([boot/0, connect/3, start_channel/5]). +-export([boot/0, connect/3, start_channel/6]). -include("rabbit.hrl"). @@ -28,9 +28,10 @@ -spec(connect/3 :: (binary(), binary(), binary()) -> {'ok', {rabbit_types:user(), rabbit_framing:amqp_table()}}). --spec(start_channel/5 :: (rabbit_channel:channel_number(), pid(), - rabbit_types:user(), rabbit_types:vhost(), pid()) -> - {'ok', pid()}). +-spec(start_channel/6 :: + (rabbit_framing:amqp_table(), rabbit_channel:channel_number(), pid(), + rabbit_types:user(), rabbit_types:vhost(), pid()) -> + {'ok', pid()}). -endif. @@ -67,9 +68,10 @@ connect(Username, Password, VHost) -> {error, broker_not_found_on_node} end. -start_channel(Number, ClientChannelPid, User, VHost, Collector) -> +start_channel(Capabilities, Number, ClientChannelPid, User, VHost, Collector) -> {ok, _, {ChannelPid, _}} = supervisor2:start_child( rabbit_direct_client_sup, - [{direct, Number, ClientChannelPid, User, VHost, Collector}]), + [{direct, Capabilities, Number, ClientChannelPid, User, VHost, + Collector}]), {ok, ChannelPid}. |