Skip to content

Commit da0be17

Browse files
committed
[broker-22] fixed for code review
1 parent d1a25a1 commit da0be17

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

src/main/java/com/ss/mqtt/broker/model/impl/DefaultMqttSession.java

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -140,15 +140,17 @@ public int nextPacketId() {
140140
@Override
141141
public void registerOutPublish(
142142
@NotNull PublishInPacket publish,
143-
@NotNull PendingPacketHandler handler, int packetId
143+
@NotNull PendingPacketHandler handler,
144+
int packetId
144145
) {
145146
registerPublish(publish, handler, packetId, pendingOutPublishes);
146147
}
147148

148149
@Override
149150
public void registerInPublish(
150151
@NotNull PublishInPacket publish,
151-
@NotNull PendingPacketHandler handler, int packetId
152+
@NotNull PendingPacketHandler handler,
153+
int packetId
152154
) {
153155
registerPublish(publish, handler, packetId, pendingInPublishes);
154156
}

0 commit comments

Comments
 (0)