Package eu.vstoyanov.natsy.jetstream.model

Class RepublishBuilder

  • All Implemented Interfaces:
    
public final class RepublishBuilder

    Builder for Republish configuration

    • Nested Class Summary

      Nested Classes 
      Modifier and Type Class Description

    • Enum Constant Summary

      Enum Constants 
      Enum Constant Description

    • Method Summary

      Modifier and Type Method Description
      final String getSource() Subject filter selecting which published messages are republishednull - the default - republishes everything the stream captures.
      final Unit setSource(String value) Subject filter selecting which published messages are republishednull - the default - republishes everything the stream captures.
      final String getDestination() Subject template the copy is published toSupports the $1, $2 … tokens matched by wildcards in source, so source = "orders.*" with destination = "mirror.$1" sends orders.created on to mirror.created.
      final Unit setDestination(String value) Subject template the copy is published toSupports the $1, $2 … tokens matched by wildcards in source, so source = "orders.*" with destination = "mirror.$1" sends orders.created on to mirror.created.
      final Boolean getHeadersOnly() Republish the headers without the body
      final Unit setHeadersOnly(Boolean value) Republish the headers without the body

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • RepublishBuilder

        RepublishBuilder()

    • Method Detail

      • getSource

         final String getSource()

        Subject filter selecting which published messages are republished

        null - the default - republishes everything the stream captures.

      • setSource

         final Unit setSource(String value)

        Subject filter selecting which published messages are republished

        null - the default - republishes everything the stream captures.

      • getDestination

         final String getDestination()

        Subject template the copy is published to

        Supports the $1, $2 … tokens matched by wildcards in source, so source = "orders.*" with destination = "mirror.$1" sends orders.created on to mirror.created.

      • setDestination

         final Unit setDestination(String value)

        Subject template the copy is published to

        Supports the $1, $2 … tokens matched by wildcards in source, so source = "orders.*" with destination = "mirror.$1" sends orders.created on to mirror.created.