Class DefaultPartitioningInterceptor

java.lang.Object
org.springframework.cloud.stream.binding.DefaultPartitioningInterceptor
public class DefaultPartitioningInterceptor extends Object
Since:
3.1
Author:
Oleg Zhurakousky

  • Constructor Summary

    Constructors
    Constructor
    Description
    DefaultPartitioningInterceptor(BindingProperties bindingProperties, org.springframework.beans.factory.config.ConfigurableListableBeanFactory beanFactory)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    default void
    afterReceiveCompletion(@Nullable org.springframework.messaging.Message<?> arg0, org.springframework.messaging.MessageChannel arg1, @Nullable Exception arg2)
     
    default void
    afterSendCompletion(org.springframework.messaging.Message<?> arg0, org.springframework.messaging.MessageChannel arg1, boolean arg2, @Nullable Exception arg3)
     
    default @Nullable org.springframework.messaging.Message<?>
    postReceive(org.springframework.messaging.Message<?> arg0, org.springframework.messaging.MessageChannel arg1)
     
    default void
    postSend(org.springframework.messaging.Message<?> arg0, org.springframework.messaging.MessageChannel arg1, boolean arg2)
     
    default boolean
    preReceive(org.springframework.messaging.MessageChannel arg0)
     
    org.springframework.messaging.Message<?>
    preSend(org.springframework.messaging.Message<?> message, org.springframework.messaging.MessageChannel channel)
     
    void
    setPartitionCount(int partitionCount)
     

    Methods inherited from class Object

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

  • Constructor Details

    • DefaultPartitioningInterceptor

      public DefaultPartitioningInterceptor(BindingProperties bindingProperties, org.springframework.beans.factory.config.ConfigurableListableBeanFactory beanFactory)

  • Method Details

    • setPartitionCount

      public void setPartitionCount(int partitionCount)

    • preSend

      public org.springframework.messaging.Message<?> preSend(org.springframework.messaging.Message<?> message, org.springframework.messaging.MessageChannel channel)

    • postSend

      default void postSend(org.springframework.messaging.Message<?> arg0, org.springframework.messaging.MessageChannel arg1, boolean arg2)

    • afterSendCompletion

      default void afterSendCompletion(org.springframework.messaging.Message<?> arg0, org.springframework.messaging.MessageChannel arg1, boolean arg2, @Nullable Exception arg3)

    • preReceive

      default boolean preReceive(org.springframework.messaging.MessageChannel arg0)

    • postReceive

      default @Nullable org.springframework.messaging.Message<?> postReceive(org.springframework.messaging.Message<?> arg0, org.springframework.messaging.MessageChannel arg1)

    • afterReceiveCompletion

      default void afterReceiveCompletion(@Nullable org.springframework.messaging.Message<?> arg0, org.springframework.messaging.MessageChannel arg1, @Nullable Exception arg2)