root
/
rabbitmq-server
mirror of https://github.com/rabbitmq/rabbitmq-server.git
1
0
Fork 0
Code Issues Actions Packages Projects Releases Wiki Activity

API change

This commit is contained in:
Simon MacMullen 2013-01-09 12:06:09 +00:00
parent cb693d294a
commit 441a099dd0
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
deps/rabbitmq_mqtt/src/rabbit_mqtt_processor.erl vendored
View File

@ -452,8 +452,8 @@ amqp_pub(#mqtt_msg{ qos = Qos,
awaiting_seqno = SeqNo1 }.
adapter_info(Sock) ->
amqp_direct_connection:socket_adapter_info(
Sock,{'MQTT', {?MQTT_PROTO_MAJOR, ?MQTT_PROTO_MINOR}}).
amqp_connection:socket_adapter_info(
Sock, {'MQTT', {?MQTT_PROTO_MAJOR, ?MQTT_PROTO_MINOR}}).
send_client(Frame, #proc_state{ socket = Sock }) ->
%rabbit_log:info("MQTT sending frame ~p ~n", [Frame]),