akka.persistence.multidc.serialization

Class WrappedPayloadSupport

java.lang.Object

akka.persistence.multidc.serialization.WrappedPayloadSupport

public class WrappedPayloadSupport
extends java.lang.Object

INTERNAL API: copy of akka.remote.WrappedPayloadSupport, don't see a way to reuse it without being able to import the proto file

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	WrappedPayloadSupport.Comparator$

Constructor Summary

Constructors

Constructor and Description
WrappedPayloadSupport(akka.actor.ExtendedActorSystem system)

Method Summary

Modifier and Type	Method and Description
byte[]	compress(akka.protobuf.MessageLite msg)
byte[]	decompress(byte[] bytes)
java.lang.Object	deserializeWrapped(WrappedPayload.Wrapped enclosed)
WrappedPayload.Wrapped.Builder	wrappedBuilder(java.lang.Object input)

Methods inherited from class java.lang.Object

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

Constructor Detail

WrappedPayloadSupport

public WrappedPayloadSupport(akka.actor.ExtendedActorSystem system)

Method Detail

wrappedBuilder

public WrappedPayload.Wrapped.Builder wrappedBuilder(java.lang.Object input)

deserializeWrapped

public java.lang.Object deserializeWrapped(WrappedPayload.Wrapped enclosed)

compress

public byte[] compress(akka.protobuf.MessageLite msg)

decompress

public byte[] decompress(byte[] bytes)