Fixed test for TCP

This commit is contained in:
nathan 2020-05-08 01:13:32 +02:00
parent 2dfea11c09
commit 693482dcff

View File

@ -41,8 +41,8 @@ class FirewallTest extends BaseTest {
public public
void sendDataFromClientClass() throws SecurityException, IOException { void sendDataFromClientClass() throws SecurityException, IOException {
Configuration configuration = new Configuration(); Configuration configuration = new Configuration();
// configuration.tcpPort = tcpPort; configuration.tcpPort = tcpPort;
configuration.udpPort = udpPort; // configuration.udpPort = udpPort;
configuration.host = host; configuration.host = host;
configuration.serialization = Serialization.DEFAULT(); configuration.serialization = Serialization.DEFAULT();
register(configuration.serialization); register(configuration.serialization);
@ -63,8 +63,7 @@ class FirewallTest extends BaseTest {
public public
void received(Connection connection, AMessage object) { void received(Connection connection, AMessage object) {
System.err.println("Server received message from client. Bouncing back."); System.err.println("Server received message from client. Bouncing back.");
connection.send() connection.send(object);
.TCP(object);
} }
}); });
@ -82,8 +81,7 @@ class FirewallTest extends BaseTest {
} }
}); });
client.send() client.send(new AMessage());
.TCP(new AMessage());
waitForThreads(); waitForThreads();