diff options
Diffstat (limited to 'sca-java-2.x/contrib/modules/binding-comet-runtime/src/main/java/org/apache/tuscany/sca/binding/comet/runtime/CometServiceBindingProvider.java')
-rw-r--r-- | sca-java-2.x/contrib/modules/binding-comet-runtime/src/main/java/org/apache/tuscany/sca/binding/comet/runtime/CometServiceBindingProvider.java | 17 |
1 files changed, 6 insertions, 11 deletions
diff --git a/sca-java-2.x/contrib/modules/binding-comet-runtime/src/main/java/org/apache/tuscany/sca/binding/comet/runtime/CometServiceBindingProvider.java b/sca-java-2.x/contrib/modules/binding-comet-runtime/src/main/java/org/apache/tuscany/sca/binding/comet/runtime/CometServiceBindingProvider.java index 7081081a14..0077504296 100644 --- a/sca-java-2.x/contrib/modules/binding-comet-runtime/src/main/java/org/apache/tuscany/sca/binding/comet/runtime/CometServiceBindingProvider.java +++ b/sca-java-2.x/contrib/modules/binding-comet-runtime/src/main/java/org/apache/tuscany/sca/binding/comet/runtime/CometServiceBindingProvider.java @@ -30,34 +30,31 @@ import org.atmosphere.cpr.MeteorServlet; public class CometServiceBindingProvider implements ServiceBindingProvider { + private static final String SERVLET_KEY = "org.atmosphere.servlet"; + private static final String SERVLET_VALUE = "org.apache.tuscany.sca.binding.comet.runtime.CometServlet"; + private RuntimeEndpoint endpoint; private ServletHost servletHost; public CometServiceBindingProvider(RuntimeEndpoint endpoint, ServletHost servletHost) { - System.out.println("Entering CometServiceBindingProvider constructor..."); this.endpoint = endpoint; this.servletHost = servletHost; } public void start() { - System.out.println("Entering CometServiceBindingProvider#start..."); ComponentService service = endpoint.getService(); Interface serviceInterface = service.getInterfaceContract().getInterface(); for (Operation op : serviceInterface.getOperations()) { MeteorServlet servlet = new MeteorServlet(); - servlet.addInitParameter("org.atmosphere.servlet", "org.apache.tuscany.sca.binding.comet.runtime.CometServlet"); - // TODO fix TuscanyServletFilter to use Servlets 3.0 - servlet.addInitParameter("org.atmosphere.useNative", "true"); + servlet.addInitParameter(SERVLET_KEY, SERVLET_VALUE); String path = endpoint.getBinding().getURI() + "/" + op.getName(); servletHost.addServletMapping(path, servlet); - System.out.println("Adding attributes to servlet context..."); - servlet.getServletContext().setAttribute("org.apache.tuscany.sca.binding.comet.endpoint", endpoint); - servlet.getServletContext().setAttribute("org.apache.tuscany.sca.binding.comet.operation", op); + servlet.getServletContext().setAttribute(CometServlet.ENDPOINT_KEY, endpoint); + servlet.getServletContext().setAttribute(CometServlet.OPERATION_KEY, op); } } public void stop() { - System.out.println("Entering CometServiceBindingProvider#stop..."); ComponentService service = endpoint.getService(); Interface serviceInterface = service.getInterfaceContract().getInterface(); for (Operation op : serviceInterface.getOperations()) { @@ -67,12 +64,10 @@ public class CometServiceBindingProvider implements ServiceBindingProvider { } public InterfaceContract getBindingInterfaceContract() { - System.out.println("Entering CometServiceBindingProvider#getBindingInterfaceContract..."); return null; } public boolean supportsOneWayInvocation() { - System.out.println("Entering CometServiceBindingProvider#supportsOneWayInvocation..."); return true; } |