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 <[email protected]>
AuthorDate: Thu Dec 15 14:58:27 2022 -0500
NIFI-10988 - Fix ConsumeGCPubSubLite processors delivering incorrect
messages
Signed-off-by: Pierre Villard <[email protected]>
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) {
