[nifi] branch main updated: NIFI-10988 - Fix ConsumeGCPubSubLite processors delivering incorrect messages

[pv...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

pvillard pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git


The following commit(s) were added to refs/heads/main by this push:
     new b65431564d NIFI-10988 - Fix ConsumeGCPubSubLite processors delivering incorrect messages
b65431564d is described below

commit b65431564ddf14073e3bf2f75cd0750a0ef07169
Author: Eric Bernard <er...@gmail.com>
AuthorDate: Thu Dec 15 14:58:27 2022 -0500

    NIFI-10988 - Fix ConsumeGCPubSubLite processors delivering incorrect messages
    
    Signed-off-by: Pierre Villard <pi...@gmail.com>
    
    This closes #6788.
---
 .../org/apache/nifi/processors/gcp/pubsub/lite/ConsumeGCPubSubLite.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/nifi-nar-bundles/nifi-gcp-bundle/nifi-gcp-processors/src/main/java/org/apache/nifi/processors/gcp/pubsub/lite/ConsumeGCPubSubLite.java b/nifi-nar-bundles/nifi-gcp-bundle/nifi-gcp-processors/src/main/java/org/apache/nifi/processors/gcp/pubsub/lite/ConsumeGCPubSubLite.java
index 9cf23af8a4..ac40fb79df 100644
--- a/nifi-nar-bundles/nifi-gcp-bundle/nifi-gcp-processors/src/main/java/org/apache/nifi/processors/gcp/pubsub/lite/ConsumeGCPubSubLite.java
+++ b/nifi-nar-bundles/nifi-gcp-bundle/nifi-gcp-processors/src/main/java/org/apache/nifi/processors/gcp/pubsub/lite/ConsumeGCPubSubLite.java
@@ -118,7 +118,7 @@ public class ConsumeGCPubSubLite extends AbstractGCPubSubProcessor implements Ve
             .build();
 
     private Subscriber subscriber = null;
-    private static final BlockingQueue<Message> messages = new LinkedBlockingQueue<>();
+    private BlockingQueue<Message> messages = new LinkedBlockingQueue<>();
 
     @Override
     protected Collection<ValidationResult> customValidate(final ValidationContext validationContext) {