package rocketmq

const (
	// Broker 发送消息
	SEND_MESSAGE = 10
	// Broker 订阅消息
	PULL_MESSAGE = 11
	// Broker 查询消息
	QUERY_MESSAGE = 12
	// Broker 查询Broker Offset
	QUERY_BROKER_OFFSET = 13
	// Broker 查询Consumer Offset
	QUERY_CONSUMER_OFFSET = 14
	// Broker 更新Consumer Offset
	UPDATE_CONSUMER_OFFSET = 15
	// Broker 更新或者增加一个Topic
	UPDATE_AND_CREATE_TOPIC = 17
	// Broker 获取所有Topic的配置（Slave和Namesrv都会向Master请求此配置）
	GET_ALL_TOPIC_CONFIG = 21
	// Broker 获取所有Topic配置（Slave和Namesrv都会向Master请求此配置）
	GET_TOPIC_CONFIG_LIST = 22
	// Broker 获取所有Topic名称列表
	GET_TOPIC_NAME_LIST = 23
	// Broker 更新Broker上的配置
	UPDATE_BROKER_CONFIG = 25
	// Broker 获取Broker上的配置
	GET_BROKER_CONFIG = 26
	// Broker 触发Broker删除文件
	TRIGGER_DELETE_FILES = 27
	// Broker 获取Broker运行时信息
	GET_BROKER_RUNTIME_INFO = 28
	// Broker 根据时间查询队列的Offset
	SEARCH_OFFSET_BY_TIMESTAMP = 29
	// Broker 查询队列最大Offset
	GET_MAX_OFFSET = 30
	// Broker 查询队列最小Offset
	GET_MIN_OFFSET = 31
	// Broker 查询队列最早消息对应时间
	GET_EARLIEST_MSG_STORETIME = 32
	// Broker 根据消息ID来查询消息
	VIEW_MESSAGE_BY_ID = 33
	// Broker Client向Client发送心跳，并注册自身
	HEART_BEAT = 34
	// Broker Client注销
	UNREGISTER_CLIENT = 35
	// Broker Consumer将处理不了的消息发回服务器
	CONSUMER_SEND_MSG_BACK = 36
	// Broker Commit或者Rollback事务
	END_TRANSACTION = 37
	// Broker 获取ConsumerId列表通过GroupName
	GET_CONSUMER_LIST_BY_GROUP = 38
	// Broker 主动向Producer回查事务状态
	CHECK_TRANSACTION_STATE = 39
	// Broker Broker通知Consumer列表变化
	NOTIFY_CONSUMER_IDS_CHANGED = 40
	// Broker Consumer向Master锁定队列
	LOCK_BATCH_MQ = 41
	// Broker Consumer向Master解锁队列
	UNLOCK_BATCH_MQ = 42
	// Broker 获取所有Consumer Offset
	GET_ALL_CONSUMER_OFFSET = 43
	// Broker 获取所有定时进度
	GET_ALL_DELAY_OFFSET = 45
	// Namesrv 向Namesrv追加KV配置
	PUT_KV_CONFIG = 100
	// Namesrv 从Namesrv获取KV配置
	GET_KV_CONFIG = 101
	// Namesrv 从Namesrv获取KV配置
	DELETE_KV_CONFIG = 102
	// Namesrv 注册一个Broker，数据都是持久化的，如果存在则覆盖配置
	REGISTER_BROKER = 103
	// Namesrv 卸载一个Broker，数据都是持久化的
	UNREGISTER_BROKER = 104
	// Namesrv 根据Topic获取Broker Name、队列数(包含读队列与写队列)
	GET_ROUTEINTO_BY_TOPIC = 105
	// Namesrv 获取注册到Name Server的所有Broker集群信息
	GET_BROKER_CLUSTER_INFO             = 106
	UPDATE_AND_CREATE_SUBSCRIPTIONGROUP = 200
	GET_ALL_SUBSCRIPTIONGROUP_CONFIG    = 201
	GET_TOPIC_STATS_INFO                = 202
	GET_CONSUMER_CONNECTION_LIST        = 203
	GET_PRODUCER_CONNECTION_LIST        = 204
	WIPE_WRITE_PERM_OF_BROKER           = 205

	// 从Name Server获取完整Topic列表
	GET_ALL_TOPIC_LIST_FROM_NAMESERVER = 206
	// 从Broker删除订阅组
	DELETE_SUBSCRIPTIONGROUP = 207
	// 从Broker获取消费状态（进度）
	GET_CONSUME_STATS = 208
	// Suspend Consumer消费过程
	SUSPEND_CONSUMER = 209
	// Resume Consumer消费过程
	RESUME_CONSUMER = 210
	// 重置Consumer Offset
	RESET_CONSUMER_OFFSET_IN_CONSUMER = 211
	// 重置Consumer Offset
	RESET_CONSUMER_OFFSET_IN_BROKER = 212
	// 调整Consumer线程池数量
	ADJUST_CONSUMER_THREAD_POOL = 213
	// 查询消息被哪些消费组消费
	WHO_CONSUME_THE_MESSAGE = 214

	// 从Broker删除Topic配置
	DELETE_TOPIC_IN_BROKER = 215
	// 从Namesrv删除Topic配置
	DELETE_TOPIC_IN_NAMESRV = 216
	// Namesrv 通过 project 获取所有的 server ip 信息
	GET_KV_CONFIG_BY_VALUE = 217
	// Namesrv 删除指定 project group 下的所有 server ip 信息
	DELETE_KV_CONFIG_BY_VALUE = 218
	// 通过NameSpace获取所有的KV List
	GET_KVLIST_BY_NAMESPACE = 219

	// offset 重置
	RESET_CONSUMER_CLIENT_OFFSET = 220
	// 客户端订阅消息
	GET_CONSUMER_STATUS_FROM_CLIENT = 221
	// 通知 broker 调用 offset 重置处理
	INVOKE_BROKER_TO_RESET_OFFSET = 222
	// 通知 broker 调用客户端订阅消息处理
	INVOKE_BROKER_TO_GET_CONSUMER_STATUS = 223

	// Broker 查询topic被谁消费
	// 2014-03-21 Add By shijia
	QUERY_TOPIC_CONSUME_BY_WHO = 300

	// 获取指定集群下的所有 topic
	// 2014-03-26
	GET_TOPICS_BY_CLUSTER = 224

	// 向Broker注册Filter Server
	// 2014-04-06 Add By shijia
	REGISTER_FILTER_SERVER = 301
	// 向Filter Server注册Class
	// 2014-04-06 Add By shijia
	REGISTER_MESSAGE_FILTER_CLASS = 302
	// 根据 topic 和 group 获取消息的时间跨度
	QUERY_CONSUME_TIME_SPAN = 303
	// 获取所有系统内置 Topic 列表
	GET_SYSTEM_TOPIC_LIST_FROM_NS     = 304
	GET_SYSTEM_TOPIC_LIST_FROM_BROKER = 305

	// 清理失效队列
	CLEAN_EXPIRED_CONSUMEQUEUE = 306

	// 通过Broker查询Consumer内存数据
	// 2014-07-19 Add By shijia
	GET_CONSUMER_RUNNING_INFO = 307

	// 查找被修正 offset (转发组件）
	QUERY_CORRECTION_OFFSET = 308

	// 通过Broker直接向某个Consumer发送一条消息，并立刻消费，返回结果给broker，再返回给调用方
	// 2014-08-11 Add By shijia
	CONSUME_MESSAGE_DIRECTLY = 309

	// Broker 发送消息，优化网络数据包
	SEND_MESSAGE_V2 = 310

	// 单元化相关 topic
	GET_UNIT_TOPIC_LIST = 311
	// 获取含有单元化订阅组的 Topic 列表
	GET_HAS_UNIT_SUB_TOPIC_LIST = 312
	// 获取含有单元化订阅组的非单元化 Topic 列表
	GET_HAS_UNIT_SUB_UNUNIT_TOPIC_LIST = 313
	// 克隆某一个组的消费进度到新的组
	CLONE_GROUP_OFFSET = 314

	// 查看Broker上的各种统计信息
	VIEW_BROKER_STATS_DATA = 315
)