@Test
  public void registerDataSerializerGetsPropagatedToAnotherClient() throws Exception {
    PORT1 = initServerCache(server1);
    PORT2 = initServerCache(server2);

    createClientCache(NetworkUtils.getServerHostName(server1.getHost()), PORT1);

    client2.invoke(() -> DataSerializerPropagationDUnitTest
        .createClientCache(NetworkUtils.getServerHostName(server2.getHost()), PORT2));
    setClientServerObserver1();
    client2.invoke(DataSerializerPropagationDUnitTest::setClientServerObserver2);

    registerDataSerializer(DSObject1.class);

    assertNotNull(eventId);
    await("event propagates to client 2").untilAsserted(() -> assertEquals(eventId,
        client2.invoke(DataSerializerPropagationDUnitTest::getObservedEventID)));
  }
Register two DataSerializers on the server and verify that they get propagated to client.
geode-core/src/distributedTest/java/org/apache/geode/internal/cache/tier/sockets/DataSerializerPropagationDUnitTest.java