Skip to content

Commit 4533f65

Browse files
authored
Ensure new mqtt subscriptions are not empty (#1040)
1 parent a06c70f commit 4533f65

File tree

1 file changed

+2
-1
lines changed
  • runtime/binding-mqtt/src/main/java/io/aklivity/zilla/runtime/binding/mqtt/internal/stream

1 file changed

+2
-1
lines changed

runtime/binding-mqtt/src/main/java/io/aklivity/zilla/runtime/binding/mqtt/internal/stream/MqttServerFactory.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5369,7 +5369,8 @@ private void onSessionData(
53695369
List<Subscription> newSubscriptions = newState.stream()
53705370
.filter(s -> !currentSubscriptions.contains(s))
53715371
.collect(Collectors.toList());
5372-
if (subscribePacketIds.containsKey(newSubscriptions.get(0).id))
5372+
if (!newSubscriptions.isEmpty() &&
5373+
subscribePacketIds.containsKey(newSubscriptions.get(0).id))
53735374
{
53745375
int packetId = subscribePacketIds.get(newSubscriptions.get(0).id);
53755376
newSubscriptions.forEach(sub -> subscribePacketIds.remove(sub.id));

0 commit comments

Comments
 (0)