raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

Increase timeout to fix PersistentActorJavaDslTest (#26799)

Browse source 
* Increase timeout to fix #26466
This commit is contained in:
Johan Andrén 2019-05-02 14:21:13 +02:00 • committed by Arnout Engelen
parent 282b38e832
commit 1128024797
1 changed files with 5 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

11
akka-persistence-typed/src/test/java/akka/persistence/typed/javadsl/PersistentActorJavaDslTest.java
View file

@ -29,7 +29,6 @@ import com.typesafe.config.ConfigFactory;
import org.junit.ClassRule;
import org.junit.Test;
import org.scalatest.junit.JUnitSuite;
import scala.Function0;
import java.io.Serializable;
import java.time.Duration;
@ -413,7 +412,7 @@ public class PersistentActorJavaDslTest extends JUnitSuite {
}
@Override
public SignalHandler signalHandler() {
public SignalHandler<State> signalHandler() {
return newSignalHandlerBuilder()
.onSignal(
SnapshotCompleted.class,
@ -462,7 +461,7 @@ public class PersistentActorJavaDslTest extends JUnitSuite {
TestProbe<State> probe = testKit.createTestProbe();
ActorRef<Command> c = testKit.spawn(counter(new PersistenceId("c12")));
c.tell(StopThenLog.INSTANCE);
probe.expectTerminated(c, Duration.ofSeconds(1));
probe.expectTerminated(c);
}
@Test
@ -474,7 +473,7 @@ public class PersistentActorJavaDslTest extends JUnitSuite {
new CounterBehavior(new PersistenceId("c5"), ctx) {
@Override
public SignalHandler signalHandler() {
public SignalHandler<State> signalHandler() {
return newSignalHandlerBuilder()
.onSignal(
PostStop.instance(),
@ -635,7 +634,7 @@ public class PersistentActorJavaDslTest extends JUnitSuite {
}
@Override
public SignalHandler signalHandler() {
public SignalHandler<Object> signalHandler() {
return newSignalHandlerBuilder()
.onSignal(
RecoveryCompleted.class,
@ -716,7 +715,7 @@ public class PersistentActorJavaDslTest extends JUnitSuite {
}
@Override
public SignalHandler signalHandler() {
public SignalHandler<String> signalHandler() {
return newSignalHandlerBuilder()
.onSignal(
RecoveryCompleted.class,