MQTT connections use exactly one channel

2016-02-02 16:03:24 +01:00 · 2016-02-02 16:03:24 +01:00 · 738f263798
parent 7b42c20b7e
commit 738f263798
1 changed files with 8 additions and 1 deletions
--- a/deps/rabbitmq_mqtt/src/rabbit_mqtt_processor.erl
+++ b/deps/rabbitmq_mqtt/src/rabbit_mqtt_processor.erl
@ -36,7 +36,14 @@ initial_state(Socket, SSLLoginName) ->
        adapter_info(Socket, 'MQTT'),
        fun send_client/2).

-initial_state(Socket, SSLLoginName, AdapterInfo, SendFun) ->
+initial_state(Socket, SSLLoginName,
+              AdapterInfo0 = #amqp_adapter_info{additional_info=Extra},
+              SendFun) ->
+    %% MQTT connections use exactly one channel.
+    AdapterInfo = AdapterInfo0#amqp_adapter_info{additional_info=[
+        {channels, 1},
+        {channel_max, 1}
+        |Extra]},
    #proc_state{ unacked_pubs   = gb_trees:empty(),
                 awaiting_ack   = gb_trees:empty(),
                 message_id     = 1,