Skip to content

Commit 2c1f128

Browse files
committed
move subscriber
1 parent bc0a1a9 commit 2c1f128

File tree

5 files changed

+16
-9
lines changed

5 files changed

+16
-9
lines changed

legacy/src/main/java/javasabr/mqtt/legacy/model/SharedSubscriber.java renamed to model/src/main/java/javasabr/mqtt/model/subscriber/SharedSubscriber.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
1-
package javasabr.mqtt.legacy.model;
1+
package javasabr.mqtt.model.subscriber;
22

3-
import javasabr.mqtt.legacy.model.topic.SharedTopicFilter;
4-
import javasabr.mqtt.legacy.network.client.MqttClient;
3+
import javasabr.mqtt.model.network.MqttClient;
4+
import javasabr.mqtt.model.topic.SharedTopicFilter;
55
import java.util.Collection;
66
import java.util.concurrent.atomic.AtomicInteger;
77
import javasabr.rlib.collections.array.Array;

legacy/src/main/java/javasabr/mqtt/legacy/model/SingleSubscriber.java renamed to model/src/main/java/javasabr/mqtt/model/subscriber/SingleSubscriber.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
1-
package javasabr.mqtt.legacy.model;
1+
package javasabr.mqtt.model.subscriber;
22

3-
import javasabr.mqtt.legacy.network.client.MqttClient;
3+
import javasabr.mqtt.model.QoS;
4+
import javasabr.mqtt.model.network.MqttClient;
45
import lombok.EqualsAndHashCode;
56
import lombok.Getter;
67
import lombok.RequiredArgsConstructor;

legacy/src/main/java/javasabr/mqtt/legacy/model/SubscribeTopicFilter.java renamed to model/src/main/java/javasabr/mqtt/model/subscriber/SubscribeTopicFilter.java

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,10 @@
1-
package javasabr.mqtt.legacy.model;
1+
package javasabr.mqtt.model.subscriber;
22

3-
import static javasabr.mqtt.legacy.util.TopicUtils.buildTopicFilter;
3+
import static javasabr.mqtt.model.utils.TopicUtils.buildTopicFilter;
44

5-
import javasabr.mqtt.legacy.model.topic.TopicFilter;
5+
import javasabr.mqtt.model.topic.TopicFilter;
6+
import javasabr.mqtt.model.QoS;
7+
import javasabr.mqtt.model.SubscribeRetainHandling;
68
import lombok.EqualsAndHashCode;
79
import lombok.Getter;
810
import lombok.RequiredArgsConstructor;
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,3 @@
1-
package javasabr.mqtt.legacy.model;
1+
package javasabr.mqtt.model.subscriber;
22

33
public sealed interface Subscriber permits SingleSubscriber, SharedSubscriber {}
Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,4 @@
1+
@NullMarked
2+
package javasabr.mqtt.model.subscriber;
3+
4+
import org.jspecify.annotations.NullMarked;

0 commit comments

Comments
 (0)