All Classes and Interfaces
Class
Description
Outbound handler that adds an
Alt-Svc header to responses served
over the TCP (HTTP/1.1 and HTTP/2) paths when HTTP/3 is enabled.Represents a single channel from an AsyncAPI specification,
with its name, zero or more message payload examples, and
optional publish-time bindings (MQTT qos/retain, Kafka key).
Implementation of
AsyncApiControlPlane that lives in the mockserver-async
module and is registered into the core's AsyncApiControlPlaneRegistry
at server startup.Represents a single message definition within an AsyncAPI channel.
Orchestrates publishing of example messages derived from an AsyncAPI spec
to a message broker via a
MessagePublisher.Parses an AsyncAPI 2.x or 3.x document (JSON or YAML) into an
AsyncApiSpec.Validates JSON payloads against an AsyncAPI channel's JSON Schema definition,
reusing
JsonSchemaValidator from mockserver-core (which uses the
com.networknt:json-schema-validator library under the hood).Result of a schema validation.
A parsed AsyncAPI specification containing the channels and their message definitions.
A thread-safe, bounded FIFO store for
RecordedMessage instances.A composite
TransparentProxyHandler.OriginalDestinationResolver that tries
an ordered chain of resolution strategies and returns the first non-null result.Resolves the original destination of a transparently intercepted TCP connection
by reading the Linux conntrack table (
/proc/net/nf_conntrack).Resolves the original destination of a transparently intercepted TCP connection
by consulting the
DnsIntentRegistry — a record of hostname-to-IP answers
that MockServer's DNS server has handed out.Inspects the incoming Netty HttpRequest (headers only) and, when a matching expectation
is configured with
respondBeforeBody=true, dispatches the response and closes the
connection before HttpObjectAggregator buffers the request body.Response writer for the early-dispatch path.
Resolves the original destination of a transparently intercepted TCP connection
by reading a pinned BPF hash map populated by an external eBPF program.
Per-stream handler for serving gRPC Server Reflection interactively over the
bidirectional-streaming multiplex pipeline.
Per-stream router that inspects the first
Http2HeadersFrame to determine whether
this stream is a true bidirectional-streaming gRPC method.Per-stream handler for true bidirectional gRPC streaming.
Adapter that bridges gRPC request/response framing for the HTTP/3 path.
Holds the parts of a gRPC response for HTTP/3 framing:
the gRPC-framed body bytes, the grpc-status value, and
an optional grpc-message.
Per-stream child initializer used with
Http2MultiplexHandler
when the gRPC bidi-streaming multiplex pipeline is enabled.HTTP/3 CONNECT-UDP (MASQUE, RFC 9298) relay handler.
Drives true bidirectional gRPC streaming over a single QUIC bidirectional stream
(HTTP/3).
A
ResponseWriter that writes gRPC responses over HTTP/3 with correct
gRPC wire framing: initial HEADERS (:status=200,
content-type=application/grpc), DATA (gRPC length-prefixed message),
and trailing HEADERS (grpc-status, grpc-message).HTTP/3 request stream handler that bridges incoming QUIC requests into
MockServer's standard request-processing pipeline (expectation matching,
actions, recording, proxy forwarding).
Converts between HTTP/3 frames and MockServer's
HttpRequest/HttpResponse model.Parsed HTTP/3 pseudo-headers and regular headers.
A
ResponseWriter that serialises the MockServer HttpResponse
as HTTP/3 frames and writes them to a QUIC stream channel.HTTP/3 (QUIC) server for MockServer, integrated with the full request pipeline.
A
MessagePublisher that delegates to a Kafka KafkaProducer.A
MessageSubscriber that uses a Kafka KafkaConsumer to subscribe
to topics and record received messages.Immutable carrier for Kafka security configuration (SASL and/or SSL).
Utility for applying
KafkaSecurity settings to Kafka client
Properties.Deterministic conformance / contract tester for a target MCP (Model Context Protocol)
server reachable over Streamable HTTP.
Outcome of a single named conformance check.
Result of a single JSON-RPC exchange.
One JSON-RPC exchange against the target server.
Full conformance report.
Transport-neutral MCP (Model Context Protocol) JSON-RPC request processor.
Result of processing an MCP request.
Netty channel handler that intercepts MCP (Model Context Protocol) requests
on the TCP (HTTP/1.1 and HTTP/2) path.
Generates example JSON payloads for each channel in an
AsyncApiSpec.Publishes a message payload to a named channel (topic).
Subscribes to a message broker channel and records received messages for
later retrieval/verification — the consumer counterpart of
MessagePublisher.Wires the
IP_TRANSPARENT socket option on the server bootstrap when
TPROXY mode is enabled.A
MessagePublisher that delegates to an MQTT MqttClient.A
MessageSubscriber that uses an MQTT MqttClient to subscribe
to topics and record received messages.Immutable carrier for MQTT security configuration (username/password and/or SSL).
Utility for building
MqttConnectOptions from MqttSecurity
configuration.Serves the embedded OpenAPI specification at GET /mockserver/openapi.yaml
Inbound handler that detects and parses PROXY protocol v1 (text format) and v2 (binary
format) headers prepended to TCP connections by upstream load balancers (e.g., AWS GWLB,
HAProxy, nginx with
proxy_protocol on).Immutable carrier for per-message publish-time options extracted from AsyncAPI bindings.
An immutable record of a message received from a broker subscription.
This class is expected to be used from within a
ReplayingDecoder, or with enough bytes available.Reads the original destination of an intercepted TCP connection on Linux.
Resolves the original destination of a transparently intercepted TCP connection
by calling
getsockopt(fd, SOL_IP, SO_ORIGINAL_DST, ...) via JNA on Linux.Netty
ChannelDuplexHandler that injects raw TCP-layer faults
before HTTP decoding, based on the TcpChaosProfile
registered in TcpChaosRegistry for the connection's remote host.Resolves the original destination of a transparently intercepted TCP connection
using the TPROXY (IP_TRANSPARENT) mechanism.
Netty handler that extracts W3C
traceparent / tracestate
headers from inbound HttpRequest objects and stores the parsed
W3CTraceContext as a channel attribute.A Netty channel handler that resolves the original destination for transparently
intercepted connections and stores it as the
HttpActionHandler.REMOTE_SOCKET
channel attribute.Strategy interface for resolving the original destination.
Utility for transparent HTTP proxy mode — provides Host-header parsing helpers
and an
TransparentProxyInitializer.isEnabled() configuration check.