程序包 | 说明 |
---|---|
com.huawei.dms.client.entity | |
com.huawei.dms.client.produce |
限定符和类型 | 方法和说明 |
---|---|
DmsMessage |
DmsConsumeResult.getMessage()
返回 message
|
限定符和类型 | 方法和说明 |
---|---|
java.util.List<DmsMessage> |
DmsProduceRequest.getMessages() |
限定符和类型 | 方法和说明 |
---|---|
void |
DmsConsumeResult.setMessage(DmsMessage message)
对message进行赋值
|
限定符和类型 | 方法和说明 |
---|---|
void |
DmsProduceRequest.setMessages(java.util.List<DmsMessage> messages) |
限定符和类型 | 方法和说明 |
---|---|
java.util.List<DmsProduceResult> |
DmsAbstractProducer.produce(java.lang.String queueId,
java.util.List<DmsMessage> messages) |
java.util.List<DmsProduceResult> |
DmsProducer.produce(java.lang.String queueId,
java.util.List<DmsMessage> messages)
同步生产接口,一次生产多条,通过用户ak、sk鉴权
projectId, ak, sk从配置读取 |
java.util.List<DmsProduceResult> |
DmsAbstractProducer.produce(java.lang.String projectId,
java.lang.String ak,
java.lang.String sk,
java.lang.String queueId,
java.util.List<DmsMessage> messages) |
java.util.List<DmsProduceResult> |
DmsProducer.produce(java.lang.String projectId,
java.lang.String ak,
java.lang.String sk,
java.lang.String queueId,
java.util.List<DmsMessage> messages)
同步生产接口,一次生产多条,通过用户ak、sk鉴权
|
void |
DmsAbstractProducer.produceAsyn(java.lang.String queueId,
java.util.List<DmsMessage> messages,
DmsCallBack<java.util.List<DmsProduceResult>> callback) |
void |
DmsProducer.produceAsyn(java.lang.String queueId,
java.util.List<DmsMessage> messages,
DmsCallBack<java.util.List<DmsProduceResult>> callback)
异步生产接口,一次生产多条,通过用户ak、sk鉴权
projectId, ak, sk从配置读取 |
void |
DmsAbstractProducer.produceAsyn(java.lang.String projectId,
java.lang.String ak,
java.lang.String sk,
java.lang.String queueId,
java.util.List<DmsMessage> messages,
DmsCallBack<java.util.List<DmsProduceResult>> callback) |
void |
DmsProducer.produceAsyn(java.lang.String projectId,
java.lang.String ak,
java.lang.String sk,
java.lang.String queueId,
java.util.List<DmsMessage> messages,
DmsCallBack<java.util.List<DmsProduceResult>> callback)
异步生产接口,一次生产多条,通过用户ak、sk鉴权
|
void |
DmsAbstractProducer.produceOneWay(java.lang.String queueId,
java.util.List<DmsMessage> messages) |
void |
DmsProducer.produceOneWay(java.lang.String queueId,
java.util.List<DmsMessage> messages)
oneway生产接口,一次生产多条,通过用户ak、sk鉴权
projectId, ak, sk从配置读取 |
void |
DmsAbstractProducer.produceOneWay(java.lang.String projectId,
java.lang.String ak,
java.lang.String sk,
java.lang.String queueId,
java.util.List<DmsMessage> messages) |
void |
DmsProducer.produceOneWay(java.lang.String projectId,
java.lang.String ak,
java.lang.String sk,
java.lang.String queueId,
java.util.List<DmsMessage> messages)
oneway生产接口,一次生产多条,通过用户ak、sk鉴权
|