This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch camel-3.11.x
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/camel-3.11.x by this push:
new a0df68f CAMEL-16874: fix bug with sendEmptyMessages and pollEnrich
(#5962)
a0df68f is described below
commit a0df68f30be76d737f19f36a0d389fb0146feecc
Author: klease <[email protected]>
AuthorDate: Thu Aug 19 15:21:50 2021 +0200
CAMEL-16874: fix bug with sendEmptyMessages and pollEnrich (#5962)
* CAMEL-16874: fix bug with sendEmptyMessages and pollEnrich
* Remove commented out lines in unit test
---
.../component/file/GenericFilePollingConsumer.java | 2 +
.../FileConsumePollEnrichFileIdleEventTest.java | 80 ++++++++++++++++++++++
2 files changed, 82 insertions(+)
diff --git
a/components/camel-file/src/main/java/org/apache/camel/component/file/GenericFilePollingConsumer.java
b/components/camel-file/src/main/java/org/apache/camel/component/file/GenericFilePollingConsumer.java
index 85c23bd..56b74ab 100644
---
a/components/camel-file/src/main/java/org/apache/camel/component/file/GenericFilePollingConsumer.java
+++
b/components/camel-file/src/main/java/org/apache/camel/component/file/GenericFilePollingConsumer.java
@@ -146,6 +146,8 @@ public class GenericFilePollingConsumer extends
EventDrivenPollingConsumer {
if (polledMessages == 0 && sendEmptyMessageWhenIdle) {
// send an "empty" exchange
processEmptyMessage();
+ // set polledMessages=1 since the empty message is
queued
+ polledMessages = 1;
} else if (polledMessages == 0 && timeout > 0) {
// if we did not poll a file and we are using
// timeout then try to poll again
diff --git
a/core/camel-core/src/test/java/org/apache/camel/component/file/FileConsumePollEnrichFileIdleEventTest.java
b/core/camel-core/src/test/java/org/apache/camel/component/file/FileConsumePollEnrichFileIdleEventTest.java
new file mode 100644
index 0000000..98e2267
--- /dev/null
+++
b/core/camel-core/src/test/java/org/apache/camel/component/file/FileConsumePollEnrichFileIdleEventTest.java
@@ -0,0 +1,80 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.component.file;
+
+import org.apache.camel.ContextTestSupport;
+import org.apache.camel.Exchange;
+import org.apache.camel.builder.RouteBuilder;
+import org.apache.camel.component.mock.MockEndpoint;
+import org.junit.jupiter.api.Test;
+
+public class FileConsumePollEnrichFileIdleEventTest extends ContextTestSupport
{
+
+ @Test
+ public void testNonEmptyAfterEmpty() throws Exception {
+ getMockEndpoint("mock:start").expectedBodiesReceived("Event1",
"Event2");
+
+ MockEndpoint mock = getMockEndpoint("mock:result");
+ mock.expectedBodiesReceived("Event1", "EnrichData");
+ mock.expectedFileExists(testFile("enrich/.done/Event1.txt"));
+ mock.expectedFileExists(testFile("enrich/.done/Event2.txt"));
+ mock.expectedFileExists(testFile("enrichdata/.done/AAA.dat"));
+
+ template.sendBodyAndHeader(fileUri("enrich"), "Event1",
Exchange.FILE_NAME,
+ "Event1.txt");
+
+ log.info("Sleeping for 1 sec before writing enrichdata file");
+ Thread.sleep(1000);
+ template.sendBodyAndHeader(fileUri("enrichdata"), "EnrichData",
+ Exchange.FILE_NAME, "AAA.dat");
+ // Trigger second event which should find the EnrichData file
+ template.sendBodyAndHeader(fileUri("enrich"), "Event2",
Exchange.FILE_NAME,
+ "Event2.txt");
+ log.info("... write done");
+
+ assertMockEndpointsSatisfied();
+ }
+
+ @Test
+ public void testPollEmptyEnrich() throws Exception {
+ getMockEndpoint("mock:start").expectedBodiesReceived("Event1");
+
+ MockEndpoint mock = getMockEndpoint("mock:result");
+ mock.expectedBodiesReceived("Event1");
+ mock.expectedFileExists(testFile("enrich/.done/Event1.txt"));
+
+ template.sendBodyAndHeader(fileUri("enrich"), "Event1",
Exchange.FILE_NAME,
+ "Event1.txt");
+
+ assertMockEndpointsSatisfied();
+ }
+
+ @Override
+ protected RouteBuilder createRouteBuilder() throws Exception {
+ return new RouteBuilder() {
+ @Override
+ public void configure() throws Exception {
+ from(fileUri("enrich?initialDelay=0&delay=10&move=.done"))
+ .to("mock:start")
+ .pollEnrich(
+
fileUri("enrichdata?initialDelay=0&delay=10&move=.done&sendEmptyMessageWhenIdle=true"),
1000)
+ .to("mock:result");
+ }
+ };
+ }
+
+}
