Package org.mockserver.log

Class MockServerEventLog

java.lang.Object
org.mockserver.model.ObjectWithReflectiveEqualsHashCodeToString
org.mockserver.mock.listeners.MockServerEventLogNotifier
org.mockserver.log.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 recorded exchange (FORWARDED_REQUEST or EXPECTATION_RESPONSE) log entry, off the request-matching / forwarding hot path, so a recorded proxied or mocked 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.

    • importRecordedRequestResponse

      public void importRecordedRequestResponse(HttpRequest httpRequest, HttpResponse httpResponse)
      Re-inject a recorded request/response pair loaded from a persisted NDJSON archive back into the live event log so it is retrievable exactly like an in-memory recording (via retrieveRecordedRequests / retrieveRequestResponses and the derived export formats). The entry is logged as a FORWARDED_REQUEST and marked LogEntry.setSkipRecordedRequestPersistence(boolean) so re-loading an archive is idempotent and never appends the same exchanges back to the (possibly same) file.

    • 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 void verify(Verification verification, int additionalRemoteMatchCount, Consumer<String> resultConsumer)
      Evaluate a request-count verification, adding additionalRemoteMatchCount to this node's local match count before comparing against the VerificationTimes.

      Used by the T1.9 cluster verify fan-in: HttpState sums the match count reported by every cluster peer's LOCAL log and passes the total remote count here, so a count-based verification behind a load balancer is evaluated against the fleet-wide total rather than only the traffic that reached this node. additionalRemoteMatchCount is 0 on the ordinary single-node / non-fan-in path (identical behaviour to before). Only applies to request verification; response-aware verification always receives 0.

    • 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