Native (Web)STOMP

Author: deadtrickster

deps/rabbitmq_stomp/Makefile

@@ -9,7 +9,7 @@ define PROJECT_ENV
 	      {passcode, <<"guest">>}]},
 	    {default_vhost, <<"/">>},
 	    {default_topic_exchange, <<"amq.topic">>},
-		{default_nack_requeue, true},
+	    {default_nack_requeue, true},
 	    {ssl_cert_login, false},
 	    {implicit_connect, false},
 	    {tcp_listeners, [61613]},

deps/rabbitmq_stomp/include/rabbit_stomp.hrl

@@ -15,15 +15,16 @@
 
 -define(INFO_ITEMS,
         [conn_name,
+         name,
+         user,
          connection,
          connection_state,
          session_id,
-         channel,
          version,
          implicit_connect,
          auth_login,
          auth_mechanism,
-         peer_addr,
+         %% peer_addr,
          host,
          port,
          peer_host,
@@ -42,3 +43,16 @@
 -define(STOMP_GUIDE_URL, <<"https://rabbitmq.com/docs/stomp">>).
 
 -define(DEFAULT_MAX_FRAME_SIZE, 4 * 1024 * 1024).
+
+-define(SIMPLE_METRICS,
+        [pid,
+         recv_oct,
+         send_oct,
+         reductions]).
+-define(OTHER_METRICS,
+        [recv_cnt,
+         send_cnt,
+         send_pend,
+         garbage_collection,
+         state,
+         timeout]).

deps/rabbitmq_stomp/include/rabbit_stomp_headers.hrl

@@ -81,3 +81,20 @@
                         ?HEADER_EXCLUSIVE,
                         ?HEADER_PERSISTENT
                        ]).
+
+
+-define(QUEUE_PREFIX, "/queue").
+-define(TOPIC_PREFIX, "/topic").
+-define(EXCHANGE_PREFIX, "/exchange").
+-define(AMQQUEUE_PREFIX, "/amq/queue").
+-define(TEMP_QUEUE_PREFIX, "/temp-queue").
+%% reply queues names can have slashes in the content so no further
+%% parsing happens.
+-define(REPLY_QUEUE_PREFIX, "/reply-queue/").
+
+%%-------------------------------------------------
+
+-define(DEST_PREFIXES, [?EXCHANGE_PREFIX, ?TOPIC_PREFIX, ?QUEUE_PREFIX,
+                        ?AMQQUEUE_PREFIX, ?REPLY_QUEUE_PREFIX]).
+
+-define(ALL_DEST_PREFIXES, [?TEMP_QUEUE_PREFIX | ?DEST_PREFIXES]).

deps/rabbitmq_stomp/src/rabbit_stomp.erl

@@ -28,6 +28,7 @@
 start(normal, []) ->
     Config = parse_configuration(),
     Listeners = parse_listener_configuration(),
+    rabbit_global_counters:init([{protocol, stomp}]),
     Result = rabbit_stomp_sup:start_link(Listeners, Config),
     EMPid = case rabbit_event:start_link() of
               {ok, Pid}                       -> Pid;