public static final class PubSubMqttJsonConnectionConf.Builder extends Object
PubSubMqttJsonConnectionConf.| Modifier and Type | Field and Description |
|---|---|
protected PubSubBrokerAuthConf |
authConf |
protected Boolean |
disableMqttRetain |
protected Boolean |
enabled |
protected Boolean |
enableStatusMessage |
protected String |
mqttTopicTreePrefix |
protected String |
name |
protected String |
networkAddress |
protected PublisherId |
publisherId |
protected Map<String,PubSubMqttJsonReaderGroupConf> |
readerGroups |
protected Map<String,PubSubMqttJsonWriterGroupConf> |
writerGroups |
| Modifier | Constructor and Description |
|---|---|
protected |
Builder() |
protected String name
protected PublisherId publisherId
protected Boolean enabled
protected PubSubBrokerAuthConf authConf
protected String mqttTopicTreePrefix
protected String networkAddress
protected Boolean disableMqttRetain
protected Boolean enableStatusMessage
protected Map<String,PubSubMqttJsonReaderGroupConf> readerGroups
protected Map<String,PubSubMqttJsonWriterGroupConf> writerGroups
public PubSubMqttJsonConnectionConf.Builder addOrReplaceGroup(PubSubGroupConf value)
PubSubConnectionConf.BuilderPubSubTransportProfile implementation as this connection (e.g. UDP-UADP WriterGroup
for UDP-UADP Connection), otherwise throws IllegalArgumentException. Replaces any
existing Group with the same name as the given one.public final PubSubTransportProfile getTransportProfile()
PubSubConnectionConf.Builderpublic PubSubConfSpecification specification()
PubSubConf.Builderspecification in interface PubSubConf.Builder<PubSubMqttJsonConnectionConf.Builder>public String getName()
public PublisherId getPublisherId()
public Boolean isEnabled()
public PubSubBrokerAuthConf getAuthConf()
public String getMqttTopicTreePrefix()
public String getNetworkAddress()
public Boolean isDisableMqttRetain()
public Boolean isEnableStatusMessage()
public Map<String,PubSubMqttJsonReaderGroupConf> getReaderGroups()
public Map<String,PubSubMqttJsonWriterGroupConf> getWriterGroups()
public PubSubMqttJsonConnectionConf.Builder setName(String name)
PubSubMqttJsonConnectionConf.getName(). Returns itself for method chaining.setName in interface PubSubNamedConf.Builder<PubSubMqttJsonConnectionConf.Builder>public PubSubMqttJsonConnectionConf.Builder setPublisherId(PublisherId publisherId)
PubSubMqttJsonConnectionConf.getPublisherId(). Returns itself for method chaining.setPublisherId in interface PubSubConnectionConf.Builder<PubSubMqttJsonConnectionConf.Builder>public PubSubMqttJsonConnectionConf.Builder setEnabled(Boolean enabled)
PubSubMqttJsonConnectionConf#getEnabled(). Returns itself for method chaining.setEnabled in interface PubSubConnectionConf.Builder<PubSubMqttJsonConnectionConf.Builder>public PubSubMqttJsonConnectionConf.Builder setAuthConf(PubSubBrokerAuthConf authConf)
PubSubMqttJsonConnectionConf.getAuthConf(). Returns itself for method chaining.setAuthConf in interface PubSubBrokerConnectionConf.Builder<PubSubMqttJsonConnectionConf.Builder>public PubSubMqttJsonConnectionConf.Builder setMqttTopicTreePrefix(String mqttTopicTreePrefix)
PubSubMqttJsonConnectionConf.getMqttTopicTreePrefix(). Returns itself for method chaining.public PubSubMqttJsonConnectionConf.Builder setNetworkAddress(String networkAddress)
PubSubMqttJsonConnectionConf.getNetworkAddress(). Returns itself for method chaining.setNetworkAddress in interface PubSubBrokerConnectionConf.Builder<PubSubMqttJsonConnectionConf.Builder>public PubSubMqttJsonConnectionConf.Builder setDisableMqttRetain(Boolean disableMqttRetain)
PubSubMqttJsonConnectionConf#getDisableMqttRetain(). Returns itself for method chaining.setDisableMqttRetain in interface PubSubBrokerConnectionConf.Builder<PubSubMqttJsonConnectionConf.Builder>public PubSubMqttJsonConnectionConf.Builder setEnableStatusMessage(Boolean enableStatusMessage)
PubSubMqttJsonConnectionConf#getEnableStatusMessage(). Returns itself for method chaining.setEnableStatusMessage in interface PubSubBrokerConnectionConf.Builder<PubSubMqttJsonConnectionConf.Builder>public PubSubMqttJsonConnectionConf.Builder addOrReplaceGroup(PubSubMqttJsonReaderGroupConf value)
PubSubMqttJsonReaderGroupConf.getName().public PubSubMqttJsonConnectionConf.Builder addOrReplaceGroup(PubSubMqttJsonWriterGroupConf value)
PubSubMqttJsonWriterGroupConf.getName().public PubSubMqttJsonConnectionConf build()
PubSubMqttJsonConnectionConf with the values given to this builder.build in interface PubSubConf.Builder<PubSubMqttJsonConnectionConf.Builder>build in interface PubSubConnectionConf.Builder<PubSubMqttJsonConnectionConf.Builder>public PubSubMqttJsonConnectionConf.Builder removeGroup(String name)
PubSubConnectionConf.BuilderremoveGroup in interface PubSubConnectionConf.Builder<PubSubMqttJsonConnectionConf.Builder>Copyright © 2026. All rights reserved.