Interface FanoutPublishArgs<V>

Type Parameters:
V - type
All Superinterfaces:
SyncArgs<FanoutPublishArgs<V>>
All Known Implementing Classes:
FanoutPublishParams

public interface FanoutPublishArgs<V> extends SyncArgs<FanoutPublishArgs<V>>
Interface defining parameters for queue addition operations.
Author:
Nikita Koksharov
  • Method Details

    • headersCodec

      FanoutPublishArgs<V> headersCodec(Codec codec)
      Sets the codec to be used for encoding and decoding message headers.
      Parameters:
      codec - the codec
      Returns:
      arguments object
    • messages

      @SafeVarargs static <V> FanoutPublishArgs<V> messages(MessageArgs<V>... msgs)
      Defines messages to be added.
      Parameters:
      msgs - The message arguments to be added to the queue
      Returns:
      arguments object