A B C D E F G H I L M N O P Q R S T U V W
S
- send(DmsTask<OperEntity>) - 类 中的方法com.huawei.dms.client.DmsSendThread
-
异步发送请求
- send(DmsTask<OperEntity>) - 接口 中的方法com.huawei.dms.client.transport.DmsNetClient
-
发送任务
- send(DmsTask<OperEntity>) - 类 中的方法com.huawei.dms.client.transport.vertx.DmsVertxNetClient
-
- serialize(byte[], JsonGenerator, SerializerProvider) - 类 中的方法com.huawei.dms.client.entity.MessageBodySerializer
-
- setAsOneway() - 类 中的方法com.huawei.dms.client.DmsTask
-
设置任务为oneway任务
- setAttrFilterList(List<String>) - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsConsumeConfig
-
- setAttributes(Map<String, Object>) - 类 中的方法com.huawei.dms.client.entity.DmsMessage
-
- setAttributes(Map<String, Object>) - 类 中的方法com.huawei.dms.protocol.produce.DmsProduceRecord
-
- setAutoCommit(boolean) - 接口 中的方法com.huawei.dms.client.consume.DmsConsumer
-
广播模式,设置自动确认
- setAutoCommit(boolean) - 类 中的方法com.huawei.dms.client.consume.DmsConsumerImpl
-
广播模式,设置自动确认
- setAutoCommit(boolean) - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsConsumeConfig
-
- setBody(byte[]) - 类 中的方法com.huawei.dms.client.entity.DmsMessage
-
- setBody(byte[]) - 类 中的方法com.huawei.dms.protocol.entity.OperEntity
-
- setBody(Object) - 类 中的方法com.huawei.dms.protocol.produce.DmsProduceRecord
-
- setClientId(short) - 类 中的方法com.huawei.dms.protocol.entity.OperHead
-
- setClientType(byte) - 类 中的方法com.huawei.dms.protocol.entity.OperHead
-
- setConsumeId(String) - 接口 中的方法com.huawei.dms.client.consume.DmsConsumer
-
设置消费实例id
- setConsumeId(String) - 类 中的方法com.huawei.dms.client.consume.DmsConsumerImpl
-
设置消费实例id
- setConsumeId(String) - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsConsumeConfig
-
- setConsumeMode(ConsumeMode) - 接口 中的方法com.huawei.dms.client.consume.DmsConsumer
-
设置消费模式
- setConsumeMode(ConsumeMode) - 类 中的方法com.huawei.dms.client.consume.DmsConsumerImpl
-
设置消费模式
- setConsumeMode(ConsumeMode) - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsConsumeConfig
-
- setConsumerId(String) - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsMessageHandler
-
- setConsumerVersion(int) - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsMessageHandler
-
- setDlEnable(boolean) - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsConsumeConfig
-
- setDlReveives(int) - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsConsumeConfig
-
- setError(String) - 类 中的方法com.huawei.dms.protocol.produce.DmsProduceResult
-
- setErrorCode(Integer) - 类 中的方法com.huawei.dms.protocol.produce.DmsProduceResult
-
- setExtField(Map<String, Object>) - 类 中的方法com.huawei.dms.protocol.entity.OperHead
-
- setFail(int) - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsCommitResult
-
- setFuture(DmsRequestFuture<T>) - 类 中的方法com.huawei.dms.client.DmsTask
-
- setGroup(String) - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsMessageHandler
-
- setHandler(String) - 类 中的方法com.huawei.dms.client.entity.DmsConsumeResult
-
对handler进行赋值
- setHandler(String) - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsCommitItem
-
- setHandler(String) - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsConsumeRecord
-
对handler进行赋值
- setHead(OperHead) - 类 中的方法com.huawei.dms.protocol.entity.OperEntity
-
- setKey(String) - 类 中的方法com.huawei.dms.client.entity.DmsMessage
-
- setKey(String) - 类 中的方法com.huawei.dms.protocol.produce.DmsProduceRecord
-
- setKeyBytes(byte[]) - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsConsumeRecord
-
- setKeyByteSize(int) - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsConsumeRecord
-
- setLongPoll(boolean) - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsConsumeConfig
-
- setLongPullTime(int) - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsConsumeConfig
-
setLongPullTime
- setMaxBytes(int) - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsConsumeConfig
-
- setMaxRecords(int) - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsConsumeConfig
-
- setMessage(DmsMessage) - 类 中的方法com.huawei.dms.client.entity.DmsConsumeResult
-
对message进行赋值
- setMessage(List<DmsCommitItem>) - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsCommitRequest
-
- setMessage(DmsProduceRecord) - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsConsumeRecord
-
对message进行赋值
- setMessageBytes(byte[]) - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsConsumeRecord
-
对messageBytes进行赋值
- setMessageByteSize(int) - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsConsumeRecord
-
对messageByteSize进行赋值
- setMessages(List<DmsMessage>) - 类 中的方法com.huawei.dms.client.entity.DmsProduceRequest
-
- setMessages(List<DmsProduceRecord>) - 类 中的方法com.huawei.dms.protocol.produce.DmsBatchProduceRequest
-
- setMsLoadTick(long) - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsConsumeRecord
-
- setMsPullTime(int) - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsConsumeConfig
-
- setMsWaitCommit(int) - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsConsumeConfig
-
- setOffset(long) - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsConsumeRecord
-
对offset进行赋值
- setOffset(long) - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsMessageHandler
-
- setOper(Operation) - 类 中的方法com.huawei.dms.protocol.entity.OperHead
-
- setOperId(int) - 类 中的方法com.huawei.dms.protocol.entity.OperHead
-
- setPartition(Integer) - 类 中的方法com.huawei.dms.client.entity.DmsMessage
-
- setPartition(int) - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsMessageHandler
-
- setPartition(Integer) - 类 中的方法com.huawei.dms.protocol.produce.DmsProduceRecord
-
- setRedeliver(Boolean) - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsCommitItem
-
设置重投开关
- setRedeliverTimes(Integer) - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsConsumeRecord
-
对getRedeliverTimes进行赋值
- setRedeliverTimes(int) - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsMessageHandler
-
- setRedeliverTimes(Integer) - 类 中的方法com.huawei.dms.protocol.produce.DmsProduceRecord
-
- setResponseBody(Buffer) - 类 中的方法com.huawei.dms.client.utils.DmsClientHttpResponse
-
- setSerialType(SerialType) - 类 中的方法com.huawei.dms.protocol.entity.OperHead
-
- setState(DmsProduceResult.State) - 类 中的方法com.huawei.dms.protocol.produce.DmsProduceResult
-
- setStatus(DmsTask.TaskStatus) - 类 中的方法com.huawei.dms.client.DmsTask
-
- setStatus(Boolean) - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsCommitItem
-
设置消息状态
- setStoreRecord(Object) - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsConsumeRecord
-
- setSuccess(int) - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsCommitResult
-
- setTagList(List<String>) - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsConsumeConfig
-
- setTagList(List<String>) - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsMessageHandler
-
- setTags(List<String>) - 类 中的方法com.huawei.dms.client.entity.DmsMessage
-
- setTags(List<String>) - 类 中的方法com.huawei.dms.protocol.produce.DmsProduceRecord
-
- setTagType(String) - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsConsumeConfig
-
- setTagType(String) - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsMessageHandler
-
- setTimestamp(Long) - 类 中的方法com.huawei.dms.client.entity.DmsMessage
-
- setTimestamp(Long) - 类 中的方法com.huawei.dms.protocol.produce.DmsProduceRecord
-
- setTopic(String) - 类 中的方法com.huawei.dms.protocol.consume.entity.DmsMessageHandler
-
- setVersion(byte) - 类 中的方法com.huawei.dms.protocol.entity.OperHead
-
- SEVEN - 类 中的静态变量com.huawei.dms.Constant
-
SEVEN
- SEVEN - 类 中的静态变量com.huawei.dms.protocol.ProtocolConstant
-
SEVEN
- shutdown() - 类 中的方法com.huawei.dms.client.DmsSendThread
-
强制停止
- SIX - 类 中的静态变量com.huawei.dms.Constant
-
SIX
- SIX - 类 中的静态变量com.huawei.dms.protocol.ProtocolConstant
-
SIX
- start() - 类 中的方法com.huawei.dms.client.DmsAbstractClient
-
- start() - 接口 中的方法com.huawei.dms.client.DmsClient
-
启动方法
- start() - 类 中的方法com.huawei.dms.client.DmsSendThread
-
- start() - 接口 中的方法com.huawei.dms.client.transport.DmsNetClient
-
启动
- start() - 类 中的方法com.huawei.dms.client.transport.vertx.DmsVertxNetClient
-
- stop() - 类 中的方法com.huawei.dms.client.DmsAbstractClient
-
- stop() - 接口 中的方法com.huawei.dms.client.DmsClient
-
停止方法
- stop() - 接口 中的方法com.huawei.dms.client.transport.DmsNetClient
-
停止
- stop() - 类 中的方法com.huawei.dms.client.transport.vertx.DmsVertxNetClient
-
- stopGracefully() - 类 中的方法com.huawei.dms.client.DmsSendThread
-
优雅停止
- STRING_CLASS_NAME - 类 中的静态变量com.huawei.dms.Constant
-
STRING_CLASS_NAME
- STRING_CLASS_NAME - 类 中的静态变量com.huawei.dms.protocol.ProtocolConstant
-
STRING_CLASS_NAME
- SUCC - 类 中的静态变量com.huawei.dms.protocol.consume.entity.DmsCommitItem
-
success result
- success(T) - 接口 中的方法com.huawei.dms.client.DmsCallBack
-
调用成功执行方法
- success(T) - 类 中的方法com.huawei.dms.client.DmsRequestFuture
-
成功响应
- SUCCESS_RESULT - 类 中的静态变量com.huawei.dms.protocol.produce.DmsProduceResult
-
成功结果
- SUCCESS_RESULT_BUFFER - 类 中的静态变量com.huawei.dms.protocol.produce.DmsProduceResult
-
成功结果缓存
A B C D E F G H I L M N O P Q R S T U V W