package be.nikiroo.utils.test;
+import java.net.URL;
+
import be.nikiroo.utils.Version;
import be.nikiroo.utils.serial.server.ConnectActionClientObject;
import be.nikiroo.utils.serial.server.ConnectActionClientString;
throws Exception {
return null;
}
+
+ @Override
+ protected void onError(Exception e) {
+ }
};
int port = server.getPort();
ServerBridge br = null;
if (bridge) {
br = new ServerBridge(0, ssl, "", port, ssl);
+ br.setTraceHandler(null);
port = br.getPort();
assertEquals(
@Override
protected void onError(Exception e) {
- super.onError(e);
err[0] = e;
}
};
ServerBridge br = null;
if (bridge) {
br = new ServerBridge(0, ssl, "", port, ssl);
+ br.setTraceHandler(null);
port = br.getPort();
br.start();
}
@Override
protected void onError(Exception e) {
- super.onError(e);
err[0] = e;
}
};
ServerBridge br = null;
if (bridge) {
br = new ServerBridge(0, ssl, "", port, ssl);
+ br.setTraceHandler(null);
port = br.getPort();
br.start();
}
@Override
protected void onError(Exception e) {
- super.onError(e);
err[0] = e;
}
};
ServerBridge br = null;
if (bridge) {
br = new ServerBridge(0, ssl, "", port, ssl);
+ br.setTraceHandler(null);
port = br.getPort();
br.start();
}
throws Exception {
return null;
}
+
+ @Override
+ protected void onError(Exception e) {
+ }
};
int port = server.getPort();
ServerBridge br = null;
if (bridge) {
br = new ServerBridge(0, ssl, "", port, ssl);
+ br.setTraceHandler(null);
port = br.getPort();
br.start();
}
throws Exception {
rec[0] = true;
}
+
+ @Override
+ protected void onError(Exception e) {
+ }
}.connect();
} finally {
server.stop();
@Override
protected void onError(Exception e) {
- super.onError(e);
err[0] = e;
}
};
ServerBridge br = null;
if (bridge) {
br = new ServerBridge(0, ssl, "", port, ssl);
+ br.setTraceHandler(null);
port = br.getPort();
br.start();
}
@Override
protected void onError(Exception e) {
- super.onError(e);
err[0] = e;
}
};
ServerBridge br = null;
if (bridge) {
br = new ServerBridge(0, ssl, "", port, ssl);
+ br.setTraceHandler(null);
port = br.getPort();
br.start();
}
}
});
+ series.addTest(new TestCase("Object array of URLs " + ssls) {
+ final Object[] sent = new Object[1];
+ final Object[] recd = new Object[1];
+ final Exception[] err = new Exception[1];
+
+ @Override
+ public void test() throws Exception {
+ ServerObject server = new ServerObject(this.getName(), 0, ssl) {
+ @Override
+ protected Object onRequest(
+ ConnectActionServerObject action,
+ Version clientVersion, Object data)
+ throws Exception {
+ sent[0] = data;
+ return new Object[] { "ACK" };
+ }
+
+ @Override
+ protected void onError(Exception e) {
+ err[0] = e;
+ }
+ };
+
+ int port = server.getPort();
+
+ server.start();
+
+ ServerBridge br = null;
+ if (bridge) {
+ br = new ServerBridge(0, ssl, "", port, ssl);
+ br.setTraceHandler(null);
+ port = br.getPort();
+ br.start();
+ }
+
+ try {
+ try {
+ new ConnectActionClientObject(null, port, ssl) {
+ @Override
+ public void action(Version serverVersion)
+ throws Exception {
+ recd[0] = send(new Object[] {
+ "key",
+ new URL(
+ "https://example.com/from_client"),
+ "https://example.com/from_client" });
+ }
+ }.connect();
+ } finally {
+ server.stop();
+ }
+ } finally {
+ if (br != null) {
+ br.stop();
+ }
+ }
+
+ if (err[0] != null) {
+ fail("An exception was thrown: " + err[0].getMessage());
+ }
+
+ Object[] sento = (Object[]) (sent[0]);
+ Object[] recdo = (Object[]) (recd[0]);
+
+ assertEquals("key", sento[0]);
+ assertEquals("https://example.com/from_client",
+ ((URL) sento[1]).toString());
+ assertEquals("https://example.com/from_client", sento[2]);
+ assertEquals("ACK", recdo[0]);
+ }
+ });
+
series.addTest(new TestCase("Multiple call from client " + ssls) {
final Object[] sent = new Object[3];
final Object[] recd = new Object[3];
@Override
protected void onError(Exception e) {
- super.onError(e);
err[0] = e;
}
};
ServerBridge br = null;
if (bridge) {
br = new ServerBridge(0, ssl, "", port, ssl);
+ br.setTraceHandler(null);
port = br.getPort();
br.start();
}