Packages

object ProducerMessage

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ProducerMessage
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Type Members

  1. trait Envelope[+P] extends AnyRef

    Zero or more events to be produced to an EventHub, routed to a particular partition and alongside a pass-through value to be emitted downstream after production.

    Zero or more events to be produced to an EventHub, routed to a particular partition and alongside a pass-through value to be emitted downstream after production.

    Not for user extension.

    Annotations
    @DoNotInherit()
  2. sealed trait Partitioning extends AnyRef

    How the contents of a given Envelope should be routed by Event Hubs.

    How the contents of a given Envelope should be routed by Event Hubs.

    Not for user extension

    Annotations
    @DoNotInherit()

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def batch[P](events: List[EventData], passThrough: P, partitioning: Partitioning): Envelope[P]

    Java API: Create an Envelope with a list of events to produce and the given pass-through value with the given Partitioning.

    Java API: Create an Envelope with a list of events to produce and the given pass-through value with the given Partitioning.

    This is an optimized equivalent to batch(events).withPassThrough(passThrough).withPartitioning(partitioning).

    The events in the Envelope will be produced as a single batch and are subject to the size constraints imposed by Event Hubs.

  6. def batch[P](events: Seq[EventData], passThrough: P, partitioning: Partitioning): Envelope[P]

    Scala API: Create an Envelope with a sequence of events to produce and the given pass-through value with the given Partitioning.

    Scala API: Create an Envelope with a sequence of events to produce and the given pass-through value with the given Partitioning.

    This is an optimized equivalent to batch(events).withPassThrough(passThrough).withPartitioning(partitioning).

    The events in the Envelope will be produced as a single batch and are subject to the size constraints imposed by Event Hubs.

  7. def batch[P](events: List[EventData], passThrough: P): Envelope[P]

    Java API: Create an Envelope with a list of events to produce and the given pass-through value.

    Java API: Create an Envelope with a list of events to produce and the given pass-through value. The default Partitioning is "round-robin".

    This is an optimized equivalent to batch(events).withPassThrough(passThrough).

    The events in the Envelope will be produced as a single batch and are subject to the size constraints imposed by Event Hubs.

  8. def batch[P](events: Seq[EventData], passThrough: P): Envelope[P]

    Scala API: Create an Envelope with a sequence of events to produce and the given pass-through value.

    Scala API: Create an Envelope with a sequence of events to produce and the given pass-through value. The default Partitioning is "round-robin".

    This is an optimized equivalent to batch(events).withPassThrough(passThrough).

    The events in the Envelope will be produced as a single batch and are subject to the size constraints imposed by Event Hubs.

  9. def batch(events: List[EventData]): Envelope[NotUsed]

    Java API: Create an Envelope with a list of events to produce and no useful pass-through value.

    Java API: Create an Envelope with a list of events to produce and no useful pass-through value. The default Partitioning is "round-robin".

    The events in the Envelope will be produced as a single batch and are subject to the size constraints imposed by Event Hubs.

  10. def batch(events: Seq[EventData]): Envelope[NotUsed]

    Scala API: Create an Envelope with a sequence of events to produce and no useful pass-through value.

    Scala API: Create an Envelope with a sequence of events to produce and no useful pass-through value. The default Partitioning is "round-robin".

    The events in the Envelope will be produced as a single batch and are subject to the size constraints imposed by Event Hubs.

  11. def batchWithPartitioning(events: List[EventData], partitioning: Partitioning): Envelope[NotUsed]

    Java API: Create an Envelope with a list of events to produce, no useful pass-through value, and the given Partitioning.

    Java API: Create an Envelope with a list of events to produce, no useful pass-through value, and the given Partitioning.

    This is an optimized equivalent to batch(events).withPartitioning(partitioning).

    The events in the Envelope will be produced as a single batch and are subject to the size constraints imposed by Event Hubs.

  12. def batchWithPartitioning(events: Seq[EventData], partitioning: Partitioning): Envelope[NotUsed]

    Scala API: Create an Envelope with a sequence of events to produce, no useful pass-through value, and the given Partitioning.

    Scala API: Create an Envelope with a sequence of events to produce, no useful pass-through value, and the given Partitioning.

    This is an optimized equivalent to batch(events).withPartitioning(partitioning).

    The events in the Envelope will be produced as a single batch and are subject to the size constraints imposed by Event Hubs.

  13. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native()
  14. def empty[P](passThrough: P, partitioning: Partitioning): Envelope[P]

    Create an Envelope with the given pass-through value and no events to produce.

    Create an Envelope with the given pass-through value and no events to produce. If events are appended, the resulting Envelope will have the given Partitioning.

    This is an optimized equivalent to empty().withPassThrough(passThrough).withPartitioning(partitioning)

  15. def empty[P](passThrough: P): Envelope[P]

    Create an Envelope with the given pass-through value and no events to produce.

    Create an Envelope with the given pass-through value and no events to produce. If events are appended, the resulting Envelope will have "round-robin" partitioning unless withPartitioning is also used.

    This is an optimized equivalent to empty().withPassThrough(passThrough)

  16. def empty(): Envelope[NotUsed]

    Create an Envelope with no events to produce and no useful pass-through value.

    Create an Envelope with no events to produce and no useful pass-through value. If events are appended, the resulting Envelope will have "round-robin" partitioning unless withPartitioning is also used.

    This is a reasonable starting point for programmatically building up an Envelope.

  17. def emptyWithPartitioning(partitioning: Partitioning): Envelope[NotUsed]

    Create an Envelope with no events to produce and no useful pass-through value, but with a Partitioning set in case events are appended to the Envelope.

    Create an Envelope with no events to produce and no useful pass-through value, but with a Partitioning set in case events are appended to the Envelope.

    This is an optimized equivalent to empty().withPartitioning(partitioning).

  18. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  19. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  20. def explicitPartitioning(partitionId: String): Partitioning

    A Envelope with this Partitioning will be routed to a specific partition in an Event Hub.

  21. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  22. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  23. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  24. def multi[P](events: List[EventData], passThrough: P, partitioning: Partitioning): Envelope[P]

    Java API: Create an Envelope from a list of events to produce and the given pass-through value with the given Partitioning.

    Java API: Create an Envelope from a list of events to produce and the given pass-through value with the given Partitioning.

    This is an optimized equivalent to multi(events).withPassThrough(passThrough).withPartitioning(partitioning).

    The events in the Envelope may be produced in separate operations (e.g. to satisfy size constraints imposed by Event Hubs) and the individual operations may be retried separately. If an event in this envelope is successfully published to an Event Hub, all events in this envelope before that event were also successfully published.

  25. def multi[P](events: Seq[EventData], passThrough: P, partitioning: Partitioning): Envelope[P]

    Scala API: Create an Envelope from a sequence of events to produce and the given pass-through value with the given Partitioning.

    Scala API: Create an Envelope from a sequence of events to produce and the given pass-through value with the given Partitioning.

    This is an optimized equivalent to multi(events).withPassThrough(passThrough).withPartitioning(partitioning).

    The events in the Envelope may be produced in separate operations (e.g. to satisfy size constraints imposed by Event Hubs) and the individual operations may be retried separately. If an event in this envelope is successfully published to an Event Hub, all events in this envelope before that event were also successfully published.

  26. def multi[P](events: List[EventData], passThrough: P): Envelope[P]

    Java API: Create an Envelope from a list of events to produce and the given pass-through value.

    Java API: Create an Envelope from a list of events to produce and the given pass-through value. The default Partitioning is "round-robin".

    This is an optimized equivalent to multi(events).withPassThrough(passThrough).

    The events in the Envelope may be produced in separate operations (e.g. to satisfy size constraints imposed by Event Hubs) and the individual operations may be retried separately. If an event in this envelope is successfully published to an Event Hub, all events in this envelope before that event were also successfully published.

  27. def multi[P](events: Seq[EventData], passThrough: P): Envelope[P]

    Scala API: Create an Envelope from a sequence of events to produce and the given pass-through value.

    Scala API: Create an Envelope from a sequence of events to produce and the given pass-through value. The default Partitioning is "round-robin".

    This is an optimized equivalent to multi(events).withPassThrough(passThrough).

    The events in the Envelope may be produced in separate operations (e.g. to satisfy size constraints imposed by Event Hubs) and the individual operations may be retried separately. If an event in this envelope is successfully published to an Event Hub, all events in this envelope before that event were also successfully published.

  28. def multi(events: List[EventData]): Envelope[NotUsed]

    Java API: Create an Envelope from a list of events to produce and no useful pass-through value.

    Java API: Create an Envelope from a list of events to produce and no useful pass-through value. The default Partitioning is "round-robin".

    The events in the Envelope may be produced in separate operations (e.g. to satisfy size constraints imposed by Event Hubs) and the individual operations may be retried separately. If an event in this envelope is successfully published to an Event Hub, all events in this envelope before that event were also successfully published.

  29. def multi(events: Seq[EventData]): Envelope[NotUsed]

    Scala API: Create an Envelope with a sequence of events to produce and no useful pass-through value.

    Scala API: Create an Envelope with a sequence of events to produce and no useful pass-through value. The default Partitioning is "round-robin".

    The events in the Envelope may be produced in separate operations (e.g. to satisfy size constraints imposed by Event Hubs) and the individual operations may be retried separately. If an event in this envelope is successfully published to an Event Hub, all events in this envelope before that event were also successfully published.

  30. def multiWithPartitioning(events: List[EventData], partitioning: Partitioning): Envelope[NotUsed]

    Java API: Create an Envelope from a list of events to produce, no useful pass-through value, and the given Partitioning.

    Java API: Create an Envelope from a list of events to produce, no useful pass-through value, and the given Partitioning.

    This is an optimized equivalent to multi(events).withPartitioning(partitioning).

    The events in the Envelope may be produced in separate operations (e.g. to satisfy size constraints imposed by Event Hubs) and the individual operations may be retried separately. If an event in this envelope is successfully published to an Event Hub, all events in this envelope before that event were also successfully published.

  31. def multiWithPartitioning(events: Seq[EventData], partitioning: Partitioning): Envelope[NotUsed]

    Scala API: Create an Envelope with a sequence of events to produce, no useful pass-through value, and the given Partitioning.

    Scala API: Create an Envelope with a sequence of events to produce, no useful pass-through value, and the given Partitioning.

    This is an optimized equivalent to multi(events).withPartitioning(partitioning).

    The events in the Envelope may be produced in separate operations (e.g. to satisfy size constraints imposed by Event Hubs) and the individual operations may be retried separately. If an event in this envelope is successfully published to an Event Hub, all events in this envelope before that event were also successfully published.

  32. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  33. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  34. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  35. def partitionByKey(key: String): Partitioning

    A Envelope with this Partitioning will be routed to a partition based on the hash of the given key modulo the current number of partitions in the Event Hub.

  36. def roundRobinPartitioning: Partitioning

    An Envelope with this Partitioning will be routed to any available partition in an Event Hub.

    An Envelope with this Partitioning will be routed to any available partition in an Event Hub. There is no guarantee on the order of consumption of events with this Partitioning.

  37. def single[P](event: EventData, passThrough: P, partitioning: Partitioning): Envelope[P]

    Create an Envelope with the given event, pass-through value, and Partitioning

    Create an Envelope with the given event, pass-through value, and Partitioning

    This is an optimized equivalent to single(event).withPassThrough(passThrough).withPartitioning(partitioning)

  38. def single[P](event: EventData, passThrough: P): Envelope[P]

    Create an Envelope with the given event and pass-through value.

    Create an Envelope with the given event and pass-through value. The default Partitioning is "round-robin"

    This is an optimized equivalent to single(event).withPassThrough(passThrough)

  39. def single(event: EventData): Envelope[NotUsed]

    Create an Envelope with the given event and no useful pass-through value.

    Create an Envelope with the given event and no useful pass-through value. The default Partitioning is "round-robin".

  40. def singleWithPartitioning(event: EventData, partitioning: Partitioning): Envelope[NotUsed]

    Create an Envelope with the given event, no useful pass-through value, and the given Partitioning.

    Create an Envelope with the given event, no useful pass-through value, and the given Partitioning.

    This is an optimized equivalent to single(event).withPartitioning(partitioning)

  41. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  42. def toString(): String
    Definition Classes
    AnyRef → Any
  43. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  44. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  45. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable]) @Deprecated @Deprecated
    Deprecated

Inherited from AnyRef

Inherited from Any

Ungrouped