Package org.redisson.api.fanout

Class FanoutPublishParams<V>

java.lang.Object

org.redisson.api.BaseSyncParams<FanoutPublishArgs<V>>

org.redisson.api.fanout.FanoutPublishParams<V>

All Implemented Interfaces:

FanoutPublishArgs<V>, SyncArgs<FanoutPublishArgs<V>>

public final class FanoutPublishParams<V>
extends BaseSyncParams<FanoutPublishArgs<V>>
implements FanoutPublishArgs<V>

Constructor Summary

Constructors

Constructor	Description
FanoutPublishParams(MessageArgs<V>[] msgs)

Method Summary

Modifier and Type	Method	Description
Codec	getHeadersCodec()
MessageArgs<V>[]	getMsgs()
FanoutPublishArgs<V>	headersCodec(Codec codec)	Sets the codec to be used for encoding and decoding message headers.

Methods inherited from class org.redisson.api.BaseSyncParams

getSyncFailureMode, getSyncMode, getSyncTimeout, syncFailureMode, syncMode, syncTimeout

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.redisson.api.SyncArgs

syncFailureMode, syncMode, syncTimeout

Constructor Details

FanoutPublishParams

public FanoutPublishParams(MessageArgs<V>[] msgs)

Method Details

headersCodec

public FanoutPublishArgs<V> headersCodec(Codec codec)

Description copied from interface: FanoutPublishArgs

Sets the codec to be used for encoding and decoding message headers.

Specified by:

headersCodec in interface FanoutPublishArgs<V>

Parameters:

codec - the codec

Returns:

arguments object

getMsgs

public MessageArgs<V>[] getMsgs()

getHeadersCodec

public Codec getHeadersCodec()