Skip to content

Commit 24664c4

Browse files
committed
[broker-30] Cleanup code after merge
1 parent 94b32db commit 24664c4

File tree

4 files changed

+3
-8
lines changed

4 files changed

+3
-8
lines changed

model/src/main/java/javasabr/mqtt/model/subscriber/tree/ConcurrentSubscriberTree.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,6 @@
1313
import org.jspecify.annotations.Nullable;
1414

1515
@FieldDefaults(level = AccessLevel.PRIVATE, makeFinal = true)
16-
1716
public class ConcurrentSubscriberTree implements ThreadSafe {
1817

1918
SubscriberNode rootNode;

model/src/main/java/javasabr/mqtt/model/subscriber/tree/SubscriberNode.java

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -44,7 +44,6 @@ public SingleSubscriber subscribe(int level, SubscriptionOwner owner, Subscripti
4444
if (level == topicFilter.levelsCount()) {
4545
return addSubscriber(getOrCreateSubscribers(), owner, subscription, topicFilter);
4646
}
47-
4847
SubscriberNode childNode = getOrCreateChildNode(topicFilter.segment(level));
4948
return childNode.subscribe(level + 1, owner, subscription, topicFilter);
5049
}
@@ -53,7 +52,6 @@ public boolean unsubscribe(int level, SubscriptionOwner owner, TopicFilter topic
5352
if (level == topicFilter.levelsCount()) {
5453
return removeSubscriber(subscribers(), owner, topicFilter);
5554
}
56-
5755
SubscriberNode childNode = getOrCreateChildNode(topicFilter.segment(level));
5856
return childNode.unsubscribe(level + 1, owner, topicFilter);
5957
}
@@ -86,7 +84,6 @@ private void singleWildcardTopicMatch(
8684
TopicName topicName,
8785
int lastLevel,
8886
MutableArray<SingleSubscriber> result) {
89-
9087
SubscriberNode subscriberNode = childNode(TopicFilter.SINGLE_LEVEL_WILDCARD);
9188
if (subscriberNode == null) {
9289
return;
@@ -99,7 +96,6 @@ private void singleWildcardTopicMatch(
9996
}
10097

10198
private void multiWildcardTopicMatch(MutableArray<SingleSubscriber> result) {
102-
10399
SubscriberNode subscriberNode = childNode(TopicFilter.MULTI_LEVEL_WILDCARD);
104100
if (subscriberNode != null) {
105101
appendSubscribersTo(result, subscriberNode);

model/src/main/java/javasabr/mqtt/model/topic/TopicFilter.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -11,9 +11,9 @@
1111
public class TopicFilter extends AbstractTopic {
1212

1313
public static final String MULTI_LEVEL_WILDCARD = "#";
14-
public static final char MULTI_LEVEL_WILDCARD_CHAR = MULTI_LEVEL_WILDCARD.charAt(0);
14+
public static final char MULTI_LEVEL_WILDCARD_CHAR = '#';
1515
public static final String SINGLE_LEVEL_WILDCARD = "+";
16-
public static final char SINGLE_LEVEL_WILDCARD_CHAR = SINGLE_LEVEL_WILDCARD.charAt(0);
16+
public static final char SINGLE_LEVEL_WILDCARD_CHAR = '+';
1717
public static final String SPECIAL = "$";
1818

1919
public static final TopicFilter INVALID_TOPIC_FILTER = new TopicFilter("$invalid$") {
Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
11
@NullMarked
22
package javasabr.mqtt.model.topic.tree;
33

4-
import org.jspecify.annotations.NullMarked;
4+
import org.jspecify.annotations.NullMarked;

0 commit comments

Comments
 (0)