summaryrefslogtreecommitdiffstats
path: root/java/sca/modules/node-impl-osgi/src/main/java/org/apache/tuscany/sca/osgi/remoteserviceadmin/impl/RemoteServiceAdminImpl.java
diff options
context:
space:
mode:
Diffstat (limited to 'java/sca/modules/node-impl-osgi/src/main/java/org/apache/tuscany/sca/osgi/remoteserviceadmin/impl/RemoteServiceAdminImpl.java')
-rw-r--r--java/sca/modules/node-impl-osgi/src/main/java/org/apache/tuscany/sca/osgi/remoteserviceadmin/impl/RemoteServiceAdminImpl.java289
1 files changed, 0 insertions, 289 deletions
diff --git a/java/sca/modules/node-impl-osgi/src/main/java/org/apache/tuscany/sca/osgi/remoteserviceadmin/impl/RemoteServiceAdminImpl.java b/java/sca/modules/node-impl-osgi/src/main/java/org/apache/tuscany/sca/osgi/remoteserviceadmin/impl/RemoteServiceAdminImpl.java
deleted file mode 100644
index 28b2d864aa..0000000000
--- a/java/sca/modules/node-impl-osgi/src/main/java/org/apache/tuscany/sca/osgi/remoteserviceadmin/impl/RemoteServiceAdminImpl.java
+++ /dev/null
@@ -1,289 +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.osgi.remoteserviceadmin.impl;
-
-import java.util.ArrayList;
-import java.util.Collection;
-import java.util.Dictionary;
-import java.util.HashMap;
-import java.util.Hashtable;
-import java.util.List;
-import java.util.Map;
-
-import org.apache.tuscany.sca.osgi.remoteserviceadmin.EndpointDescription;
-import org.apache.tuscany.sca.osgi.remoteserviceadmin.ExportRegistration;
-import org.apache.tuscany.sca.osgi.remoteserviceadmin.ImportRegistration;
-import org.apache.tuscany.sca.osgi.remoteserviceadmin.RemoteServiceAdmin;
-import org.apache.tuscany.sca.osgi.remoteserviceadmin.RemoteServiceAdminEvent;
-import org.apache.tuscany.sca.osgi.remoteserviceadmin.RemoteServiceAdminListener;
-import org.osgi.framework.Bundle;
-import org.osgi.framework.BundleContext;
-import org.osgi.framework.Constants;
-import org.osgi.framework.ServiceReference;
-import org.osgi.framework.ServiceRegistration;
-import org.osgi.service.cm.ConfigurationException;
-import org.osgi.service.cm.ManagedService;
-import org.osgi.service.event.Event;
-import org.osgi.service.event.EventAdmin;
-import org.osgi.util.tracker.ServiceTracker;
-
-/**
- * SCA Implementation of {@link RemoteServiceAdmin}
- */
-public class RemoteServiceAdminImpl implements RemoteServiceAdmin, ManagedService {
- private BundleContext context;
- private ServiceRegistration registration;
- private ServiceRegistration managedService;
- private ServiceTracker listeners;
-
- private OSGiServiceExporter exporter;
- private OSGiServiceImporter importer;
-
- private Collection<ImportRegistration> importedEndpoints = new ArrayList<ImportRegistration>();
- private Collection<ExportRegistration> exportedServices = new ArrayList<ExportRegistration>();
-
- public RemoteServiceAdminImpl(BundleContext context) {
- this.context = context;
- }
-
- public void start() {
- this.exporter = new OSGiServiceExporter(context);
- this.importer = new OSGiServiceImporter(context);
- exporter.start();
- importer.start();
- registration = context.registerService(RemoteServiceAdmin.class.getName(), this, null);
- Hashtable<String, Object> props = new Hashtable<String, Object>();
- props.put(Constants.SERVICE_PID, RemoteServiceAdminImpl.class.getName());
- managedService = context.registerService(ManagedService.class.getName(), this, props);
- listeners = new ServiceTracker(this.context, RemoteServiceAdminListener.class.getName(), null);
- listeners.open();
- }
-
- public void stop() {
- if (registration != null) {
- try {
- registration.unregister();
- } catch (IllegalStateException e) {
- // The service has been unregistered, ignore it
- }
- registration = null;
- }
- if (managedService != null) {
- try {
- managedService.unregister();
- } catch (IllegalStateException e) {
- // The service has been unregistered, ignore it
- }
- managedService = null;
- }
- if (listeners != null) {
- listeners.close();
- listeners = null;
- }
- for (ExportRegistration exportRegistration : exportedServices) {
- exportRegistration.close();
- }
- exportedServices.clear();
- for (ImportRegistration importRegistration : importedEndpoints) {
- importRegistration.close();
- }
- importedEndpoints.clear();
- if (importer != null) {
- importer.stop();
- importer = null;
- }
- if (exporter != null) {
- exporter.stop();
- exporter = null;
- }
- }
-
- /**
- * @see org.apache.tuscany.sca.osgi.remoteserviceadmin.RemoteServiceAdmin#exportService(org.osgi.framework.ServiceReference,
- * java.util.Map)
- */
- public List<ExportRegistration> exportService(ServiceReference ref, Map properties) {
- List<ExportRegistration> exportRegistrations = exporter.exportService(ref, properties);
- if (exportRegistrations != null) {
- exportedServices.addAll(exportRegistrations);
- fireExportEvents(ref.getBundle(), exportRegistrations);
- }
- return exportRegistrations;
- }
-
- private void fireExportEvents(Bundle source, List<ExportRegistration> exportRegistrations) {
- for (ExportRegistration registration : exportRegistrations) {
- RemoteServiceAdminEvent rsaEvent =
- new RemoteServiceAdminEvent(RemoteServiceAdminEvent.EXPORT_REGISTRATION, source, registration.getExportReference(),
- registration.getException());
- EventAdmin eventAdmin = getEventAdmin();
- if (eventAdmin != null) {
- eventAdmin.postEvent(wrap(rsaEvent));
- }
- for (Object listener : listeners.getServices()) {
- RemoteServiceAdminListener rsaListener = (RemoteServiceAdminListener)listener;
- rsaListener.remoteAdminEvent(rsaEvent);
- }
- }
- }
-
- private EventAdmin getEventAdmin() {
- ServiceReference reference = context.getServiceReference(EventAdmin.class.getName());
- if (reference == null) {
- return null;
- } else {
- return (EventAdmin)context.getService(reference);
- }
- }
-
- private Event wrap(RemoteServiceAdminEvent rsaEvent) {
- int type = rsaEvent.getType();
- String eventType = null;
- switch (type) {
- case RemoteServiceAdminEvent.EXPORT_ERROR:
- eventType = "EXPORT_ERROR";
- break;
- case RemoteServiceAdminEvent.EXPORT_REGISTRATION:
- eventType = "EXPORT_REGISTRATION";
- break;
- case RemoteServiceAdminEvent.EXPORT_UNREGISTRATION:
- eventType = "EXPORT_UNREGISTRATION";
- break;
- case RemoteServiceAdminEvent.EXPORT_WARNING:
- eventType = "EXPORT_WARNING";
- break;
- case RemoteServiceAdminEvent.IMPORT_ERROR:
- eventType = "IMPORT_ERROR";
- break;
- case RemoteServiceAdminEvent.IMPORT_REGISTRATION:
- eventType = "IMPORT_REGISTRATION";
- break;
- case RemoteServiceAdminEvent.IMPORT_UNREGISTRATION:
- eventType = "EXPORT_ERROR";
- break;
- case RemoteServiceAdminEvent.IMPORT_WARNING:
- eventType = "IMPORT_UNREGISTRATION";
- break;
- }
- String topic = "org/osgi/service/remoteserviceadmin/" + eventType;
- Map<String, Object> props = new HashMap<String, Object>();
- /*
- * <ul>
- <li>bundle – (Bundle) The Remote Service Admin bundle
- <li>bundle-id – (Long) The id of the Blueprint bundle.
- <li>bundle-symbolicname – (String) The Bundle Symbolic Name of the
- Remote Service Admin bundle.
- <li>bundle-version - (Version) The version of the Blueprint bundle.
- <li>cause – The exception, if present.
- <li>import.registration – An imported endpoint, if present
- <li>export.registration – An exported endpoint, if present
- <li>service.remote.id – Remote service UUID, if present
- <li>service.remote.uuid – Remote service UUID, if present
- <li>service.remote.uri – (String) The URI of the endpoint, if present
- <li>objectClass – (String[]) The interface names, if present
- <li>service.imported.configs – (String+) The configuration types of the
- imported services, if present
- <li>timestamp – (Long) The time when the event occurred
- <li>event – (RemoteServiceAdminEvent) The RemoteServiceAdminEvent
- object that caused this event.
- </ul>
- */
- Bundle rsaBundle = context.getBundle();
- props.put("bundle", rsaBundle);
- props.put("bundle-id", rsaBundle.getBundleId());
- props.put("bundle-symbolicname", rsaBundle.getSymbolicName());
- props.put("bundle-version", rsaBundle.getHeaders().get(Constants.BUNDLE_VERSION));
- props.put("cause", rsaEvent.getException());
- props.put("import.reference", rsaEvent.getImportReference());
- props.put("export.reference", rsaEvent.getExportReference());
- EndpointDescription ep = null;
- if (rsaEvent.getImportReference() != null) {
- ep = rsaEvent.getImportReference().getImportedEndpointDescription();
- } else {
- ep = rsaEvent.getExportReference().getEndpointDescription();
- }
- props.put("service.remote.id", ep.getRemoteServiceID());
- props.put("service.remote.uuid", ep.getRemoteFrameworkUUID());
- props.put("service.remote.uri", ep.getRemoteURI());
- props.put("objectClass", ep.getInterfaces());
- props.put("service.imported.configs", ep.getConfigurationTypes());
- props.put("timestamp", new Long(System.currentTimeMillis()));
- props.put("event", rsaEvent);
- return new Event(topic, props);
- }
-
- private void fireImportEvents(Bundle source, ImportRegistration registration) {
- RemoteServiceAdminEvent rsaEvent =
- new RemoteServiceAdminEvent(RemoteServiceAdminEvent.IMPORT_REGISTRATION, source, registration.getImportedReference(), registration
- .getException());
- EventAdmin eventAdmin = getEventAdmin();
- if (eventAdmin != null) {
- eventAdmin.postEvent(wrap(rsaEvent));
- }
- for (Object listener : listeners.getServices()) {
- RemoteServiceAdminListener rsaListener = (RemoteServiceAdminListener)listener;
- rsaListener.remoteAdminEvent(rsaEvent);
- }
- }
-
- /**
- * @see org.apache.tuscany.sca.osgi.remoteserviceadmin.RemoteServiceAdmin#getExportedServices()
- */
- public Collection<ExportRegistration> getExportedServices() {
- return exportedServices;
- }
-
- /**
- * @see org.apache.tuscany.sca.osgi.remoteserviceadmin.RemoteServiceAdmin#getImportedEndpoints()
- */
- public Collection<ImportRegistration> getImportedEndpoints() {
- return importedEndpoints;
- }
-
- /**
- * @see org.apache.tuscany.sca.osgi.remoteserviceadmin.RemoteServiceAdmin#importService(org.apache.tuscany.sca.dosgi.discovery.EndpointDescription)
- */
- public ImportRegistration importService(EndpointDescription endpoint) {
- Bundle bundle = (Bundle)endpoint.getProperties().get(Bundle.class.getName());
- ImportRegistration importReg = importer.importService(bundle, endpoint);
- if (importReg != null) {
- fireImportEvents(bundle, importReg);
- importedEndpoints.add(importReg);
- }
- return importReg;
- }
-
- public synchronized void updated(Dictionary props) throws ConfigurationException {
- if (props == null) {
- // It can be null in Apache Felix
- return;
- }
- String domainRegistry = (String)props.get("org.osgi.sca.domain.registry");
- String domainURI = (String)props.get("org.osgi.sca.domain.uri");
- if (domainRegistry != null) {
- exporter.setDomainRegistry(domainRegistry);
- importer.setDomainRegistry(domainRegistry);
- }
- if (domainURI != null) {
- exporter.setDomainURI(domainURI);
- importer.setDomainURI(domainURI);
- }
- }
-}
generated by cgit v1.2.3 (git 2.25.1) at 2024-05-17 10:16:18 +0000