GitHub user StyleTang opened a pull request:
https://github.com/apache/incubator-rocketmq-externals/pull/22
Go-Client's implement
All features of milestone 1 has been completed
Detail Design:
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)
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/StyleTang/incubator-rocketmq-externals
go-client-all
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/incubator-rocketmq-externals/pull/22.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #22
----
commit c005ff3542596b75834e3fb2d45264033c151d51
Author: tangjie <[email protected]>
Date: 2017-05-09T15:44:40Z
rocketmq allocate_message
commit df20c3ed8783d1d6f39b99c90ef3dfd35ae4ba3f
Author: tangjie <[email protected]>
Date: 2017-05-09T15:45:24Z
add some utils like compress regex
commit 6f81f9c2077414cd5a43224444b6a16226d68eca
Author: tangjie <[email protected]>
Date: 2017-05-09T15:46:05Z
consumer clean expire msg
commit 19fe7cebd7faeef058128cfec94013c68ca4d859
Author: tangjie <[email protected]>
Date: 2017-05-10T15:21:10Z
add consumer and producer implement
commit b0b509f67c10e6b0479542540fc74da2cdd5af3c
Author: tangjie <[email protected]>
Date: 2017-05-10T15:22:06Z
add rocketmq manager implement
commit 5d8aef59c16db99f66990de007274c0f75ea6a87
Author: tangjie <[email protected]>
Date: 2017-05-11T15:30:42Z
add rocketmq example implement
commit 8d8ac87aa07de2103589c506358532283e9f9882
Author: tangjie <[email protected]>
Date: 2017-05-12T15:11:14Z
go rocketmq client's all Features
commit f72691db529263d319c9dfe2e4907d6a3fd93691
Author: tangjie <[email protected]>
Date: 2017-05-12T15:40:23Z
update roadmap
commit 237b6253fdec958b07234eb7ad93d174924f49a5
Author: tangjie <[email protected]>
Date: 2017-05-12T15:54:41Z
go fmt
code format
remove chinese comment
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
