camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ningji...@apache.org
Subject git commit: Fixed eclipse warning of camel-disruptor
Date Wed, 12 Feb 2014 09:55:55 GMT
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.jiang@gmail.com>
Authored: Wed Feb 12 17:55:41 2014 +0800
Committer: Willem Jiang <willem.jiang@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);


Mime
View raw message