Skip to content

Commit 7ae4fc9

Browse files
committed
continue rework network part
1 parent 6b7f3d1 commit 7ae4fc9

File tree

11 files changed

+147
-403
lines changed

11 files changed

+147
-403
lines changed

application/src/main/java/javasabr/mqtt/broker/application/config/MqttBrokerConfig.java

Lines changed: 0 additions & 66 deletions
This file was deleted.

application/src/main/java/javasabr/mqtt/broker/application/config/MqttBrokerSpringConfig.java

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -14,14 +14,14 @@
1414
import javasabr.mqtt.service.ConnectionService;
1515
import javasabr.mqtt.service.CredentialSource;
1616
import javasabr.mqtt.service.MessageOutFactoryService;
17-
import javasabr.mqtt.service.SessionService;
1817
import javasabr.mqtt.service.PublishDeliveringService;
1918
import javasabr.mqtt.service.PublishReceivingService;
19+
import javasabr.mqtt.service.SessionService;
2020
import javasabr.mqtt.service.SubscriptionService;
2121
import javasabr.mqtt.service.handler.client.ExternalMqttClientReleaseHandler;
2222
import javasabr.mqtt.service.impl.DefaultConnectionService;
23-
import javasabr.mqtt.service.impl.DefaultMqttConnectionFactory;
2423
import javasabr.mqtt.service.impl.DefaultMessageOutFactoryService;
24+
import javasabr.mqtt.service.impl.DefaultMqttConnectionFactory;
2525
import javasabr.mqtt.service.impl.DefaultPublishDeliveringService;
2626
import javasabr.mqtt.service.impl.DefaultPublishReceivingService;
2727
import javasabr.mqtt.service.impl.ExternalMqttClientFactory;
@@ -42,7 +42,7 @@
4242
import javasabr.mqtt.service.message.handler.impl.UnsubscribeMqttInMessageHandler;
4343
import javasabr.mqtt.service.message.out.factory.Mqtt311MessageOutFactory;
4444
import javasabr.mqtt.service.message.out.factory.Mqtt5MessageOutFactory;
45-
import javasabr.mqtt.service.message.out.factory.MessageOutFactory;
45+
import javasabr.mqtt.service.message.out.factory.MqttMessageOutFactory;
4646
import javasabr.mqtt.service.publish.handler.MqttPublishInMessageHandler;
4747
import javasabr.mqtt.service.publish.handler.MqttPublishOutMessageHandler;
4848
import javasabr.mqtt.service.publish.handler.impl.Qos0MqttPublishInMessageHandler;
@@ -100,18 +100,18 @@ SubscriptionService subscriptionService() {
100100
}
101101

102102
@Bean
103-
MessageOutFactory mqtt311MessageOutFactory() {
103+
MqttMessageOutFactory mqtt311MessageOutFactory() {
104104
return new Mqtt311MessageOutFactory();
105105
}
106106

107107
@Bean
108-
MessageOutFactory mqtt5MessageOutFactory() {
108+
MqttMessageOutFactory mqtt5MessageOutFactory() {
109109
return new Mqtt5MessageOutFactory();
110110
}
111111

112112
@Bean
113113
MessageOutFactoryService mqttMessageOutFactoryService(
114-
Collection<? extends MessageOutFactory> knownFactories) {
114+
Collection<? extends MqttMessageOutFactory> knownFactories) {
115115
return new DefaultMessageOutFactoryService(knownFactories);
116116
}
117117

application/src/main/java/javasabr/mqtt/broker/application/config/MqttNetworkConfig.java

Lines changed: 0 additions & 282 deletions
This file was deleted.

0 commit comments

Comments
 (0)