Shard extends RaftActor { String getShardName() { return shardName; } protected  Shard(final AbstractBuilder<?, ?> builder); @Override void postStop(); int getPendingTxCommitQueueSize(); int getCohortCacheSize(); @Override @VisibleForTesting RaftActorSnapshotCohort getRaftActorSnapshotCohort(); Collection<?> convertPendingTransactionsToMessages(); @Override String persistenceId(); DatastoreContext getDatastoreContext(); @VisibleForTesting ShardDataTree getDataStore(); static Builder builder(); static final String DEFAULT_NAME; }
@Test public void testCreateTransactionOnChain() { final ShardTestKit testKit = new ShardTestKit(getSystem()); final ActorRef shard = actorFactory.createActor(newShardProps(), "testCreateTransactionOnChain"); ShardTestKit.waitUntilLeader(shard); shard.tell(new CreateTransaction(nextTransactionId(), TransactionType.READ_ONLY.ordinal(), DataStoreVersions.CURRENT_VERSION).toSerializable(), testKit.getRef()); final CreateTransactionReply reply = testKit.expectMsgClass(Duration.ofSeconds(3), CreateTransactionReply.class); final String path = reply.getTransactionPath().toString(); assertTrue("Unexpected transaction path " + path, path.startsWith(String.format( "akka: shardID.getShardName(), shardID.getMemberName().getName()))); }