Sending a class over the network always requires explicit registration now (previously, RMI message implementations did not require explicit registration)
This commit is contained in:
parent
ff350991a4
commit
05f3272f96
@ -106,9 +106,10 @@ class RmiSendObjectOverrideMethodTest extends BaseTest {
|
|||||||
|
|
||||||
final boolean isUDP = configuration.udpPort > 0;
|
final boolean isUDP = configuration.udpPort > 0;
|
||||||
|
|
||||||
configuration.serialization = Serialization.DEFAULT(true, true, false, null);
|
configuration.serialization = Serialization.DEFAULT();
|
||||||
configuration.serialization.registerRmi(TestObject.class, TestObjectImpl.class);
|
configuration.serialization.registerRmi(TestObject.class, TestObjectImpl.class);
|
||||||
configuration.serialization.registerRmi(OtherObject.class, OtherObjectImpl.class);
|
configuration.serialization.registerRmi(OtherObject.class, OtherObjectImpl.class);
|
||||||
|
configuration.serialization.register(OtherObjectImpl.class); // registered because this class is sent over the wire
|
||||||
|
|
||||||
Server server = new Server(configuration);
|
Server server = new Server(configuration);
|
||||||
server.setIdleTimeout(0);
|
server.setIdleTimeout(0);
|
||||||
@ -138,9 +139,12 @@ class RmiSendObjectOverrideMethodTest extends BaseTest {
|
|||||||
configuration = new Configuration();
|
configuration = new Configuration();
|
||||||
config.apply(configuration);
|
config.apply(configuration);
|
||||||
|
|
||||||
configuration.serialization = Serialization.DEFAULT(true, true, false, null);
|
configuration.serialization = Serialization.DEFAULT();
|
||||||
configuration.serialization.registerRmi(TestObject.class, TestObjectImpl.class);
|
configuration.serialization.registerRmi(TestObject.class, TestObjectImpl.class);
|
||||||
configuration.serialization.registerRmi(OtherObject.class, OtherObjectImpl.class);
|
configuration.serialization.registerRmi(OtherObject.class, OtherObjectImpl.class);
|
||||||
|
configuration.serialization.register(OtherObjectImpl.class); // registered because this class is sent over the wire
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
Client client = new Client(configuration);
|
Client client = new Client(configuration);
|
||||||
client.setIdleTimeout(0);
|
client.setIdleTimeout(0);
|
||||||
|
@ -90,9 +90,11 @@ class RmiSendObjectTest extends BaseTest {
|
|||||||
Configuration configuration = new Configuration();
|
Configuration configuration = new Configuration();
|
||||||
config.apply(configuration);
|
config.apply(configuration);
|
||||||
|
|
||||||
configuration.serialization = Serialization.DEFAULT(true, true, false, null);
|
configuration.serialization = Serialization.DEFAULT();
|
||||||
configuration.serialization.registerRmi(TestObject.class, TestObjectImpl.class);
|
configuration.serialization.registerRmi(TestObject.class, TestObjectImpl.class);
|
||||||
configuration.serialization.registerRmi(OtherObject.class, OtherObjectImpl.class);
|
configuration.serialization.registerRmi(OtherObject.class, OtherObjectImpl.class);
|
||||||
|
configuration.serialization.register(OtherObjectImpl.class); // registered because this class is sent over the wire
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
@ -124,9 +126,10 @@ class RmiSendObjectTest extends BaseTest {
|
|||||||
configuration = new Configuration();
|
configuration = new Configuration();
|
||||||
config.apply(configuration);
|
config.apply(configuration);
|
||||||
|
|
||||||
configuration.serialization = Serialization.DEFAULT(true, true, false, null);
|
configuration.serialization = Serialization.DEFAULT();
|
||||||
configuration.serialization.registerRmi(TestObject.class, TestObjectImpl.class);
|
configuration.serialization.registerRmi(TestObject.class, TestObjectImpl.class);
|
||||||
configuration.serialization.registerRmi(OtherObject.class, OtherObjectImpl.class);
|
configuration.serialization.registerRmi(OtherObject.class, OtherObjectImpl.class);
|
||||||
|
configuration.serialization.register(OtherObjectImpl.class); // registered because this class is sent over the wire
|
||||||
|
|
||||||
|
|
||||||
Client client = new Client(configuration);
|
Client client = new Client(configuration);
|
||||||
|
@ -218,7 +218,7 @@ class RmiTest extends BaseTest {
|
|||||||
Configuration configuration = new Configuration();
|
Configuration configuration = new Configuration();
|
||||||
config.apply(configuration);
|
config.apply(configuration);
|
||||||
|
|
||||||
configuration.serialization = Serialization.DEFAULT(true, true, false, null);
|
configuration.serialization = Serialization.DEFAULT();
|
||||||
register(configuration.serialization);
|
register(configuration.serialization);
|
||||||
|
|
||||||
// for Client -> Server RMI (ID 1)
|
// for Client -> Server RMI (ID 1)
|
||||||
@ -275,7 +275,7 @@ class RmiTest extends BaseTest {
|
|||||||
configuration = new Configuration();
|
configuration = new Configuration();
|
||||||
config.apply(configuration);
|
config.apply(configuration);
|
||||||
|
|
||||||
configuration.serialization = Serialization.DEFAULT(true, true, false, null);
|
configuration.serialization = Serialization.DEFAULT();
|
||||||
register(configuration.serialization);
|
register(configuration.serialization);
|
||||||
|
|
||||||
// for Client -> Server RMI (ID 1)
|
// for Client -> Server RMI (ID 1)
|
||||||
|
@ -78,10 +78,8 @@ class TestClient
|
|||||||
configuration.udpPort = 2001;
|
configuration.udpPort = 2001;
|
||||||
configuration.host = "localhost";
|
configuration.host = "localhost";
|
||||||
|
|
||||||
configuration.serialization = Serialization.DEFAULT(true, true, false, null);
|
configuration.serialization = Serialization.DEFAULT();
|
||||||
RmiTest.register(configuration.serialization);
|
RmiTest.register(configuration.serialization);
|
||||||
configuration.serialization.registerRmi(TestCow.class);
|
|
||||||
|
|
||||||
|
|
||||||
try {
|
try {
|
||||||
final Client client = new Client(configuration);
|
final Client client = new Client(configuration);
|
||||||
|
@ -21,8 +21,9 @@ class TestServer
|
|||||||
configuration.tcpPort = 2000;
|
configuration.tcpPort = 2000;
|
||||||
configuration.udpPort = 2001;
|
configuration.udpPort = 2001;
|
||||||
|
|
||||||
configuration.serialization = Serialization.DEFAULT(true, true, false, null);
|
configuration.serialization = Serialization.DEFAULT();
|
||||||
RmiTest.register(configuration.serialization);
|
RmiTest.register(configuration.serialization);
|
||||||
|
|
||||||
configuration.serialization.registerRmi(TestCow.class, TestCowImpl.class);
|
configuration.serialization.registerRmi(TestCow.class, TestCowImpl.class);
|
||||||
|
|
||||||
Server server = null;
|
Server server = null;
|
||||||
|
Loading…
Reference in New Issue
Block a user