import org.opendaylight.controller.sal.core.spi.data.DOMStoreReadWriteTransaction;
import org.opendaylight.controller.sal.core.spi.data.DOMStoreThreePhaseCommitCohort;
import org.opendaylight.controller.sal.core.spi.data.DOMStoreTransactionChain;
-import org.opendaylight.yangtools.yang.data.api.InstanceIdentifier;
+import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier;
import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode;
import org.opendaylight.yangtools.yang.model.api.SchemaContext;
mergeData(MergeData.fromSerializable(message, schemaContext));
} else if (DeleteData.SERIALIZABLE_CLASS.equals(message.getClass())) {
deleteData(DeleteData.fromSerizalizable(message));
- } else if (message instanceof ReadyTransaction) {
- readyTransaction((ReadyTransaction) message);
- } else if (message instanceof CloseTransaction) {
- closeTransaction((CloseTransaction) message);
+ } else if (ReadyTransaction.SERIALIZABLE_CLASS.equals(message.getClass())) {
+ readyTransaction(new ReadyTransaction());
+ } else if (message.getClass().equals(CloseTransaction.SERIALIZABLE_CLASS)) {
+ closeTransaction(new CloseTransaction());
} else if (message instanceof GetCompositedModification) {
// This is here for testing only
getSender().tell(new GetCompositeModificationReply(
new ImmutableCompositeModification(modification)), getSelf());
}else{
- throw new Exception ("handleRecieve received an unknown mesages"+message);
+ throw new Exception ("Shard:handleRecieve received an unknown message"+message);
}
}
private void readData(ReadData message) {
final ActorRef sender = getSender();
final ActorRef self = getSelf();
- final InstanceIdentifier path = message.getPath();
+ final YangInstanceIdentifier path = message.getPath();
final ListenableFuture<Optional<NormalizedNode<?, ?>>> future =
transaction.read(path);
private void writeData(WriteData message) {
modification.addModification(
new WriteModification(message.getPath(), message.getData(),schemaContext));
+ LOG.debug("writeData at path : " + message.getPath().toString());
transaction.write(message.getPath(), message.getData());
- getSender().tell(new WriteDataReply(), getSelf());
+ getSender().tell(new WriteDataReply().toSerializable(), getSelf());
}
private void mergeData(MergeData message) {
modification.addModification(
new MergeModification(message.getPath(), message.getData(), schemaContext));
+ LOG.debug("mergeData at path : " + message.getPath().toString());
transaction.merge(message.getPath(), message.getData());
- getSender().tell(new MergeDataReply(), getSelf());
+ getSender().tell(new MergeDataReply().toSerializable(), getSelf());
}
private void deleteData(DeleteData message) {
modification.addModification(new DeleteModification(message.getPath()));
transaction.delete(message.getPath());
- getSender().tell(new DeleteDataReply(), getSelf());
+ getSender().tell(new DeleteDataReply().toSerializable(), getSelf());
}
private void readyTransaction(ReadyTransaction message) {
ActorRef cohortActor = getContext().actorOf(
ThreePhaseCommitCohort.props(cohort, shardActor, modification), "cohort");
getSender()
- .tell(new ReadyTransactionReply(cohortActor.path()), getSelf());
+ .tell(new ReadyTransactionReply(cohortActor.path()).toSerializable(), getSelf());
}
private void closeTransaction(CloseTransaction message) {
transaction.close();
- getSender().tell(new CloseTransactionReply(), getSelf());
+ getSender().tell(new CloseTransactionReply().toSerializable(), getSelf());
getSelf().tell(PoisonPill.getInstance(), getSelf());
}