File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed
src/main/java/com/ss/mqtt/broker/service/impl Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -29,16 +29,16 @@ public class SimpleSubscriptions implements Subscriptions {
2929 }
3030
3131 public @ NotNull SubscribeAckReasonCode addSubscription (
32- @ NotNull SubscribeTopicFilter topicName ,
32+ @ NotNull SubscribeTopicFilter topicFilter ,
3333 @ NotNull MqttClient mqttClient
3434 ) {
35- var subscriber = new Subscriber (mqttClient , topicName );
35+ var subscriber = new Subscriber (mqttClient , topicFilter );
3636 var subscribers = subscriptions .computeIfAbsent (
37- topicName .getTopicFilter (),
37+ topicFilter .getTopicFilter (),
3838 key -> new FastArraySet <>(Subscriber .class )
3939 );
4040 subscribers .add (subscriber );
41- return topicName .getQos ().getSubscribeAckReasonCode ();
41+ return topicFilter .getQos ().getSubscribeAckReasonCode ();
4242 }
4343
4444 /**
You can’t perform that action at this time.
0 commit comments