Apache
/
nifi
mirror of https://github.com/apache/nifi.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

NIFI-10988 - Fix ConsumeGCPubSubLite processors delivering incorrect messages 

Signed-off-by: Pierre Villard <pierre.villard.fr@gmail.com>

This closes #6788.
This commit is contained in:
Eric Bernard 2022-12-15 14:58:27 -05:00 committed by Pierre Villard
parent f38f14b363
commit b65431564d
No known key found for this signature in database
GPG Key ID: F92A93B30C07C6D5
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
nifi-nar-bundles/nifi-gcp-bundle/nifi-gcp-processors/src/main/java/org/apache/nifi/processors/gcp/pubsub/lite/ConsumeGCPubSubLite.java
View File

@ -118,7 +118,7 @@ public class ConsumeGCPubSubLite extends AbstractGCPubSubProcessor implements Ve
.build(); .build();
private Subscriber subscriber = null; private Subscriber subscriber = null;
private static final BlockingQueue<Message> messages = new LinkedBlockingQueue<>(); private BlockingQueue<Message> messages = new LinkedBlockingQueue<>();
@Override @Override
protected Collection<ValidationResult> customValidate(final ValidationContext validationContext) { protected Collection<ValidationResult> customValidate(final ValidationContext validationContext) {