/* * 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 callback.service; import java.util.Hashtable; import org.osgi.framework.BundleActivator; import org.osgi.framework.BundleContext; import org.osgi.framework.ServiceReference; import org.osoa.sca.annotations.Callback; import callback.client.CallbackCallback; /* * OSGi Callback service implementation */ public class OSGiCallbackServiceImpl implements CallbackService, BundleActivator { @Callback protected CallbackCallback callback; private BundleContext bundleContext; public void knockKnock(String aString) { System.out.println("CallbackServiceImpl message received: " + aString); callback.callbackMessage("Who's There"); System.out.println("CallbackServiceImpl response sent"); return; } public void multiCallback(String aString) { System.out.println("CallbackServiceImpl message received: " + aString); callback.callbackIncrement("Who's There 1"); System.out.println("CallbackServiceImpl response sent"); callback.callbackIncrement("Who's There 2"); System.out.println("CallbackServiceImpl response sent"); callback.callbackIncrement("Who's There 3"); System.out.println("CallbackServiceImpl response sent"); return; } public void noCallback(String aString) { System.out.println("CallbackServiceImpl message received: " + aString); // System.out.println("CallbackServiceImpl No response desired"); return; } public void start(BundleContext bc) throws Exception { System.out.println("Started OSGiCallbackServiceImpl bundle "); this.bundleContext = bc; Hashtable serviceProps = new Hashtable(); serviceProps.put("component.service.name", "CallbackService/CallbackService"); bundleContext.registerService("callback.service.CallbackService", this, serviceProps); ServiceReference ref= bundleContext.getServiceReference("callback.client.CallbackCallback"); if (ref != null) callback = (CallbackCallback)bundleContext.getService(ref); } public void stop(BundleContext bc) { } }