Updated Branches: refs/heads/master 56e313264 -> 52555435f
Fixed eclipse warning of camel-disruptor Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/52555435 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/52555435 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/52555435 Branch: refs/heads/master Commit: 52555435f15bbef745fba4246ce2969faadfc8e7 Parents: 56e3132 Author: Willem Jiang <willem.ji...@gmail.com> Authored: Wed Feb 12 17:55:41 2014 +0800 Committer: Willem Jiang <willem.ji...@gmail.com> Committed: Wed Feb 12 17:55:41 2014 +0800 ---------------------------------------------------------------------- .../camel/component/disruptor/DisruptorConsumer.java | 2 +- .../camel/component/disruptor/DisruptorConfigureTest.java | 10 ---------- 2 files changed, 1 insertion(+), 11 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/52555435/components/camel-disruptor/src/main/java/org/apache/camel/component/disruptor/DisruptorConsumer.java ---------------------------------------------------------------------- diff --git a/components/camel-disruptor/src/main/java/org/apache/camel/component/disruptor/DisruptorConsumer.java b/components/camel-disruptor/src/main/java/org/apache/camel/component/disruptor/DisruptorConsumer.java index e355599..bb89aed 100644 --- a/components/camel-disruptor/src/main/java/org/apache/camel/component/disruptor/DisruptorConsumer.java +++ b/components/camel-disruptor/src/main/java/org/apache/camel/component/disruptor/DisruptorConsumer.java @@ -62,7 +62,7 @@ public class DisruptorConsumer extends ServiceSupport implements Consumer, Suspe public ExceptionHandler getExceptionHandler() { if (exceptionHandler == null) { - exceptionHandler = new LoggingExceptionHandler(getClass()); + exceptionHandler = new LoggingExceptionHandler(endpoint.getCamelContext(), getClass()); } return exceptionHandler; } http://git-wip-us.apache.org/repos/asf/camel/blob/52555435/components/camel-disruptor/src/test/java/org/apache/camel/component/disruptor/DisruptorConfigureTest.java ---------------------------------------------------------------------- diff --git a/components/camel-disruptor/src/test/java/org/apache/camel/component/disruptor/DisruptorConfigureTest.java b/components/camel-disruptor/src/test/java/org/apache/camel/component/disruptor/DisruptorConfigureTest.java index 4d96449..7d21f62 100644 --- a/components/camel-disruptor/src/test/java/org/apache/camel/component/disruptor/DisruptorConfigureTest.java +++ b/components/camel-disruptor/src/test/java/org/apache/camel/component/disruptor/DisruptorConfigureTest.java @@ -56,16 +56,6 @@ public class DisruptorConfigureTest extends CamelTestSupport { } @Test - public void testSizeThroughQueueSizeComponentProperty() throws Exception { - final DisruptorComponent disruptor = context.getComponent("disruptor", DisruptorComponent.class); - disruptor.setQueueSize(2000); - assertEquals(2000, disruptor.getQueueSize()); - final DisruptorEndpoint endpoint = resolveMandatoryEndpoint("disruptor:foo", DisruptorEndpoint.class); - assertEquals("size", 2048, endpoint.getBufferSize()); - assertEquals("getRemainingCapacity", 2048, endpoint.getRemainingCapacity()); - } - - @Test public void testMultipleConsumersConfigured() { final DisruptorEndpoint endpoint = resolveMandatoryEndpoint("disruptor:foo?multipleConsumers=true", DisruptorEndpoint.class);
