- public ShardReadTransaction(DOMStoreTransactionChain transactionChain, DOMStoreReadTransaction transaction, ActorRef shardActor, SchemaContext schemaContext) {
- super(transactionChain, shardActor, schemaContext);
- this.transaction = transaction;
- }
+ @Override
+ public void handleReceive(final Object message) {
+ if (ReadData.isSerializedType(message)) {
+ readData(transaction, ReadData.fromSerializable(message));
+ } else if (DataExists.isSerializedType(message)) {
+ dataExists(transaction, DataExists.fromSerializable(message));
+ } else {
+ super.handleReceive(message);
+ }
+ }