svn commit: r1341049 - /camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastSedaConfigurationTest.java

[davsclaus]

Author: davsclaus
Date: Mon May 21 14:39:09 2012
New Revision: 1341049

URL: http://svn.apache.org/viewvc?rev=1341049&view=rev
Log:
Fixed test

Modified:
    
camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastSedaConfigurationTest.java

Modified: 
camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastSedaConfigurationTest.java
URL: 
http://svn.apache.org/viewvc/camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastSedaConfigurationTest.java?rev=1341049&r1=1341048&r2=1341049&view=diff
==============================================================================
--- 
camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastSedaConfigurationTest.java
 (original)
+++ 
camel/trunk/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastSedaConfigurationTest.java
 Mon May 21 14:39:09 2012
@@ -24,62 +24,42 @@ public class HazelcastSedaConfigurationT
 
     @Test
     public void createEndpointWithTransferExchange() throws Exception {
-        HazelcastComponent hzlqComponent = new HazelcastComponent(context);
-        hzlqComponent.start();
-
-        HazelcastSedaEndpoint hzlqEndpoint = (HazelcastSedaEndpoint) 
hzlqComponent.createEndpoint("hazelcast:seda:foo?transferExchange=true");
+        HazelcastSedaEndpoint hzlqEndpoint = (HazelcastSedaEndpoint) 
context.getEndpoint("hazelcast:seda:foo?transferExchange=true");
 
         assertEquals("Invalid queue name", "foo", 
hzlqEndpoint.getConfiguration().getQueueName());
         assertTrue("Default value of concurrent consumers is invalid", 
hzlqEndpoint.getConfiguration().isTransferExchange());
 
-        hzlqEndpoint = (HazelcastSedaEndpoint) 
hzlqComponent.createEndpoint("hazelcast:seda:foo?transferExchange=false");
+        hzlqEndpoint = (HazelcastSedaEndpoint) 
context.getEndpoint("hazelcast:seda:foo?transferExchange=false");
 
         assertEquals("Invalid queue name", "foo", 
hzlqEndpoint.getConfiguration().getQueueName());
         assertFalse("Default value of concurrent consumers is invalid", 
hzlqEndpoint.getConfiguration().isTransferExchange());
-        hzlqComponent.stop();
     }
 
     @Test
     public void createEndpointWithNoParams() throws Exception {
-        HazelcastComponent hzlqComponent = new HazelcastComponent(context);
-        hzlqComponent.start();
-        HazelcastSedaEndpoint hzlqEndpoint = (HazelcastSedaEndpoint) 
hzlqComponent.createEndpoint("hazelcast:seda:foo");
+        HazelcastSedaEndpoint hzlqEndpoint = (HazelcastSedaEndpoint) 
context.getEndpoint("hazelcast:seda:foo");
 
         assertEquals("Invalid queue name", "foo", 
hzlqEndpoint.getConfiguration().getQueueName());
         assertEquals("Default value of concurrent consumers is invalid", 1, 
hzlqEndpoint.getConfiguration().getConcurrentConsumers());
         assertEquals("Default value of pool interval is invalid", 1000, 
hzlqEndpoint.getConfiguration().getPollInterval());
-        hzlqComponent.stop();
     }
 
     @Test
     public void createEndpointWithConcurrentConsumersParam() throws Exception {
-        HazelcastComponent hzlqComponent = new HazelcastComponent(context);
-        hzlqComponent.start();
-        HazelcastSedaEndpoint hzlqEndpoint = (HazelcastSedaEndpoint) 
hzlqComponent.createEndpoint("hazelcast:seda:foo?concurrentConsumers=4");
+        HazelcastSedaEndpoint hzlqEndpoint = (HazelcastSedaEndpoint) 
context.getEndpoint("hazelcast:seda:foo?concurrentConsumers=4");
 
         assertEquals("Invalid queue name", "foo", 
hzlqEndpoint.getConfiguration().getQueueName());
         assertEquals("Value of concurrent consumers is invalid", 4, 
hzlqEndpoint.getConfiguration().getConcurrentConsumers());
         assertEquals("Default value of pool interval is invalid", 1000, 
hzlqEndpoint.getConfiguration().getPollInterval());
-        hzlqComponent.stop();
     }
 
     @Test
     public void createEndpointWithPoolIntevalParam() throws Exception {
-        HazelcastComponent hzlqComponent = new HazelcastComponent(context);
-        hzlqComponent.start();
-        HazelcastSedaEndpoint hzlqEndpoint = (HazelcastSedaEndpoint) 
hzlqComponent.createEndpoint("hazelcast:seda:foo?pollInterval=4000");
+        HazelcastSedaEndpoint hzlqEndpoint = (HazelcastSedaEndpoint) 
context.getEndpoint("hazelcast:seda:foo?pollInterval=4000");
 
         assertEquals("Invalid queue name", "foo", 
hzlqEndpoint.getConfiguration().getQueueName());
         assertEquals("Default value of concurrent consumers is invalid", 1, 
hzlqEndpoint.getConfiguration().getConcurrentConsumers());
         assertEquals("Invalid pool interval", 4000, 
hzlqEndpoint.getConfiguration().getPollInterval());
-        hzlqComponent.stop();
     }
 
-    @Test(expected = IllegalArgumentException.class)
-    public void createEndpointWithoutEmptyName() throws Exception {
-        HazelcastComponent hzlqComponent = new HazelcastComponent(context);
-        hzlqComponent.start();
-        hzlqComponent.createEndpoint("hazelcast:seda: ?concurrentConsumers=4");
-        hzlqComponent.stop();
-    }
 }