akka.persistence.multidc.internal

Class NotificationWriter

java.lang.Object

akka.persistence.multidc.internal.NotificationWriter

All Implemented Interfaces:

akka.actor.Actor, akka.actor.ActorLogging, akka.actor.Timers

public class NotificationWriter
extends java.lang.Object
implements akka.actor.Actor, akka.actor.ActorLogging, akka.actor.Timers

INTERNAL API

Nested Class Summary

Nested Classes

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$

Nested classes/interfaces inherited from interface akka.actor.Actor

akka.actor.Actor.emptyBehavior$, akka.actor.Actor.ignoringBehavior$

Constructor Summary

Constructors

Constructor and Description
NotificationWriter(akka.persistence.cassandra.session.scaladsl.CassandraSession session, java.lang.String writeNotificationCql, NotificationSettings settings)

Method Summary

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface akka.actor.ActorLogging

akka$actor$ActorLogging$$_log_$eq, akka$actor$ActorLogging$$_log

Methods inherited from interface akka.actor.Timers

akka$actor$Timers$_setter_$akka$actor$Timers$$_timers_$eq, akka$actor$Timers$$_timers, aroundPostStop, aroundPreRestart, aroundReceive, timers

Methods inherited from interface akka.actor.Actor

akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, aroundPostRestart, aroundPreStart, context, postRestart, postStop, preRestart, preStart, self, sender, supervisorStrategy, unhandled

Constructor Detail

NotificationWriter

public NotificationWriter(akka.persistence.cassandra.session.scaladsl.CassandraSession session,
                          java.lang.String writeNotificationCql,
                          NotificationSettings settings)

Method Detail

props

public static akka.actor.Props props(akka.persistence.cassandra.session.scaladsl.CassandraSession session,
                                     java.lang.String writeNotificationCql,
                                     NotificationSettings settings)

executeWriteNotification

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)

log

public akka.event.LoggingAdapter log()

Specified by:

log in interface akka.actor.ActorLogging

receive

public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()

Specified by:

receive in interface akka.actor.Actor

writeCollected

public void writeCollected()

writeNotification

public void writeNotification(NotificationWriter.Notification notification)