[
https://issues.apache.org/jira/browse/ROCKETMQ-198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jie.Tang updated ROCKETMQ-198:
------------------------------
Description:
Go-Client's implement:
https://github.com/apache/incubator-rocketmq-externals/pull/22
Go-Client's design:
https://issues.apache.org/jira/browse/ROCKETMQ-177
https://github.com/apache/incubator-rocketmq-externals/pull/19
RoadMap-Milestone1
Consumer
- [x] ConsumerType
- [x] PushConsumer
- [x] MessageListener
- [x] Concurrently
- [x] MessageModel
- [x] CLUSTERING
- [x] OffsetStore
- [x] RemoteBrokerOffsetStore
- [x] RebalanceService
- [x] PullMessageService
- [x] ConsumeMessageService
- [x] AllocateMessageQueueStrategy
- [x] AllocateMessageQueueAveragely
- [x] Other
- [x] Config
- [x] ZIP
- [x] ConsumeFromWhere
- [x] CONSUME_FROM_LAST_OFFSET
- [x] CONSUME_FROM_FIRST_OFFSET
- [x] CONSUME_FROM_TIMESTAMP
- [x] Retry(sendMessageBack)
- [x] TimeOut(clearExpiredMessage)
- [x] ACK(partSuccess)
- [x] FlowControl(messageCanNotConsume)
Producer
- [x] ProducerType
- [x] DefaultProducer
- [x] API
- [x] Send
- [x] Sync
- [x] Other
- [x] DelayMessage
- [x] Config
- [x] MessageId Generate
- [x] CompressMsg
- [x] TimeOut
- [x] LoadBalance
- [x] DefaultTopic
- [x] VipChannel
- [x] MQFaultStrategy
Manager
- [x] Controller
- [x] PullMessageController
- [x] Task
- [x] UpdateTopicRouteInfo
- [x] Heartbeat
- [x] Rebalance
- [x] PullMessage
- [x] CleanExpireMsg
- [x] ClientRemotingProcessor
- [x] CHECK_TRANSACTION_STATE
- [x] NOTIFY_CONSUMER_IDS_CHANGED
- [x] RESET_CONSUMER_CLIENT_OFFSET
- [x] GET_CONSUMER_STATUS_FROM_CLIENT
- [x] GET_CONSUMER_RUNNING_INFO
- [x] CONSUME_MESSAGE_DIRECTLY
Remoting
- [x] MqClientRequest
- [x] InvokeSync
- [x] InvokeAsync
- [x] InvokeOneWay
- [x] Serialize
- [x] JSON
- [x] ROCKETMQ
- [x] NamesrvAddrChoosed(HA)
was:
Go-Client's implement:
https://github.com/apache/incubator-rocketmq-externals/pull/22
Go-Client's design:
https://issues.apache.org/jira/browse/ROCKETMQ-177
https://github.com/apache/incubator-rocketmq-externals/pull/19
# RoadMap-Milestone1
## Consumer
- [x] ConsumerType
- [x] PushConsumer
- [x] MessageListener
- [x] Concurrently
- [x] MessageModel
- [x] CLUSTERING
- [x] OffsetStore
- [x] RemoteBrokerOffsetStore
- [x] RebalanceService
- [x] PullMessageService
- [x] ConsumeMessageService
- [x] AllocateMessageQueueStrategy
- [x] AllocateMessageQueueAveragely
- [x] Other
- [x] Config
- [x] ZIP
- [x] ConsumeFromWhere
- [x] CONSUME_FROM_LAST_OFFSET
- [x] CONSUME_FROM_FIRST_OFFSET
- [x] CONSUME_FROM_TIMESTAMP
- [x] Retry(sendMessageBack)
- [x] TimeOut(clearExpiredMessage)
- [x] ACK(partSuccess)
- [x] FlowControl(messageCanNotConsume)
## Producer
- [x] ProducerType
- [x] DefaultProducer
- [x] API
- [x] Send
- [x] Sync
- [x] Other
- [x] DelayMessage
- [x] Config
- [x] MessageId Generate
- [x] CompressMsg
- [x] TimeOut
- [x] LoadBalance
- [x] DefaultTopic
- [x] VipChannel
- [x] MQFaultStrategy
## Manager
- [x] Controller
- [x] PullMessageController
- [x] Task
- [x] UpdateTopicRouteInfo
- [x] Heartbeat
- [x] Rebalance
- [x] PullMessage
- [x] CleanExpireMsg
- [x] ClientRemotingProcessor
- [x] CHECK_TRANSACTION_STATE
- [x] NOTIFY_CONSUMER_IDS_CHANGED
- [x] RESET_CONSUMER_CLIENT_OFFSET
- [x] GET_CONSUMER_STATUS_FROM_CLIENT
- [x] GET_CONSUMER_RUNNING_INFO
- [x] CONSUME_MESSAGE_DIRECTLY
## Remoting
- [x] MqClientRequest
- [x] InvokeSync
- [x] InvokeAsync
- [x] InvokeOneWay
- [x] Serialize
- [x] JSON
- [x] ROCKETMQ
- [x] NamesrvAddrChoosed(HA)
> RocketMQ-Go-Client-Implement
> ----------------------------
>
> Key: ROCKETMQ-198
> URL: https://issues.apache.org/jira/browse/ROCKETMQ-198
> Project: Apache RocketMQ
> Issue Type: New Feature
> Reporter: Jie.Tang
> Assignee: Jie.Tang
> Priority: Critical
>
> Go-Client's implement:
> https://github.com/apache/incubator-rocketmq-externals/pull/22
> Go-Client's design:
> https://issues.apache.org/jira/browse/ROCKETMQ-177
> https://github.com/apache/incubator-rocketmq-externals/pull/19
> RoadMap-Milestone1
> Consumer
> - [x] ConsumerType
> - [x] PushConsumer
> - [x] MessageListener
> - [x] Concurrently
> - [x] MessageModel
> - [x] CLUSTERING
> - [x] OffsetStore
> - [x] RemoteBrokerOffsetStore
> - [x] RebalanceService
> - [x] PullMessageService
> - [x] ConsumeMessageService
> - [x] AllocateMessageQueueStrategy
> - [x] AllocateMessageQueueAveragely
> - [x] Other
> - [x] Config
> - [x] ZIP
> - [x] ConsumeFromWhere
> - [x] CONSUME_FROM_LAST_OFFSET
> - [x] CONSUME_FROM_FIRST_OFFSET
> - [x] CONSUME_FROM_TIMESTAMP
> - [x] Retry(sendMessageBack)
> - [x] TimeOut(clearExpiredMessage)
> - [x] ACK(partSuccess)
> - [x] FlowControl(messageCanNotConsume)
>
> Producer
> - [x] ProducerType
> - [x] DefaultProducer
> - [x] API
> - [x] Send
> - [x] Sync
> - [x] Other
> - [x] DelayMessage
> - [x] Config
> - [x] MessageId Generate
> - [x] CompressMsg
> - [x] TimeOut
> - [x] LoadBalance
> - [x] DefaultTopic
> - [x] VipChannel
> - [x] MQFaultStrategy
> Manager
> - [x] Controller
> - [x] PullMessageController
> - [x] Task
> - [x] UpdateTopicRouteInfo
> - [x] Heartbeat
> - [x] Rebalance
> - [x] PullMessage
> - [x] CleanExpireMsg
> - [x] ClientRemotingProcessor
> - [x] CHECK_TRANSACTION_STATE
> - [x] NOTIFY_CONSUMER_IDS_CHANGED
> - [x] RESET_CONSUMER_CLIENT_OFFSET
> - [x] GET_CONSUMER_STATUS_FROM_CLIENT
> - [x] GET_CONSUMER_RUNNING_INFO
> - [x] CONSUME_MESSAGE_DIRECTLY
> Remoting
> - [x] MqClientRequest
> - [x] InvokeSync
> - [x] InvokeAsync
> - [x] InvokeOneWay
> - [x] Serialize
> - [x] JSON
> - [x] ROCKETMQ
> - [x] NamesrvAddrChoosed(HA)
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
