Class RocketMQCommonProperties
java.lang.Object
com.alibaba.cloud.stream.binder.rocketmq.properties.RocketMQCommonProperties
- All Implemented Interfaces:
Serializable
- Direct Known Subclasses:
RocketMQBinderConfigurationProperties,RocketMQConsumerProperties,RocketMQProducerProperties
- Author:
- zkzlx
- See Also:
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionbooleanbooleangetGroup()intintintbooleanbooleanvoidsetAccessChannel(String accessChannel) voidsetAccessKey(String accessKey) voidsetCustomizedTraceTopic(String customizedTraceTopic) voidsetEnabled(boolean enabled) voidsetEnableMsgTrace(boolean enableMsgTrace) voidvoidsetHeartbeatBrokerInterval(int heartbeatBrokerInterval) voidsetNameServer(String nameServer) voidsetNamespace(String namespace) voidsetNamespaceV2(String namespaceV2) voidsetPersistConsumerOffsetInterval(int persistConsumerOffsetInterval) voidsetPollNameServerInterval(int pollNameServerInterval) voidsetSecretKey(String secretKey) voidsetUnitName(String unitName) voidsetUseTLS(boolean useTLS) voidsetVipChannelEnabled(boolean vipChannelEnabled)
-
Constructor Details
-
RocketMQCommonProperties
public RocketMQCommonProperties()
-
-
Method Details
-
getEnabled
public boolean getEnabled() -
setEnabled
public void setEnabled(boolean enabled) -
getNameServer
-
setNameServer
-
getAccessKey
-
setAccessKey
-
getSecretKey
-
setSecretKey
-
getGroup
-
setGroup
-
getNamespace
-
setNamespace
-
getNamespaceV2
-
setNamespaceV2
-
getAccessChannel
-
setAccessChannel
-
getPollNameServerInterval
public int getPollNameServerInterval() -
setPollNameServerInterval
public void setPollNameServerInterval(int pollNameServerInterval) -
getHeartbeatBrokerInterval
public int getHeartbeatBrokerInterval() -
setHeartbeatBrokerInterval
public void setHeartbeatBrokerInterval(int heartbeatBrokerInterval) -
getPersistConsumerOffsetInterval
public int getPersistConsumerOffsetInterval() -
setPersistConsumerOffsetInterval
public void setPersistConsumerOffsetInterval(int persistConsumerOffsetInterval) -
getVipChannelEnabled
public boolean getVipChannelEnabled() -
setVipChannelEnabled
public void setVipChannelEnabled(boolean vipChannelEnabled) -
getUseTLS
public boolean getUseTLS() -
setUseTLS
public void setUseTLS(boolean useTLS) -
getEnableMsgTrace
public boolean getEnableMsgTrace() -
setEnableMsgTrace
public void setEnableMsgTrace(boolean enableMsgTrace) -
getCustomizedTraceTopic
-
setCustomizedTraceTopic
-
getUnitName
-
setUnitName
-