svn commit: r1210367 - in /camel/trunk/components/camel-hazelcast/src: main/java/org/apache/camel/component/hazelcast/queue/HazelcastQueueProducer.java test/java/org/apache/camel/component/hazelcast/HazelcastQueueProducerTest.java

[iocanel]

Author: iocanel
Date: Mon Dec  5 09:08:07 2011
New Revision: 1210367

URL: http://svn.apache.org/viewvc?rev=1210367&view=rev
Log:
[CAMEL-4741] Hazelcast queue producer uses add as a default operation. Added a 
small test case.

Modified:
    
camel/trunk/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/queue/HazelcastQueueProducer.java
    
camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastQueueProducerTest.java

Modified: 
camel/trunk/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/queue/HazelcastQueueProducer.java
URL: 
http://svn.apache.org/viewvc/camel/trunk/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/queue/HazelcastQueueProducer.java?rev=1210367&r1=1210366&r2=1210367&view=diff
==============================================================================
--- 
camel/trunk/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/queue/HazelcastQueueProducer.java
 (original)
+++ 
camel/trunk/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/queue/HazelcastQueueProducer.java
 Mon Dec  5 09:08:07 2011
@@ -59,6 +59,8 @@ public class HazelcastQueueProducer exte
 
         switch (operation) {
 
+        case -1:
+        //If no operation is specified use ADD.
         case HazelcastConstants.ADD_OPERATION:
             this.add(exchange);
             break;

Modified: 
camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastQueueProducerTest.java
URL: 
http://svn.apache.org/viewvc/camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastQueueProducerTest.java?rev=1210367&r1=1210366&r2=1210367&view=diff
==============================================================================
--- 
camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastQueueProducerTest.java
 (original)
+++ 
camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastQueueProducerTest.java
 Mon Dec  5 09:08:07 2011
@@ -53,6 +53,15 @@ public class HazelcastQueueProducerTest 
     }
 
     @Test
+    public void noOperation() throws InterruptedException {
+        template.sendBody("direct:no-operation", "bar");
+
+        assertTrue(queue.contains("bar"));
+
+        queue.clear();
+    }
+
+    @Test
     public void add() throws InterruptedException {
         template.sendBody("direct:add", "bar");
 
@@ -122,6 +131,8 @@ public class HazelcastQueueProducerTest 
         return new RouteBuilder() {
             @Override
             public void configure() throws Exception {
+                
from("direct:no-operation").to(String.format("hazelcast:%sbar", 
HazelcastConstants.QUEUE_PREFIX));
+
                 from("direct:put").setHeader(HazelcastConstants.OPERATION, 
constant(HazelcastConstants.PUT_OPERATION)).to(String.format("hazelcast:%sbar", 
HazelcastConstants.QUEUE_PREFIX));
 
                 from("direct:add").setHeader(HazelcastConstants.OPERATION, 
constant(HazelcastConstants.ADD_OPERATION)).to(String.format("hazelcast:%sbar", 
HazelcastConstants.QUEUE_PREFIX));