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:
[email protected]


With regards,
Apache Git Services

Reply via email to