diff options
| author | ash <ash@lshift.net> | 2015-09-25 12:52:51 +0100 |
|---|---|---|
| committer | ash <ash@lshift.net> | 2015-09-25 12:53:11 +0100 |
| commit | ce514ace295baa88270a0dbfc075f106e966e2f8 (patch) | |
| tree | a3dbae819c35ded08ca134a1af9814a39ead7669 /src | |
| parent | e35e05833ad9a36f7461e94f59666b16083cc984 (diff) | |
| download | rabbitmq-server-git-ce514ace295baa88270a0dbfc075f106e966e2f8.tar.gz | |
allow initial frame_max to be configured
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_reader.erl | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/rabbit_reader.erl b/src/rabbit_reader.erl index c1cfb10c67..d2b2bb812d 100644 --- a/src/rabbit_reader.erl +++ b/src/rabbit_reader.erl @@ -336,6 +336,7 @@ start_connection(Parent, HelperSup, Deb, Sock, SockTransform) -> exit(normal) end, {ok, HandshakeTimeout} = application:get_env(rabbit, handshake_timeout), + InitialFrameMax = application:get_env(rabbit, initial_frame_max, ?FRAME_MIN_SIZE), ClientSock = socket_op(Sock, SockTransform), erlang:send_after(HandshakeTimeout, self(), handshake_timeout), {PeerHost, PeerPort, Host, Port} = @@ -352,7 +353,7 @@ start_connection(Parent, HelperSup, Deb, Sock, SockTransform) -> protocol = none, user = none, timeout_sec = (HandshakeTimeout / 1000), - frame_max = ?FRAME_MIN_SIZE, + frame_max = InitialFrameMax, vhost = none, client_properties = none, capabilities = [], |