disconnect error handler when trade initialized
This commit is contained in:
parent
b4fe0f0ee6
commit
477246f8f0
@ -237,6 +237,7 @@ public class BuyerAsMakerProtocol extends BuyerProtocol implements MakerProtocol
|
|||||||
() -> {
|
() -> {
|
||||||
stopTimeout();
|
stopTimeout();
|
||||||
unlatchTrade();
|
unlatchTrade();
|
||||||
|
this.errorMessageHandler = null;
|
||||||
handleTaskRunnerSuccess(sender, request);
|
handleTaskRunnerSuccess(sender, request);
|
||||||
},
|
},
|
||||||
errorMessage -> {
|
errorMessage -> {
|
||||||
|
@ -252,8 +252,9 @@ public class BuyerAsTakerProtocol extends BuyerProtocol implements TakerProtocol
|
|||||||
ProcessPaymentAccountPayloadRequest.class)
|
ProcessPaymentAccountPayloadRequest.class)
|
||||||
.using(new TradeTaskRunner(trade,
|
.using(new TradeTaskRunner(trade,
|
||||||
() -> {
|
() -> {
|
||||||
unlatchTrade();
|
|
||||||
stopTimeout();
|
stopTimeout();
|
||||||
|
unlatchTrade();
|
||||||
|
this.errorMessageHandler = null;
|
||||||
handleTaskRunnerSuccess(sender, request);
|
handleTaskRunnerSuccess(sender, request);
|
||||||
tradeResultHandler.handleResult(trade); // trade is initialized
|
tradeResultHandler.handleResult(trade); // trade is initialized
|
||||||
},
|
},
|
||||||
|
@ -237,8 +237,9 @@ public class SellerAsMakerProtocol extends SellerProtocol implements MakerProtoc
|
|||||||
MakerRemovesOpenOffer.class)
|
MakerRemovesOpenOffer.class)
|
||||||
.using(new TradeTaskRunner(trade,
|
.using(new TradeTaskRunner(trade,
|
||||||
() -> {
|
() -> {
|
||||||
unlatchTrade();
|
|
||||||
stopTimeout();
|
stopTimeout();
|
||||||
|
unlatchTrade();
|
||||||
|
this.errorMessageHandler = null;
|
||||||
handleTaskRunnerSuccess(sender, request);
|
handleTaskRunnerSuccess(sender, request);
|
||||||
},
|
},
|
||||||
errorMessage -> {
|
errorMessage -> {
|
||||||
|
@ -245,8 +245,9 @@ public class SellerAsTakerProtocol extends SellerProtocol implements TakerProtoc
|
|||||||
ProcessPaymentAccountPayloadRequest.class)
|
ProcessPaymentAccountPayloadRequest.class)
|
||||||
.using(new TradeTaskRunner(trade,
|
.using(new TradeTaskRunner(trade,
|
||||||
() -> {
|
() -> {
|
||||||
unlatchTrade();
|
|
||||||
stopTimeout();
|
stopTimeout();
|
||||||
|
unlatchTrade();
|
||||||
|
this.errorMessageHandler = null;
|
||||||
handleTaskRunnerSuccess(sender, request);
|
handleTaskRunnerSuccess(sender, request);
|
||||||
tradeResultHandler.handleResult(trade); // trade is initialized
|
tradeResultHandler.handleResult(trade); // trade is initialized
|
||||||
},
|
},
|
||||||
|
Loading…
Reference in New Issue
Block a user