Skip to content

Commit f5b8922

Browse files
committed
[broker-5] rename topicFilter argument to topic name
1 parent fd5c67d commit f5b8922

File tree

1 file changed

+6
-6
lines changed

1 file changed

+6
-6
lines changed

src/main/java/com/ss/mqtt/broker/service/impl/SimpleSubscriptions.java

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -29,26 +29,26 @@ public class SimpleSubscriptions implements Subscriptions {
2929
}
3030

3131
public @NotNull SubscribeAckReasonCode addSubscription(
32-
@NotNull SubscribeTopicFilter topicFilter,
32+
@NotNull SubscribeTopicFilter topicName,
3333
@NotNull MqttClient mqttClient
3434
) {
35-
var subscriber = new Subscriber(mqttClient, topicFilter);
35+
var subscriber = new Subscriber(mqttClient, topicName);
3636
var subscribers = subscriptions.computeIfAbsent(
37-
topicFilter.getTopicFilter(),
37+
topicName.getTopicFilter(),
3838
key -> new FastArraySet<>(Subscriber.class)
3939
);
4040
subscribers.add(subscriber);
41-
return topicFilter.getQos().getSubscribeAckReasonCode();
41+
return topicName.getQos().getSubscribeAckReasonCode();
4242
}
4343

4444
/**
4545
* Return true if subscription is removed
4646
*/
4747
public @NotNull UnsubscribeAckReasonCode removeSubscription(
48-
@NotNull String topicFilter,
48+
@NotNull String topicName,
4949
@NotNull MqttClient mqttClient
5050
) {
51-
var subscribers = subscriptions.getOrDefault(topicFilter, Array.empty());
51+
var subscribers = subscriptions.getOrDefault(topicName, Array.empty());
5252
if (subscribers.removeIf(subscriber -> mqttClient.equals(subscriber.getMqttClient()))) {
5353
return UnsubscribeAckReasonCode.SUCCESS;
5454
} else {

0 commit comments

Comments
 (0)