- private void commit(Persistent message) {
- Modification modification = (Modification) message.payload();
+ private void createTransaction(CreateTransaction createTransaction) {
+ DOMStoreReadWriteTransaction transaction =
+ store.newReadWriteTransaction();
+ String transactionId = "shard-" + createTransaction.getTransactionId();
+ LOG.info("Creating transaction : {} " , transactionId);
+ ActorRef transactionActor = getContext().actorOf(
+ ShardTransaction.props(transaction, getSelf(), schemaContext), transactionId);
+
+ getSender()
+ .tell(new CreateTransactionReply(Serialization.serializedActorPath(transactionActor), createTransaction.getTransactionId()).toSerializable(),
+ getSelf());
+ }
+
+ private void commit(final ActorRef sender, Object serialized) {
+ Modification modification = MutableCompositeModification.fromSerializable(serialized, schemaContext);