@Override
    public void fromData(final DataInput in, final DeserializationContext context)
        throws IOException, ClassNotFoundException {
      super.fromData(in, context);

      messageId = in.readInt();

      final int length = in.readInt();

      final byte[] payload = new byte[length];

      in.readFully(payload);

      bytesTransferredAdder.add(length);
    }
Tests one-way P2P messaging between two peers.
Many concurrent tasks compete on the sending side.
The main purpose of the test is to exercise
ByteBufferSharing and friends.

Tests combinations of: conserve-sockets true/false,
TLS on/off, and socket-buffer-size for sender
and receiver both set to the default (and equal)
and set to the sender's buffer twice as big as the
receiver's buffer.
geode-core/src/distributedTest/java/org/apache/geode/distributed/internal/P2PMessagingConcurrencyDUnitTest.java