You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by sa...@apache.org on 2019/03/04 18:31:54 UTC
[pulsar] branch retry_creation updated: Fix build
This is an automated email from the ASF dual-hosted git repository.
sanjeevrk pushed a commit to branch retry_creation
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/retry_creation by this push:
new 5d5d13c Fix build
5d5d13c is described below
commit 5d5d13c96e30b531b95e5c75e0b77040074ff78e
Author: Sanjeev Kulkarni <sa...@streaml.io>
AuthorDate: Mon Mar 4 10:31:39 2019 -0800
Fix build
---
.../apache/pulsar/functions/utils/ActionsTest.java | 25 +++++++++++-----------
1 file changed, 13 insertions(+), 12 deletions(-)
diff --git a/pulsar-functions/utils/src/test/java/org/apache/pulsar/functions/utils/ActionsTest.java b/pulsar-functions/utils/src/test/java/org/apache/pulsar/functions/utils/ActionsTest.java
index 2ada089..d665178 100644
--- a/pulsar-functions/utils/src/test/java/org/apache/pulsar/functions/utils/ActionsTest.java
+++ b/pulsar-functions/utils/src/test/java/org/apache/pulsar/functions/utils/ActionsTest.java
@@ -23,6 +23,7 @@ import org.testng.annotations.Test;
import java.util.function.Supplier;
+import static org.mockito.Matchers.any;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.spy;
import static org.mockito.Mockito.times;
@@ -42,8 +43,8 @@ public class ActionsTest {
Supplier<Actions.ActionResult> supplier2 = mock(Supplier.class);
when(supplier2.get()).thenReturn(Actions.ActionResult.builder().success(true).build());
- Runnable onFail = mock(Runnable.class);
- Runnable onSucess = mock(Runnable.class);
+ java.util.function.Consumer<Actions.ActionResult> onFail = mock(java.util.function.Consumer.class);
+ java.util.function.Consumer<Actions.ActionResult> onSucess = mock(java.util.function.Consumer.class);
Actions.Action action1 = spy(
Actions.Action.builder()
@@ -71,8 +72,8 @@ public class ActionsTest {
assertEquals(actions.numActions(), 2);
verify(supplier1, times(1)).get();
- verify(onFail, times(0)).run();
- verify(onSucess, times(1)).run();
+ verify(onFail, times(0)).accept(any());
+ verify(onSucess, times(1)).accept(any());
verify(supplier2, times(1)).get();
// test only run 1 action
@@ -83,8 +84,8 @@ public class ActionsTest {
supplier2 = mock(Supplier.class);
when(supplier2.get()).thenReturn(Actions.ActionResult.builder().success(true).build());
- onFail = mock(Runnable.class);
- onSucess = mock(Runnable.class);
+ onFail = mock(java.util.function.Consumer.class);
+ onSucess = mock(java.util.function.Consumer.class);
action1 = spy(
Actions.Action.builder()
@@ -114,8 +115,8 @@ public class ActionsTest {
assertEquals(actions.numActions(), 2);
verify(supplier1, times(1)).get();
- verify(onFail, times(0)).run();
- verify(onSucess, times(1)).run();
+ verify(onFail, times(0)).accept(any());
+ verify(onSucess, times(1)).accept(any());
verify(supplier2, times(0)).get();
// test retry
@@ -126,8 +127,8 @@ public class ActionsTest {
supplier2 = mock(Supplier.class);
when(supplier2.get()).thenReturn(Actions.ActionResult.builder().success(true).build());
- onFail = mock(Runnable.class);
- onSucess = mock(Runnable.class);
+ onFail = mock(java.util.function.Consumer.class);
+ onSucess = mock(java.util.function.Consumer.class);
action1 = spy(
Actions.Action.builder()
@@ -155,8 +156,8 @@ public class ActionsTest {
assertEquals(actions.numActions(), 2);
verify(supplier1, times(10)).get();
- verify(onFail, times(1)).run();
- verify(onSucess, times(0)).run();
+ verify(onFail, times(1)).accept(any());
+ verify(onSucess, times(0)).accept(any());
verify(supplier2, times(1)).get();
}