Skip to content

Commit 7c6c81a

Browse files
JavaSaBrJavaSaBr
committed
start restructuring project
1 parent ac6a6a4 commit 7c6c81a

File tree

231 files changed

+1061
-994
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

231 files changed

+1061
-994
lines changed

‎application/build.gradle‎

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,8 @@
1+
plugins {
2+
id "java-library"
3+
}
4+
5+
dependencies {
6+
7+
testImplementation projects.testSupport
8+
}

‎base/build.gradle‎

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,6 @@
1+
apply plugin: "java-library"
2+
apply from: "$rootDir/gradle/configure-java.gradle"
3+
4+
dependencies {
5+
testImplementation projects.testSupport
6+
}

‎build.gradle‎

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,16 @@ repositories {
2020
rootProject.version = "0.0.1"
2121
group = "javasabr.mqtt"
2222

23+
subprojects {
24+
repositories {
25+
mavenCentral()
26+
mavenLocal()
27+
maven {
28+
url "https://gitlab.com/api/v4/projects/37512056/packages/maven"
29+
}
30+
}
31+
}
32+
2333
allprojects {
2434
apply plugin: "java"
2535
apply plugin: "groovy"

‎gradle/configure-java.gradle‎

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,5 @@
1+
dependencies {
2+
compileOnly libs.jspecify
3+
compileOnly libs.lombok
4+
annotationProcessor libs.lombok
5+
}

‎legacy/build.gradle‎

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,10 @@
1+
plugins {
2+
id "java"
3+
}
4+
5+
apply from: "$rootDir/gradle/configure-java.gradle"
6+
7+
dependencies {
8+
9+
testImplementation projects.testSupport
10+
}

‎src/main/java/com/ss/mqtt/broker/MqttBrokerApplication.java‎ renamed to ‎legacy/src/main/java/javasabr/mqtt/legacy/MqttBrokerApplication.java‎

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

3-
import com.ss.mqtt.broker.config.MqttBrokerConfig;
4-
import com.ss.mqtt.broker.config.MqttNetworkConfig;
3+
import javasabr.mqtt.legacy.config.MqttBrokerConfig;
4+
import javasabr.mqtt.legacy.config.MqttNetworkConfig;
55
import lombok.RequiredArgsConstructor;
66
import org.springframework.boot.SpringApplication;
77
import org.springframework.context.annotation.Configuration;

‎src/main/java/com/ss/mqtt/broker/config/MqttBrokerConfig.java‎ renamed to ‎legacy/src/main/java/javasabr/mqtt/legacy/config/MqttBrokerConfig.java‎

Lines changed: 34 additions & 34 deletions
Original file line numberDiff line numberDiff line change
@@ -1,38 +1,38 @@
1-
package com.ss.mqtt.broker.config;
1+
package javasabr.mqtt.legacy.config;
22

3-
import com.ss.mqtt.broker.handler.client.DefaultMqttClientReleaseHandler;
4-
import com.ss.mqtt.broker.handler.client.MqttClientReleaseHandler;
5-
import com.ss.mqtt.broker.handler.packet.in.ConnectInPacketHandler;
6-
import com.ss.mqtt.broker.handler.packet.in.DisconnetInPacketHandler;
7-
import com.ss.mqtt.broker.handler.packet.in.PacketInHandler;
8-
import com.ss.mqtt.broker.handler.packet.in.PublishAckInPacketHandler;
9-
import com.ss.mqtt.broker.handler.packet.in.PublishCompleteInPacketHandler;
10-
import com.ss.mqtt.broker.handler.packet.in.PublishInPacketHandler;
11-
import com.ss.mqtt.broker.handler.packet.in.PublishReceiveInPacketHandler;
12-
import com.ss.mqtt.broker.handler.packet.in.PublishReleaseInPacketHandler;
13-
import com.ss.mqtt.broker.handler.packet.in.SubscribeInPacketHandler;
14-
import com.ss.mqtt.broker.handler.packet.in.UnsubscribeInPacketHandler;
15-
import com.ss.mqtt.broker.handler.publish.in.PublishInHandler;
16-
import com.ss.mqtt.broker.handler.publish.in.Qos0PublishInHandler;
17-
import com.ss.mqtt.broker.handler.publish.in.Qos1PublishInHandler;
18-
import com.ss.mqtt.broker.handler.publish.in.Qos2PublishInHandler;
19-
import com.ss.mqtt.broker.handler.publish.out.PublishOutHandler;
20-
import com.ss.mqtt.broker.handler.publish.out.Qos0PublishOutHandler;
21-
import com.ss.mqtt.broker.handler.publish.out.Qos1PublishOutHandler;
22-
import com.ss.mqtt.broker.handler.publish.out.Qos2PublishOutHandler;
23-
import com.ss.mqtt.broker.network.packet.PacketType;
24-
import com.ss.mqtt.broker.service.AuthenticationService;
25-
import com.ss.mqtt.broker.service.ClientIdRegistry;
26-
import com.ss.mqtt.broker.service.CredentialSource;
27-
import com.ss.mqtt.broker.service.MqttSessionService;
28-
import com.ss.mqtt.broker.service.PublishingService;
29-
import com.ss.mqtt.broker.service.SubscriptionService;
30-
import com.ss.mqtt.broker.service.impl.DefaultPublishingService;
31-
import com.ss.mqtt.broker.service.impl.FileCredentialsSource;
32-
import com.ss.mqtt.broker.service.impl.InMemoryClientIdRegistry;
33-
import com.ss.mqtt.broker.service.impl.InMemoryMqttSessionService;
34-
import com.ss.mqtt.broker.service.impl.SimpleAuthenticationService;
35-
import com.ss.mqtt.broker.service.impl.SimpleSubscriptionService;
3+
import javasabr.mqtt.legacy.handler.client.DefaultMqttClientReleaseHandler;
4+
import javasabr.mqtt.legacy.handler.client.MqttClientReleaseHandler;
5+
import javasabr.mqtt.legacy.handler.packet.in.ConnectInPacketHandler;
6+
import javasabr.mqtt.legacy.handler.packet.in.DisconnetInPacketHandler;
7+
import javasabr.mqtt.legacy.handler.packet.in.PacketInHandler;
8+
import javasabr.mqtt.legacy.handler.packet.in.PublishAckInPacketHandler;
9+
import javasabr.mqtt.legacy.handler.packet.in.PublishCompleteInPacketHandler;
10+
import javasabr.mqtt.legacy.handler.packet.in.PublishInPacketHandler;
11+
import javasabr.mqtt.legacy.handler.packet.in.PublishReceiveInPacketHandler;
12+
import javasabr.mqtt.legacy.handler.packet.in.PublishReleaseInPacketHandler;
13+
import javasabr.mqtt.legacy.handler.packet.in.SubscribeInPacketHandler;
14+
import javasabr.mqtt.legacy.handler.packet.in.UnsubscribeInPacketHandler;
15+
import javasabr.mqtt.legacy.handler.publish.in.PublishInHandler;
16+
import javasabr.mqtt.legacy.handler.publish.in.Qos0PublishInHandler;
17+
import javasabr.mqtt.legacy.handler.publish.in.Qos1PublishInHandler;
18+
import javasabr.mqtt.legacy.handler.publish.in.Qos2PublishInHandler;
19+
import javasabr.mqtt.legacy.handler.publish.out.PublishOutHandler;
20+
import javasabr.mqtt.legacy.handler.publish.out.Qos0PublishOutHandler;
21+
import javasabr.mqtt.legacy.handler.publish.out.Qos1PublishOutHandler;
22+
import javasabr.mqtt.legacy.handler.publish.out.Qos2PublishOutHandler;
23+
import javasabr.mqtt.legacy.network.packet.PacketType;
24+
import javasabr.mqtt.legacy.service.AuthenticationService;
25+
import javasabr.mqtt.legacy.service.ClientIdRegistry;
26+
import javasabr.mqtt.legacy.service.CredentialSource;
27+
import javasabr.mqtt.legacy.service.MqttSessionService;
28+
import javasabr.mqtt.legacy.service.PublishingService;
29+
import javasabr.mqtt.legacy.service.SubscriptionService;
30+
import javasabr.mqtt.legacy.service.impl.DefaultPublishingService;
31+
import javasabr.mqtt.legacy.service.impl.FileCredentialsSource;
32+
import javasabr.mqtt.legacy.service.impl.InMemoryClientIdRegistry;
33+
import javasabr.mqtt.legacy.service.impl.InMemoryMqttSessionService;
34+
import javasabr.mqtt.legacy.service.impl.SimpleAuthenticationService;
35+
import javasabr.mqtt.legacy.service.impl.SimpleSubscriptionService;
3636
import lombok.RequiredArgsConstructor;
3737
import lombok.extern.log4j.Log4j2;
3838
import org.springframework.context.annotation.Bean;

‎src/main/java/com/ss/mqtt/broker/config/MqttConnectionConfig.java‎ renamed to ‎legacy/src/main/java/javasabr/mqtt/legacy/config/MqttConnectionConfig.java‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
1-
package com.ss.mqtt.broker.config;
1+
package javasabr.mqtt.legacy.config;
22

3-
import com.ss.mqtt.broker.model.QoS;
3+
import javasabr.mqtt.legacy.model.QoS;
44
import lombok.Getter;
55
import lombok.RequiredArgsConstructor;
66

‎src/main/java/com/ss/mqtt/broker/config/MqttNetworkConfig.java‎ renamed to ‎legacy/src/main/java/javasabr/mqtt/legacy/config/MqttNetworkConfig.java‎

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -1,13 +1,13 @@
1-
package com.ss.mqtt.broker.config;
1+
package javasabr.mqtt.legacy.config;
22

3-
import com.ss.mqtt.broker.handler.client.MqttClientReleaseHandler;
4-
import com.ss.mqtt.broker.handler.packet.in.PacketInHandler;
5-
import com.ss.mqtt.broker.model.MqttPropertyConstants;
6-
import com.ss.mqtt.broker.model.QoS;
7-
import com.ss.mqtt.broker.network.MqttConnection;
8-
import com.ss.mqtt.broker.network.client.ExternalMqttClient;
9-
import com.ss.mqtt.broker.network.client.InternalMqttClient;
10-
import com.ss.mqtt.broker.network.client.MqttClient.UnsafeMqttClient;
3+
import javasabr.mqtt.legacy.handler.client.MqttClientReleaseHandler;
4+
import javasabr.mqtt.legacy.handler.packet.in.PacketInHandler;
5+
import javasabr.mqtt.legacy.model.MqttPropertyConstants;
6+
import javasabr.mqtt.legacy.model.QoS;
7+
import javasabr.mqtt.legacy.network.MqttConnection;
8+
import javasabr.mqtt.legacy.network.client.ExternalMqttClient;
9+
import javasabr.mqtt.legacy.network.client.InternalMqttClient;
10+
import javasabr.mqtt.legacy.network.client.MqttClient.UnsafeMqttClient;
1111
import java.net.InetSocketAddress;
1212
import java.nio.channels.AsynchronousSocketChannel;
1313
import java.util.function.BiFunction;

‎src/main/java/com/ss/mqtt/broker/service/package-info.java‎ renamed to ‎legacy/src/main/java/javasabr/mqtt/legacy/config/package-info.java‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
11
@NullMarked
2-
package com.ss.mqtt.broker.service;
2+
package javasabr.mqtt.legacy.config;
33

44
import org.jspecify.annotations.NullMarked;

0 commit comments

Comments
 (0)