This is an automated email from the ASF dual-hosted git repository.
ningjiang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-servicecomb-saga.git
The following commit(s) were added to refs/heads/master by this push:
new 44491f1 SCB-615 fix typos in EventScanner
44491f1 is described below
commit 44491f1dcbb9353792cb44d0be60946e0e4d7a1a
Author: Eric Lee <[email protected]>
AuthorDate: Fri May 25 14:47:39 2018 +0800
SCB-615 fix typos in EventScanner
Signed-off-by: Eric Lee <[email protected]>
---
.../java/org/apache/servicecomb/saga/alpha/core/EventScanner.java | 8 +++-----
1 file changed, 3 insertions(+), 5 deletions(-)
diff --git
a/alpha/alpha-core/src/main/java/org/apache/servicecomb/saga/alpha/core/EventScanner.java
b/alpha/alpha-core/src/main/java/org/apache/servicecomb/saga/alpha/core/EventScanner.java
index 8082ab3..298274c 100644
---
a/alpha/alpha-core/src/main/java/org/apache/servicecomb/saga/alpha/core/EventScanner.java
+++
b/alpha/alpha-core/src/main/java/org/apache/servicecomb/saga/alpha/core/EventScanner.java
@@ -147,19 +147,17 @@ public class EventScanner implements Runnable {
private void markSagaEnded(TxEvent event) {
if
(commandRepository.findUncompletedCommands(event.globalTxId()).isEmpty()) {
- markGlobalTxEntWithEvent(event);
+ markGlobalTxEndWithEvent(event);
}
}
- private void markGlobalTxEntWithEvent(TxEvent event) {
+ private void markGlobalTxEndWithEvent(TxEvent event) {
eventRepository.save(toSagaEndedEvent(event));
LOG.info("Marked end of transaction with globalTxId {}",
event.globalTxId());
}
private void markGlobalTxEndWithEvents(List<TxEvent> events) {
- events.forEach(event -> {
- markGlobalTxEntWithEvent(event);
- });
+ events.forEach(this::markGlobalTxEndWithEvent);
}
private TxEvent toTxAbortedEvent(TxTimeout timeout) {
--
To stop receiving notification emails like this one, please contact
[email protected].
