Skip to content

Commit 31ff664

Browse files
committed
[broker-30] Fix formatting
1 parent 12f8069 commit 31ff664

File tree

5 files changed

+12
-12
lines changed

5 files changed

+12
-12
lines changed

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

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -343,8 +343,7 @@ NetworkMqttUserFactory externalClientFactory(NetworkMqttUserReleaseHandler exter
343343
MqttConnectionFactory externalConnectionFactory(
344344
MqttServerConnectionConfig externalServerConnectionConfig,
345345
NetworkMqttUserFactory mqttUserFactory,
346-
@Value("${mqtt.external.connection.max.packets.by.read:100}")
347-
int maxPacketsByRead) {
346+
@Value("${mqtt.external.connection.max.packets.by.read:100}") int maxPacketsByRead) {
348347
return new DefaultMqttConnectionFactory(externalServerConnectionConfig, mqttUserFactory, maxPacketsByRead);
349348
}
350349

core-service/src/main/java/javasabr/mqtt/service/PublishDeliveringService.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,6 @@
33
import javasabr.mqtt.model.publishing.Publish;
44
import javasabr.mqtt.model.subscriber.SingleSubscriber;
55
import javasabr.mqtt.service.publish.handler.PublishHandlingResult;
6-
import javasabr.rlib.collections.array.Array;
76

87
public interface PublishDeliveringService {
98

core-service/src/main/java/javasabr/mqtt/service/impl/DefaultPublishDeliveringService.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -39,6 +39,7 @@ public DefaultPublishDeliveringService(
3939
}
4040
handlers[qos.level()] = knownPublishOutHandler;
4141
}
42+
4243
this.publishOutMessageHandlers = handlers;
4344
log.info(publishOutMessageHandlers, DefaultPublishDeliveringService::buildServiceDescription);
4445
}

core-service/src/main/java/javasabr/mqtt/service/impl/InMemorySubscriptionService.java

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -83,13 +83,12 @@ private SubscribeAckReasonCode addSubscription(MqttUser user, MqttSession sessio
8383
activeSubscriptions.remove(previous.subscription());
8484
}
8585
QoS subscriptionQoS = subscription.qos();
86-
if (subscriptionQoS.ordinal() <= 2 && (subscription.retainHandling() == SEND ||
87-
(subscription.retainHandling() == SEND_IF_SUBSCRIPTION_DOES_NOT_EXIST && previous == null))) {
86+
if (subscriptionQoS.ordinal() <= 2 && (subscription.retainHandling() == SEND || (
87+
subscription.retainHandling() == SEND_IF_SUBSCRIPTION_DOES_NOT_EXIST && previous == null))) {
8888
sendRetainedMessages(user, subscription);
8989
}
9090
activeSubscriptions.add(subscription);
91-
return subscriptionQoS
92-
.subscribeAckReasonCode();
91+
return subscriptionQoS.subscribeAckReasonCode();
9392
}
9493

9594
@Override

core-service/src/main/java/javasabr/mqtt/service/publish/handler/impl/Qos1MqttPublishInMessageHandler.java

Lines changed: 7 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,12 @@ public Qos1MqttPublishInMessageHandler(
2727
PublishDeliveringService publishDeliveringService,
2828
MessageOutFactoryService messageOutFactoryService,
2929
RetainMessageService retainMessageService) {
30-
super(ExternalNetworkMqttUser.class, subscriptionService, publishDeliveringService, messageOutFactoryService, retainMessageService);
30+
super(
31+
ExternalNetworkMqttUser.class,
32+
subscriptionService,
33+
publishDeliveringService,
34+
messageOutFactoryService,
35+
retainMessageService);
3136
}
3237

3338
@Override
@@ -55,10 +60,7 @@ protected boolean validateImpl(ExternalNetworkMqttUser user, NetworkMqttSession
5560
}
5661

5762
@Override
58-
protected void handleNoMatchedSubscribers(
59-
ExternalNetworkMqttUser user,
60-
NetworkMqttSession session,
61-
Publish publish) {
63+
protected void handleNoMatchedSubscribers(ExternalNetworkMqttUser user, NetworkMqttSession session, Publish publish) {
6264
super.handleNoMatchedSubscribers(user, session, publish);
6365
int messageId = publish.messageId();
6466
MqttOutMessage response = messageOutFactoryService

0 commit comments

Comments
 (0)