Class RepublishMessageRecovererWithConfirms

    • Constructor Detail

      • RepublishMessageRecovererWithConfirms

        public RepublishMessageRecovererWithConfirms​(RabbitTemplate errorTemplate,
                                                     CachingConnectionFactory.ConfirmType confirmType)
        Use the supplied template to publish the messsage with the provided confirm type. The template and its connection factory must be suitably configured to support the confirm type.
        Parameters:
        errorTemplate - the template.
        confirmType - the confirmType.
      • RepublishMessageRecovererWithConfirms

        public RepublishMessageRecovererWithConfirms​(RabbitTemplate errorTemplate,
                                                     java.lang.String errorExchange,
                                                     CachingConnectionFactory.ConfirmType confirmType)
        Use the supplied template to publish the messsage with the provided confirm type to the provided exchange with the default routing key. The template and its connection factory must be suitably configured to support the confirm type.
        Parameters:
        errorTemplate - the template.
        confirmType - the confirmType.
        errorExchange - the exchange.
      • RepublishMessageRecovererWithConfirms

        public RepublishMessageRecovererWithConfirms​(RabbitTemplate errorTemplate,
                                                     java.lang.String errorExchange,
                                                     java.lang.String errorRoutingKey,
                                                     CachingConnectionFactory.ConfirmType confirmType)
        Use the supplied template to publish the messsage with the provided confirm type to the provided exchange with the provided routing key. The template and its connection factory must be suitably configured to support the confirm type.
        Parameters:
        errorTemplate - the template.
        confirmType - the confirmType.
        errorExchange - the exchange.
        errorRoutingKey - the routing key.
    • Method Detail

      • setConfirmTimeout

        public void setConfirmTimeout​(long confirmTimeout)
        Set the confirm timeout; default 10 seconds.
        Parameters:
        confirmTimeout - the timeout.
      • doSend

        protected void doSend​(@Nullable
                              java.lang.String exchange,
                              java.lang.String routingKey,
                              Message message)
        Description copied from class: RepublishMessageRecoverer
        Send the message.
        Overrides:
        doSend in class RepublishMessageRecoverer
        Parameters:
        exchange - the exchange or null to use the template's default.
        routingKey - the routing key.
        message - the message.