sampleFlow.java

public TokenIssueFlowInitiator(Party owner, int amount) {
    this.owner = owner;
    this.amount = amount;
}


@Suspendable
@Override
public SignedTransaction call() throws FlowException {
    Party notary = getServiceHub().getNetworkMapCache().getNotaryIdentities().get(0);

    Party issuer = getOurIdentity();

    TokenState tokenState = new TokenState(issuer, owner, amount);

    TransactionBuilder transactionBuilder = new TransactionBuilder(notary);

    CommandData commandData = new TokenContract.Commands.Issue();

    transactionBuilder.addCommand(commandData, issuer.getOwningKey(), owner.getOwningKey());

    transactionBuilder.addOutputState(tokenState, TokenContract.ID);

    transactionBuilder.verify(getServiceHub());

    FlowSession session = initiateFlow(owner);

    SignedTransaction signedTransaction = getServiceHub().signInitialTransaction(transactionBuilder);

    SignedTransaction fullySignedTransaction = subFlow(new CollectSignaturesFlow(signedTransaction, singletonList(session)));

    return subFlow(new FinalityFlow(fullySignedTransaction, singletonList(session)));
}