public static final class PubSubMqttUadpWriterGroupConf.Builder extends Object
PubSubMqttUadpWriterGroupConf.| Modifier and Type | Field and Description |
|---|---|
protected DataSetOrderingType |
dataSetOrdering |
protected Boolean |
enabled |
protected UnsignedInteger |
groupVersion |
protected Duration |
keepAliveTime |
protected List<String> |
localeIds |
protected UnsignedInteger |
maxNetworkMessageSize |
protected UadpNetworkMessageContentMask |
messageContentMask |
protected String |
metaDataQueueName |
protected Duration |
metaDataUpdateTime |
protected String |
name |
protected UnsignedByte |
priority |
protected Duration |
publishingInterval |
protected PubSubPublishingOffsets |
publishingOffset |
protected String |
queueName |
protected BrokerTransportQualityOfService |
requestedDeliveryGuarantee |
protected Duration |
samplingOffset |
protected PubSubSecurityConf |
securityConf |
protected UnsignedShort |
writerGroupId |
protected Map<String,PubSubMqttUadpDataSetWriterConf> |
writers |
| Modifier | Constructor and Description |
|---|---|
protected |
Builder() |
protected String metaDataQueueName
protected Duration metaDataUpdateTime
protected String queueName
protected BrokerTransportQualityOfService requestedDeliveryGuarantee
protected UnsignedInteger maxNetworkMessageSize
protected String name
protected PubSubSecurityConf securityConf
protected Boolean enabled
protected Duration keepAliveTime
protected UnsignedByte priority
protected Duration publishingInterval
protected UnsignedShort writerGroupId
protected DataSetOrderingType dataSetOrdering
protected UnsignedInteger groupVersion
protected UadpNetworkMessageContentMask messageContentMask
protected PubSubPublishingOffsets publishingOffset
protected Duration samplingOffset
protected Map<String,PubSubMqttUadpDataSetWriterConf> writers
public PubSubMqttUadpWriterGroupConf.Builder addOrReplaceWriter(PubSubDataSetWriterConf value)
PubSubWriterGroupConf.BuilderPubSubTransportProfile implementation as this group (e.g. UDP-UADP Writer for
UDP-UADP WriterGroup), otherwise throws IllegalArgumentException. Replaces any
existing Writer with the same name as the given one.public final PubSubTransportProfile getTransportProfile()
PubSubGroupConf.Builderpublic PubSubConfSpecification specification()
PubSubConf.Builderspecification in interface PubSubConf.Builder<PubSubMqttUadpWriterGroupConf.Builder>public String getMetaDataQueueName()
public Duration getMetaDataUpdateTime()
public String getQueueName()
public BrokerTransportQualityOfService getRequestedDeliveryGuarantee()
public UnsignedInteger getMaxNetworkMessageSize()
public String getName()
public PubSubSecurityConf getSecurityConf()
public Boolean isEnabled()
public Duration getKeepAliveTime()
public UnsignedByte getPriority()
public Duration getPublishingInterval()
public UnsignedShort getWriterGroupId()
public DataSetOrderingType getDataSetOrdering()
public UnsignedInteger getGroupVersion()
public UadpNetworkMessageContentMask getMessageContentMask()
public PubSubPublishingOffsets getPublishingOffset()
public Duration getSamplingOffset()
public Map<String,PubSubMqttUadpDataSetWriterConf> getWriters()
public PubSubMqttUadpWriterGroupConf.Builder setMetaDataQueueName(String metaDataQueueName)
PubSubMqttUadpWriterGroupConf.getMetaDataQueueName(). Returns itself for method chaining.setMetaDataQueueName in interface PubSubBrokerTransportSettingsConf.Builder<PubSubMqttUadpWriterGroupConf.Builder>public PubSubMqttUadpWriterGroupConf.Builder setMetaDataUpdateTime(Duration metaDataUpdateTime)
PubSubMqttUadpWriterGroupConf.getMetaDataUpdateTime(). Returns itself for method chaining.setMetaDataUpdateTime in interface PubSubBrokerTransportSettingsConf.Builder<PubSubMqttUadpWriterGroupConf.Builder>public PubSubMqttUadpWriterGroupConf.Builder setQueueName(String queueName)
PubSubMqttUadpWriterGroupConf.getQueueName(). Returns itself for method chaining.setQueueName in interface PubSubBrokerTransportSettingsConf.Builder<PubSubMqttUadpWriterGroupConf.Builder>public PubSubMqttUadpWriterGroupConf.Builder setRequestedDeliveryGuarantee(BrokerTransportQualityOfService requestedDeliveryGuarantee)
PubSubMqttUadpWriterGroupConf.getRequestedDeliveryGuarantee(). Returns itself for method chaining.setRequestedDeliveryGuarantee in interface PubSubBrokerTransportSettingsConf.Builder<PubSubMqttUadpWriterGroupConf.Builder>public PubSubMqttUadpWriterGroupConf.Builder setMaxNetworkMessageSize(UnsignedInteger maxNetworkMessageSize)
PubSubMqttUadpWriterGroupConf.getMaxNetworkMessageSize(). Returns itself for method chaining.setMaxNetworkMessageSize in interface PubSubGroupConf.Builder<PubSubMqttUadpWriterGroupConf.Builder>public PubSubMqttUadpWriterGroupConf.Builder setName(String name)
PubSubMqttUadpWriterGroupConf.getName(). Returns itself for method chaining.setName in interface PubSubNamedConf.Builder<PubSubMqttUadpWriterGroupConf.Builder>public PubSubMqttUadpWriterGroupConf.Builder setSecurityConf(PubSubSecurityConf securityConf)
PubSubMqttUadpWriterGroupConf.getSecurityConf(). Returns itself for method chaining.setSecurityConf in interface PubSubGroupConf.Builder<PubSubMqttUadpWriterGroupConf.Builder>public PubSubMqttUadpWriterGroupConf.Builder setEnabled(Boolean enabled)
PubSubMqttUadpWriterGroupConf#getEnabled(). Returns itself for method chaining.setEnabled in interface PubSubGroupConf.Builder<PubSubMqttUadpWriterGroupConf.Builder>public PubSubMqttUadpWriterGroupConf.Builder setKeepAliveTime(Duration keepAliveTime)
PubSubMqttUadpWriterGroupConf.getKeepAliveTime(). Returns itself for method chaining.setKeepAliveTime in interface PubSubWriterGroupConf.Builder<PubSubMqttUadpWriterGroupConf.Builder>public PubSubMqttUadpWriterGroupConf.Builder addLocaleIds(String localeIds)
PubSubMqttUadpWriterGroupConf.getLocaleIds(). Returns itself for method chaining.addLocaleIds in interface PubSubWriterGroupConf.Builder<PubSubMqttUadpWriterGroupConf.Builder>public PubSubMqttUadpWriterGroupConf.Builder setPriority(UnsignedByte priority)
PubSubMqttUadpWriterGroupConf.getPriority(). Returns itself for method chaining.setPriority in interface PubSubWriterGroupConf.Builder<PubSubMqttUadpWriterGroupConf.Builder>public PubSubMqttUadpWriterGroupConf.Builder setPublishingInterval(Duration publishingInterval)
PubSubMqttUadpWriterGroupConf.getPublishingInterval(). Returns itself for method chaining.setPublishingInterval in interface PubSubWriterGroupConf.Builder<PubSubMqttUadpWriterGroupConf.Builder>public PubSubMqttUadpWriterGroupConf.Builder setWriterGroupId(UnsignedShort writerGroupId)
PubSubMqttUadpWriterGroupConf.getWriterGroupId(). Returns itself for method chaining.setWriterGroupId in interface PubSubWriterGroupConf.Builder<PubSubMqttUadpWriterGroupConf.Builder>public PubSubMqttUadpWriterGroupConf.Builder setDataSetOrdering(DataSetOrderingType dataSetOrdering)
PubSubMqttUadpWriterGroupConf.getDataSetOrdering(). Returns itself for method chaining.setDataSetOrdering in interface PubSubUadpWriterGroupConf.Builder<PubSubMqttUadpWriterGroupConf.Builder>public PubSubMqttUadpWriterGroupConf.Builder setGroupVersion(UnsignedInteger groupVersion)
PubSubMqttUadpWriterGroupConf.getGroupVersion(). Returns itself for method chaining.setGroupVersion in interface PubSubUadpWriterGroupConf.Builder<PubSubMqttUadpWriterGroupConf.Builder>public PubSubMqttUadpWriterGroupConf.Builder setMessageContentMask(UadpNetworkMessageContentMask messageContentMask)
PubSubMqttUadpWriterGroupConf.getMessageContentMask(). Returns itself for method chaining.setMessageContentMask in interface PubSubUadpWriterGroupConf.Builder<PubSubMqttUadpWriterGroupConf.Builder>public PubSubMqttUadpWriterGroupConf.Builder setPublishingOffset(PubSubPublishingOffsets publishingOffset)
PubSubMqttUadpWriterGroupConf.getPublishingOffset(). Returns itself for method chaining.setPublishingOffset in interface PubSubUadpWriterGroupConf.Builder<PubSubMqttUadpWriterGroupConf.Builder>public PubSubMqttUadpWriterGroupConf.Builder setSamplingOffset(Duration samplingOffset)
PubSubMqttUadpWriterGroupConf.getSamplingOffset(). Returns itself for method chaining.setSamplingOffset in interface PubSubUadpWriterGroupConf.Builder<PubSubMqttUadpWriterGroupConf.Builder>public PubSubMqttUadpWriterGroupConf.Builder addOrReplaceWriter(PubSubMqttUadpDataSetWriterConf value)
PubSubMqttUadpDataSetWriterConf.getName().public PubSubMqttUadpWriterGroupConf build()
PubSubMqttUadpWriterGroupConf with the values given to this builder.build in interface PubSubConf.Builder<PubSubMqttUadpWriterGroupConf.Builder>build in interface PubSubWriterGroupConf.Builder<PubSubMqttUadpWriterGroupConf.Builder>public PubSubMqttUadpWriterGroupConf.Builder removeWriter(String name)
PubSubWriterGroupConf.BuilderremoveWriter in interface PubSubWriterGroupConf.Builder<PubSubMqttUadpWriterGroupConf.Builder>Copyright © 2026. All rights reserved.