Inline CreateOfferCoordinator#onFailed

This commit is contained in:
Chris Beams 2014-11-05 13:21:07 +01:00
parent 45a4bf7c09
commit b3670c5201
No known key found for this signature in database
GPG Key ID: 3D214F8F5BC5ED73

View File

@ -115,19 +115,19 @@ public class CreateOfferCoordinator {
public void start() {
model.setState(State.STARTED);
VerifyOffer.run(this::onOfferValidated, this::onFailed, offer);
VerifyOffer.run(this::onOfferValidated, faultHandler, offer);
}
private void onOfferValidated() {
model.setState(State.VALIDATED);
CreateOfferFeeTx.run(this::onOfferFeeTxCreated, this::onFailed, walletFacade, offer.getId());
CreateOfferFeeTx.run(this::onOfferFeeTxCreated, faultHandler, walletFacade, offer.getId());
}
private void onOfferFeeTxCreated(Transaction transaction) {
model.transaction = transaction;
model.setState(State.OFFER_FEE_TX_CREATED);
offer.setOfferFeePaymentTxID(transaction.getHashAsString());
BroadCastOfferFeeTx.run(this::onOfferFeeTxBroadCasted, this::onFailed, walletFacade, transaction);
BroadCastOfferFeeTx.run(this::onOfferFeeTxBroadCasted, faultHandler, walletFacade, transaction);
}
private void onOfferFeeTxBroadCasted() {
@ -140,11 +140,6 @@ public class CreateOfferCoordinator {
resultHandler.onResult(model.transaction);
}
private void onFailed(String message, Throwable throwable) {
//TODO recover policy, timer
faultHandler.handleFault(message, throwable);
}
///////////////////////////////////////////////////////////////////////////////////////////
// Recovery