You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ni...@apache.org on 2014/02/12 10:55:55 UTC
git commit: Fixed eclipse warning of camel-disruptor
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 <wi...@gmail.com>
Authored: Wed Feb 12 17:55:41 2014 +0800
Committer: Willem Jiang <wi...@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);