[ https://issues.apache.org/jira/browse/ROCKETMQ-198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16011878#comment-16011878 ]
ASF subversion and git services commented on ROCKETMQ-198: ---------------------------------------------------------- Commit 1630f277b9c9f8e85c9bdb09a323d39e13e797e4 in incubator-rocketmq's branch refs/heads/develop from Li Zhanhui [ https://git-wip-us.apache.org/repos/asf?p=incubator-rocketmq.git;h=1630f27 ] This is to close issue ROCKETMQ-198: Add language code for Go and PHP Thanks to StyleTang > 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)