[ 
https://issues.apache.org/jira/browse/ROCKETMQ-198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16123327#comment-16123327
 ] 

ASF GitHub Bot commented on ROCKETMQ-198:
-----------------------------------------

Github user coveralls commented on the issue:

    https://github.com/apache/incubator-rocketmq/pull/103
  
    
    [![Coverage 
Status](https://coveralls.io/builds/12794894/badge)](https://coveralls.io/builds/12794894)
    
    Coverage increased (+7.8%) to 38.816% when pulling 
**dea7f85d6bcd55e941aa8831128e901e2db2f1e0 on StyleTang:master** into 
**fa85abcdf6ee46e56403ddf86828a38683103fd0 on apache:master**.



> 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.4.14#64029)

Reply via email to