Index (Eclipse Ditto :: Internal :: Utils :: Pub-Sub Things 3.3.3 API)

C

command() - Method in interface org.eclipse.ditto.internal.utils.pubsubthings.LiveSignalPub

declareAcknowledgementLabels(Collection<AcknowledgementLabel>, ActorRef, String) - Method in interface org.eclipse.ditto.internal.utils.pubsubthings.DittoProtocolSub: Declare acknowledgement labels for a subscriber.
DittoProtocolSub - Interface in org.eclipse.ditto.internal.utils.pubsubthings: Subscriptions for Ditto protocol channels.

event() - Method in interface org.eclipse.ditto.internal.utils.pubsubthings.LiveSignalPub

get(ActorSystem) - Static method in interface org.eclipse.ditto.internal.utils.pubsubthings.DittoProtocolSub: Get the DittoProtocolSub for an actor system.

LiveSignalPub - Interface in org.eclipse.ditto.internal.utils.pubsubthings: Publishing of all live signals.

message() - Method in interface org.eclipse.ditto.internal.utils.pubsubthings.LiveSignalPub

of(ActorContext, ShardRegionExtractor, DistributedAcks) - Static method in class org.eclipse.ditto.internal.utils.pubsubthings.ThingEventPubSubFactory: Create a pubsub factory for thing events from an actor system and its shard region extractor.
of(ActorContext, DistributedAcks) - Static method in interface org.eclipse.ditto.internal.utils.pubsubthings.LiveSignalPub: Start a live signal pub in an actor system.
org.eclipse.ditto.internal.utils.pubsubthings - package org.eclipse.ditto.internal.utils.pubsubthings

readSubjectsOnly(ActorSystem, DistributedAcks) - Static method in class org.eclipse.ditto.internal.utils.pubsubthings.ThingEventPubSubFactory: Create a pubsub factory for thing events ignoring shard ID topics.
removeAcknowledgementLabelDeclaration(ActorRef) - Method in interface org.eclipse.ditto.internal.utils.pubsubthings.DittoProtocolSub: Relinquish any acknowledgement labels declared by a subscriber.
removePolicyAnnouncementSubscriber(ActorRef, Collection<String>) - Method in interface org.eclipse.ditto.internal.utils.pubsubthings.DittoProtocolSub: Remove a subscriber from the policy announcements only.
removeSubscriber(ActorRef) - Method in interface org.eclipse.ditto.internal.utils.pubsubthings.DittoProtocolSub: Remove a subscriber.
removeSubscriber(ActorRef, Collection<String>) - Method in interface org.eclipse.ditto.internal.utils.pubsubthings.DittoProtocolSub: Remove subscriber from all distributed data and wait for acknowledgements.
removeTwinSubscriber(ActorRef, Collection<String>) - Method in interface org.eclipse.ditto.internal.utils.pubsubthings.DittoProtocolSub: Remove a subscriber from the twin events channel only.

subscribe(Collection<StreamingType>, Collection<String>, ActorRef) - Method in interface org.eclipse.ditto.internal.utils.pubsubthings.DittoProtocolSub: Subscribe for each streaming type the same collection of topics.
subscribe(Collection<StreamingType>, Collection<String>, ActorRef, String, boolean) - Method in interface org.eclipse.ditto.internal.utils.pubsubthings.DittoProtocolSub: Subscribe for each streaming type the same collection of topics.

ThingEventPubSubFactory - Class in org.eclipse.ditto.internal.utils.pubsubthings: Pub-sub factory for thing events.

updateLiveSubscriptions(Collection<StreamingType>, Collection<String>, ActorRef) - Method in interface org.eclipse.ditto.internal.utils.pubsubthings.DittoProtocolSub: Update streaming types of a subscriber.