public enum PubSubTransportProfile extends Enum<PubSubTransportProfile>
public static final PubSubTransportProfile UDP_UADP
public static final PubSubTransportProfile MQTT_UADP
public static final PubSubTransportProfile MQTT_JSON
public static PubSubTransportProfile[] values()
for (PubSubTransportProfile c : PubSubTransportProfile.values()) System.out.println(c);
public static PubSubTransportProfile valueOf(String name)
name - the name of the enum constant to be returned.IllegalArgumentException - if this enum type has no constant with the specified nameNullPointerException - if the argument is nullpublic static PubSubTransportProfile valueOf(PubSubTransportProtocol transportProtocol, PubSubMessageEncoding messageEncoding)
PubSubTransportProfile that has the given combination or throws
IllegalArgumentException if a given combination is not valid.public abstract PubSubConnectionConf.Builder<?> createConnectionConfBuilder()
public abstract PubSubDataSetReaderConf.Builder<?> createDataSetReaderConfBuilder()
public abstract PubSubDataSetWriterConf.Builder<?> createDataSetWriterConfBuilder()
public abstract PubSubReaderGroupConf.Builder<?> createReaderGroupConfBuilder()
public abstract PubSubWriterGroupConf.Builder<?> createWriterGroupConfBuilder()
public PubSubMessageEncoding getMessageEncoding()
public String getProfileUri()
public PubSubTransportProtocol getTransportProtocol()
Copyright © 2026. All rights reserved.