We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent d6c7038 commit 4cf6f2fCopy full SHA for 4cf6f2f
src/main/java/com/rabbitmq/stream/MessageHandler.java
@@ -100,6 +100,10 @@ interface Context {
100
* ConsumerFlowStrategy#creditWhenHalfMessagesProcessed(int)}, and {@link
101
* ConsumerFlowStrategy#creditOnProcessedMessageCount(int, double)}, otherwise the broker may
102
* stop sending messages to the consumer.
103
+ *
104
+ * <p>Applications should make sure to call <code>processed()</code> only once on each context,
105
+ * as this method does not have to be idempotent. What several calls on the same context does
106
+ * depends on the underlying {@link ConsumerFlowStrategy} implementation.
107
*/
108
void processed();
109
}
0 commit comments