super(transactionID, version);
}
+ @Deprecated
@Override
protected Object newLegacySerializedInstance() {
return ThreePhaseCommitCohortMessages.AbortTransaction.newBuilder().
import org.opendaylight.controller.protobuff.messages.cohort3pc.ThreePhaseCommitCohortMessages;
public class AbortTransactionReply extends VersionedExternalizableMessage {
+ @Deprecated
private static final Object SERIALIZED_INSTANCE =
ThreePhaseCommitCohortMessages.AbortTransactionReply.newBuilder().build();
super(version);
}
+ @Deprecated
@Override
protected Object newLegacySerializedInstance() {
return SERIALIZED_INSTANCE;
super(transactionID, version);
}
+ @Deprecated
@Override
protected Object newLegacySerializedInstance() {
return ThreePhaseCommitCohortMessages.CanCommitTransaction.newBuilder().
private static final CanCommitTransactionReply NO =
new CanCommitTransactionReply(false, DataStoreVersions.CURRENT_VERSION);
+ @Deprecated
private static final ThreePhaseCommitCohortMessages.CanCommitTransactionReply YES_SERIALIZED =
ThreePhaseCommitCohortMessages.CanCommitTransactionReply.newBuilder().setCanCommit(true).build();
+ @Deprecated
private static final ThreePhaseCommitCohortMessages.CanCommitTransactionReply NO_SERIALIZED =
ThreePhaseCommitCohortMessages.CanCommitTransactionReply.newBuilder().setCanCommit(false).build();
out.writeBoolean(canCommit);
}
+ @Deprecated
@Override
protected Object newLegacySerializedInstance() {
return canCommit ? YES_SERIALIZED : NO_SERIALIZED;
public class CloseTransaction extends VersionedExternalizableMessage {
private static final long serialVersionUID = 1L;
+ @Deprecated
private static final Object SERIALIZED_INSTANCE =
ShardTransactionMessages.CloseTransaction.newBuilder().build();
super(version);
}
+ @Deprecated
@Override
protected Object newLegacySerializedInstance() {
return SERIALIZED_INSTANCE;
out.writeUTF(transactionChainId);
}
+ @Deprecated
@Override
protected Object newLegacySerializedInstance() {
return ShardTransactionChainMessages.CloseTransactionChain.newBuilder().setTransactionChainId(transactionChainId)
super(transactionID, version);
}
+ @Deprecated
@Override
protected Object newLegacySerializedInstance() {
return ThreePhaseCommitCohortMessages.CommitTransaction.newBuilder().setTransactionId(
import org.opendaylight.controller.protobuff.messages.cohort3pc.ThreePhaseCommitCohortMessages;
public class CommitTransactionReply extends VersionedExternalizableMessage {
+ @Deprecated
private static final Object SERIALIZED_INSTANCE =
ThreePhaseCommitCohortMessages.CommitTransactionReply.newBuilder().build();
super(version);
}
+ @Deprecated
@Override
protected Object newLegacySerializedInstance() {
return SERIALIZED_INSTANCE;
out.writeUTF(transactionChainId);
}
+ @Deprecated
@Override
protected Object newLegacySerializedInstance() {
return ShardTransactionMessages.CreateTransaction.newBuilder().setTransactionId(transactionId)
out.writeUTF(transactionPath);
}
+ @Deprecated
@Override
protected Object newLegacySerializedInstance() {
return ShardTransactionMessages.CreateTransactionReply.newBuilder().setTransactionActorPath(transactionPath)
super(path, version);
}
+ @Deprecated
@Override
protected Object newLegacySerializedInstance() {
return ShardTransactionMessages.DataExists.newBuilder()
public class DataExistsReply extends VersionedExternalizableMessage {
private static final long serialVersionUID = 1L;
+ @Deprecated
private static final ShardTransactionMessages.DataExistsReply SERIALIZABLE_TRUE =
ShardTransactionMessages.DataExistsReply.newBuilder().setExists(true).build();
+ @Deprecated
private static final ShardTransactionMessages.DataExistsReply SERIALIZABLE_FALSE =
ShardTransactionMessages.DataExistsReply.newBuilder().setExists(false).build();
out.writeBoolean(exists);
}
+ @Deprecated
@Override
protected Object newLegacySerializedInstance() {
return exists ? SERIALIZABLE_TRUE : SERIALIZABLE_FALSE;
super(path, version);
}
+ @Deprecated
@Override
protected Object newLegacySerializedInstance() {
return ShardTransactionMessages.ReadData.newBuilder()
out.writeShort(version);
}
+ /**
+ * @deprecated Pre-Boron compatibility.
+ */
+ @Deprecated
protected abstract Object newLegacySerializedInstance();
@Override