summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMatthew Sackman <matthew@rabbitmq.com>2011-06-24 15:02:47 +0100
committerMatthew Sackman <matthew@rabbitmq.com>2011-06-24 15:02:47 +0100
commita8edc75e7239a1e872734219a7b8e17bc852062a (patch)
tree01966ecfd019ba153be7a14d2d87ea03256228e6
parente25775ed83d4fb6190c755cf52182678715fbe8c (diff)
downloadrabbitmq-server-bug23956.tar.gz
Avoid changing any api for erlang client directbug23956
-rw-r--r--src/rabbit_direct.erl10
1 files changed, 8 insertions, 2 deletions
diff --git a/src/rabbit_direct.erl b/src/rabbit_direct.erl
index 7ff534ee..4c93dcdb 100644
--- a/src/rabbit_direct.erl
+++ b/src/rabbit_direct.erl
@@ -75,11 +75,17 @@ connect(Username, VHost, Protocol, Infos) ->
start_channel(Number, ClientChannelPid, ConnPid, Protocol, User, VHost,
Capabilities, Collector) ->
+ Connection = #connection{protocol = Protocol,
+ user = User,
+ timeout_sec = 0,
+ frame_max = 0,
+ vhost = VHost,
+ client_properties = [],
+ capabilities = Capabilities},
{ok, _, {ChannelPid, _}} =
supervisor2:start_child(
rabbit_direct_client_sup,
- [{direct, Number, ClientChannelPid, ConnPid, Protocol, User, VHost,
- Capabilities, Collector}]),
+ [{direct, Number, ClientChannelPid, ConnPid, Connection, Collector}]),
{ok, ChannelPid}.
disconnect(Infos) ->