--- /dev/null
+package org.simantics.databoard.example.old;
+import java.io.IOException;
+import java.net.Inet4Address;
+import java.util.HashMap;
+import java.util.Map;
+
+import org.simantics.databoard.Methods;
+import org.simantics.databoard.annotations.Unit;
+import org.simantics.databoard.binding.error.BindingConstructionException;
+import org.simantics.databoard.binding.error.BindingException;
+import org.simantics.databoard.method.Client;
+import org.simantics.databoard.method.MethodInterface;
+import org.simantics.databoard.method.Server;
+import org.simantics.databoard.serialization.SerializationException;
+
+/*******************************************************************************\r
+ * Copyright (c) 2010 Association for Decentralized Information Management in\r
+ * Industry THTH ry.\r
+ * All rights reserved. This program and the accompanying materials\r
+ * are made available under the terms of the Eclipse Public License v1.0\r
+ * which accompanies this distribution, and is available at\r
+ * http://www.eclipse.org/legal/epl-v10.html\r
+ *\r
+ * Contributors:\r
+ * VTT Technical Research Centre of Finland - initial API and implementation\r
+ *******************************************************************************/\r
+
+public class RPCExample3 {
+
+ public interface SiCarProvider {
+ SiCar findCar(String modelName) throws CarNotFoundError;
+ }
+
+ static public class SiCar {
+ public String modelName;
+ public @Unit("km/h") double maxVelocity;
+ public @Unit("kg") double mass;
+ public @Unit("cm") double length;
+ public @Unit("kW") double power;
+
+ public SiCar(String modelName, double maxVelocity, double mass, double length, double power)
+ {
+ this.modelName = modelName;
+ this.maxVelocity = maxVelocity;
+ this.mass = mass;
+ this.length = length;
+ this.power = power;
+ }
+
+ @Override
+ public String toString() {
+ return String.format("Name:%s, Mass: %2.0f kg, Power: %2.0f kW, Speed: %2.0f km/h, Length: %2.0f cm", modelName, mass, power, maxVelocity, length);
+ }
+ }
+
+
+ public interface ImCarProvider {
+ ImCar findCar(String modelName) throws CarNotFoundError;
+ }
+
+ static public class ImCar {
+ public String modelName;
+ public @Unit("mph") float maxVelocity;
+ public @Unit("lbs") float mass;
+ public @Unit("ft") float length;
+ public @Unit("hp(M)") float power;
+
+ public ImCar(String modelName, float maxVelocity, float mass, float length, float power)
+ {
+ this.modelName = modelName;
+ this.maxVelocity = maxVelocity;
+ this.mass = mass;
+ this.length = length;
+ this.power = power;
+ }
+
+ @Override
+ public String toString() {
+ return String.format("Name:%s, Mass: %2.0f lbs, Power: %2.0f hp, Speed: %2.0f mph, Length: %2.0f ft", modelName, mass, power, maxVelocity, length);
+ }
+ }
+
+
+ // Implementation
+ public static class CarCatalog implements SiCarProvider {
+ Map<String, SiCar> cars = new HashMap<String, SiCar>();
+ @Override
+ public SiCar findCar(String modelName)
+ throws CarNotFoundError{
+ if (cars.containsKey(modelName)) return cars.get(modelName);
+ throw new CarNotFoundError(modelName);
+ }
+
+ public void addCar(SiCar car) {
+ cars.put(car.modelName, car);
+ }
+
+ }
+
+ // Example Code
+ public static void main(String[] args) throws IOException, CarNotFoundError, BindingConstructionException, SerializationException, BindingException {
+ // Server
+ CarCatalog catalog = new CarCatalog();
+ catalog.addCar( new SiCar("Fiat 500", 205., 1034., 355., 75.) );
+
+ MethodInterface serverMi = Methods.bindInterface(SiCarProvider.class, catalog);
+ Server myServerSocket = new Server(8193, serverMi);
+
+ // Client
+ Client myClientSocket = new Client(Inet4Address.getByName("localhost"), 8193);
+
+ try {
+ SiCarProvider siCarProvider = Methods.createProxy(SiCarProvider.class, serverMi);
+ ImCarProvider imCarProvider = Methods.createProxy(ImCarProvider.class, Methods.adaptMethods(serverMi, Methods.getInterfaceType(ImCarProvider.class).getMethodDefinitions()));
+
+ System.out.println( siCarProvider.findCar("Fiat 500") );
+ System.out.println( imCarProvider.findCar("Fiat 500") );
+
+ } finally {
+ myClientSocket.close();
+ myServerSocket.close();
+ }
+ }
+
+ public static class CarNotFoundError extends Exception {
+ public String modelName;
+ public CarNotFoundError(String modelName) {
+ this.modelName = modelName;
+ }
+ @Override
+ public String toString() {
+ return modelName+" is not in the catalog";
+ }
+ }
+
+
+}
+