1 23 package com.sun.enterprise.jbi.serviceengine.bridge; 24 25 import com.sun.enterprise.jbi.serviceengine.comm.MessageProcessor; 26 import com.sun.enterprise.jbi.serviceengine.core.Bridge; 27 import com.sun.enterprise.jbi.serviceengine.core.EndpointRegistry; 28 import com.sun.enterprise.jbi.serviceengine.core.ServiceEngineEndpoint; 29 import com.sun.enterprise.webservice.ServiceEngineRtObjectFactory; 30 import com.sun.enterprise.webservice.spi.DefaultServiceDelegateFactory; 31 import javax.jbi.messaging.MessageExchange; 32 33 37 public class AppServerBridge implements Bridge{ 38 39 40 public AppServerBridge() { 41 } 42 43 public void initialize() { 44 ServiceEngineRtObjectFactory.getInstance(). 45 setFacade(ServiceEngineFacadeImpl.getInstance()); 46 47 EndpointHelper.getInstance().initialize(); 49 DefaultServiceDelegateFactory.getFactory().addListener(new ServiceCreationListenerImpl()); 50 } 51 52 public MessageProcessor getMessageProcessor(MessageExchange me) { 53 ServiceEngineEndpoint seEndpoint = 54 EndpointRegistry.getInstance().get( 55 me.getEndpoint().getServiceName(), 56 me.getEndpoint().getEndpointName()); 57 if(seEndpoint.isJAXWSEndpoint()) 58 return new JAXWSMessageProcessor(); 59 else 60 return new JAXRPCMessageProcessor(); 61 } 62 63 public void destroy() { 64 EndpointHelper.getInstance().destroy(); 65 } 66 } 67 | Popular Tags |