public interface DmsProducer extends DmsClient
限定符和类型 | 方法和说明 |
---|---|
java.util.List<DmsProduceResult> |
produce(java.lang.String queueId,
java.util.List<DmsMessage> messages)
同步生产接口,一次生产多条,通过用户ak、sk鉴权
projectId, ak, sk从配置读取 |
java.util.List<DmsProduceResult> |
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 |
produceAsyn(java.lang.String queueId,
java.util.List<DmsMessage> messages,
DmsCallBack<java.util.List<DmsProduceResult>> callback)
异步生产接口,一次生产多条,通过用户ak、sk鉴权
projectId, ak, sk从配置读取 |
void |
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 |
produceOneWay(java.lang.String queueId,
java.util.List<DmsMessage> messages)
oneway生产接口,一次生产多条,通过用户ak、sk鉴权
projectId, ak, sk从配置读取 |
void |
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鉴权
|
java.util.List<DmsProduceResult> produce(java.lang.String projectId, java.lang.String ak, java.lang.String sk, java.lang.String queueId, java.util.List<DmsMessage> messages) throws DmsClientException
projectId
- 区域/项目IDak
- 用户aksk
- 用户skqueueId
- 队列IDmessages
- 生产消息DmsClientException
- 生产过程抛出的异常java.util.List<DmsProduceResult> produce(java.lang.String queueId, java.util.List<DmsMessage> messages) throws DmsClientException
queueId
- 队列IDmessages
- 生产消息DmsClientException
- 生产过程抛出的异常void 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)
projectId
- 区域/项目IDak
- 用户aksk
- 用户skqueueId
- 队列IDmessages
- 生产消息callback
- 结果回调DmsBlockedCallBack
,
DmsNonBlockedCallBack
void produceAsyn(java.lang.String queueId, java.util.List<DmsMessage> messages, DmsCallBack<java.util.List<DmsProduceResult>> callback)
queueId
- 队列IDmessages
- 生产消息callback
- 结果回调DmsBlockedCallBack
,
DmsNonBlockedCallBack
void produceOneWay(java.lang.String projectId, java.lang.String ak, java.lang.String sk, java.lang.String queueId, java.util.List<DmsMessage> messages)
projectId
- 区域/项目IDak
- 用户aksk
- 用户skqueueId
- 队列IDmessages
- 生产消息void produceOneWay(java.lang.String queueId, java.util.List<DmsMessage> messages)
queueId
- 队列IDmessages
- 生产消息