Class MockServerEventLog


public class MockServerEventLog extends MockServerEventLogNotifier
Author:
jamesdbloom
  • Constructor Details

  • Method Details

    • add

      public void add(LogEntry logEntry)
    • size

      public int size()
    • getDroppedLogEventCount

      public long getDroppedLogEventCount()
      Number of log events dropped because the disruptor ring buffer was full. A non-zero, growing value indicates the event log cannot keep up with the incoming load — increase ringBufferSize or reduce log verbosity. Always available (independent of whether Prometheus metrics are enabled); also mirrored to the mock_server_dropped_log_events Prometheus counter when metrics are enabled.
    • setRecordedRequestConsumer

      public void setRecordedRequestConsumer(Consumer<LogEntry> recordedRequestConsumer)
      Register a hook invoked once per FORWARDED_REQUEST log entry, off the request-matching / forwarding hot path, so a recorded proxied exchange can be persisted to disk without coupling file I/O into this class. The hook receives the entry with FULL (un-truncated) bodies because processLogEntry(org.mockserver.log.model.LogEntry) invokes it BEFORE applying maxLoggedBodyBytes truncation.
    • stop

      public void stop()
    • reset

      public void reset()
    • clear

      public void clear(RequestDefinition requestDefinition)
    • retrieveMessageLogEntries

      public void retrieveMessageLogEntries(RequestDefinition requestDefinition, Consumer<List<LogEntry>> listConsumer)
    • retrieveMessageLogEntriesIncludingDeleted

      public void retrieveMessageLogEntriesIncludingDeleted(RequestDefinition requestDefinition, Consumer<List<LogEntry>> listConsumer)
    • retrieveRequestLogEntries

      public void retrieveRequestLogEntries(RequestDefinition requestDefinition, Consumer<List<LogEntry>> listConsumer)
    • retrieveRequests

      public void retrieveRequests(Verification verification, String logCorrelationId, Consumer<List<RequestDefinition>> listConsumer)
    • retrieveAllRequests

      public void retrieveAllRequests(boolean matchingExpectationsOnly, Consumer<List<RequestDefinition>> listConsumer)
    • retrieveAllRequests

      public void retrieveAllRequests(List<String> expectationIds, Consumer<List<RequestAndExpectationId>> listConsumer)
    • retrieveRequests

      public void retrieveRequests(RequestDefinition requestDefinition, Consumer<List<RequestDefinition>> listConsumer)
    • retrieveRequests

      public void retrieveRequests(ExpectationId expectationId, Consumer<List<RequestDefinition>> listConsumer)
    • retrieveRequests

      public void retrieveRequests(List<String> expectationIds, Consumer<List<RequestDefinition>> listConsumer)
    • retrieveRequestResponseMessageLogEntries

      public void retrieveRequestResponseMessageLogEntries(RequestDefinition requestDefinition, Consumer<List<LogEntry>> listConsumer)
    • retrieveRequestResponses

      public void retrieveRequestResponses(RequestDefinition requestDefinition, Consumer<List<LogEventRequestAndResponse>> listConsumer)
    • retrieveRecordedExpectationLogEntries

      public void retrieveRecordedExpectationLogEntries(RequestDefinition requestDefinition, Consumer<List<LogEntry>> listConsumer)
    • retrieveRecordedExpectations

      public void retrieveRecordedExpectations(RequestDefinition requestDefinition, Consumer<List<Expectation>> listConsumer)
    • retrieveLogEntriesByCorrelationId

      public void retrieveLogEntriesByCorrelationId(String correlationId, Consumer<List<LogEntry>> listConsumer)
    • retrieveAlmostMatchedEntries

      public void retrieveAlmostMatchedEntries(Consumer<List<LogEntry>> listConsumer)
    • retrieveUnmatchedRequests

      public void retrieveUnmatchedRequests(int limit, Consumer<List<LogEntry>> listConsumer)
      Retrieves the most recent NO_MATCH_RESPONSE log entries (requests that hit the server and matched no expectation). Results are ordered most-recent-first and limited.
      Parameters:
      limit - maximum number of entries to return (capped at 100)
      listConsumer - callback receiving the list of matching log entries
    • retrieveLogEntriesInReverseForUI

      public <T> void retrieveLogEntriesInReverseForUI(RequestDefinition requestDefinition, Predicate<LogEntry> logEntryPredicate, Function<LogEntry,T> logEntryMapper, Consumer<Stream<T>> consumer)
    • verify

      public Future<String> verify(Verification verification)
    • verify

      public void verify(Verification verification, Consumer<String> resultConsumer)
    • verify

      public Future<String> verify(VerificationSequence verification)
    • verify

      public void verify(VerificationSequence verificationSequence, Consumer<String> resultConsumer)
    • fieldsExcludedFromEqualsAndHashCode

      protected String[] fieldsExcludedFromEqualsAndHashCode()
      Overrides:
      fieldsExcludedFromEqualsAndHashCode in class ObjectWithReflectiveEqualsHashCodeToString