This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git
commit 000e9208b3f192e706a39ed5fe17e36bc4df1981 Author: Andrea Cosentino <anco...@gmail.com> AuthorDate: Thu Jul 25 10:10:02 2019 +0200 Camel-guava-eventbus - Fixed CS --- .../component/guava/eventbus/GuavaEventBusConsumerTest.java | 11 ++++------- .../guava/eventbus/GuavaEventBusConsumingDeadEventsTest.java | 8 +++----- .../component/guava/eventbus/GuavaEventBusProducerTest.java | 2 +- 3 files changed, 8 insertions(+), 13 deletions(-) diff --git a/components/camel-guava-eventbus/src/test/java/org/apache/camel/component/guava/eventbus/GuavaEventBusConsumerTest.java b/components/camel-guava-eventbus/src/test/java/org/apache/camel/component/guava/eventbus/GuavaEventBusConsumerTest.java index 729b937..c7ed085 100644 --- a/components/camel-guava-eventbus/src/test/java/org/apache/camel/component/guava/eventbus/GuavaEventBusConsumerTest.java +++ b/components/camel-guava-eventbus/src/test/java/org/apache/camel/component/guava/eventbus/GuavaEventBusConsumerTest.java @@ -28,7 +28,7 @@ import org.junit.Test; public class GuavaEventBusConsumerTest extends CamelTestSupport { - @BindToRegistry("eventBus") + @BindToRegistry("eventBus") EventBus eventBus = new EventBus(); @Override @@ -39,14 +39,11 @@ public class GuavaEventBusConsumerTest extends CamelTestSupport { from("guava-eventbus:eventBus").to("mock:allEvents"); from("guava-eventbus:eventBus").to("mock:multipliedConsumer"); - from("guava-eventbus:eventBus?eventClass=org.apache.camel.component.guava.eventbus.MessageWrapper"). - to("mock:wrapperEvents"); + from("guava-eventbus:eventBus?eventClass=org.apache.camel.component.guava.eventbus.MessageWrapper").to("mock:wrapperEvents"); - from("guava-eventbus:eventBus?listenerInterface=org.apache.camel.component.guava.eventbus.CustomListener"). - to("mock:customListenerEvents"); + from("guava-eventbus:eventBus?listenerInterface=org.apache.camel.component.guava.eventbus.CustomListener").to("mock:customListenerEvents"); - from("guava-eventbus:eventBus?listenerInterface=org.apache.camel.component.guava.eventbus.CustomMultiEventListener"). - to("mock:customMultiEventListenerEvents"); + from("guava-eventbus:eventBus?listenerInterface=org.apache.camel.component.guava.eventbus.CustomMultiEventListener").to("mock:customMultiEventListenerEvents"); } }; } diff --git a/components/camel-guava-eventbus/src/test/java/org/apache/camel/component/guava/eventbus/GuavaEventBusConsumingDeadEventsTest.java b/components/camel-guava-eventbus/src/test/java/org/apache/camel/component/guava/eventbus/GuavaEventBusConsumingDeadEventsTest.java index 686fc55..b795908 100644 --- a/components/camel-guava-eventbus/src/test/java/org/apache/camel/component/guava/eventbus/GuavaEventBusConsumingDeadEventsTest.java +++ b/components/camel-guava-eventbus/src/test/java/org/apache/camel/component/guava/eventbus/GuavaEventBusConsumingDeadEventsTest.java @@ -29,7 +29,7 @@ import org.junit.Test; public class GuavaEventBusConsumingDeadEventsTest extends CamelTestSupport { - @BindToRegistry("eventBus") + @BindToRegistry("eventBus") EventBus eventBus = new EventBus(); @Override @@ -37,11 +37,9 @@ public class GuavaEventBusConsumingDeadEventsTest extends CamelTestSupport { return new RouteBuilder() { @Override public void configure() throws Exception { - from("guava-eventbus:eventBus?listenerInterface=org.apache.camel.component.guava.eventbus.CustomListener"). - to("mock:customListenerEvents"); + from("guava-eventbus:eventBus?listenerInterface=org.apache.camel.component.guava.eventbus.CustomListener").to("mock:customListenerEvents"); - from("guava-eventbus:eventBus?listenerInterface=org.apache.camel.component.guava.eventbus.DeadEventListener"). - to("mock:deadEvents"); + from("guava-eventbus:eventBus?listenerInterface=org.apache.camel.component.guava.eventbus.DeadEventListener").to("mock:deadEvents"); } }; } diff --git a/components/camel-guava-eventbus/src/test/java/org/apache/camel/component/guava/eventbus/GuavaEventBusProducerTest.java b/components/camel-guava-eventbus/src/test/java/org/apache/camel/component/guava/eventbus/GuavaEventBusProducerTest.java index d06f97c..ca3c94a 100644 --- a/components/camel-guava-eventbus/src/test/java/org/apache/camel/component/guava/eventbus/GuavaEventBusProducerTest.java +++ b/components/camel-guava-eventbus/src/test/java/org/apache/camel/component/guava/eventbus/GuavaEventBusProducerTest.java @@ -27,7 +27,7 @@ import org.junit.Test; public class GuavaEventBusProducerTest extends CamelTestSupport { - @BindToRegistry("eventBus") + @BindToRegistry("eventBus") EventBus eventBus = new EventBus(); Object receivedEvent;