Add cuttlefish config and test

Author: lukebakken

Makefile

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

priv/schema/rabbitmq_stomp.schema

@@ -185,6 +185,15 @@ end}.
     {datatype, string}
 ]}.
 
+{mapping, "stomp.default_topic_exchange", "rabbitmq_stomp.default_topic_exchange", [
+    {datatype, string}
+]}.
+
+{translation, "rabbitmq_stomp.default_topic_exchange",
+fun(Conf) ->
+    list_to_binary(cuttlefish:conf_get("stomp.default_topic_exchange", Conf, "amq.topic"))
+end}.
+
 %% If a default user is configured, or you have configured use SSL client
 %% certificate based authentication, you can choose to allow clients to
 %% omit the CONNECT frame entirely. If set to true, the client is

src/rabbit_stomp_processor.erl

@@ -1186,19 +1186,19 @@ additional_info(Key,
     proplists:get_value(Key, AddInfo).
 
 maybe_apply_default_topic_exchange("amq.topic"=Exchange) ->
-    FromConfig = application:get_env(rabbitmq_stomp, default_topic_exchange, "amq.topic"),
+    FromConfig = application:get_env(rabbitmq_stomp, default_topic_exchange, <<"amq.topic">>),
     maybe_apply_default_topic_exchange(Exchange, FromConfig);
 maybe_apply_default_topic_exchange(Exchange) ->
     Exchange.
 
-maybe_apply_default_topic_exchange("amq.topic"=Exchange, "amq.topic") ->
+maybe_apply_default_topic_exchange("amq.topic"=Exchange, <<"amq.topic">>) ->
     %% This is the case where the destination is the same
     %% as the default of amq.topic
     Exchange;
 maybe_apply_default_topic_exchange("amq.topic", FromConfig) ->
     %% This is the case where the destination would have been
     %% amq.topic but we have configured a different default
-    FromConfig;
+    binary_to_list(FromConfig);
 maybe_apply_default_topic_exchange(Exchange, _FromConfig) ->
     %% This is the case where the destination is different than
     %% amq.topic, so it must have been specified in the

test/config_schema_SUITE_data/rabbitmq_stomp.snippets

@@ -84,4 +84,9 @@
  {default_vhost,
   "stomp.default_vhost = /",
   [{rabbitmq_stomp,[{default_vhost,<<"/">>}]}],
-  [rabbitmq_stomp]}].
+  [rabbitmq_stomp]},
+ {default_topic_exchange,
+  "stomp.default_topic_exchange = my.fancy.topic",
+  [{rabbitmq_stomp,[{default_topic_exchange,<<"my.fancy.topic">>}]}],
+  [rabbitmq_stomp]}
+].