diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2010-07-02 16:22:19 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2010-07-02 16:22:19 +0100 |
| commit | b12b37d042c71e715d5c12ea99a5d57435aeebdb (patch) | |
| tree | 7249aaed39aa9c0c8dade561284b103aa8fc6532 /src | |
| parent | cc02e78c26074b62bab6441c8a022421e18c6cd6 (diff) | |
| download | rabbitmq-server-git-b12b37d042c71e715d5c12ea99a5d57435aeebdb.tar.gz | |
oops
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_reader.erl | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/src/rabbit_reader.erl b/src/rabbit_reader.erl index ee95a4626f..72d95c7bd7 100644 --- a/src/rabbit_reader.erl +++ b/src/rabbit_reader.erl @@ -757,13 +757,13 @@ i(Item, #v1{}) -> %%-------------------------------------------------------------------------- send_to_new_channel(Channel, AnalyzedFrame, - State = #v1{connection = #connection{ - frame_max = FrameMax, - user = #user{username = Username}, - vhost = VHost, - protocol = Protocol}, - sock = Sock, - queue_collector = Collector}) -> + #v1{connection = #connection{ + frame_max = FrameMax, + user = #user{username = Username}, + vhost = VHost, + protocol = Protocol}, + sock = Sock, + queue_collector = Collector}) -> WriterPid = rabbit_writer:start(Sock, Channel, FrameMax, Protocol), ChPid = rabbit_framing_channel:start_link( fun rabbit_channel:start_link/6, |
