public abstract class DmsAbstractProducer extends DmsAbstractClient implements DmsProducer
构造器和说明 |
---|
DmsAbstractProducer(DmsNetClient netClient)
构造函数
|
限定符和类型 | 方法和说明 |
---|---|
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鉴权
|
start, stop
public DmsAbstractProducer(DmsNetClient netClient)
netClient
- netClientpublic 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
DmsProducer
produce
在接口中 DmsProducer
projectId
- 区域/项目IDak
- 用户aksk
- 用户skqueueId
- 队列IDmessages
- 生产消息DmsClientException
- 生产过程抛出的异常public 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)
DmsProducer
produceAsyn
在接口中 DmsProducer
projectId
- 区域/项目IDak
- 用户aksk
- 用户skqueueId
- 队列IDmessages
- 生产消息callback
- 结果回调DmsBlockedCallBack
,
DmsNonBlockedCallBack
public void produceOneWay(java.lang.String projectId, java.lang.String ak, java.lang.String sk, java.lang.String queueId, java.util.List<DmsMessage> messages)
DmsProducer
produceOneWay
在接口中 DmsProducer
projectId
- 区域/项目IDak
- 用户aksk
- 用户skqueueId
- 队列IDmessages
- 生产消息public java.util.List<DmsProduceResult> produce(java.lang.String queueId, java.util.List<DmsMessage> messages) throws DmsClientException
DmsProducer
produce
在接口中 DmsProducer
queueId
- 队列IDmessages
- 生产消息DmsClientException
- 生产过程抛出的异常public void produceAsyn(java.lang.String queueId, java.util.List<DmsMessage> messages, DmsCallBack<java.util.List<DmsProduceResult>> callback)
DmsProducer
produceAsyn
在接口中 DmsProducer
queueId
- 队列IDmessages
- 生产消息callback
- 结果回调DmsBlockedCallBack
,
DmsNonBlockedCallBack
public void produceOneWay(java.lang.String queueId, java.util.List<DmsMessage> messages)
DmsProducer
produceOneWay
在接口中 DmsProducer
queueId
- 队列IDmessages
- 生产消息