DurableEventSerializerWithBinaryPayload

A Protocol Buffers based serializer for DurableEvents. Serialization of DurableEvent's payload is delegated to BinaryPayloadSerializer.

To use this serializer the default config provided by reference.conf has to be overwritten in an application.conf like follows:

akka.actor.serializers.eventuate-durable-event = com.rbmhtechnology.eventuate.serializer.DurableEventSerializerWithBinaryPayload

This serializer can be useful in scenarios where an Eventuate application is just used for event forwarding (through replication) and only handles the payload of events based on their metadata (like the manifest).

Linear Supertypes

DurableEventSerializer, Serializer, AnyRef, Any

Instance Constructors

new DurableEventSerializerWithBinaryPayload(system: ExtendedActorSystem)

Value Members

final def !=(arg0: Any): Boolean

Definition Classes
AnyRef → Any
final def ##(): Int

Definition Classes
AnyRef → Any
final def ==(arg0: Any): Boolean

Definition Classes
AnyRef → Any
val DurableEventClass: Class[DurableEvent]

Definition Classes
DurableEventSerializer
final def asInstanceOf[T0]: T0

Definition Classes
Any
def clone(): AnyRef

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( ... )
val commonSerializer: CommonSerializer

Definition Classes
DurableEventSerializer
def durableEvent(durableEventFormat: DurableEventFormat): DurableEvent

Definition Classes
DurableEventSerializer
def durableEventFormatBuilder(durableEvent: DurableEvent): Builder

Definition Classes
DurableEventSerializer
final def eq(arg0: AnyRef): Boolean

Definition Classes
AnyRef
def equals(arg0: Any): Boolean

Definition Classes
AnyRef → Any
def eventId(eventId: EventIdFormat): EventId

Definition Classes
DurableEventSerializer
def eventIdFormatBuilder(eventId: EventId): Builder

Definition Classes
DurableEventSerializer
def finalize(): Unit

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( classOf[java.lang.Throwable] )
def fromBinary(bytes: Array[Byte], manifest: Option[Class[_]]): AnyRef

Definition Classes
DurableEventSerializer → Serializer
final def fromBinary(bytes: Array[Byte], clazz: Class[_]): AnyRef

Definition Classes
Serializer
Annotations
@throws( ... )
final def fromBinary(bytes: Array[Byte]): AnyRef

Definition Classes
Serializer
final def getClass(): Class[_]

Definition Classes
AnyRef → Any
def hashCode(): Int

Definition Classes
AnyRef → Any
def identifier: Int

Definition Classes
DurableEventSerializer → Serializer
def includeManifest: Boolean

Definition Classes
DurableEventSerializer → Serializer
final def isInstanceOf[T0]: Boolean

Definition Classes
Any
final def ne(arg0: AnyRef): Boolean

Definition Classes
AnyRef
final def notify(): Unit

Definition Classes
AnyRef
final def notifyAll(): Unit

Definition Classes
AnyRef
final def synchronized[T0](arg0: ⇒ T0): T0

Definition Classes
AnyRef
def toBinary(o: AnyRef): Array[Byte]

Definition Classes
DurableEventSerializer → Serializer
def toString(): String

Definition Classes
AnyRef → Any
final def wait(): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long, arg1: Int): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )

Related Doc: package serializer

class DurableEventSerializerWithBinaryPayload extends DurableEventSerializer

Instance Constructors

new DurableEventSerializerWithBinaryPayload(system: ExtendedActorSystem)

Value Members

final def !=(arg0: Any): Boolean

final def ##(): Int

final def ==(arg0: Any): Boolean

val DurableEventClass: Class[DurableEvent]

final def asInstanceOf[T0]: T0

def clone(): AnyRef

val commonSerializer: CommonSerializer

def durableEvent(durableEventFormat: DurableEventFormat): DurableEvent

def durableEventFormatBuilder(durableEvent: DurableEvent): Builder

final def eq(arg0: AnyRef): Boolean

def equals(arg0: Any): Boolean

def eventId(eventId: EventIdFormat): EventId

def eventIdFormatBuilder(eventId: EventId): Builder

def finalize(): Unit

def fromBinary(bytes: Array[Byte], manifest: Option[Class[_]]): AnyRef

final def fromBinary(bytes: Array[Byte], clazz: Class[_]): AnyRef

final def fromBinary(bytes: Array[Byte]): AnyRef

final def getClass(): Class[_]

def hashCode(): Int

def identifier: Int

def includeManifest: Boolean

final def isInstanceOf[T0]: Boolean

final def ne(arg0: AnyRef): Boolean

final def notify(): Unit

final def notifyAll(): Unit

final def synchronized[T0](arg0: ⇒ T0): T0

def toBinary(o: AnyRef): Array[Byte]

def toString(): String

final def wait(): Unit

final def wait(arg0: Long, arg1: Int): Unit

final def wait(arg0: Long): Unit

Inherited from DurableEventSerializer

Inherited from Serializer

Inherited from AnyRef

Inherited from Any

Ungrouped