Remote Dynamic Method Invocation Handbook

// create a RDMI server using binary protocol and TCP as transport protocol
RemoteDmiServer server = new RemoteDmiServer(new TcpServer(1111), new BinaryProtocol());
// starts the server in a background thread
server.startInBackground();

out.println("RemoteDmiServer started on port 1111");
// wait for finishing server
// this only happens if a client request for shuting down the server
server.join();

out.println("RemoteDmiServer terminates");

// create a client connecting to server
RemoteDmiServer client = new RemoteDmiServer(new TcpServer(InetAddress::getLocalHost(), 1111), new BinaryProtocol());
// create an object with 'new acdk.lang.StringBuffer("hello")' on 
// the server and return the object as remote object
Object o = client.createRemote("acdk.lang.StringBuffer", "hello");
// call the append function on the remote object
o.append(" from remote");
// call the toString method on the remote object
out.println(o.toString());

  RRemoteDmiServer client = new RemoteDmiServer(new TcpServer(::acdk::net::InetAddress::getLocalHost(), 1111), new BinaryProtocol());
  RObject remSb = client->createRemoteObject("acdk/lang/StringBuffer", "acdk/lang/Object", inOf("Hello"));
  System::out->println((RString)remSb->invoke("toString"));

!

Object o = client.createRemote("acdk.lang.StringBuffer", "hello");

// C++
// Weak object
RObject object = client.createRemote("acdk.lang.StringBuffer", "hello");
// make a weak call.
// If the object doesn't provide the toString method
// an exception will be thrown
RString erg = (RString)object->invoke("toString");

// o is a weak object
Object o = client.createRemote("acdk.lang.StringBuffer", "hello");
// CfgScript knowns, that o is a weak type
// so the method call append will be tranformed to a weak call
o.append(" from remote");

// C++
// constructor are still called via the weak interface
acdk::io::RPrintWriter rout = 
  (acdk::io::RPrintWriter)client->peekStaticAs("acdk/lang/System", "acdk/io/PrintWriter", "out");
// as result a native interface can be used with no difference in the call syntax to
// local object invocations
rout->println("Hello");

// C++ sample
RComparable cmp = (RComparable)client->createRemoteAs("acdk/lang/StringBuffer", "acdk/lang/Comparable", "hello");
// the interface Comparable only support the compareTo method
// with weak invocation the other methods of the real remote object
// can be addressed
cmp->invoke("append", " to remote");

  // C++
class XY
{
  int callFoo(IN(RStringBuffer) sb, OUT(RComparable) cmp)
  {
    cmp = (RComparable)sb;
    return sb->length();
  }
  // ...
  // or CfgScript
  int callFoo(StringBuffer sb, out Comparable cmp)
  {
    cmp = sb;
    return sb.length();
  }
  // ...
  
// client code
RStringBuffer sb1 = new StringBuffer();
RComparable cmp;
int i = remoteObject->callFoo(sb1, cmp);

  // C++
class XY
{
  int callFoo(INBYVAL(RStringBuffer) sb, OUTREF(RStringBuffer) sb2)
  {
    sb2 = sb;
    return sb->length();
  }
  // ...
  // or CfgScript
  int callFoo(StringBuffer sb, out byref StringBuffer sb2)
  {
    sb2 = sb;
    return sb.length();
  }
  // ...

!

• The returned byref StringBuffer may be casted to StringBuffer, but all calls of non virtual methods are not dispatched to remote object.
  
• Forcing serialization of objects, which doesn't implement the Serializable interface may result in errors either rised by the remoting protocol or results in incorrectly initialized objects.
  

!

  // C++ & CfgScript
  RStringBuffer sb  = new StringBuffer("asdf");
  RObject objremote;
  // C++
  sb->invoke("callFoo", inOf(sb), byRef(outOf(objremote)));
  // CfgScript
  sb.callFoo(inOf(sb), byRef(outOf(objremote)));

  // C++
  sb->invoke("callFoo", byValAs(inOf(sb), StringBuffer::getClass()), byRefAs(outOf(objremote), Comparable::GetClass()));
  // CfgScript
  using acdk.cfgscript.ScriptGlobals;
  sb.callFoo(byValAs(inOf(sb), StringBuffer.getClass()), byRefAs(outOf(objremote), Comparable.GetClass()));

// CfgScript
Object o = ...;
o.toString__byRefAs("acdk/lang/Comparable");
// C++
RObject o = ...;
RComparable rcomp = o->invoke("toString__byRefAs", "acdk/lang/Comparable");

Object o = client.createRemote("acdk.lang.StringBuffer", "hello");
try {
  String s = o.substring(-2, 2004); // misuse: the server throws IndexOutOfBoundsException
                                    // The exception will be transfered serialized to client
                                    // and will (re-)thrown in the client
} catch (IndexOutOfBoundsException ex) {
  out.println(ex.getMessage());
}

// common source, known by server and client
interface Callback 
{
  void callIt(String s) = 0;
}
interface CallCallback 
{
  void callForEach(Callback cb) = 0;
}

// A server object
class MyServerObject
  implements CallCallback
{
  StringArray sa = [ "a", "b", "c" ];
  MyServerObject() {}
  void callForEach(Callback cb)
  {
    foreach (String s in sa)
    {
      cb.callIt(s);
    }
  }
}

// use it in client
class MyCallback
  implements Callback
{
  MyCallback() {}
  void callIt(String s)
  {
    out.println("MyCallback.callIt: " + s);
  }
}
MyCallback mycb = new MyCallback();

CallCallback cb =  client.createRemoteAs("MyServerObject", "CallCallback");
cb.callForEach(mycb);