From 2f187c12e2ceceb61ca2745463fcd7fbbb438b72 Mon Sep 17 00:00:00 2001 From: antelder Date: Thu, 16 Feb 2012 15:39:43 +0000 Subject: Rename beta3 tag to final name git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@1245035 13f79535-47bb-0310-9956-ffa450edef68 --- .../runtime/WebsocketServiceBindingProvider.java | 109 --------------------- 1 file changed, 109 deletions(-) delete mode 100644 sca-java-2.x/tags/2.0-Beta3/modules/binding-websocket/src/main/java/org/apache/tuscany/sca/binding/websocket/runtime/WebsocketServiceBindingProvider.java (limited to 'sca-java-2.x/tags/2.0-Beta3/modules/binding-websocket/src/main/java/org/apache/tuscany/sca/binding/websocket/runtime/WebsocketServiceBindingProvider.java') diff --git a/sca-java-2.x/tags/2.0-Beta3/modules/binding-websocket/src/main/java/org/apache/tuscany/sca/binding/websocket/runtime/WebsocketServiceBindingProvider.java b/sca-java-2.x/tags/2.0-Beta3/modules/binding-websocket/src/main/java/org/apache/tuscany/sca/binding/websocket/runtime/WebsocketServiceBindingProvider.java deleted file mode 100644 index 2352970b2e..0000000000 --- a/sca-java-2.x/tags/2.0-Beta3/modules/binding-websocket/src/main/java/org/apache/tuscany/sca/binding/websocket/runtime/WebsocketServiceBindingProvider.java +++ /dev/null @@ -1,109 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - */ - -package org.apache.tuscany.sca.binding.websocket.runtime; - -import java.util.HashMap; -import java.util.Map; - -import org.apache.tuscany.sca.binding.websocket.WebsocketBinding; -import org.apache.tuscany.sca.host.http.ServletHost; -import org.apache.tuscany.sca.interfacedef.InterfaceContract; -import org.apache.tuscany.sca.interfacedef.Operation; -import org.apache.tuscany.sca.provider.ServiceBindingProvider; -import org.apache.tuscany.sca.runtime.RuntimeEndpoint; - -/** - * The service binding provider initiates the necessary infrastructure to expose - * services via websockets. - */ -public class WebsocketServiceBindingProvider implements ServiceBindingProvider { - - private static final int DEFAULT_PORT = 9000; - private static final String JAVASCRIPT_RESOURCE_PATH = "/org.apache.tuscany.sca.WebsocketComponentContext.js"; - private static Map servers = new HashMap(); - private RuntimeEndpoint endpoint; - private ServletHost servletHost; - - public WebsocketServiceBindingProvider(RuntimeEndpoint endpoint, ServletHost servletHost) { - this.endpoint = endpoint; - this.servletHost = servletHost; - } - - public void start() { - WebsocketBinding binding = (WebsocketBinding) endpoint.getBinding(); - int port = DEFAULT_PORT; - if (binding.getPort() != null) { - port = Integer.parseInt(binding.getPort()); - } - try { - WebsocketServer server = initServerForURI(port); - String component = endpoint.getComponent().getName(); - String service = endpoint.getService().getName(); - for (Operation op : getBindingInterfaceContract().getInterface().getOperations()) { - String operation = op.getName(); - server.getDispatcher().addOperation(component + "." + service + "." + operation, endpoint, op); - } - JavascriptGenerator.generateServiceProxy(component, service, getBindingInterfaceContract().getInterface() - .getOperations(), port); - } catch (Exception e) { - throw new RuntimeException(e); - } - initJavascriptResource(); - } - - private WebsocketServer initServerForURI(int port) throws Exception { - WebsocketServer server = servers.get(port); - if (server == null) { - server = new WebsocketServer(port); - server.start(); - servers.put(port, server); - } - return server; - } - - private void initJavascriptResource() { - if (servletHost.getServletMapping(JAVASCRIPT_RESOURCE_PATH) == null) { - servletHost.addServletMapping(JAVASCRIPT_RESOURCE_PATH, new JavascriptResourceServlet()); - } - } - - public void stop() { - for (WebsocketServer server : servers.values()) { - try { - server.stop(); - } catch (Exception e) { - throw new RuntimeException(e); - } - } - servers.clear(); - servletHost.removeServletMapping(JAVASCRIPT_RESOURCE_PATH); - JavascriptGenerator.clear(); - WebsocketConnectionManager.clear(); - } - - public InterfaceContract getBindingInterfaceContract() { - return endpoint.getService().getInterfaceContract(); - } - - public boolean supportsOneWayInvocation() { - return false; - } - -} -- cgit v1.2.3