+ public ShardTransactionChain(DOMStoreTransactionChain chain, SchemaContext schemaContext) {
+ this.chain = chain;
+ this.schemaContext = schemaContext;
+ }
+
+ @Override
+ public void handleReceive(Object message) throws Exception {
+ if (message.getClass().equals(CreateTransaction.SERIALIZABLE_CLASS)) {
+ CreateTransaction createTransaction = CreateTransaction.fromSerializable( message);
+ createTransaction(createTransaction);
+ } else if (message.getClass().equals(CloseTransactionChain.SERIALIZABLE_CLASS)) {
+ chain.close();
+ getSender().tell(new CloseTransactionChainReply().toSerializable(), getSelf());
+ }else{
+ throw new Exception("Not recognized message recieved="+message);
+ }
+ }