public class RocketMQProducerInfo extends Object
| 限定符和类型 | 字段和说明 |
|---|---|
private String |
accessKey
The property of "access-key".
|
private int |
compressMessageBodyThreshold
Compress message body threshold, namely, message body larger than 4k will be compressed on default.
|
private String |
customizedTraceTopic
The name value of message trace topic.If you don't config, you can use the default trace topic name.
|
private boolean |
enableMsgTrace
Switch flag instance for message trace.
|
private String |
group
Group name of producer.
|
private int |
maxMessageSize
Maximum allowed message size in bytes.
|
private boolean |
retryNextServer
Indicate whether to retry another broker on sending failure internally.
|
private int |
retryTimesWhenSendAsyncFailed
Maximum number of retry to perform internally before claiming sending failure in asynchronous mode.
|
private int |
retryTimesWhenSendFailed
Maximum number of retry to perform internally before claiming sending failure in synchronous mode.
|
private String |
secretKey
The property of "secret-key".
|
private int |
sendMessageTimeout
Millis of send message timeout.
|
| 构造器和说明 |
|---|
RocketMQProducerInfo() |
| 限定符和类型 | 方法和说明 |
|---|---|
boolean |
equals(Object obj) |
String |
getAccessKey() |
int |
getCompressMessageBodyThreshold() |
String |
getCustomizedTraceTopic() |
String |
getGroup() |
int |
getMaxMessageSize() |
int |
getRetryTimesWhenSendAsyncFailed() |
int |
getRetryTimesWhenSendFailed() |
String |
getSecretKey() |
int |
getSendMessageTimeout() |
int |
hashCode() |
boolean |
isEnableMsgTrace() |
boolean |
isRetryNextServer() |
void |
setAccessKey(String accessKey) |
void |
setCompressMessageBodyThreshold(int compressMessageBodyThreshold) |
void |
setCustomizedTraceTopic(String customizedTraceTopic) |
void |
setEnableMsgTrace(boolean enableMsgTrace) |
void |
setGroup(String group) |
void |
setMaxMessageSize(int maxMessageSize) |
void |
setRetryNextServer(boolean retryNextServer) |
void |
setRetryTimesWhenSendAsyncFailed(int retryTimesWhenSendAsyncFailed) |
void |
setRetryTimesWhenSendFailed(int retryTimesWhenSendFailed) |
void |
setSecretKey(String secretKey) |
void |
setSendMessageTimeout(int sendMessageTimeout) |
String |
toString() |
private String group
private int sendMessageTimeout
private int compressMessageBodyThreshold
private int retryTimesWhenSendFailed
private int retryTimesWhenSendAsyncFailed
Maximum number of retry to perform internally before claiming sending failure in asynchronous mode.
This may potentially cause message duplication which is up to application developers to resolve.private boolean retryNextServer
private int maxMessageSize
private String accessKey
private String secretKey
private boolean enableMsgTrace
private String customizedTraceTopic
public String getGroup()
public void setGroup(String group)
public int getSendMessageTimeout()
public void setSendMessageTimeout(int sendMessageTimeout)
public int getCompressMessageBodyThreshold()
public void setCompressMessageBodyThreshold(int compressMessageBodyThreshold)
public int getRetryTimesWhenSendFailed()
public void setRetryTimesWhenSendFailed(int retryTimesWhenSendFailed)
public int getRetryTimesWhenSendAsyncFailed()
public void setRetryTimesWhenSendAsyncFailed(int retryTimesWhenSendAsyncFailed)
public boolean isRetryNextServer()
public void setRetryNextServer(boolean retryNextServer)
public int getMaxMessageSize()
public void setMaxMessageSize(int maxMessageSize)
public String getAccessKey()
public void setAccessKey(String accessKey)
public String getSecretKey()
public void setSecretKey(String secretKey)
public boolean isEnableMsgTrace()
public void setEnableMsgTrace(boolean enableMsgTrace)
public String getCustomizedTraceTopic()
public void setCustomizedTraceTopic(String customizedTraceTopic)
Copyright © 2025 Zodiac. All rights reserved.