Class DestinationTopic


  • public class DestinationTopic
    extends java.lang.Object
    Representation of a Destination Topic to which messages can be forwarded, such as retry topics and dlt.
    Since:
    2.7
    Author:
    Tomaz Fernandes, Gary Russell
    • Constructor Detail

      • DestinationTopic

        public DestinationTopic​(java.lang.String destinationName,
                                DestinationTopic sourceDestinationtopic,
                                java.lang.String suffix,
                                org.springframework.kafka.retrytopic.DestinationTopic.Type type)
    • Method Detail

      • getDestinationDelay

        public java.lang.Long getDestinationDelay()
      • getDestinationPartitions

        public java.lang.Integer getDestinationPartitions()
      • isAlwaysRetryOnDltFailure

        public boolean isAlwaysRetryOnDltFailure()
      • isDltTopic

        public boolean isDltTopic()
      • isNoOpsTopic

        public boolean isNoOpsTopic()
      • isSingleTopicRetry

        public boolean isSingleTopicRetry()
      • isMainTopic

        public boolean isMainTopic()
      • getDestinationName

        public java.lang.String getDestinationName()
      • shouldRetryOn

        public boolean shouldRetryOn​(java.lang.Integer attempt,
                                     java.lang.Throwable e)
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object
      • equals

        public boolean equals​(java.lang.Object o)
        Overrides:
        equals in class java.lang.Object
      • hashCode

        public int hashCode()
        Overrides:
        hashCode in class java.lang.Object
      • getDestinationTimeout

        public long getDestinationTimeout()