rocketmq_proxy

RocketMQ gRPC Proxy Supporting different languages client SDK

Roadmap

• batch
• batch
  • SimpleBatchProducer.java
  • SplitBatchProducer.java
• benchmark
  • Consumer.java
  • Producer.java
  • TransactionProducer.java
• broadcast
  • PushConsumer.java
• filter
  • SqlFilterConsumer.java
  • SqlFilterProducer.java
  • TagFilterConsumer.java
  • TagFilterProducer.java
• namespace
  • ProducerWithNamespace.java
  • PullConsumerWithNamespace.java
  • PushConsumerWithNamespace.java
• openmessaging
  • SimpleProducer.java
  • SimplePullConsumer.java
  • SimplePushConsumer.java
• operation
  • Consumer.java
  • Producer.java
• ordermessage
  • Consumer.java
  • Producer.java
• quickstart
  • Consumer.java
  • Producer.java
• rpc
  • AsyncRequestProducer.java
  • RequestProducer.java
  • ResponseConsumer.java
• simple
  • AclClient.java
  • AsyncProducer.java
  • CachedQueue.java
  • LitePullConsumerAssign.java
  • LitePullConsumerSubscribe.java
  • Producer.java
  • PullConsumer.java
  • PullConsumerTest.java
  • PullScheduleService.java
  • PushConsumer.java
  • RandomAsyncCommit.java
  • TestProducer.java
• tracemessage
  • TraceProducer.java
  • TracePushConsumer.java
• transaction
  • TransactionListenerImpl.java
  • TransactionProducer.java