First version of skeleton-stub communication using queue and 2 sockets (one send...

[iot2.git] / iotjava / iotrmi / Java / basics / TestClassCallbacks_Stub.java

diff --git a/iotjava/iotrmi/Java/basics/TestClassCallbacks_Stub.java b/iotjava/iotrmi/Java/basics/TestClassCallbacks_Stub.java
index 81b20dd25dab5eedbe22daedb801bedb7b5730c0..1b0bc08d5f9fe51a7d14a8b554262e9e0b01ba4b 100644 (file)
--- a/iotjava/iotrmi/Java/basics/TestClassCallbacks_Stub.java
+++ b/iotjava/iotrmi/Java/basics/TestClassCallbacks_Stub.java
@@ -9,10 +9,12 @@ public class TestClassCallbacks_Stub {
 
                CommunicationHandler comHan = new CommunicationHandler(true);
                int numOfPorts = 2;
-               int[] ports = comHan.getCallbackPorts(numOfPorts);
+               //int[] ports = comHan.getCallbackPorts(numOfPorts);
 
-               int localport = 5011;
-               int port = 5010;
+               int localportsend = 5011;
+               int localportrecv = 6011;
+               int portsend = 5000;
+               int portrecv = 6000;
                //String address = "localhost";
                //String address = "192.168.2.191";     // RPi2
                //String skeletonAddress = "128.195.136.170";   // dc-9.calit2.uci.edu
@@ -22,18 +24,22 @@ public class TestClassCallbacks_Stub {
                //String callbackAddress = "192.168.2.191";     // RPi2
                int rev = 0;
 
-               TestClassComplete_Stub tcstub = new TestClassComplete_Stub(localport, port, skeletonAddress, callbackAddress, rev, ports);
+               TestClassComplete_Stub tcstub = new TestClassComplete_Stub(localportsend, localportrecv, portsend, portrecv, 
+                       skeletonAddress, rev);
                System.out.println("==== CALLBACKS ====");
                CallBackInterface cbSingle = new CallBack(2354);
                tcstub.registerCallback(cbSingle);
                System.out.println("Registered callback!");
-               //CallBackInterface cbSingle1 = new CallBack(2356);
-               //tcstub.registerCallback(cbSingle1);
+               CallBackInterface cbSingle1 = new CallBack(2356);
+               tcstub.registerCallback(cbSingle1);
+               System.out.println("Registered callback!");
+               CallBackInterface cbSingle2 = new CallBack(2360);
+               tcstub.registerCallback(cbSingle2);
                System.out.println("Registered callback!");
 
                System.out.println("Return value from callback 1: " + tcstub.callBack() + "\n\n");
                //System.out.println("\n\nCalling short one more time value: " + tcstub.getShort((short)4576) + "\n\n");
-               System.out.println("Return value from callback 2: " + tcstub.callBack() + "\n\n");
+               //System.out.println("Return value from callback 2: " + tcstub.callBack() + "\n\n");
                //System.out.println("\n\nCalling short one more time value: " + tcstub.getShort((short)1233) + "\n\n");
                //System.out.println("\n\nCalling short one more time value: " + tcstub.getShort((short)1321) + "\n\n");
                while(true) {}