Package org.apache.pekko.cluster.pubsub.protobuf.msg

Class DistributedPubSubMessages

java.lang.Object

org.apache.pekko.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 org.apache.pekko.protobufv3.internal.Descriptors.FileDescriptor	getDescriptor()
static void	registerAllExtensions(org.apache.pekko.protobufv3.internal.ExtensionRegistry registry)
static void	registerAllExtensions(org.apache.pekko.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(org.apache.pekko.protobufv3.internal.ExtensionRegistryLite registry)

registerAllExtensions

public static void registerAllExtensions(org.apache.pekko.protobufv3.internal.ExtensionRegistry registry)

getDescriptor

public static org.apache.pekko.protobufv3.internal.Descriptors.FileDescriptor getDescriptor()