We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 5c7e96f commit e0e11d4Copy full SHA for e0e11d4
src/main/java/com/hivemq/client/internal/mqtt/handler/publish/incoming/MqttIncomingPublishFlows.java
@@ -131,12 +131,12 @@ void findMatching(final @NotNull MqttStatefulPublishWithFlows publishWithFlows)
131
}
132
133
private static void add(
134
- final @NotNull MqttStatefulPublishWithFlows matchingPublishFlows,
+ final @NotNull MqttStatefulPublishWithFlows publishWithFlows,
135
final @Nullable HandleList<MqttGlobalIncomingPublishFlow> globalFlows) {
136
137
if (globalFlows != null) {
138
for (Handle<MqttGlobalIncomingPublishFlow> h = globalFlows.getFirst(); h != null; h = h.getNext()) {
139
- matchingPublishFlows.add(h.getElement());
+ publishWithFlows.add(h.getElement());
140
141
142
0 commit comments