svn commit: r1460876 - in /camel/trunk/components/camel-guava-eventbus/src/test/java/org/apache/camel/component/guava/eventbus: CustomMultiEventListener.java GuavaEventBusConsumerTest.java

[hekonsek]

Author: hekonsek
Date: Mon Mar 25 20:23:10 2013
New Revision: 1460876

URL: http://svn.apache.org/r1460876
Log:
[Guava EventBus] Added test case for multi-event interface listener support.

Added:
    
camel/trunk/components/camel-guava-eventbus/src/test/java/org/apache/camel/component/guava/eventbus/CustomMultiEventListener.java
      - copied, changed from r1460860, 
camel/trunk/components/camel-guava-eventbus/src/test/java/org/apache/camel/component/guava/eventbus/CustomListener.java
Modified:
    
camel/trunk/components/camel-guava-eventbus/src/test/java/org/apache/camel/component/guava/eventbus/GuavaEventBusConsumerTest.java

Copied: 
camel/trunk/components/camel-guava-eventbus/src/test/java/org/apache/camel/component/guava/eventbus/CustomMultiEventListener.java
 (from r1460860, 
camel/trunk/components/camel-guava-eventbus/src/test/java/org/apache/camel/component/guava/eventbus/CustomListener.java)
URL: 
http://svn.apache.org/viewvc/camel/trunk/components/camel-guava-eventbus/src/test/java/org/apache/camel/component/guava/eventbus/CustomMultiEventListener.java?p2=camel/trunk/components/camel-guava-eventbus/src/test/java/org/apache/camel/component/guava/eventbus/CustomMultiEventListener.java&p1=camel/trunk/components/camel-guava-eventbus/src/test/java/org/apache/camel/component/guava/eventbus/CustomListener.java&r1=1460860&r2=1460876&rev=1460876&view=diff
==============================================================================
--- 
camel/trunk/components/camel-guava-eventbus/src/test/java/org/apache/camel/component/guava/eventbus/CustomListener.java
 (original)
+++ 
camel/trunk/components/camel-guava-eventbus/src/test/java/org/apache/camel/component/guava/eventbus/CustomMultiEventListener.java
 Mon Mar 25 20:23:10 2013
@@ -16,11 +16,16 @@
  */
 package org.apache.camel.component.guava.eventbus;
 
+import java.util.Date;
+
 import com.google.common.eventbus.Subscribe;
 
-public interface CustomListener {
+public interface CustomMultiEventListener {
+
+    @Subscribe
+    void stringReceived(String stringEvent);
 
     @Subscribe
-    void eventReceived(MessageWrapper messageWrapper);
+    void dateReceived(Date dateEvent);
 
 }

Modified: 
camel/trunk/components/camel-guava-eventbus/src/test/java/org/apache/camel/component/guava/eventbus/GuavaEventBusConsumerTest.java
URL: 
http://svn.apache.org/viewvc/camel/trunk/components/camel-guava-eventbus/src/test/java/org/apache/camel/component/guava/eventbus/GuavaEventBusConsumerTest.java?rev=1460876&r1=1460875&r2=1460876&view=diff
==============================================================================
--- 
camel/trunk/components/camel-guava-eventbus/src/test/java/org/apache/camel/component/guava/eventbus/GuavaEventBusConsumerTest.java
 (original)
+++ 
camel/trunk/components/camel-guava-eventbus/src/test/java/org/apache/camel/component/guava/eventbus/GuavaEventBusConsumerTest.java
 Mon Mar 25 20:23:10 2013
@@ -16,6 +16,8 @@
  */
 package org.apache.camel.component.guava.eventbus;
 
+import java.util.Date;
+
 import com.google.common.eventbus.EventBus;
 import org.apache.camel.builder.RouteBuilder;
 import org.apache.camel.impl.JndiRegistry;
@@ -39,6 +41,9 @@ public class GuavaEventBusConsumerTest e
 
                 
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");
             }
         };
     }
@@ -110,4 +115,21 @@ public class GuavaEventBusConsumerTest e
         assertEquals(wrappedMessage, 
getMockEndpoint("mock:customListenerEvents").getExchanges().get(0).getIn().getBody());
     }
 
+    @Test
+    public void shouldSupportMultiEventCustomListener() throws 
InterruptedException {
+        // Given
+        String stringEvent = "stringEvent";
+        Date dateEvent = new Date();
+
+        // When
+        eventBus.post(stringEvent);
+        eventBus.post(dateEvent);
+
+        // Then
+        
getMockEndpoint("mock:customMultiEventListenerEvents").setExpectedMessageCount(2);
+        assertMockEndpointsSatisfied();
+        assertEquals(stringEvent, 
getMockEndpoint("mock:customMultiEventListenerEvents").getExchanges().get(0).getIn().getBody());
+        assertEquals(dateEvent, 
getMockEndpoint("mock:customMultiEventListenerEvents").getExchanges().get(1).getIn().getBody());
+    }
+
 }