Package deltix.qsrv.hf.tickdb.pub.topic
Class TopicChannelPreferences<T extends TopicChannelPreferences>
- java.lang.Object
-
- deltix.data.stream.ChannelPreferences
-
- deltix.qsrv.hf.tickdb.pub.topic.TopicChannelPreferences<T>
-
- Direct Known Subclasses:
ConsumerPreferences
,PublisherPreferences
public abstract class TopicChannelPreferences<T extends TopicChannelPreferences> extends ChannelPreferences
Base class for fluent-style API for setting up topic channel preferences.
-
-
Field Summary
-
Fields inherited from class deltix.data.stream.ChannelPreferences
channelPerformance, raw, typeLoader
-
-
Constructor Summary
Constructors Constructor Description TopicChannelPreferences()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description T
copyFrom(ChannelPreferences channelPreferences)
Populates this object with values from providedChannelPreferences
.IdleStrategy
getEffectiveIdleStrategy(IdleStrategy idleStrategy)
DeterminesIdleStrategy
to be used for this channel (if applicable).T
setChannelPerformance(ChannelPerformance channelPerformance)
T
setRaw(boolean raw)
T
setTypeLoader(TypeLoader typeLoader)
-
Methods inherited from class deltix.data.stream.ChannelPreferences
getChannelPerformance, getTypeLoader
-
-
-
-
Method Detail
-
setRaw
public T setRaw(boolean raw)
- Parameters:
raw
- input message type (true
meansRawMessage
-
setTypeLoader
public T setTypeLoader(TypeLoader typeLoader)
- Parameters:
typeLoader
- type loader to be used for message
-
setChannelPerformance
public T setChannelPerformance(ChannelPerformance channelPerformance)
-
copyFrom
public T copyFrom(ChannelPreferences channelPreferences)
Populates this object with values from providedChannelPreferences
.
-
getEffectiveIdleStrategy
@Nonnull public IdleStrategy getEffectiveIdleStrategy(@Nullable IdleStrategy idleStrategy)
DeterminesIdleStrategy
to be used for this channel (if applicable). If a non-nullIdleStrategy
provided as a parameter then it is returned as is. OtherwiseIdleStrategy
is determined byChannelPreferences.channelPerformance
.
-
-