Searched refs:messageProcessor (Results 1 – 1 of 1) sorted by relevance
732 public void processEnqueuedMessages(final Consumer<Message> messageProcessor) { in processEnqueuedMessages() argument734 messageProcessor.accept(enqueued); in processEnqueuedMessages()