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

Interface LiveSignalPub

public interface LiveSignalPub
Publishing of all live signals.

  • Method Summary

    Modifier and Type
    Method
    Description
    DistributedPub<org.eclipse.ditto.things.model.signals.commands.ThingCommand<?>>
    command()
     
    DistributedPub<org.eclipse.ditto.things.model.signals.events.ThingEvent<?>>
    event()
     
    DistributedPub<org.eclipse.ditto.base.model.signals.SignalWithEntityId<?>>
    message()
     
    static LiveSignalPub
    of(akka.actor.ActorContext context, DistributedAcks distributedAcks)
    Start a live signal pub in an actor system.

  • Method Details

    • of

      static LiveSignalPub of(akka.actor.ActorContext context, DistributedAcks distributedAcks)
      Start a live signal pub in an actor system.
      Parameters:
      context - context of the actor under which pub and sub actors are started.
      Returns:
      the live signal pub.

    • command

      DistributedPub<org.eclipse.ditto.things.model.signals.commands.ThingCommand<?>> command()
      Returns:
      Distributed-pub access for live commands.

    • event

      DistributedPub<org.eclipse.ditto.things.model.signals.events.ThingEvent<?>> event()
      Returns:
      Distributed-pub access for live events.

    • message

      DistributedPub<org.eclipse.ditto.base.model.signals.SignalWithEntityId<?>> message()
      Returns:
      Distributed-pub access for messages.