Class Republish
-
- All Implemented Interfaces:
public final class RepublishRepublish configuration: a copy of every matching message, on a subject of its own
The copy is a plain core-NATS message rather than a stream message, so a subscriber gets it without a consumer - which is how a stream feeds a cache or an audit listener that must not acknowledge anything.
-
-
Field Summary
Fields Modifier and Type Field Description private final Stringsourceprivate final Stringdestinationprivate final BooleanheadersOnly
-
Method Summary
Modifier and Type Method Description final StringgetSource()Subject filter selecting which published messages are republished final StringgetDestination()Subject template the copy is published to final BooleangetHeadersOnly()Republish the headers without the body -
-
Method Detail
-
getSource
final String getSource()
Subject filter selecting which published messages are republished
-
getDestination
final String getDestination()
Subject template the copy is published to
-
getHeadersOnly
final Boolean getHeadersOnly()
Republish the headers without the body
-
-
-
-