CommitTransactionReply extends VersionedExternalizableMessage { public static CommitTransactionReply instance(short version) { return version == DataStoreVersions.CURRENT_VERSION ? INSTANCE : new CommitTransactionReply(version); } CommitTransactionReply(); private  CommitTransactionReply(short version); static CommitTransactionReply instance(short version); static boolean isSerializedType(Object message); static final CommitTransactionReply INSTANCE; }
@Test public void testSerialization() { CommitTransactionReply expected = CommitTransactionReply.instance(DataStoreVersions.CURRENT_VERSION); Object serialized = expected.toSerializable(); assertEquals("Serialized type", CommitTransactionReply.class, serialized.getClass()); CommitTransactionReply actual = (CommitTransactionReply)SerializationUtils.clone((Serializable) serialized); assertEquals("getVersion", DataStoreVersions.CURRENT_VERSION, actual.getVersion()); }