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