Package org.eclipse.ditto.internal.utils.pubsubthings

Class ThingEventPubSubFactory

java.lang.Object

org.eclipse.ditto.internal.utils.pubsub.AbstractPubSubFactory<org.eclipse.ditto.things.model.signals.events.ThingEvent<?>>

org.eclipse.ditto.internal.utils.pubsubthings.ThingEventPubSubFactory

All Implemented Interfaces:

PubSubFactory<org.eclipse.ditto.things.model.signals.events.ThingEvent<?>>

public final class ThingEventPubSubFactory
extends AbstractPubSubFactory<org.eclipse.ditto.things.model.signals.events.ThingEvent<?>>

Pub-sub factory for thing events.

Nested Class Summary

Nested classes/interfaces inherited from class org.eclipse.ditto.internal.utils.pubsub.AbstractPubSubFactory

AbstractPubSubFactory.DDataProvider

Field Summary

Fields inherited from class org.eclipse.ditto.internal.utils.pubsub.AbstractPubSubFactory

ackExtractor, actorRefFactory, ddata, ddataConfig, distributedAcks, factoryId, messageClass, topicExtractor

Method Summary

Modifier and Type	Method	Description
static ThingEventPubSubFactory	of(akka.actor.ActorContext context, org.eclipse.ditto.internal.utils.cluster.ShardRegionExtractor shardRegionExtractor, DistributedAcks distributedAcks)	Create a pubsub factory for thing events from an actor system and its shard region extractor.
static ThingEventPubSubFactory	readSubjectsOnly(akka.actor.ActorSystem system, DistributedAcks distributedAcks)	Create a pubsub factory for thing events ignoring shard ID topics.

Methods inherited from class org.eclipse.ditto.internal.utils.pubsub.AbstractPubSubFactory

getDistributedAcks, startDistributedPub, startDistributedSub

Methods inherited from class java.lang.Object

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

Method Details

of

public static ThingEventPubSubFactory of(akka.actor.ActorContext context,
 org.eclipse.ditto.internal.utils.cluster.ShardRegionExtractor shardRegionExtractor,
 DistributedAcks distributedAcks)

Create a pubsub factory for thing events from an actor system and its shard region extractor.

Parameters:

context - context of the actor under which publisher and subscriber actors are created.

shardRegionExtractor - the shard region extractor.

distributedAcks - the distributed acks interface.

Returns:

the thing event pub-sub factory.

readSubjectsOnly

public static ThingEventPubSubFactory readSubjectsOnly(akka.actor.ActorSystem system,
 DistributedAcks distributedAcks)

Create a pubsub factory for thing events ignoring shard ID topics.

Parameters:

system - the actor system.

distributedAcks - the distributed acks interface.

Returns:

the thing event pub-sub factory.