You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by bv...@apache.org on 2012/02/21 19:09:38 UTC
svn commit: r1291945 - in /camel/trunk: components/camel-hazelcast/
components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/
parent/
Author: bvahdat
Date: Tue Feb 21 18:09:37 2012
New Revision: 1291945
URL: http://svn.apache.org/viewvc?rev=1291945&view=rev
Log:
CAMEL-5026: Upgrade to Hazelcast 1.9.4.8 and cleanup the camel-hazelcast's own unit-tests.
Modified:
camel/trunk/components/camel-hazelcast/pom.xml
camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastAtomicnumberProducerForSpringTest.java
camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastAtomicnumberProducerTest.java
camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastInstanceConsumerTest.java
camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastListConsumerTest.java
camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastListProducerTest.java
camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastMapConsumerTest.java
camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastMapProducerForSpringTest.java
camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastMapProducerTest.java
camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastMultimapConsumerTest.java
camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastMultimapProducerForSpringTest.java
camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastMultimapProducerTest.java
camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastQueueConsumerTest.java
camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastQueueProducerTest.java
camel/trunk/parent/pom.xml
Modified: camel/trunk/components/camel-hazelcast/pom.xml
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-hazelcast/pom.xml?rev=1291945&r1=1291944&r2=1291945&view=diff
==============================================================================
--- camel/trunk/components/camel-hazelcast/pom.xml (original)
+++ camel/trunk/components/camel-hazelcast/pom.xml Tue Feb 21 18:09:37 2012
@@ -68,22 +68,4 @@
</dependencies>
- <build>
- <plugins>
-
- <plugin>
- <artifactId>maven-surefire-plugin</artifactId>
- <configuration>
- <childDelegation>false</childDelegation>
- <useFile>true</useFile>
- <forkMode>pertest</forkMode>
- <excludes>
- <exclude>**/XXXTest.*</exclude>
- </excludes>
- </configuration>
- </plugin>
-
- </plugins>
- </build>
-
</project>
Modified: camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastAtomicnumberProducerForSpringTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastAtomicnumberProducerForSpringTest.java?rev=1291945&r1=1291944&r2=1291945&view=diff
==============================================================================
--- camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastAtomicnumberProducerForSpringTest.java (original)
+++ camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastAtomicnumberProducerForSpringTest.java Tue Feb 21 18:09:37 2012
@@ -16,8 +16,12 @@
*/
package org.apache.camel.component.hazelcast;
+import com.hazelcast.core.Hazelcast;
+
import org.apache.camel.test.junit4.CamelSpringTestSupport;
+
import org.junit.Test;
+
import org.springframework.context.support.AbstractApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
@@ -60,21 +64,12 @@ public class HazelcastAtomicnumberProduc
assertEquals(9, body);
}
- /*
- * will be fixed in next hazelcast version (1.9.3). Mail from Talip (21.02.2011):
- *
- * I see. Hazelcast.shutdownAll() should cleanup instances (maps/queues). I just fixed it.
- *
- * AtomicNumber.destroy() should also destroy the number and if you call atomicNumber.get() after the destroy it should throw IllegalStateException. It is also fixed.
- *
- * set test to true by default. TODO: if we'll get the new hazelcast version I'll fix the test.
- */
@Test
public void testDestroy() {
template.sendBody("direct:set", 10);
template.sendBody("direct:destroy", null);
- // assertTrue(Hazelcast.getInstances().isEmpty());
+ assertTrue(Hazelcast.getInstances().isEmpty());
}
}
Modified: camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastAtomicnumberProducerTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastAtomicnumberProducerTest.java?rev=1291945&r1=1291944&r2=1291945&view=diff
==============================================================================
--- camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastAtomicnumberProducerTest.java (original)
+++ camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastAtomicnumberProducerTest.java Tue Feb 21 18:09:37 2012
@@ -16,8 +16,11 @@
*/
package org.apache.camel.component.hazelcast;
+import com.hazelcast.core.Hazelcast;
+
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.test.junit4.CamelTestSupport;
+
import org.junit.Test;
public class HazelcastAtomicnumberProducerTest extends CamelTestSupport {
@@ -54,21 +57,12 @@ public class HazelcastAtomicnumberProduc
assertEquals(9, body);
}
- /*
- * will be fixed in next hazelcast version (1.9.3). Mail from Talip (21.02.2011):
- *
- * I see. Hazelcast.shutdownAll() should cleanup instances (maps/queues). I just fixed it.
- *
- * AtomicNumber.destroy() should also destroy the number and if you call atomicNumber.get() after the destroy it should throw IllegalStateException. It is also fixed.
- *
- * set test to true by default. TODO: if we'll get the new hazelcast version I'll fix the test.
- */
@Test
public void testDestroy() {
template.sendBody("direct:set", 10);
template.sendBody("direct:destroy", null);
- // assertTrue(Hazelcast.getInstances().isEmpty());
+ assertTrue(Hazelcast.getInstances().isEmpty());
}
@Override
Modified: camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastInstanceConsumerTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastInstanceConsumerTest.java?rev=1291945&r1=1291944&r2=1291945&view=diff
==============================================================================
--- camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastInstanceConsumerTest.java (original)
+++ camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastInstanceConsumerTest.java Tue Feb 21 18:09:37 2012
@@ -26,6 +26,7 @@ import org.apache.camel.Exchange;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.mock.MockEndpoint;
import org.apache.camel.test.junit4.CamelTestSupport;
+
import org.junit.Ignore;
import org.junit.Test;
@@ -53,7 +54,6 @@ public class HazelcastInstanceConsumerTe
}
@Test
- @SuppressWarnings("deprecation")
@Ignore("Shutdown causes further hazelast tests to fail")
public void testRemoveInstance() throws InterruptedException {
@@ -62,8 +62,7 @@ public class HazelcastInstanceConsumerTe
HazelcastInstance h1 = Hazelcast.newHazelcastInstance(null);
- // TODO --> check how an instance can be killed...
- h1.shutdown();
+ h1.getLifecycleService().shutdown();
assertMockEndpointsSatisfied(5000, TimeUnit.MILLISECONDS);
Modified: camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastListConsumerTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastListConsumerTest.java?rev=1291945&r1=1291944&r2=1291945&view=diff
==============================================================================
--- camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastListConsumerTest.java (original)
+++ camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastListConsumerTest.java Tue Feb 21 18:09:37 2012
@@ -32,13 +32,12 @@ public class HazelcastListConsumerTest e
@Override
protected void doPostSetup() throws Exception {
- HazelcastComponent component = (HazelcastComponent) context().getComponent("hazelcast");
+ HazelcastComponent component = context().getComponent("hazelcast", HazelcastComponent.class);
HazelcastInstance hazelcastInstance = component.getHazelcastInstance();
list = hazelcastInstance.getList("mm");
list.clear();
}
-
@Test
public void add() throws InterruptedException {
MockEndpoint out = getMockEndpoint("mock:added");
Modified: camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastListProducerTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastListProducerTest.java?rev=1291945&r1=1291944&r2=1291945&view=diff
==============================================================================
--- camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastListProducerTest.java (original)
+++ camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastListProducerTest.java Tue Feb 21 18:09:37 2012
@@ -18,11 +18,11 @@ package org.apache.camel.component.hazel
import java.util.List;
-import com.hazelcast.core.Hazelcast;
-
import com.hazelcast.core.HazelcastInstance;
+
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.test.junit4.CamelTestSupport;
+
import org.junit.Test;
public class HazelcastListProducerTest extends CamelTestSupport {
@@ -31,7 +31,7 @@ public class HazelcastListProducerTest e
@Override
protected void doPostSetup() throws Exception {
- HazelcastComponent component = (HazelcastComponent) context().getComponent("hazelcast");
+ HazelcastComponent component = context().getComponent("hazelcast", HazelcastComponent.class);
HazelcastInstance hazelcastInstance = component.getHazelcastInstance();
list = hazelcastInstance.getList("bar");
list.clear();
@@ -39,14 +39,12 @@ public class HazelcastListProducerTest e
@Test
public void addValue() throws InterruptedException {
-
template.sendBody("direct:add", "bar");
assertTrue(list.contains("bar"));
}
@Test
public void removeValue() throws InterruptedException {
-
list.add("foo1");
list.add("foo2");
list.add("foo3");
@@ -62,8 +60,6 @@ public class HazelcastListProducerTest e
@Test
public void getValueWithIdx() {
- // unsupported operation --> supported since 1.9.3
-
list.add("foo1");
list.add("foo2");
@@ -77,8 +73,6 @@ public class HazelcastListProducerTest e
@Test
public void setValueWithIdx() {
- // unsupported operation --> supported since 1.9.3
-
list.add("foo1");
list.add("foo2");
@@ -93,36 +87,30 @@ public class HazelcastListProducerTest e
@Test
public void removeValueWithIdx() {
- // unsupported operation --> supported since 1.9.3
-
list.add("foo1");
list.add("foo2");
assertEquals(2, list.size());
+ // do not specify the value to delete, but the index
template.sendBodyAndHeader("direct:removevalue", null, HazelcastConstants.OBJECT_POS, 1);
assertEquals(1, list.size());
-
+ assertEquals("foo1", list.get(0));
}
- // @Test(expected = CamelExecutionException.class)
- public void removeNullValue() {
- // unsupported operation
-
- /*
- * TODO: is this case a norm ? should this case handled in a different way ?
- */
-
- List<String> list = Hazelcast.getList("bar");
- list.clear();
-
+ @Test
+ public void removeValueWithoutIdx() {
list.add("foo1");
+ list.add("foo2");
+
+ assertEquals(2, list.size());
- // do not specify the value to delete (null)
- template.sendBody("direct:removevalue", null);
- assertEquals(0, list.size());
+ // do not specify the index to delete, but the value
+ template.sendBody("direct:removevalue", "foo1");
+ assertEquals(1, list.size());
+ assertEquals("foo2", list.get(0));
}
@Override
Modified: camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastMapConsumerTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastMapConsumerTest.java?rev=1291945&r1=1291944&r2=1291945&view=diff
==============================================================================
--- camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastMapConsumerTest.java (original)
+++ camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastMapConsumerTest.java Tue Feb 21 18:09:37 2012
@@ -33,7 +33,7 @@ public class HazelcastMapConsumerTest ex
@Override
protected void doPostSetup() throws Exception {
- HazelcastComponent component = (HazelcastComponent) context().getComponent("hazelcast");
+ HazelcastComponent component = context().getComponent("hazelcast", HazelcastComponent.class);
HazelcastInstance hazelcastInstance = component.getHazelcastInstance();
map = hazelcastInstance.getMap("foo");
map.clear();
Modified: camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastMapProducerForSpringTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastMapProducerForSpringTest.java?rev=1291945&r1=1291944&r2=1291945&view=diff
==============================================================================
--- camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastMapProducerForSpringTest.java (original)
+++ camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastMapProducerForSpringTest.java Tue Feb 21 18:09:37 2012
@@ -37,7 +37,7 @@ public class HazelcastMapProducerForSpri
@Override
protected void doPostSetup() throws Exception {
super.doPostSetup();
- HazelcastComponent component = (HazelcastComponent) context().getComponent("hazelcast");
+ HazelcastComponent component = context().getComponent("hazelcast", HazelcastComponent.class);
HazelcastInstance hazelcastInstance = component.getHazelcastInstance();
this.map = hazelcastInstance.getMap("foo");
this.map.clear();
@@ -110,7 +110,7 @@ public class HazelcastMapProducerForSpri
public class Dummy implements Serializable {
- private static final long serialVersionUID = 3688457704655925278L;
+ private static final long serialVersionUID = 1L;
private String foo;
private int bar;
Modified: camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastMapProducerTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastMapProducerTest.java?rev=1291945&r1=1291944&r2=1291945&view=diff
==============================================================================
--- camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastMapProducerTest.java (original)
+++ camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastMapProducerTest.java Tue Feb 21 18:09:37 2012
@@ -35,7 +35,7 @@ public class HazelcastMapProducerTest ex
@Override
protected void doPostSetup() throws Exception {
- HazelcastComponent component = (HazelcastComponent) context().getComponent("hazelcast");
+ HazelcastComponent component = context().getComponent("hazelcast", HazelcastComponent.class);
HazelcastInstance hazelcastInstance = component.getHazelcastInstance();
map = hazelcastInstance.getMap("foo");
map.clear();
@@ -125,7 +125,7 @@ public class HazelcastMapProducerTest ex
public class Dummy implements Serializable {
- private static final long serialVersionUID = 3688457704655925278L;
+ private static final long serialVersionUID = 1L;
private String foo;
private int bar;
Modified: camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastMultimapConsumerTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastMultimapConsumerTest.java?rev=1291945&r1=1291944&r2=1291945&view=diff
==============================================================================
--- camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastMultimapConsumerTest.java (original)
+++ camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastMultimapConsumerTest.java Tue Feb 21 18:09:37 2012
@@ -25,8 +25,8 @@ import com.hazelcast.core.MultiMap;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.mock.MockEndpoint;
import org.apache.camel.test.junit4.CamelTestSupport;
-import org.junit.Test;
+import org.junit.Test;
public class HazelcastMultimapConsumerTest extends CamelTestSupport {
@@ -35,7 +35,7 @@ public class HazelcastMultimapConsumerTe
@Override
protected void doPostSetup() throws Exception {
- HazelcastComponent component = (HazelcastComponent) context().getComponent("hazelcast");
+ HazelcastComponent component = context().getComponent("hazelcast", HazelcastComponent.class);
HazelcastInstance hazelcastInstance = component.getHazelcastInstance();
this.map = hazelcastInstance.getMultiMap("mm");
this.map.clear();
@@ -57,11 +57,11 @@ public class HazelcastMultimapConsumerTe
/*
* mail from talip (hazelcast) on 21.02.2011: MultiMap doesn't support eviction yet. We can and should add this feature.
*
- * we leave the test in our code an set the result to asserted by default.
+ * see also http://code.google.com/p/hazelcast/issues/detail?id=577&q=eviction
*/
@Test
public void testEnvict() throws InterruptedException {
- MockEndpoint out = super.getMockEndpoint("mock:envicted");
+ MockEndpoint out = getMockEndpoint("mock:envicted");
out.expectedMessageCount(1);
map.put("1", "my-foo-1");
@@ -72,8 +72,6 @@ public class HazelcastMultimapConsumerTe
map.put("6", "my-foo-6");
// assertMockEndpointsSatisfied(30000, TimeUnit.MILLISECONDS);
-
- assertTrue(true);
}
@Test
Modified: camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastMultimapProducerForSpringTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastMultimapProducerForSpringTest.java?rev=1291945&r1=1291944&r2=1291945&view=diff
==============================================================================
--- camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastMultimapProducerForSpringTest.java (original)
+++ camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastMultimapProducerForSpringTest.java Tue Feb 21 18:09:37 2012
@@ -22,10 +22,10 @@ import com.hazelcast.core.Hazelcast;
import com.hazelcast.core.MultiMap;
import org.apache.camel.test.junit4.CamelSpringTestSupport;
-import org.apache.camel.util.CastUtils;
import org.junit.AfterClass;
import org.junit.Test;
+
import org.springframework.context.support.AbstractApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
@@ -81,7 +81,7 @@ public class HazelcastMultimapProducerFo
map.put("4711", "my-foo");
template.sendBodyAndHeader("direct:get", null, HazelcastConstants.OBJECT_ID, "4711");
- Collection<Object> body = CastUtils.cast(consumer.receiveBody("seda:out", 5000, Collection.class));
+ Collection<?> body = consumer.receiveBody("seda:out", 5000, Collection.class);
assertTrue(body.contains("my-foo"));
}
Modified: camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastMultimapProducerTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastMultimapProducerTest.java?rev=1291945&r1=1291944&r2=1291945&view=diff
==============================================================================
--- camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastMultimapProducerTest.java (original)
+++ camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastMultimapProducerTest.java Tue Feb 21 18:09:37 2012
@@ -42,8 +42,6 @@ public class HazelcastMultimapProducerTe
Hazelcast.shutdownAll();
}
-
-
@Test
public void testPut() throws InterruptedException {
template.sendBodyAndHeader("direct:put", "my-foo", HazelcastConstants.OBJECT_ID, "4711");
@@ -70,12 +68,11 @@ public class HazelcastMultimapProducerTe
}
@Test
- @SuppressWarnings("unchecked")
public void testGet() {
map.put("4711", "my-foo");
template.sendBodyAndHeader("direct:get", null, HazelcastConstants.OBJECT_ID, "4711");
- Collection<Object> body = consumer.receiveBody("seda:out", 5000, Collection.class);
+ Collection<?> body = consumer.receiveBody("seda:out", 5000, Collection.class);
assertTrue(body.contains("my-foo"));
}
Modified: camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastQueueConsumerTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastQueueConsumerTest.java?rev=1291945&r1=1291944&r2=1291945&view=diff
==============================================================================
--- camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastQueueConsumerTest.java (original)
+++ camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastQueueConsumerTest.java Tue Feb 21 18:09:37 2012
@@ -34,19 +34,17 @@ public class HazelcastQueueConsumerTest
@Override
protected void doPostSetup() throws Exception {
- HazelcastComponent component = (HazelcastComponent) context().getComponent("hazelcast");
+ HazelcastComponent component = context().getComponent("hazelcast", HazelcastComponent.class);
HazelcastInstance hazelcastInstance = component.getHazelcastInstance();
this.map = hazelcastInstance.getQueue("mm");
this.map.clear();
}
-
@AfterClass
public static void tearDownClass() {
Hazelcast.shutdownAll();
}
-
@Test
public void add() throws InterruptedException {
MockEndpoint out = getMockEndpoint("mock:added");
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=1291945&r1=1291944&r2=1291945&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 Tue Feb 21 18:09:37 2012
@@ -32,7 +32,7 @@ public class HazelcastQueueProducerTest
@Override
protected void doPostSetup() throws Exception {
- HazelcastComponent component = (HazelcastComponent) context().getComponent("hazelcast");
+ HazelcastComponent component = context().getComponent("hazelcast", HazelcastComponent.class);
HazelcastInstance hazelcastInstance = component.getHazelcastInstance();
queue = hazelcastInstance.getQueue("bar");
queue.clear();
Modified: camel/trunk/parent/pom.xml
URL: http://svn.apache.org/viewvc/camel/trunk/parent/pom.xml?rev=1291945&r1=1291944&r2=1291945&view=diff
==============================================================================
--- camel/trunk/parent/pom.xml (original)
+++ camel/trunk/parent/pom.xml Tue Feb 21 18:09:37 2012
@@ -87,7 +87,7 @@
<hapi-version>1.2</hapi-version>
<hawtbuf-version>1.7</hawtbuf-version>
<hawtdb-version>1.6</hawtdb-version>
- <hazelcast-version>1.9.4.6</hazelcast-version>
+ <hazelcast-version>1.9.4.8</hazelcast-version>
<hibernate-version>3.2.6.ga</hibernate-version>
<hibernate-entitymanager-version>3.2.1.ga</hibernate-entitymanager-version>
<hsqldb-version>2.2.8</hsqldb-version>