Repository: camel Updated Branches: refs/heads/camel-2.14.x d430125a2 -> 99c8f6b4d
[CAMEL-8430] Fixes of camel-hdfs tests for camel-2.14.x Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/99c8f6b4 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/99c8f6b4 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/99c8f6b4 Branch: refs/heads/camel-2.14.x Commit: 99c8f6b4db724d029898877850badfdb14b53705 Parents: b2cd681 Author: Grzegorz Grzybek <gr.grzy...@gmail.com> Authored: Tue Mar 3 14:44:27 2015 +0100 Committer: Grzegorz Grzybek <gr.grzy...@gmail.com> Committed: Wed Mar 4 08:38:05 2015 +0100 ---------------------------------------------------------------------- .../java/org/apache/camel/component/hdfs/HdfsConsumerTest.java | 3 ++- .../java/org/apache/camel/component/hdfs2/HdfsConsumerTest.java | 3 ++- 2 files changed, 4 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/99c8f6b4/components/camel-hdfs/src/test/java/org/apache/camel/component/hdfs/HdfsConsumerTest.java ---------------------------------------------------------------------- diff --git a/components/camel-hdfs/src/test/java/org/apache/camel/component/hdfs/HdfsConsumerTest.java b/components/camel-hdfs/src/test/java/org/apache/camel/component/hdfs/HdfsConsumerTest.java index 368b1d8..f60c09c 100644 --- a/components/camel-hdfs/src/test/java/org/apache/camel/component/hdfs/HdfsConsumerTest.java +++ b/components/camel-hdfs/src/test/java/org/apache/camel/component/hdfs/HdfsConsumerTest.java @@ -130,7 +130,8 @@ public class HdfsConsumerTest extends HdfsTestSupport { }); Map<String, Object> props = new HashMap<String, Object>(); ScheduledExecutorService pool = context.getExecutorServiceManager().newScheduledThreadPool(null, "unitTestPool", 1); - DefaultScheduledPollConsumerScheduler scheduler = new DefaultScheduledPollConsumerScheduler(pool); + DefaultScheduledPollConsumerScheduler scheduler = new DefaultScheduledPollConsumerScheduler(); + scheduler.setScheduledExecutorService(pool); props.put("scheduler", scheduler); ((JndiRegistry) ((PropertyPlaceholderDelegateRegistry) context.getRegistry()).getRegistry()).bind("cprops", props); context.start(); http://git-wip-us.apache.org/repos/asf/camel/blob/99c8f6b4/components/camel-hdfs2/src/test/java/org/apache/camel/component/hdfs2/HdfsConsumerTest.java ---------------------------------------------------------------------- diff --git a/components/camel-hdfs2/src/test/java/org/apache/camel/component/hdfs2/HdfsConsumerTest.java b/components/camel-hdfs2/src/test/java/org/apache/camel/component/hdfs2/HdfsConsumerTest.java index 48c155f..95f3fe7 100644 --- a/components/camel-hdfs2/src/test/java/org/apache/camel/component/hdfs2/HdfsConsumerTest.java +++ b/components/camel-hdfs2/src/test/java/org/apache/camel/component/hdfs2/HdfsConsumerTest.java @@ -130,7 +130,8 @@ public class HdfsConsumerTest extends HdfsTestSupport { }); Map<String, Object> props = new HashMap<String, Object>(); ScheduledExecutorService pool = context.getExecutorServiceManager().newScheduledThreadPool(null, "unitTestPool", 1); - DefaultScheduledPollConsumerScheduler scheduler = new DefaultScheduledPollConsumerScheduler(pool); + DefaultScheduledPollConsumerScheduler scheduler = new DefaultScheduledPollConsumerScheduler(); + scheduler.setScheduledExecutorService(pool); props.put("scheduler", scheduler); ((JndiRegistry) ((PropertyPlaceholderDelegateRegistry) context.getRegistry()).getRegistry()).bind("cprops", props); context.start();
