Google Git
Sign in
apache / pulsar-client-reactive / HEAD
  1. 3ecb59f Update to Pulsar 3.1.0 (#134) by Chris Bono · 4 weeks ago main
  2. 0610e6e fix: Rename relocation prefix of Caffeine producer cache provider (#128) by Chris Bono · 6 weeks ago
  3. 2c6990e build: Upgrade Pulsar version to 3.0.1 (#129) by Chris Bono · 6 weeks ago
  4. 7bee05d Update README.adoc (#125) by Christophe Bornet · 5 months ago
  5. 64ea60d Add shaded Caffeine producer cache provider (#124) by Chris Bono · 5 months ago
  6. 2bf832c Update Pulsar to 2.11.0 (#123) by Chris Bono · 6 months ago
  7. a36900c Update copyright years (#122) by Christophe Bornet · 7 months ago
  8. eddc06b Update README.adoc (#121) by Christophe Bornet · 8 months ago
  9. 8c676db Add getValue to MessageSpec (#120) by Christophe Bornet · 8 months ago v0.2.0 v0.2.0-candidate-2
  10. 20ced03 Bump version to 0.2.0 (#119) by Christophe Bornet · 8 months ago v0.2.0-candidate-1
  11. 6074182 Add tests to verify that Pulsar Exceptions are propagated as-is (#118) by Christophe Bornet · 8 months ago
  12. 839b8a6 Add stopOnError option to ReactiveMessageSenderBuilder (#116) by Christophe Bornet · 8 months ago
  13. 3070bf2 Add correlation metadata to the message sent (#115) by Christophe Bornet · 8 months ago
  14. dfd8247 Improve Gradle configuration in GitHub Actions (#113) by Lari Hotari · 9 months ago
  15. e19fe8a Post release 0.1.0 changes: update README, bump development version (#111) by Lari Hotari · 9 months ago
  16. 5cd3137 Update maven coordinates in README (#110) by Lari Hotari · 10 months ago
  17. d45c088 Add rat check to README and CONTRIBUTING (#109) by Christophe Bornet · 10 months ago v0.1.0 v0.1.0-candidate-2
  18. 099549b Fix flaky ReactiveMessagePipelineTest.handlingTimeout (#108) by Lari Hotari · 10 months ago
  19. 11d2b46 Update license headers to match ASF requirements (#107) by Lari Hotari · 10 months ago
  20. a818e59 Tune GitHub Actions VM to reduce flakiness (#103) by Lari Hotari · 10 months ago
  21. 0ab6836 Fix ASF release requirements (#101) by Lari Hotari · 10 months ago
  22. 94fe8a3 Pass -XX:TieredStopAtLevel=1 for tests to reduce flakiness (#102) by Lari Hotari · 10 months ago
  23. 052a219 Fix javadoc issues (#95) by Lari Hotari · 10 months ago v0.1.0-candidate-1
  24. f24ac25 Release 0.1.0 (#94) by Christophe Bornet · 10 months ago
  25. 3725e23 Test sender maxInflight with multiple values (#93) by Christophe Bornet · 10 months ago
  26. 0d574cc Reduce flakiness for shouldSpreadRequestsEvenlyAcrossUpstream (#92) by Lari Hotari · 10 months ago
  27. 3340083 Require cache when maxInflight is set for ReactiveMessageSenderBuilder (#91) by Lari Hotari · 10 months ago
  28. 0ea7d2f Fix issue with max inflight limit in sendMany (#89) by Lari Hotari · 10 months ago
  29. 6af9aca Fix bugs in InflightLimiter and add tests (#83) by Lari Hotari · 10 months ago
  30. 25d7600 Cleanup forgotten print statement (#88) by Christophe Bornet · 10 months ago
  31. 604174a Fix race in ReactiveMessagePipelineTest (#87) by Lari Hotari · 10 months ago
  32. 7970884 Add test-logger plugin and improve test logging config (#86) by Lari Hotari · 10 months ago
  33. 49ec5b3 Add tests for CaffeineProducerCacheProvider (#84) by Christophe Bornet · 10 months ago
  34. 2c95893 Add InflightLimiter parameters to producer cache key (#82) by Lari Hotari · 10 months ago
  35. 49083d9 Add tests for sender cache (#81) by Christophe Bornet · 10 months ago
  36. fd7e83d Upgrade Pulsar version to 2.10.2 (#78) by Lari Hotari · 10 months ago
  37. e2e06c0 Some cleanups (#79) by Christophe Bornet · 10 months ago
  38. f12c634 Add tests for AdaptedReactiveMessageReader (#73) by Christophe Bornet · 10 months ago
  39. 68f7ad9 Add tests for AdaptedReactiveMessageSender (#75) by Christophe Bornet · 10 months ago
  40. 6bc4cd6 Fix incorrect cast in DefaultReactiveMessagePipeline (#74) by Christophe Bornet · 10 months ago
  41. 73c0ac7 Add tests for AdaptedReactiveMessageConsumer (#71) by Christophe Bornet · 10 months ago
  42. 554ab61 Stop require author tag (#77) by tison · 10 months ago
  43. da4ec56 Add cbornet to developers (#76) by Christophe Bornet · 10 months ago
  44. a518e87 Fix InflightCounter used in ReactiveMessagePipelineTest (#69) by Lari Hotari · 10 months ago
  45. 78017c3 Add tests for the pipeline (#66) by Christophe Bornet · 10 months ago
  46. 52edc36 Add test for MessageSpec (#65) by Christophe Bornet · 10 months ago
  47. 5cc1165 Move InflightLimiterTest to pulsar-client-reactive-api module (#59) by Christophe Bornet · 10 months ago
  48. 0b07a50 Add test for StartAtSpec (#64) by Christophe Bornet · 10 months ago
  49. 18bb4bc Add test for MessageResult (#63) by Christophe Bornet · 10 months ago
  50. 48fb4c4 Add test for ReactiveMessageReaderBuilder (#62) by Christophe Bornet · 10 months ago
  51. 55a3155 Add test for ReactiveMessageSenderBuilder (#61) by Christophe Bornet · 10 months ago
  52. 8f005b8 Add test for ReactiveMessageConsumerBuilder (#60) by Christophe Bornet · 10 months ago
  53. 2891e25 Add javadoc to ApiImplementationFactory (#58) by Christophe Bornet · 10 months ago
  54. 88bd043 Fix various javadoc warnings (#57) by Christophe Bornet · 10 months ago
  55. 3005832 Add javadoc to PulsarReactiveClientModule (#56) by Christophe Bornet · 10 months ago
  56. 574d2e0 Add javadoc to InflightLimiter (#55) by Christophe Bornet · 10 months ago
  57. ddc5956 Add javadoc to MutableReactiveMessageReaderSpec (#54) by Christophe Bornet · 10 months ago
  58. 9ab5475 Add javadoc to MutableReactiveMessageSenderSpec (#53) by Christophe Bornet · 10 months ago
  59. bd608f1 Add javadoc to MutableReactiveMessageConsumerSpec (#52) by Christophe Bornet · 10 months ago
  60. 8c8cf9f Add javadoc to Producer cache related classes (#51) by Christophe Bornet · 10 months ago
  61. c3a29c0 Add javadoc to MessageGroupingFunction related classes (#49) by Christophe Bornet · 10 months ago
  62. d3fce7d Add javadoc to MessageResult related classes (#48) by Christophe Bornet · 10 months ago
  63. e1e498d Add javadoc to StartAtSpec related classes (#47) by Christophe Bornet · 10 months ago
  64. a632fd6 Add javadoc to message spec classes (#46) by Christophe Bornet · 10 months ago
  65. e6ff641 Add javadoc to MessageSpec related classes (#45) by Christophe Bornet · 10 months ago
  66. 1fdf7f0 Add references to ProducerBuilder in ReactiveMessageSenderBuilder's javadoc (#44) by Christophe Bornet · 10 months ago
  67. 0d92151 Add javadoc to ReactiveMessagePipelineBuilder (#43) by Christophe Bornet · 10 months ago
  68. 1d344db Rename ReactiveMessageConsumerBuilder::topicNames to ReactiveMessageConsumerBuilder::topics (#42) by Christophe Bornet · 10 months ago
  69. 2a3f8ec Add ReactiveMessageSenderBuilder::property (#41) by Christophe Bornet · 10 months ago
  70. 555e4b2 Replace OneByOneMessagePipelineBuilder#concurrency by OneByOneMessagePipelineBuilder#concurrency(int) (#39) by Christophe Bornet · 10 months ago
  71. 7edb245 Add clone method to consumer and sender builders (#34) by Christophe Bornet · 10 months ago
  72. 39726d5 Add javadoc to ReactiveMessagePipeline (#35) by Christophe Bornet · 10 months ago
  73. f635ed5 Move toImmutableSpec implementation to interfaces (#33) by Christophe Bornet · 10 months ago
  74. 5798c1f Add javadoc to ReactiveMessageSender (#30) by Christophe Bornet · 10 months ago
  75. ccfa309 Add javadoc to ReactiveMessageReaderBuilder (#31) by Christophe Bornet · 10 months ago
  76. fff7353 Add javadoc to ReactiveMessageReader (#29) by Christophe Bornet · 10 months ago
  77. 297e882 Add javadoc to ReactiveMessageConsumerBuilder (#27) by Christophe Bornet · 10 months ago
  78. 3ae5077 Add javadoc to ReactiveMessageReaderSpec (#36) by Christophe Bornet · 10 months ago
  79. 8d0d176 Add javadoc to ReactiveMessageSenderBuilder (#28) by Christophe Bornet · 10 months ago
  80. d96db94 Add javadoc to ReactiveMessageConsumer (#24) by Christophe Bornet · 10 months ago
  81. 9ef015b Add javadoc to ReactiveMessageConsumerSpec (#23) by Christophe Bornet · 10 months ago
  82. c27b478 Add javadoc to ReactiveMessageSenderSpec (#25) by Christophe Bornet · 10 months ago
  83. c041b47 Add methods on MessageResult to ack/nack by Message<> (#21) by Christophe Bornet · 10 months ago
  84. 17b7252 Add missing annotations in MutableReactiveMessageSenderSpec (#20) by Christophe Bornet · 10 months ago
  85. 271545e Move ReactivePulsarClient::messagePipeline to ReactiveMessageConsumer (#17) by Christophe Bornet · 11 months ago
  86. 569d3d2 Add ReactiveMessageConsumerSpec::getSubscriptionInitialPosition (#19) by Christophe Bornet · 11 months ago
  87. 5ef02b0 Simplify consumeOne API (#18) by Christophe Bornet · 11 months ago
  88. df52dfa Rename methods in README (#16) by Lari Hotari · 11 months ago
  89. 3831ea6 Rename methods to use naming convention of [action]One and [action]Many (#14) by Lari Hotari · 11 months ago
  90. 8e09480 Configure SingletonPulsarContainer with acknowledgmentAtBatchIndexLevelEnabled=true (#13) by Lari Hotari · 11 months ago
  91. 855ce09 Accept Reactive Streams Publisher as input (#12) by Christophe Bornet · 11 months ago
  92. ae66435 Add module for Jackson (#9) by Christophe Bornet · 12 months ago
  93. 99c5648 Require PRs for development by Lari Hotari · 1 year ago
  94. ac37570 Fix artifact id in examples by Lari Hotari · 1 year ago
  95. 3d5ffa3 Use org.apache.pulsar as maven artifact group by Lari Hotari · 1 year ago
  96. 0d4b344 Add concurrency control for GitHub Actions workflow by Lari Hotari · 1 year ago
  97. 592faca Fix snapshot repository url by Lari Hotari · 1 year ago
  98. e70f70a Set branch to main in GitHub Actions ci workflow by Lari Hotari · 1 year ago
  99. 6067b9e Initial commit by Lari Hotari · 1 year ago