public class NotificationWriter
extends java.lang.Object
implements akka.actor.Actor, akka.actor.ActorLogging, akka.actor.Timers
| Modifier and Type | Class and Description |
|---|---|
static class |
NotificationWriter.EventsWritten |
static class |
NotificationWriter.EventsWritten$ |
static class |
NotificationWriter.Notification |
static class |
NotificationWriter.Notification$ |
static class |
NotificationWriter.Tick$ |
static class |
NotificationWriter.WroteEvents |
static class |
NotificationWriter.WroteEvents$ |
| Constructor and Description |
|---|
NotificationWriter(akka.persistence.cassandra.session.scaladsl.CassandraSession session,
java.lang.String writeNotificationCql,
NotificationSettings settings) |
| Modifier and Type | Method and Description |
|---|---|
static scala.concurrent.Future<akka.Done> |
executeWriteNotification(java.util.UUID nowUuid,
NotificationWriter.Notification notification,
java.lang.String selfDc,
akka.persistence.cassandra.session.scaladsl.CassandraSession session,
com.datastax.driver.core.PreparedStatement stmt,
akka.serialization.Serializer serializer) |
akka.event.LoggingAdapter |
log() |
static akka.actor.Props |
props(akka.persistence.cassandra.session.scaladsl.CassandraSession session,
java.lang.String writeNotificationCql,
NotificationSettings settings) |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
receive() |
void |
writeCollected() |
void |
writeNotification(NotificationWriter.Notification notification) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitakka$actor$ActorLogging$$_log_$eq, akka$actor$ActorLogging$$_logpublic NotificationWriter(akka.persistence.cassandra.session.scaladsl.CassandraSession session,
java.lang.String writeNotificationCql,
NotificationSettings settings)
public static akka.actor.Props props(akka.persistence.cassandra.session.scaladsl.CassandraSession session,
java.lang.String writeNotificationCql,
NotificationSettings settings)
public static scala.concurrent.Future<akka.Done> executeWriteNotification(java.util.UUID nowUuid,
NotificationWriter.Notification notification,
java.lang.String selfDc,
akka.persistence.cassandra.session.scaladsl.CassandraSession session,
com.datastax.driver.core.PreparedStatement stmt,
akka.serialization.Serializer serializer)
public akka.event.LoggingAdapter log()
log in interface akka.actor.ActorLoggingpublic scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
receive in interface akka.actor.Actorpublic void writeCollected()
public void writeNotification(NotificationWriter.Notification notification)