1 10 11 package org.mule.tck; 12 13 import org.mule.MuleManager; 14 import org.mule.impl.model.seda.SedaModel; 15 import org.mule.interceptors.InterceptorStack; 16 import org.mule.interceptors.LoggingInterceptor; 17 import org.mule.umo.UMOException; 18 import org.mule.umo.UMOInterceptorStack; 19 import org.mule.umo.endpoint.UMOEndpoint; 20 import org.mule.umo.manager.UMOManager; 21 import org.mule.umo.provider.UMOConnector; 22 import org.mule.umo.transformer.UMOTransformer; 23 24 import java.util.ArrayList ; 25 import java.util.List ; 26 27 31 32 public abstract class AbstractUMOManagerTestCase extends AbstractMuleTestCase 33 { 34 private static boolean initialised = false; 35 36 protected void doSetUp() throws Exception 37 { 38 if (!initialised) 39 { 40 getUMOManager(); 41 initialised = true; 42 } 43 } 44 45 public abstract UMOManager getUMOManager() throws Exception ; 46 47 public void testConnectorLookup() throws Exception 48 { 49 UMOConnector connector = MuleManager.getInstance().lookupConnector("testConnector"); 50 assertNotNull(connector); 51 assertEquals(1, MuleManager.getInstance().getConnectors().size()); 52 UMOConnector connector2 = getTestConnector(); 53 MuleManager.getInstance().registerConnector(connector2); 54 assertEquals(2, MuleManager.getInstance().getConnectors().size()); 55 56 assertNull(MuleManager.getInstance().lookupConnector("doesnotexist")); 57 } 58 59 public void testEndpointLookup() throws Exception 60 { 61 UMOEndpoint endpoint = MuleManager.getInstance().lookupEndpoint("testEndpoint"); 62 assertNotNull(endpoint); 63 assertEquals(1, MuleManager.getInstance().getEndpoints().size()); 64 UMOEndpoint endpoint2 = getTestEndpoint("testProvider2", UMOEndpoint.ENDPOINT_TYPE_SENDER); 65 MuleManager.getInstance().registerEndpoint(endpoint2); 66 assertEquals(2, MuleManager.getInstance().getEndpoints().size()); 67 68 UMOEndpoint endpoint3 = MuleManager.getInstance().lookupEndpoint("doesnotexist"); 69 assertNull(endpoint3); 70 } 71 72 public void testTransformerLookup() throws Exception 73 { 74 UMOTransformer transformer = MuleManager.getInstance().lookupTransformer("testTransformer"); 75 assertNotNull(transformer); 76 assertEquals(1, MuleManager.getInstance().getTransformers().size()); 77 UMOTransformer transformer2 = getTestTransformer(); 78 MuleManager.getInstance().registerTransformer(transformer2); 79 assertEquals(2, MuleManager.getInstance().getTransformers().size()); 80 81 UMOTransformer transformer3 = MuleManager.getInstance().lookupTransformer("doesnotexist"); 82 assertNull(transformer3); 83 } 84 85 public void testEndpointIdentifierLookup() throws Exception 86 { 87 String endpoint = MuleManager.getInstance().lookupEndpointIdentifier("testEndpointURI", null); 88 assertNotNull(endpoint); 89 assertEquals("test://endpoint.test", endpoint); 90 assertEquals(1, MuleManager.getInstance().getEndpointIdentifiers().size()); 91 MuleManager.getInstance().registerEndpointIdentifier("testEndpoint2", "endpointUri.test.2"); 92 assertEquals(2, MuleManager.getInstance().getEndpointIdentifiers().size()); 93 94 String endpoint2 = MuleManager.getInstance().lookupEndpointIdentifier("doesnotexist", null); 95 assertNull(endpoint2); 96 } 97 98 public void testManagerProperties() 99 { 100 String value = (String )MuleManager.getInstance().getProperty("envProperty1"); 101 assertEquals("value1", value); 102 assertEquals(1, MuleManager.getInstance().getProperties().size()); 103 } 104 105 public void testInterceptorStacks() 106 { 107 UMOInterceptorStack stack1 = MuleManager.getInstance().lookupInterceptorStack("testInterceptorStack"); 108 assertNotNull(stack1); 109 List interceptors = stack1.getInterceptors(); 110 assertEquals(2, interceptors.size()); 111 112 InterceptorStack stack2 = new InterceptorStack(); 113 List interceptors2 = new ArrayList (); 114 interceptors2.add(new LoggingInterceptor()); 115 stack2.setInterceptors(interceptors2); 116 117 MuleManager.getInstance().registerInterceptorStack("testInterceptors2", stack2); 118 119 assertEquals(1, MuleManager.getInstance() 120 .lookupInterceptorStack("testInterceptors2") 121 .getInterceptors() 122 .size()); 123 124 UMOInterceptorStack stack3 = MuleManager.getInstance().lookupInterceptorStack("doesnotexist"); 125 assertNull(stack3); 126 } 127 128 public void testTrasactionSetting() throws Exception 129 { 130 assertNotNull(MuleManager.getInstance().getTransactionManager()); 131 try 132 { 133 MuleManager.getInstance().setTransactionManager(null); 134 fail("cannot set tx manager once it has been set"); 135 } 136 catch (Exception e) 137 { 138 } 140 } 141 142 public void testModelSetting() throws UMOException 143 { 144 assertNotNull(MuleManager.getInstance().getModel()); 145 MuleManager.getInstance().setModel(new SedaModel()); 146 assertEquals("mule", MuleManager.getInstance().getModel().getName()); 147 } 148 } 149 | Popular Tags |