@Override
  protected Message getMessage(CacheClientProxy proxy, byte[] latestValue) throws IOException {
    final int instantiatorsLength = serializedInstantiators.length;
    // one for eventID
    final Message message = new Message(instantiatorsLength + 1, proxy.getVersion());
    // Set message type
    message.setMessageType(MessageType.REGISTER_INSTANTIATORS);
    for (int i = 0; i < instantiatorsLength - 2; i += 3) {
      message.addBytesPart(serializedInstantiators[i]);
      message.addBytesPart(serializedInstantiators[i + 1]);
      message.addBytesPart(serializedInstantiators[i + 2]);
    }
    message.setTransactionId(0);
    message.addObjPart(getEventId());
    return message;
  }
Determines whether or not to conflate this message.

@return Whether to conflate this message
geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/ClientInstantiatorMessage.java