public static final class PubSubMqttJsonWriterGroupConf.Builder extends Object
PubSubMqttJsonWriterGroupConf.| Modifier and Type | Field and Description |
|---|---|
protected Boolean |
enabled |
protected Map<String,String> |
jsonHeaderExtraFields |
protected Duration |
keepAliveTime |
protected List<String> |
localeIds |
protected UnsignedInteger |
maxNetworkMessageSize |
protected JsonNetworkMessageContentMask |
messageContentMask |
protected String |
metaDataQueueName |
protected Duration |
metaDataUpdateTime |
protected String |
name |
protected UnsignedByte |
priority |
protected Duration |
publishingInterval |
protected String |
queueName |
protected BrokerTransportQualityOfService |
requestedDeliveryGuarantee |
protected PubSubSecurityConf |
securityConf |
protected UnsignedShort |
writerGroupId |
protected Map<String,PubSubMqttJsonDataSetWriterConf> |
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 JsonNetworkMessageContentMask messageContentMask
protected Map<String,PubSubMqttJsonDataSetWriterConf> writers
public PubSubMqttJsonWriterGroupConf.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<PubSubMqttJsonWriterGroupConf.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 JsonNetworkMessageContentMask getMessageContentMask()
public Map<String,PubSubMqttJsonDataSetWriterConf> getWriters()
public PubSubMqttJsonWriterGroupConf.Builder setMetaDataQueueName(String metaDataQueueName)
PubSubMqttJsonWriterGroupConf.getMetaDataQueueName(). Returns itself for method chaining.setMetaDataQueueName in interface PubSubBrokerTransportSettingsConf.Builder<PubSubMqttJsonWriterGroupConf.Builder>public PubSubMqttJsonWriterGroupConf.Builder setMetaDataUpdateTime(Duration metaDataUpdateTime)
PubSubMqttJsonWriterGroupConf.getMetaDataUpdateTime(). Returns itself for method chaining.setMetaDataUpdateTime in interface PubSubBrokerTransportSettingsConf.Builder<PubSubMqttJsonWriterGroupConf.Builder>public PubSubMqttJsonWriterGroupConf.Builder setQueueName(String queueName)
PubSubMqttJsonWriterGroupConf.getQueueName(). Returns itself for method chaining.setQueueName in interface PubSubBrokerTransportSettingsConf.Builder<PubSubMqttJsonWriterGroupConf.Builder>public PubSubMqttJsonWriterGroupConf.Builder setRequestedDeliveryGuarantee(BrokerTransportQualityOfService requestedDeliveryGuarantee)
PubSubMqttJsonWriterGroupConf.getRequestedDeliveryGuarantee(). Returns itself for method chaining.setRequestedDeliveryGuarantee in interface PubSubBrokerTransportSettingsConf.Builder<PubSubMqttJsonWriterGroupConf.Builder>public PubSubMqttJsonWriterGroupConf.Builder setMaxNetworkMessageSize(UnsignedInteger maxNetworkMessageSize)
PubSubMqttJsonWriterGroupConf.getMaxNetworkMessageSize(). Returns itself for method chaining.setMaxNetworkMessageSize in interface PubSubGroupConf.Builder<PubSubMqttJsonWriterGroupConf.Builder>public PubSubMqttJsonWriterGroupConf.Builder setName(String name)
PubSubMqttJsonWriterGroupConf.getName(). Returns itself for method chaining.setName in interface PubSubNamedConf.Builder<PubSubMqttJsonWriterGroupConf.Builder>public PubSubMqttJsonWriterGroupConf.Builder setSecurityConf(PubSubSecurityConf securityConf)
PubSubMqttJsonWriterGroupConf.getSecurityConf(). Returns itself for method chaining.setSecurityConf in interface PubSubGroupConf.Builder<PubSubMqttJsonWriterGroupConf.Builder>public PubSubMqttJsonWriterGroupConf.Builder setEnabled(Boolean enabled)
PubSubMqttJsonWriterGroupConf#getEnabled(). Returns itself for method chaining.setEnabled in interface PubSubGroupConf.Builder<PubSubMqttJsonWriterGroupConf.Builder>public PubSubMqttJsonWriterGroupConf.Builder setKeepAliveTime(Duration keepAliveTime)
PubSubMqttJsonWriterGroupConf.getKeepAliveTime(). Returns itself for method chaining.setKeepAliveTime in interface PubSubWriterGroupConf.Builder<PubSubMqttJsonWriterGroupConf.Builder>public PubSubMqttJsonWriterGroupConf.Builder addLocaleIds(String localeIds)
PubSubMqttJsonWriterGroupConf.getLocaleIds(). Returns itself for method chaining.addLocaleIds in interface PubSubWriterGroupConf.Builder<PubSubMqttJsonWriterGroupConf.Builder>public PubSubMqttJsonWriterGroupConf.Builder setPriority(UnsignedByte priority)
PubSubMqttJsonWriterGroupConf.getPriority(). Returns itself for method chaining.setPriority in interface PubSubWriterGroupConf.Builder<PubSubMqttJsonWriterGroupConf.Builder>public PubSubMqttJsonWriterGroupConf.Builder setPublishingInterval(Duration publishingInterval)
PubSubMqttJsonWriterGroupConf.getPublishingInterval(). Returns itself for method chaining.setPublishingInterval in interface PubSubWriterGroupConf.Builder<PubSubMqttJsonWriterGroupConf.Builder>public PubSubMqttJsonWriterGroupConf.Builder setWriterGroupId(UnsignedShort writerGroupId)
PubSubMqttJsonWriterGroupConf.getWriterGroupId(). Returns itself for method chaining.setWriterGroupId in interface PubSubWriterGroupConf.Builder<PubSubMqttJsonWriterGroupConf.Builder>public PubSubMqttJsonWriterGroupConf.Builder setMessageContentMask(JsonNetworkMessageContentMask messageContentMask)
PubSubMqttJsonWriterGroupConf.getMessageContentMask(). Returns itself for method chaining.setMessageContentMask in interface PubSubJsonWriterGroupConf.Builder<PubSubMqttJsonWriterGroupConf.Builder>public PubSubMqttJsonWriterGroupConf.Builder putJsonHeaderExtraFields(String key, String value)
PubSubMqttJsonWriterGroupConf.getJsonHeaderExtraFields(). Returns itself for method chaining.public PubSubMqttJsonWriterGroupConf.Builder addOrReplaceWriter(PubSubMqttJsonDataSetWriterConf value)
PubSubMqttJsonDataSetWriterConf.getName().public PubSubMqttJsonWriterGroupConf build()
PubSubMqttJsonWriterGroupConf with the values given to this builder.build in interface PubSubConf.Builder<PubSubMqttJsonWriterGroupConf.Builder>build in interface PubSubWriterGroupConf.Builder<PubSubMqttJsonWriterGroupConf.Builder>public PubSubMqttJsonWriterGroupConf.Builder removeWriter(String name)
PubSubWriterGroupConf.BuilderremoveWriter in interface PubSubWriterGroupConf.Builder<PubSubMqttJsonWriterGroupConf.Builder>Copyright © 2026. All rights reserved.