valitydev/sink-common-lib
14
0
Fork 0
mirror of https://github.com/valitydev/sink-common-lib.git synced 2024-11-06 02:15:23 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

add change id for handler

Browse Source
This commit is contained in:
karleowne 2019-06-03 19:50:47 +03:00
parent 78ff9290c8
commit 4f44744986
9 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
pom.xml
View File

@ -13,7 +13,7 @@
<packaging>jar</packaging> <packaging>jar</packaging>
<artifactId>sink-common-lib</artifactId> <artifactId>sink-common-lib</artifactId>
<version>0.0.2</version> <version>0.0.3</version>
<properties> <properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>

2
src/main/java/com/rbkmoney/sink/common/handle/machineevent/eventpayload/impl/CustomerChangePaymentMachineEventHandler.java
View File

@ -27,7 +27,7 @@ public class CustomerChangePaymentMachineEventHandler implements PaymentEventHan
CustomerChange change = payload.getCustomerChanges().get(i); CustomerChange change = payload.getCustomerChanges().get(i);
for (CustomerChangeEventHandler eventHandler : eventHandlers) { for (CustomerChangeEventHandler eventHandler : eventHandlers) {
if (eventHandler.accept(change)) { if (eventHandler.accept(change)) {
eventHandler.handle(change, baseEvent); eventHandler.handle(change, baseEvent, i);
} }
} }
} }

2
src/main/java/com/rbkmoney/sink/common/handle/machineevent/eventpayload/impl/InvoiceChangePaymentMachineEventHandler.java
View File

@ -25,7 +25,7 @@ public class InvoiceChangePaymentMachineEventHandler implements PaymentEventHand
InvoiceChange change = payload.getInvoiceChanges().get(i); InvoiceChange change = payload.getInvoiceChanges().get(i);
for (InvoiceChangeEventHandler eventHandler : eventHandlers) { for (InvoiceChangeEventHandler eventHandler : eventHandlers) {
if (eventHandler.accept(change)) { if (eventHandler.accept(change)) {
eventHandler.handle(change, baseEvent); eventHandler.handle(change, baseEvent, i);
} }
} }
} }

2
src/main/java/com/rbkmoney/sink/common/handle/machineevent/eventpayload/impl/PartyChangePaymentMachineEventHandler.java
View File

@ -25,7 +25,7 @@ public class PartyChangePaymentMachineEventHandler implements PaymentEventHandle
PartyChange change = payload.getPartyChanges().get(i); PartyChange change = payload.getPartyChanges().get(i);
for (PartyChangeEventHandler eventHandler : eventHandlers) { for (PartyChangeEventHandler eventHandler : eventHandlers) {
if (eventHandler.accept(change)) { if (eventHandler.accept(change)) {
eventHandler.handle(change, baseEvent); eventHandler.handle(change, baseEvent, i);
} }
} }
} }

2
src/main/java/com/rbkmoney/sink/common/handle/machineevent/eventpayload/impl/PayoutChangePayoutMachineEventHandler.java
View File

@ -25,7 +25,7 @@ public class PayoutChangePayoutMachineEventHandler implements PayoutEventHandler
PayoutChange change = payload.getPayoutChanges().get(i); PayoutChange change = payload.getPayoutChanges().get(i);
for (PayoutChangeEventHandler eventHandler : eventHandlers) { for (PayoutChangeEventHandler eventHandler : eventHandlers) {
if (eventHandler.accept(change)) { if (eventHandler.accept(change)) {
eventHandler.handle(change, baseEvent); eventHandler.handle(change, baseEvent, i);
} }
} }
} }

2
src/main/java/com/rbkmoney/sink/common/handle/stockevent/event/impl/CustomerChangePaymentStockEventHandler.java
View File

@ -25,7 +25,7 @@ public class CustomerChangePaymentStockEventHandler implements PaymentEventHandl
CustomerChange change = payload.getPayload().getCustomerChanges().get(i); CustomerChange change = payload.getPayload().getCustomerChanges().get(i);
for (CustomerChangeEventHandler eventHandler : eventHandlers) { for (CustomerChangeEventHandler eventHandler : eventHandlers) {
if (eventHandler.accept(change)) { if (eventHandler.accept(change)) {
eventHandler.handle(change, baseEvent); eventHandler.handle(change, baseEvent, i);
} }
} }
} }

2
src/main/java/com/rbkmoney/sink/common/handle/stockevent/event/impl/InvoiceChangePaymentStockEventHandler.java
View File

@ -25,7 +25,7 @@ public class InvoiceChangePaymentStockEventHandler implements PaymentEventHandle
InvoiceChange change = payload.getPayload().getInvoiceChanges().get(i); InvoiceChange change = payload.getPayload().getInvoiceChanges().get(i);
for (InvoiceChangeEventHandler eventHandler : eventHandlers) { for (InvoiceChangeEventHandler eventHandler : eventHandlers) {
if (eventHandler.accept(change)) { if (eventHandler.accept(change)) {
eventHandler.handle(change, baseEvent); eventHandler.handle(change, baseEvent, i);
} }
} }
} }

2
src/main/java/com/rbkmoney/sink/common/handle/stockevent/event/impl/PartyChangePaymentStockEventHandler.java
View File

@ -25,7 +25,7 @@ public class PartyChangePaymentStockEventHandler implements PaymentEventHandler
PartyChange change = payload.getPayload().getPartyChanges().get(i); PartyChange change = payload.getPayload().getPartyChanges().get(i);
for (PartyChangeEventHandler eventHandler : eventHandlers) { for (PartyChangeEventHandler eventHandler : eventHandlers) {
if (eventHandler.accept(change)) { if (eventHandler.accept(change)) {
eventHandler.handle(change, baseEvent); eventHandler.handle(change, baseEvent, i);
} }
} }
} }

2
src/main/java/com/rbkmoney/sink/common/handle/stockevent/event/impl/PayoutChangePayoutStockEventHandler.java
View File

@ -25,7 +25,7 @@ public class PayoutChangePayoutStockEventHandler implements PayoutEventHandler {
PayoutChange change = payload.getPayload().getPayoutChanges().get(i); PayoutChange change = payload.getPayload().getPayoutChanges().get(i);
for (PayoutChangeEventHandler eventHandler : eventHandlers) { for (PayoutChangeEventHandler eventHandler : eventHandlers) {
if (eventHandler.accept(change)) { if (eventHandler.accept(change)) {
eventHandler.handle(change, baseEvent); eventHandler.handle(change, baseEvent, i);
} }
} }
} }