Package akka.cluster.pubsub.protobuf.msg

Class DistributedPubSubMessages

java.lang.Object

akka.cluster.pubsub.protobuf.msg.DistributedPubSubMessages

public final class DistributedPubSubMessages
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	DistributedPubSubMessages.Address	Defines a remote address.
static interface	DistributedPubSubMessages.AddressOrBuilder
static class	DistributedPubSubMessages.Delta	Protobuf type Delta
static interface	DistributedPubSubMessages.DeltaOrBuilder
static class	DistributedPubSubMessages.Payload	Protobuf type Payload
static interface	DistributedPubSubMessages.PayloadOrBuilder
static class	DistributedPubSubMessages.Publish	Publish normally local, but it is also used by the ClusterClient.
static interface	DistributedPubSubMessages.PublishOrBuilder
static class	DistributedPubSubMessages.Send	Send normally local, but it is also used by the ClusterClient.
static interface	DistributedPubSubMessages.SendOrBuilder
static class	DistributedPubSubMessages.SendToAll	SendToAll normally local, but it is also used by the ClusterClient.
static interface	DistributedPubSubMessages.SendToAllOrBuilder
static class	DistributedPubSubMessages.SendToOneSubscriber	Send a message to only one subscriber of a group.
static interface	DistributedPubSubMessages.SendToOneSubscriberOrBuilder
static class	DistributedPubSubMessages.Status	Protobuf type Status
static interface	DistributedPubSubMessages.StatusOrBuilder

Method Summary

Modifier and Type	Method	Description
static akka.protobufv3.internal.Descriptors.FileDescriptor	getDescriptor()
static void	registerAllExtensions(akka.protobufv3.internal.ExtensionRegistry registry)
static void	registerAllExtensions(akka.protobufv3.internal.ExtensionRegistryLite registry)

Methods inherited from class java.lang.Object

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

Method Detail

registerAllExtensions

public static void registerAllExtensions(akka.protobufv3.internal.ExtensionRegistryLite registry)

registerAllExtensions

public static void registerAllExtensions(akka.protobufv3.internal.ExtensionRegistry registry)

getDescriptor

public static akka.protobufv3.internal.Descriptors.FileDescriptor getDescriptor()