package org.opendaylight.controller.cluster.datastore.messages;
import akka.actor.ActorPath;
+import akka.actor.ActorSystem;
+import org.opendaylight.controller.protobuff.messages.transaction.ShardTransactionMessages;
-public class ReadyTransactionReply {
+public class ReadyTransactionReply implements SerializableMessage {
+ public static final Class SERIALIZABLE_CLASS = ShardTransactionMessages.ReadyTransactionReply.class;
private final ActorPath cohortPath;
public ReadyTransactionReply(ActorPath cohortPath) {
public ActorPath getCohortPath() {
return cohortPath;
}
+
+ @Override
+ public ShardTransactionMessages.ReadyTransactionReply toSerializable() {
+ return ShardTransactionMessages.ReadyTransactionReply.newBuilder()
+ .setActorPath(cohortPath.toString()).build();
+ }
+
+ public static ReadyTransactionReply fromSerializable(ActorSystem actorSystem,Object serializable){
+ ShardTransactionMessages.ReadyTransactionReply o = (ShardTransactionMessages.ReadyTransactionReply) serializable;
+ return new ReadyTransactionReply(
+ actorSystem.actorFor(o.getActorPath()).path());
+ }
}