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

More Java getters for akka.actor.AbstractActor.ActorContext #26161

Browse source
This commit is contained in:
kerr 2019-01-10 03:13:56 +08:00 • committed by Johan Andrén
parent 56b2900c12
commit cc19367588
16 changed files with 95 additions and 38 deletions
Download patch file Download diff file Expand all files Collapse all files

8
akka-docs/src/test/java/jdocs/persistence/query/MyEventsByTagJavaPublisher.java
View file

@ -54,9 +54,9 @@ class MyEventsByTagJavaPublisher extends AbstractActorPublisher<EventEnvelope> {
final Scheduler scheduler = getContext().getSystem().scheduler();
this.continueTask = scheduler
.schedule(refreshInterval, refreshInterval, getSelf(), CONTINUE,
getContext().dispatcher(), getSelf());
getContext().getDispatcher(), getSelf());
}
@Override
public Receive createReceive() {
return receiveBuilder()
@ -70,7 +70,7 @@ class MyEventsByTagJavaPublisher extends AbstractActorPublisher<EventEnvelope> {
.build();
}
public static Props props(Connection conn, String tag, Long offset,
public static Props props(Connection conn, String tag, Long offset,
Duration refreshInterval) {
return Props.create(MyEventsByTagJavaPublisher.class, () ->
new MyEventsByTagJavaPublisher(conn, tag, offset, refreshInterval));
@ -105,7 +105,7 @@ class MyEventsByTagJavaPublisher extends AbstractActorPublisher<EventEnvelope> {
final Long id = in.first();
final byte[] bytes = in.second();
final PersistentRepr p =
final PersistentRepr p =
serialization.deserialize(bytes, PersistentRepr.class).get();
return new EventEnvelope(Offset.sequence(id), p.persistenceId(), p.sequenceNr(), p.payload());