feat(exclusive): update schema and conf

etc/emqx.conf

@@ -742,6 +742,11 @@ mqtt.wildcard_subscription = true
 ## Value: boolean
 mqtt.shared_subscription = true
 
+## Whether the Server supports MQTT Exclusive Subscriptions.
+##
+## Value: boolean
+mqtt.exclusive_subscription = false
+
 ## Whether to ignore loop delivery of messages.(for mqtt v3.1.1)
 ##
 ## Value: true | false
@@ -847,6 +852,11 @@ zone.external.force_gc_policy = 16000|16MB
 ## Value: boolean
 ## zone.external.shared_subscription = false
 
+## Whether the Server supports MQTT Exclusive Subscriptions.
+##
+## Value: boolean
+## zone.external.exclusive_subscription = false
+
 ## Server Keep Alive
 ##
 ## Value: Number
@@ -1049,6 +1059,11 @@ zone.internal.acl_deny_action = ignore
 ## Value: boolean
 ## zone.internal.shared_subscription = true
 
+## Whether the Server supports MQTT Exclusive Subscriptions.
+##
+## Value: boolean
+## zone.internal.exclusive_subscription = false
+
 ## See zone.$name.max_subscriptions.
 ##
 ## Value: Integer

priv/emqx.schema

@@ -946,8 +946,8 @@ end}.
 ]}.
 
 %% @doc Whether the Server supports Exclusive Subscriptions.
-{mapping, "mqtt.shared_subscription", "emqx.exclusive_subscription", [
+{mapping, "mqtt.exclusive_subscription", "emqx.exclusive_subscription", [
-    {default, true},
+    {default, false},
     {datatype, {enum, [true, false]}}
 ]}.
 
@@ -1207,6 +1207,7 @@ end}.
 
 %% @doc Whether the Server supports Exclusive Subscriptions.
 {mapping, "zone.$name.exclusive_subscription", "emqx.zones", [
+    {default, false},
     {datatype, {enum, [true, false]}}
 ]}.
 

src/emqx_exclusive_subscription.erl

@@ -86,7 +86,7 @@ unsubscribe(_Topic, _SubOpts) ->
 %%--------------------------------------------------------------------
 %% Internal functions
 %%--------------------------------------------------------------------
-try_subscribe(Topic, ClientId) ->
+try_subscribe(ClientId, Topic) ->
     case mnesia:wread({?TAB, Topic}) of
         [] ->
             mnesia:write(