Class MessageConverterConfigurer.PartitioningInterceptor

java.lang.Object
org.springframework.cloud.stream.binding.MessageConverterConfigurer.PartitioningInterceptor
Enclosing class:
MessageConverterConfigurer
public final class MessageConverterConfigurer.PartitioningInterceptor extends Object
Partitioning channel interceptor.
Author:
Ilayaperumal Gopinathan, Marius Bogoevici, Maxim Kirilov, Gary Russell, Soby Chacko, Oleg Zhurakousky

  • 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

  • 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)