You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@rocketmq.apache.org by GitBox <gi...@apache.org> on 2018/12/22 03:45:24 UTC

[GitHub] RongtongJin opened a new pull request #621: [ISSUE #608] Polish simple example

RongtongJin opened a new pull request #621: [ISSUE #608] Polish simple example
URL: https://github.com/apache/rocketmq/pull/621
 
 
   ## What is the purpose of the change
   
   Fix [issue608](https://github.com/apache/rocketmq/issues/608)
   Polish simple example
   
   ## Brief changelog
   
   - simple
      - AsyncProducer.java (add code comments)
      - OnewayProducer.java (new class, show users how to send meassges in oneway)
      - PullConsumer.java 
      - PullScheduleService.java (no change)
      - PushConsumer.java (Setting ConsumeTimestamp is invalid when you set ConsumeFromWhere to CONSUME_FROM_FIRST_OFFSET, so I delete releated code)
      - QueryMsgByKey.java (renamed from TestProducer.java, a clearer class name)
      - SyncProducer.java (renamed from Producer.java)
      - ~~RandomAsyncCommit.java~~(remove this class. It doesn't show the users how to send or receive messages, and it also doesn't involve client code of RocketMQ)
      - ~~CachedQueue,java~~ (remove this class used in RandomAsyncCommit.java)
      - ~~PullConsumerTest.java~~ (remove this class. The code is similar to PullConsumer.java)
   - transaction (no change)
   
   

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


With regards,
Apache Git Services