Index

A B C D E F G H I J K L M N O P Q R S T U V W 
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

A

accumulateBody(CompositeByteBuf, Http3DataFrame) - Static method in class org.mockserver.netty.http3.Http3RequestBridge
Accumulate body data from an HTTP/3 data frame into a composite buffer.
add(RecordedMessage) - Method in class org.mockserver.async.subscribe.BoundedMessageStore
Add a message to the store.
addConnectionHeader(HttpRequest, HttpResponse) - Method in class org.mockserver.netty.responsewriter.EarlyNettyResponseWriter
The connection always closes after an early response, so unless the response sets the Connection header explicitly it says so, whatever the request asked for.
afterCodec() - Method in class org.mockserver.netty.unification.HttpServerCodecResponsePairing
The handler to add immediately after the HTTP server codec.
AltSvcHeaderHandler - Class in org.mockserver.netty.unification
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.
AltSvcHeaderHandler(int, long) - Constructor for class org.mockserver.netty.unification.AltSvcHeaderHandler
 
AmqpBinding - Class in org.mockserver.async.asyncapi
Immutable model of the AsyncAPI AMQP 0.9.1 channel binding (channels.<name>.bindings.amqp), carrying the publish-time routing information that AmqpMessagePublisher needs to deliver a message to a RabbitMQ broker.
AmqpBinding(AmqpBinding.ChannelType, String, String, boolean, String, boolean, String) - Constructor for class org.mockserver.async.asyncapi.AmqpBinding
 
AmqpBinding.ChannelType - Enum Class in org.mockserver.async.asyncapi
The two shapes an AMQP channel can take, per the AsyncAPI is field.
AmqpMessagePublisher - Class in org.mockserver.async.publish
A MessagePublisher that delivers messages to an AMQP 0.9.1 broker (RabbitMQ) using the official com.rabbitmq:amqp-client library.
AmqpMessagePublisher(String, int, String, String, String, AsyncApiSpec) - Constructor for class org.mockserver.async.publish.AmqpMessagePublisher
Connect to an AMQP broker from explicit connection parameters and resolve per-channel destinations from the given spec.
AmqpMessagePublisher(String, AsyncApiSpec) - Constructor for class org.mockserver.async.publish.AmqpMessagePublisher
Connect to an AMQP broker from a connection URI (e.g.
AmqpMessageSubscriber - Class in org.mockserver.async.subscribe
A MessageSubscriber that consumes from an AMQP 0.9.1 broker (RabbitMQ) using the official com.rabbitmq:amqp-client library, the consumer-side counterpart of AmqpMessagePublisher.
AmqpMessageSubscriber(String, AsyncApiSpec, int) - Constructor for class org.mockserver.async.subscribe.AmqpMessageSubscriber
Connect to an AMQP broker from a connection URI and resolve per-channel consume sources from the given spec.
answeredLocally(Channel, String) - Static method in class org.mockserver.netty.proxy.relay.BinaryRelay
Called once MockServer has written its own reply to a message read from the client, which is not relayed and is not reported to the listener.
applyIfEnabled(ServerBootstrap, Configuration) - Static method in class org.mockserver.netty.proxy.MockServerIpTransparentHelper
Applies the IP_TRANSPARENT channel option to the server bootstrap if TPROXY mode is enabled in configuration and the epoll transport is available.
applySecurity(Properties, KafkaSecurity) - Static method in class org.mockserver.async.security.KafkaSecurityProperties
Apply security settings to the given Kafka client properties.
argumentLoadableFromEntry(int) - Method in class org.mockserver.dashboard.model.DashboardLogEntryDTO
Whether the argument at index is this entry's own request or response, so its full body can be loaded from the entry; a request or response argument that is a different object cannot.
AsyncApiChannel - Class in org.mockserver.async.asyncapi
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).
AsyncApiChannel(String, List<JsonNode>, JsonNode) - Constructor for class org.mockserver.async.asyncapi.AsyncApiChannel
Backward-compatible constructor — no bindings.
AsyncApiChannel(String, List<JsonNode>, JsonNode, Integer, Boolean, String) - Constructor for class org.mockserver.async.asyncapi.AsyncApiChannel
Full constructor with optional binding fields.
AsyncApiChannel(String, List<JsonNode>, JsonNode, Integer, Boolean, String, List<AsyncApiMessage>) - Constructor for class org.mockserver.async.asyncapi.AsyncApiChannel
Full constructor with optional binding fields and explicit multi-message list.
AsyncApiChannel(String, List<JsonNode>, JsonNode, Integer, Boolean, String, List<AsyncApiMessage>, String) - Constructor for class org.mockserver.async.asyncapi.AsyncApiChannel
Full constructor with optional binding fields, explicit multi-message list, and correlation ID location for single-message channels.
AsyncApiChannel(String, List<JsonNode>, JsonNode, Integer, Boolean, String, List<AsyncApiMessage>, String, AmqpBinding) - Constructor for class org.mockserver.async.asyncapi.AsyncApiChannel
Full constructor with optional binding fields, explicit multi-message list, correlation ID location, and AMQP channel binding.
AsyncApiControlPlaneImpl - Class in org.mockserver.async.controlplane
Implementation of AsyncApiControlPlane that lives in the mockserver-async module and is registered into the core's AsyncApiControlPlaneRegistry at server startup.
AsyncApiControlPlaneImpl() - Constructor for class org.mockserver.async.controlplane.AsyncApiControlPlaneImpl
Create a control-plane with no Configuration instance, falling back entirely to the static ConfigurationProperties store for async broker defaults.
AsyncApiControlPlaneImpl(Configuration) - Constructor for class org.mockserver.async.controlplane.AsyncApiControlPlaneImpl
Create a control-plane bound to the server's Configuration instance so that instance-set async broker defaults are honoured.
AsyncApiHttpExpectationGenerator - Class in org.mockserver.async.controlplane
Generates HTTP mock Expectations from a parsed AsyncAPI spec so that the example messages each channel describes can be served over plain HTTP — without standing up a live Kafka / MQTT / AMQP broker.
AsyncApiHttpExpectationGenerator() - Constructor for class org.mockserver.async.controlplane.AsyncApiHttpExpectationGenerator
 
AsyncApiMessage - Class in org.mockserver.async.asyncapi
Represents a single message definition within an AsyncAPI channel.
AsyncApiMessage(String, JsonNode, List<JsonNode>, String) - Constructor for class org.mockserver.async.asyncapi.AsyncApiMessage
Backward-compatible constructor — no correlation ID.
AsyncApiMessage(String, JsonNode, List<JsonNode>, String, String) - Constructor for class org.mockserver.async.asyncapi.AsyncApiMessage
Full constructor with correlation ID location.
AsyncApiMockOrchestrator - Class in org.mockserver.async
Orchestrates publishing of example messages derived from an AsyncAPI spec to a message broker via a MessagePublisher.
AsyncApiMockOrchestrator(AsyncApiSpec, MessagePublisher) - Constructor for class org.mockserver.async.AsyncApiMockOrchestrator
 
AsyncApiMockOrchestrator(AsyncApiSpec, MessagePublisher, MessageExampleGenerator) - Constructor for class org.mockserver.async.AsyncApiMockOrchestrator
Constructor for use with a custom generator (used by the control-plane implementation and tests).
AsyncApiParser - Class in org.mockserver.async.asyncapi
Parses an AsyncAPI 2.x or 3.x document (JSON or YAML) into an AsyncApiSpec.
AsyncApiParser() - Constructor for class org.mockserver.async.asyncapi.AsyncApiParser
 
AsyncApiSchemaValidator - Class in org.mockserver.async.validation
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).
AsyncApiSchemaValidator() - Constructor for class org.mockserver.async.validation.AsyncApiSchemaValidator
 
AsyncApiSchemaValidator(MockServerLogger) - Constructor for class org.mockserver.async.validation.AsyncApiSchemaValidator
Constructor accepting an external logger instance, consistent with the codebase pattern of injecting or per-instance loggers.
AsyncApiSchemaValidator.ValidationResult - Class in org.mockserver.async.validation
Result of a schema validation.
AsyncApiSpec - Class in org.mockserver.async.asyncapi
A parsed AsyncAPI specification containing the channels and their message definitions.
AsyncApiSpec(String, String, List<AsyncApiChannel>) - Constructor for class org.mockserver.async.asyncapi.AsyncApiSpec
 
atMessageBoundary() - Method in class org.mockserver.netty.proxy.BinaryMessageFramer
True when no part of a message is held: what is read next starts a message.
authority() - Method in class org.mockserver.netty.http3.Http3RequestBridge.ParsedHeaders
 
AvroPayloadCodec - Class in org.mockserver.async.serde
Converts message payloads between JSON text and Avro binary using Apache Avro's GenericDatum reader/writer — no code generation and no Confluent serde stack required.
avroToJson(Schema, byte[]) - Static method in class org.mockserver.async.serde.AvroPayloadCodec
Decode Avro binary back into JSON text for the given schema.

B

beforeCodec() - Method in class org.mockserver.netty.unification.HttpServerCodecResponsePairing
The handler to add immediately before the HTTP server codec.
beneathCodec(ChannelPipeline) - Static method in class org.mockserver.netty.unification.HttpServerCodecResponsePairing
Where to add a handler that must see what is written from beneath the codec, raw bytes and encoded responses alike, but not the stand-in responses: before this pairing's handler before the codec, or the codec if it has none.
BINARY_READ_SIZE - Static variable in class org.mockserver.netty.unification.BinaryAwareRecvByteBufAllocator
The largest buffer Netty's adaptive allocator grows to, so no read is larger than one it could already be.
BinaryAwareRecvByteBufAllocator - Class in org.mockserver.netty.unification
Sizes the buffer each read of an accepted connection is given: as the channel's own allocator does (adaptive, following recent reads down to 64 bytes) until the connection is found to be binary, then BinaryAwareRecvByteBufAllocator.BINARY_READ_SIZE for every read, so that a binary message is not cut by a buffer that has followed small messages down.
binaryLength(Object) - Method in class org.mockserver.dashboard.model.DashboardLogEntryDTO
The length, before the dashboard cut it, of a binary message that is one of this entry's requests, or null for any other message.
BinaryMessageFramer - Class in org.mockserver.netty.proxy
Cuts a binary connection into the messages of a protocol, as a client sends them, so that each is matched, forwarded and logged as one message however it was read.
BinaryMessageFramer(int, MockServerLogger, String) - Constructor for class org.mockserver.netty.proxy.BinaryMessageFramer
 
BinaryMessageGatherer - Class in org.mockserver.netty.proxy
Joins what one read loop delivers on a binary connection into one message, so that a message is not cut where a read buffer filled or where TLS handed over part of what it had decrypted.
BinaryMessageGatherer() - Constructor for class org.mockserver.netty.proxy.BinaryMessageGatherer
 
BinaryRelay - Class in org.mockserver.netty.proxy.relay
One binary client connection's single upstream connection, and the bytes relayed between the two as they arrive.
BinaryRequestProxyingHandler - Class in org.mockserver.netty.proxy
 
BinaryRequestProxyingHandler(Configuration, MockServerLogger, Scheduler, NettyHttpClient, HttpState) - Constructor for class org.mockserver.netty.proxy.BinaryRequestProxyingHandler
 
bindServerPorts(List<Integer>) - Method in class org.mockserver.lifecycle.LifeCycle
 
bossGroup - Variable in class org.mockserver.lifecycle.LifeCycle
 
BoundedMessageStore - Class in org.mockserver.async.subscribe
A thread-safe, bounded FIFO store for RecordedMessage instances.
BoundedMessageStore() - Constructor for class org.mockserver.async.subscribe.BoundedMessageStore
 
BoundedMessageStore(int) - Constructor for class org.mockserver.async.subscribe.BoundedMessageStore
 
build() - Method in class org.mockserver.async.security.KafkaSecurity.Builder
 
build() - Method in class org.mockserver.async.security.MqttSecurity.Builder
 
buildConnectOptions(MqttSecurity) - Static method in class org.mockserver.async.security.Mqtt5SecurityOptions
Build v5 connection options with security settings applied.
buildConnectOptions(MqttSecurity) - Static method in class org.mockserver.async.security.MqttSecurityOptions
Build connect options with security settings applied.
buildDataFrame(byte[]) - Static method in class org.mockserver.netty.http3.GrpcHttp3Adapter
Build an HTTP/3 DATA frame from gRPC-framed bytes.
builder() - Static method in class org.mockserver.async.security.KafkaSecurity
 
builder() - Static method in class org.mockserver.async.security.MqttSecurity
 
buildInitialHeadersFrame() - Static method in class org.mockserver.netty.http3.GrpcHttp3Adapter
Build the initial HTTP/3 HEADERS frame for a gRPC response.
buildInitialHeadersFrame(HttpResponse) - Static method in class org.mockserver.netty.http3.GrpcHttp3Adapter
As GrpcHttp3Adapter.buildInitialHeadersFrame(), additionally copying the matched response's own headers through to the client.
buildTrailersOnlyFrame(String, String) - Static method in class org.mockserver.netty.http3.GrpcHttp3Adapter
Build a "trailers-only" HTTP/3 HEADERS frame that combines :status, content-type, and grpc-status/grpc-message in a single HEADERS frame (no DATA frame follows).
buildTrailersOnlyFrame(String, String, HttpResponse) - Static method in class org.mockserver.netty.http3.GrpcHttp3Adapter
As GrpcHttp3Adapter.buildTrailersOnlyFrame(String, String), additionally copying the matched response's own headers and trailers through -- a trailers-only response is the client's only frame, so dropping either loses it entirely.
buildTrailingHeadersFrame(String, String) - Static method in class org.mockserver.netty.http3.GrpcHttp3Adapter
Build the trailing HTTP/3 HEADERS frame for a gRPC response.
buildTrailingHeadersFrame(String, String, HttpResponse) - Static method in class org.mockserver.netty.http3.GrpcHttp3Adapter
As GrpcHttp3Adapter.buildTrailingHeadersFrame(String, String), additionally emitting the matched response's user-authored trailers as gRPC trailing metadata.
bytesBeforeTlsMayStart(ByteBuf, int) - Method in class org.mockserver.netty.proxy.BinaryMessageFramer
How many of the available bytes from in's reader index, read in the clear, end a message after which a client may start a TLS handshake without waiting for a reply, when more bytes follow; otherwise 0.
bytesBeforeTlsMayStart(ByteBuf, int) - Method in class org.mockserver.netty.proxy.MysqlMessageFramer
A client sends its ClientHello straight after an SSLRequest, without waiting for a reply, so the two can be read together.

C

CallbackWebSocketServerHandler - Class in org.mockserver.netty.websocketregistry
 
CallbackWebSocketServerHandler(HttpState) - Constructor for class org.mockserver.netty.websocketregistry.CallbackWebSocketServerHandler
 
callDecode(ChannelHandlerContext, ByteBuf, List<Object>) - Method in class org.mockserver.netty.unification.PortUnificationHandler
 
callTool(String, JsonNode) - Method in class org.mockserver.netty.mcp.McpToolRegistry
 
capExpectationTree(JsonNode) - Static method in class org.mockserver.dashboard.model.DashboardBodyCap
Cuts, in place, an expectation's serialised tree for the dashboard's expectations section: every body longer than the cap (a JSON or binary body is measured and cut as its serialised text) and every other string longer than the cap.
channelActive(ChannelHandlerContext) - Method in class org.mockserver.netty.proxy.relay.DownstreamProxyRelayHandler
 
channelActive(ChannelHandlerContext) - Method in class org.mockserver.netty.proxy.relay.UpstreamProxyRelayHandler
 
channelActive(ChannelHandlerContext) - Method in class org.mockserver.netty.proxy.TransparentProxyHandler
 
channelActive(ChannelHandlerContext) - Method in class org.mockserver.netty.unification.PortUnificationHandler
 
channelIdle(ChannelHandlerContext, IdleStateEvent) - Method in class org.mockserver.netty.connection.InboundConnectionIdleHandler
 
channelInactive(ChannelHandlerContext) - Method in class org.mockserver.netty.grpc.GrpcBidiStreamHandler
Handles channel deactivation (client disconnect, connection closed, abandoned stream).
channelInactive(ChannelHandlerContext) - Method in class org.mockserver.netty.grpc.GrpcToHttpRequestHandler
 
channelInactive(ChannelHandlerContext) - Method in class org.mockserver.netty.http3.Http3ConnectUdpHandler
 
channelInactive(ChannelHandlerContext) - Method in class org.mockserver.netty.http3.Http3MockServerHandler
 
channelInactive(ChannelHandlerContext) - Method in class org.mockserver.netty.proxy.BinaryMessageGatherer
 
channelInactive(ChannelHandlerContext) - Method in class org.mockserver.netty.proxy.BinaryRequestProxyingHandler
 
channelInactive(ChannelHandlerContext) - Method in class org.mockserver.netty.proxy.relay.DownstreamProxyRelayHandler
 
channelInactive(ChannelHandlerContext) - Method in class org.mockserver.netty.proxy.relay.LoopbackHttp2ConnectionCloseHandler
 
channelInactive(ChannelHandlerContext) - Method in class org.mockserver.netty.proxy.relay.UpstreamProxyRelayHandler
 
channelInactive(ChannelHandlerContext) - Method in class org.mockserver.netty.unification.TcpChaosHandler
 
channelInputClosed(ChannelHandlerContext) - Method in class org.mockserver.netty.http3.Http3MockServerHandler
 
channelRead(ChannelHandlerContext, Http3DataFrame) - Method in class org.mockserver.netty.http3.Http3MockServerHandler
 
channelRead(ChannelHandlerContext, Http3HeadersFrame) - Method in class org.mockserver.netty.http3.Http3MockServerHandler
 
channelRead(ChannelHandlerContext, Object) - Method in class org.mockserver.dashboard.DashboardWebSocketHandler
 
channelRead(ChannelHandlerContext, Object) - Method in class org.mockserver.netty.connection.Http2StreamTransportTimer
 
channelRead(ChannelHandlerContext, Object) - Method in class org.mockserver.netty.connection.HttpExchangeTracker
 
channelRead(ChannelHandlerContext, Object) - Method in class org.mockserver.netty.connection.HttpTransportTimer
 
channelRead(ChannelHandlerContext, Object) - Method in class org.mockserver.netty.connection.InboundConnectionLimiter
 
channelRead(ChannelHandlerContext, Object) - Method in class org.mockserver.netty.grpc.GrpcBidiReflectionHandler
 
channelRead(ChannelHandlerContext, Object) - Method in class org.mockserver.netty.grpc.GrpcBidiRouterHandler
 
channelRead(ChannelHandlerContext, Object) - Method in class org.mockserver.netty.grpc.GrpcBidiStreamHandler
 
channelRead(ChannelHandlerContext, Object) - Method in class org.mockserver.netty.http3.Http3ConnectUdpHandler
 
channelRead(ChannelHandlerContext, Object) - Method in class org.mockserver.netty.http3.Http3ExceptionHandler
 
channelRead(ChannelHandlerContext, Object) - Method in class org.mockserver.netty.mcp.McpStreamableHttpHandler
 
channelRead(ChannelHandlerContext, Object) - Method in class org.mockserver.netty.proxy.BinaryMessageGatherer
 
channelRead(ChannelHandlerContext, Object) - Method in class org.mockserver.netty.proxy.ProxyProtocolOriginalDestinationHandler
 
channelRead(ChannelHandlerContext, Object) - Method in class org.mockserver.netty.proxy.relay.DownstreamProxyRelayHandler
 
channelRead(ChannelHandlerContext, Object) - Method in class org.mockserver.netty.proxy.relay.LoopbackHttp1ResponseErrorHandler
 
channelRead(ChannelHandlerContext, Object) - Method in class org.mockserver.netty.proxy.relay.LoopbackHttp2StreamIdRemapper
 
channelRead(ChannelHandlerContext, Object) - Method in class org.mockserver.netty.unification.TcpChaosHandler
 
channelRead(ChannelHandlerContext, Object) - Method in class org.mockserver.netty.unification.TraceContextHandler
 
channelRead(ChannelHandlerContext, Object) - Method in class org.mockserver.netty.websocketregistry.CallbackWebSocketServerHandler
 
channelRead0(ChannelHandlerContext, ByteBuf) - Method in class org.mockserver.netty.proxy.BinaryRequestProxyingHandler
 
channelRead0(ChannelHandlerContext, DatagramDnsQuery) - Method in class org.mockserver.netty.dns.DnsRequestHandler
 
channelRead0(ChannelHandlerContext, FullHttpRequest) - Method in class org.mockserver.netty.proxy.relay.UpstreamProxyRelayHandler
 
channelRead0(ChannelHandlerContext, HttpObject) - Method in class org.mockserver.netty.proxy.relay.DownstreamProxyRelayHandler
 
channelRead0(ChannelHandlerContext, HttpObject) - Method in class org.mockserver.netty.unification.EarlyMatchingHandler
 
channelRead0(ChannelHandlerContext, Socks4CommandRequest) - Method in class org.mockserver.netty.proxy.socks.Socks4ProxyHandler
 
channelRead0(ChannelHandlerContext, Socks5Message) - Method in class org.mockserver.netty.proxy.socks.Socks5ProxyHandler
 
channelRead0(ChannelHandlerContext, HttpRequest) - Method in class org.mockserver.netty.grpc.GrpcToHttpRequestHandler
 
channelRead0(ChannelHandlerContext, HttpRequest) - Method in class org.mockserver.netty.HttpRequestHandler
 
channelRead0(ChannelHandlerContext, T) - Method in class org.mockserver.netty.proxy.relay.RelayConnectHandler
 
channelReadComplete(ChannelHandlerContext) - Method in class org.mockserver.dashboard.DashboardWebSocketHandler
 
channelReadComplete(ChannelHandlerContext) - Method in class org.mockserver.netty.HttpRequestHandler
 
channelReadComplete(ChannelHandlerContext) - Method in class org.mockserver.netty.mcp.McpStreamableHttpHandler
 
channelReadComplete(ChannelHandlerContext) - Method in class org.mockserver.netty.proxy.BinaryMessageGatherer
 
channelReadComplete(ChannelHandlerContext) - Method in class org.mockserver.netty.proxy.BinaryRequestProxyingHandler
 
channelReadComplete(ChannelHandlerContext) - Method in class org.mockserver.netty.proxy.socks.SocksProxyHandler
 
channelReadComplete(ChannelHandlerContext) - Method in class org.mockserver.netty.websocketregistry.CallbackWebSocketServerHandler
 
channelWritabilityChanged(ChannelHandlerContext) - Method in class org.mockserver.netty.proxy.BinaryRequestProxyingHandler
 
checkIntervalMillis(long) - Static method in class org.mockserver.netty.connection.WriteStallTimeoutHandler
How often a timer checks for progress: often enough that a stall is noticed soon after the timeout, never more than once a second.
clear() - Method in class org.mockserver.async.subscribe.BoundedMessageStore
Clear all messages.
ClientAndServer - Class in org.mockserver.integration
 
ClientAndServer(Integer...) - Constructor for class org.mockserver.integration.ClientAndServer
 
ClientAndServer(String, Integer, Integer...) - Constructor for class org.mockserver.integration.ClientAndServer
 
ClientAndServer(Configuration, Integer...) - Constructor for class org.mockserver.integration.ClientAndServer
 
ClientAndServer(Configuration, String, Integer, Integer...) - Constructor for class org.mockserver.integration.ClientAndServer
 
clientInactive(Channel) - Static method in class org.mockserver.netty.proxy.relay.BinaryRelay
Ends the upstream connection once the client's has closed, after what the client sent has been written to it.
clientStartedTls(Channel) - Static method in class org.mockserver.netty.proxy.relay.BinaryRelay
The client has started TLS part way through: its handshake with MockServer is under way, so the upstream connection starts its own.
ClientTlsHandshakeFailureLog - Class in org.mockserver.netty.unification
Logs a client's failed TLS handshake, on TCP and on HTTP/3: at WARN for the first failure from a client address on a transport, with a hint about its likely cause, and at DEBUG for each later one, so a client that retries, or a scan, does not fill the log.
ClientTlsHandshakeFailureLog() - Constructor for class org.mockserver.netty.unification.ClientTlsHandshakeFailureLog
 
clientWritabilityChanged(Channel) - Static method in class org.mockserver.netty.proxy.relay.BinaryRelay
Reads the upstream again once the client can take more.
close() - Method in class org.mockserver.async.publish.AmqpMessagePublisher
 
close() - Method in class org.mockserver.async.publish.KafkaAvroMessagePublisher
 
close() - Method in class org.mockserver.async.publish.KafkaMessagePublisher
 
close() - Method in interface org.mockserver.async.publish.MessagePublisher
Release any resources held by this publisher (producer connections, etc.).
close() - Method in class org.mockserver.async.publish.Mqtt5MessagePublisher
 
close() - Method in class org.mockserver.async.publish.MqttMessagePublisher
 
close() - Method in class org.mockserver.async.subscribe.AmqpMessageSubscriber
 
close() - Method in class org.mockserver.async.subscribe.KafkaAvroMessageSubscriber
 
close() - Method in class org.mockserver.async.subscribe.KafkaMessageSubscriber
 
close() - Method in interface org.mockserver.async.subscribe.MessageSubscriber
Clear all recorded messages and stop all subscriptions.
close() - Method in class org.mockserver.async.subscribe.Mqtt5MessageSubscriber
 
close() - Method in class org.mockserver.async.subscribe.MqttMessageSubscriber
 
close() - Method in class org.mockserver.lifecycle.LifeCycle
 
close(ChannelHandlerContext, ChannelPromise) - Method in class org.mockserver.netty.unification.TcpChaosHandler
 
complete() - Method in class org.mockserver.netty.InFlightRequest
Decrement the in-flight counter, but only the first time this is called for this token.
CompositeOriginalDestinationResolver - Class in org.mockserver.netty.proxy
A composite TransparentProxyHandler.OriginalDestinationResolver that tries an ordered chain of resolution strategies and returns the first non-null result.
CompositeOriginalDestinationResolver(List<TransparentProxyHandler.OriginalDestinationResolver>) - Constructor for class org.mockserver.netty.proxy.CompositeOriginalDestinationResolver
Creates a composite resolver with the given ordered strategies.
configuration - Variable in class org.mockserver.netty.proxy.socks.SocksProxyHandler
 
ConfluentWireFormat - Class in org.mockserver.async.serde
Encoder/decoder for the Confluent Schema Registry wire format used by Kafka Avro/Protobuf messages.
ConfluentWireFormat.Decoded - Class in org.mockserver.async.serde
The result of decoding a wire-format message: the embedded schema id and the remaining serialized payload bytes.
connectBeforeClientSpeaks(ChannelHandlerContext) - Method in class org.mockserver.netty.proxy.BinaryRequestProxyingHandler
Opens the upstream connection of a connection whose client has sent nothing, for a server that speaks first (forwardBinaryServerFirstWaitMillis).
CONNECTION_SCOPED_ATTRIBUTES - Static variable in class org.mockserver.netty.unification.ConnectionScopeHandler
The connection-scoped attribute keys copied from parent to child.
ConnectionScopeHandler - Class in org.mockserver.netty.unification
Copies the connection-scoped channel attributes from a parent channel onto a child channel.
ConnectionScopeHandler() - Constructor for class org.mockserver.netty.unification.ConnectionScopeHandler
 
ConntrackOriginalDestinationResolver - Class in org.mockserver.netty.proxy
Resolves the original destination of a transparently intercepted TCP connection by reading the Linux conntrack table (/proc/net/nf_conntrack).
ConntrackOriginalDestinationResolver() - Constructor for class org.mockserver.netty.proxy.ConntrackOriginalDestinationResolver
 
containsWildcard(String) - Static method in class org.mockserver.async.subscribe.MqttTopicFilter
 
contentEncoded() - Method in class org.mockserver.netty.http3.Http3RequestBridge.ParsedHeaders
Whether the request has a content-encoding header.
createSession() - Method in class org.mockserver.netty.mcp.McpSessionManager
 

D

DashboardBodyCap - Class in org.mockserver.dashboard.model
Shortens the bodies the dashboard sends in its live updates.
DashboardBodyCap.Rendering - Class in org.mockserver.dashboard.model
Renders one log entry's bodies for the dashboard: a body already cut for an earlier row under the same variant (with redaction on, its redacted rendering) comes back as that cut text without being decoded again.
DashboardBodyCap.Sizes - Class in org.mockserver.dashboard.model
What capping one log entry's messages found: each cut copy's full body length, and roughly how many characters the entry adds to an update.
DashboardHandler - Class in org.mockserver.dashboard
 
DashboardHandler() - Constructor for class org.mockserver.dashboard.DashboardHandler
 
DashboardLogEntryDTO - Class in org.mockserver.dashboard.model
 
DashboardLogEntryDTO(String, String, String, LogEntry.LogMessageType) - Constructor for class org.mockserver.dashboard.model.DashboardLogEntryDTO
 
DashboardLogEntryDTO(LogEntry) - Constructor for class org.mockserver.dashboard.model.DashboardLogEntryDTO
 
DashboardLogEntryDTO(LogEntry, Configuration) - Constructor for class org.mockserver.dashboard.model.DashboardLogEntryDTO
 
DashboardLogEntryDTOGroup - Class in org.mockserver.dashboard.model
 
DashboardLogEntryDTOGroup(DescriptionProcessor) - Constructor for class org.mockserver.dashboard.model.DashboardLogEntryDTOGroup
 
DashboardLogEntryDTOGroupSerializer - Class in org.mockserver.dashboard.serializers
 
DashboardLogEntryDTOGroupSerializer() - Constructor for class org.mockserver.dashboard.serializers.DashboardLogEntryDTOGroupSerializer
 
DashboardLogEntryDTOSerializer - Class in org.mockserver.dashboard.serializers
 
DashboardLogEntryDTOSerializer() - Constructor for class org.mockserver.dashboard.serializers.DashboardLogEntryDTOSerializer
 
DashboardWebSocketHandler - Class in org.mockserver.dashboard
 
DashboardWebSocketHandler(HttpState, boolean, boolean) - Constructor for class org.mockserver.dashboard.DashboardWebSocketHandler
 
DataPlaneAuthenticationGate - Class in org.mockserver.netty
Shared data-plane (mocked endpoint) authentication gate used by every Netty data-plane dispatch path — HttpRequestHandler (HTTP/1.1, HTTP/2, gRPC-over-h2) and Http3MockServerHandler (HTTP/3 / QUIC, including gRPC-over-HTTP/3).
decode(byte[]) - Static method in class org.mockserver.async.serde.ConfluentWireFormat
Decode the wire-format header, returning the embedded schema id and the remaining serialized payload.
decode(ChannelHandlerContext, ByteBuf, List<Object>) - Method in class org.mockserver.netty.proxy.BinaryMessageFramer
 
decode(ChannelHandlerContext, ByteBuf, List<Object>) - Method in class org.mockserver.netty.unification.PortUnificationHandler
 
decode(ChannelHandlerContext, Http2StreamFrame, List<Object>) - Method in class org.mockserver.netty.unification.LenientInboundHttp2StreamFrameCodec
 
decodeLast(ChannelHandlerContext, ByteBuf, List<Object>) - Method in class org.mockserver.netty.unification.PortUnificationHandler
 
DEFAULT_MAX_RECORDED_MESSAGES - Static variable in class org.mockserver.async.subscribe.BoundedMessageStore
Default maximum number of recorded messages per channel.
DEFAULT_PROTOCOL_VERSION - Static variable in class org.mockserver.netty.mcp.McpContractTest
Default MCP protocol version advertised by the client when the caller supplies none.
defaultChain() - Static method in class org.mockserver.netty.proxy.CompositeOriginalDestinationResolver
Returns the default chain without TPROXY or eBPF: [SO_ORIGINAL_DST, conntrack, dns-intent].
defaultChain(Configuration) - Static method in class org.mockserver.netty.proxy.CompositeOriginalDestinationResolver
Returns the default chain: [TPROXY, eBPF, SO_ORIGINAL_DST, conntrack, dns-intent].
deferTlsDetection(Channel) - Static method in class org.mockserver.netty.unification.PortUnificationHandler
 
description(Object) - Method in class org.mockserver.dashboard.serializers.DescriptionProcessor
 
description(Object, String) - Method in class org.mockserver.dashboard.serializers.DescriptionProcessor
 
Description - Interface in org.mockserver.dashboard.serializers
 
DescriptionProcessor - Class in org.mockserver.dashboard.serializers
 
DescriptionProcessor(Configuration) - Constructor for class org.mockserver.dashboard.serializers.DescriptionProcessor
 
DescriptionSerializer - Class in org.mockserver.dashboard.serializers
 
DescriptionSerializer() - Constructor for class org.mockserver.dashboard.serializers.DescriptionSerializer
 
displayedCharacters() - Method in class org.mockserver.dashboard.model.DashboardBodyCap.Sizes
 
DnsIntentOriginalDestinationResolver - Class in org.mockserver.netty.proxy
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.
DnsIntentOriginalDestinationResolver() - Constructor for class org.mockserver.netty.proxy.DnsIntentOriginalDestinationResolver
 
DnsRequestHandler - Class in org.mockserver.netty.dns
 
DnsRequestHandler(MockServerLogger, HttpState) - Constructor for class org.mockserver.netty.dns.DnsRequestHandler
 
DnsStartupException - Exception in org.mockserver.netty.dns
Thrown at start-up when dnsEnabled is true and the DNS server could not be started on dnsPort, so that MockServer does not run without a listener it was configured to serve.
DownstreamProxyRelayHandler - Class in org.mockserver.netty.proxy.relay
 
DownstreamProxyRelayHandler(MockServerLogger, Channel) - Constructor for class org.mockserver.netty.proxy.relay.DownstreamProxyRelayHandler
Relays with no bound on the streamed bytes not yet written to upstreamChannel.
DownstreamProxyRelayHandler(MockServerLogger, Channel, long) - Constructor for class org.mockserver.netty.proxy.relay.DownstreamProxyRelayHandler
 
drop() - Static method in class org.mockserver.netty.proxy.relay.UpstreamReply
 
dualStackBindSucceeds(int) - Static method in class org.mockserver.lifecycle.Ipv4UdpPortProbe
 

E

EarlyMatchingHandler - Class in org.mockserver.netty.unification
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.
EarlyMatchingHandler(Configuration, HttpState, HttpActionHandler, boolean) - Constructor for class org.mockserver.netty.unification.EarlyMatchingHandler
 
EarlyNettyResponseWriter - Class in org.mockserver.netty.responsewriter
Response writer for the early-dispatch path.
EarlyNettyResponseWriter(Configuration, MockServerLogger, ChannelHandlerContext, Scheduler) - Constructor for class org.mockserver.netty.responsewriter.EarlyNettyResponseWriter
 
EbpfOriginalDestinationResolver - Class in org.mockserver.netty.proxy
Resolves the original destination of a transparently intercepted TCP connection by reading a pinned BPF hash map populated by an external eBPF program.
EbpfOriginalDestinationResolver(Configuration) - Constructor for class org.mockserver.netty.proxy.EbpfOriginalDestinationResolver
 
emit(ChannelHandlerContext, long, long) - Static method in class org.mockserver.netty.unification.Http2GoAwayEmitter
Emit a GOAWAY on the connection carrying ctx, whether ctx is on a connection-level HTTP/2 pipeline or a multiplex stream child channel.
empty() - Static method in class org.mockserver.async.security.KafkaSecurity
Returns a new empty (no-op) security instance.
empty() - Static method in class org.mockserver.async.security.MqttSecurity
Returns a new empty (no-op) security instance.
enableSslDownstream(Channel) - Static method in class org.mockserver.netty.unification.PortUnificationHandler
 
enableSslUpstreamAndDownstream(Channel) - Static method in class org.mockserver.netty.unification.PortUnificationHandler
 
encode(int, byte[]) - Static method in class org.mockserver.async.serde.ConfluentWireFormat
Frame a serialized payload with the Confluent wire-format header.
encode(ChannelHandlerContext, DefaultHttpMessage, List) - Method in class org.mockserver.netty.unification.HttpContentLengthRemover
 
encode(ChannelHandlerContext, HttpObject, List<Object>) - Method in class org.mockserver.netty.unification.LenientInboundHttp2StreamFrameCodec
 
encode(ChannelHandlerContext, HttpResponse, List<Object>) - Method in class org.mockserver.netty.grpc.GrpcToHttpResponseHandler
 
error(Object, int, String) - Static method in class org.mockserver.netty.mcp.JsonRpcMessage.JsonRpcResponse
 
error(Object, int, String, JsonNode) - Static method in class org.mockserver.netty.mcp.JsonRpcMessage.JsonRpcResponse
 
errorResponse(GrpcStatusMapper.GrpcStatusCode, String) - Static method in class org.mockserver.netty.http3.GrpcHttp3Adapter
Build an error response (trailers-only pattern) for gRPC over HTTP/3.
estimatedLogMessageCharacters() - Method in class org.mockserver.dashboard.model.DashboardLogEntryDTO
Roughly how many characters this entry adds to an update as a log message (its arguments), used to keep an update under its size ceiling.
exceptionCaught(ChannelHandlerContext, Throwable) - Method in class org.mockserver.dashboard.DashboardWebSocketHandler
 
exceptionCaught(ChannelHandlerContext, Throwable) - Method in class org.mockserver.netty.dns.DnsRequestHandler
 
exceptionCaught(ChannelHandlerContext, Throwable) - Method in class org.mockserver.netty.grpc.GrpcBidiReflectionHandler
 
exceptionCaught(ChannelHandlerContext, Throwable) - Method in class org.mockserver.netty.grpc.GrpcBidiStreamHandler
 
exceptionCaught(ChannelHandlerContext, Throwable) - Method in class org.mockserver.netty.http3.Http3ConnectUdpHandler
 
exceptionCaught(ChannelHandlerContext, Throwable) - Method in class org.mockserver.netty.http3.Http3ExceptionHandler
 
exceptionCaught(ChannelHandlerContext, Throwable) - Method in class org.mockserver.netty.http3.Http3ListenerExceptionHandler
 
exceptionCaught(ChannelHandlerContext, Throwable) - Method in class org.mockserver.netty.http3.Http3MockServerHandler
 
exceptionCaught(ChannelHandlerContext, Throwable) - Method in class org.mockserver.netty.HttpRequestHandler
 
exceptionCaught(ChannelHandlerContext, Throwable) - Method in class org.mockserver.netty.mcp.McpStreamableHttpHandler
 
exceptionCaught(ChannelHandlerContext, Throwable) - Method in class org.mockserver.netty.proxy.BinaryRequestProxyingHandler
 
exceptionCaught(ChannelHandlerContext, Throwable) - Method in class org.mockserver.netty.proxy.relay.DownstreamProxyRelayHandler
 
exceptionCaught(ChannelHandlerContext, Throwable) - Method in class org.mockserver.netty.proxy.relay.LoopbackHttp1ResponseErrorHandler
 
exceptionCaught(ChannelHandlerContext, Throwable) - Method in class org.mockserver.netty.proxy.relay.RelayConnectHandler
 
exceptionCaught(ChannelHandlerContext, Throwable) - Method in class org.mockserver.netty.proxy.relay.UpstreamProxyRelayHandler
 
exceptionCaught(ChannelHandlerContext, Throwable) - Method in class org.mockserver.netty.proxy.socks.SocksProxyHandler
 
exceptionCaught(ChannelHandlerContext, Throwable) - Method in class org.mockserver.netty.unification.EarlyMatchingHandler
 
exceptionCaught(ChannelHandlerContext, Throwable) - Method in class org.mockserver.netty.unification.Http2ConnectionExceptionHandler
 
exceptionCaught(ChannelHandlerContext, Throwable) - Method in class org.mockserver.netty.unification.LenientInboundHttp2StreamFrameCodec
A stream's own error, trailers over maxHeaderSize among them, reaches the stream as an exception, already logged, and Netty then resets the stream with the error's code.
exceptionCaught(ChannelHandlerContext, Throwable) - Method in class org.mockserver.netty.unification.PortUnificationHandler
 
exceptionCaught(ChannelHandlerContext, Throwable) - Method in class org.mockserver.netty.websocketregistry.CallbackWebSocketServerHandler
 
ExchangeResult(int, String, JsonNode, String) - Constructor for class org.mockserver.netty.mcp.McpContractTest.ExchangeResult
 
exempt(Channel) - Static method in class org.mockserver.netty.connection.WriteStallTimeoutHandler
Stop watching a connection whose silences are MockServer's own backpressure rather than its client's: the loopback leg of a CONNECT/SOCKS relay is read only as fast as the relay's proxy client takes what it is sent, and that client's own connection is watched.
ExpectationsListener - Interface in org.mockserver.lifecycle
 
expectationTruncationMarker(String, long) - Static method in class org.mockserver.dashboard.model.DashboardBodyCap
What the dashboard needs to say an expectation in its expectations section was cut, and to load it whole by id.
ExpectContinueInboundHttp2ToHttpAdapter - Class in org.mockserver.netty.proxy.relay
The proxy client's side of the CONNECT/SOCKS relay's HTTP/2 tunnel, handing each request on once, with its whole body.
explicitPortConflict(int, InetSocketAddress) - Static method in class org.mockserver.lifecycle.LifeCycle
The exception thrown when an explicitly requested port is shadowed by another application's loopback listener; public so callers that surface it (such as PUT /mockserver/bind) can be tested against the real wording.
ExtensionHeaderStrippingHttp2ConnectionEncoder - Class in org.mockserver.netty.unification
Leaves Netty's x-http2- extension headers (HttpConversionUtil.ExtensionHeaderNames) out of every header block an HttpToHttp2ConnectionHandler sends.
ExtensionHeaderStrippingHttp2ConnectionEncoder(Http2ConnectionEncoder) - Constructor for class org.mockserver.netty.unification.ExtensionHeaderStrippingHttp2ConnectionEncoder
 

F

failureResponse(Object) - Method in class org.mockserver.netty.proxy.connect.HttpConnectHandler
 
failureResponse(Object) - Method in class org.mockserver.netty.proxy.relay.RelayConnectHandler
 
failureResponse(Object) - Method in class org.mockserver.netty.proxy.socks.Socks4ConnectHandler
 
failureResponse(Object) - Method in class org.mockserver.netty.proxy.socks.Socks5ConnectHandler
 
fieldsExcludedFromEqualsAndHashCode() - Method in class org.mockserver.dashboard.model.DashboardLogEntryDTO
 
flush() - Method in class org.mockserver.async.publish.KafkaAvroMessagePublisher
Block until every message published so far has been acknowledged by the broker, throwing if any of them failed to be delivered.
flush() - Method in class org.mockserver.async.publish.KafkaMessagePublisher
Block until every message published so far has been acknowledged by the broker, throwing if any of them failed to be delivered.
flush() - Method in interface org.mockserver.async.publish.MessagePublisher
Block until every message published so far has been acknowledged by the broker, throwing if any of them failed to be delivered.
flush(ChannelHandlerContext) - Method in class org.mockserver.netty.connection.Http2StreamWriteStallHandler
 
flush(ChannelHandlerContext) - Method in class org.mockserver.netty.connection.WriteStallTimeoutHandler
 
flush(ChannelHandlerContext) - Method in class org.mockserver.netty.http3.Http3StreamWriteStallHandler
 
forConfiguration(Configuration, MockServerLogger) - Static method in class org.mockserver.netty.proxy.BinaryMessageFramer
The framer binaryMessageFraming names, or null for RAW.
forConnection(Http2Connection, int) - Static method in class org.mockserver.netty.proxy.relay.ExpectContinueInboundHttp2ToHttpAdapter
An adapter listening to the connection, as Netty's builder makes one: a request still being uploaded is released when its stream is removed.
forConnection(MockServerLogger, Configuration, ClientTlsHandshakeFailureLog) - Static method in class org.mockserver.netty.http3.Http3ExceptionHandler
 
forward(ChannelHandlerContext, BinaryMessage, String, UpstreamReply, InetSocketAddress, Configuration, MockServerLogger, Scheduler, NettyHttpClient, BinaryProxyListener) - Static method in class org.mockserver.netty.proxy.relay.BinaryRelay
Relays a message read from the client to its upstream connection, opening that connection for the first one, with the upstream's reply to this message relayed, dropped or replaced.
forwardClientGroup - Variable in class org.mockserver.lifecycle.LifeCycle
 
forwardConnection(ChannelHandlerContext, ChannelHandler, String, int) - Method in class org.mockserver.netty.proxy.socks.SocksProxyHandler
 
frameCodecBuilder(MockServerLogger) - Static method in class org.mockserver.netty.unification.Http2RequestHeaderLimit
 
frameListener(Http2FrameListener) - Method in class org.mockserver.netty.proxy.relay.LoopbackHttp2StreamErrorHandler
Wraps the loopback's frame listener to record why a stream is about to be reset.

G

generate(String) - Method in class org.mockserver.async.controlplane.AsyncApiHttpExpectationGenerator
Parse the request body and return the generated expectations.
generateExample(AsyncApiChannel) - Method in class org.mockserver.async.MessageExampleGenerator
Generate an example payload for a single channel.
generateExample(AsyncApiMessage) - Method in class org.mockserver.async.MessageExampleGenerator
Generate an example payload for a single AsyncApiMessage.
generateExamples(AsyncApiSpec) - Method in class org.mockserver.async.MessageExampleGenerator
Generate example payloads for all channels in the spec.
generateHttpExpectations(String) - Method in class org.mockserver.async.controlplane.AsyncApiControlPlaneImpl
 
generateSerialized(String) - Method in class org.mockserver.async.controlplane.AsyncApiHttpExpectationGenerator
Parse the request body and return the generated expectations serialized as a JSON array string in the standard MockServer expectation format.
getActionHandler() - Method in class org.mockserver.netty.MockServerUnificationInitializer
 
getActiveConnectionCount() - Method in class org.mockserver.netty.http3.Http3Server
Returns the current number of active QUIC (HTTP/3) connections.
getAllRecordedMessages() - Method in class org.mockserver.async.subscribe.AmqpMessageSubscriber
 
getAllRecordedMessages() - Method in class org.mockserver.async.subscribe.KafkaAvroMessageSubscriber
 
getAllRecordedMessages() - Method in class org.mockserver.async.subscribe.KafkaMessageSubscriber
 
getAllRecordedMessages() - Method in interface org.mockserver.async.subscribe.MessageSubscriber
Return all messages recorded across all channels.
getAllRecordedMessages() - Method in class org.mockserver.async.subscribe.Mqtt5MessageSubscriber
 
getAllRecordedMessages() - Method in class org.mockserver.async.subscribe.MqttMessageSubscriber
 
getAmqpBinding() - Method in class org.mockserver.async.asyncapi.AsyncApiChannel
The parsed AMQP channel binding (bindings.amqp), or null when the channel declares no AMQP binding.
getArguments() - Method in class org.mockserver.dashboard.model.DashboardLogEntryDTO
 
getArguments() - Method in class org.mockserver.netty.mcp.McpPromptRegistry.PromptDefinition
 
getAsyncApiVersion() - Method in class org.mockserver.async.asyncapi.AsyncApiSpec
The AsyncAPI version string (e.g. "2.6.0" or "3.0.0").
getBecause() - Method in class org.mockserver.dashboard.model.DashboardLogEntryDTO
 
getBody() - Method in class org.mockserver.netty.mcp.McpContractTest.ExchangeResult
 
getBody() - Method in class org.mockserver.netty.mcp.McpRequestProcessor.McpResult
JSON body bytes, or empty for no-body responses.
getChannel() - Method in class org.mockserver.async.subscribe.RecordedMessage
 
getChannels() - Method in class org.mockserver.async.asyncapi.AsyncApiSpec
All channels extracted from the spec.
getChannelType() - Method in class org.mockserver.async.asyncapi.AmqpBinding
 
getCheck() - Method in class org.mockserver.netty.mcp.McpContractTest.CheckResult
 
getChecks() - Method in class org.mockserver.netty.mcp.McpContractTest.Report
 
getClientRegistry() - Method in class org.mockserver.dashboard.DashboardWebSocketHandler
 
getClientTlsHandshakeFailureLog() - Method in class org.mockserver.lifecycle.LifeCycle
Shared by every TCP and HTTP/3 port of this server, so a client's failed handshake is logged at WARN once per client address and transport.
getCode() - Method in class org.mockserver.netty.mcp.JsonRpcMessage.JsonRpcError
 
getConfiguration() - Method in class org.mockserver.lifecycle.LifeCycle
The single live Configuration this server runs on: the instance shared by the HttpState, the event log and the request handlers, and the one that PUT /mockserver/configuration mutates.
getCorrelationId() - Method in class org.mockserver.dashboard.model.DashboardLogEntryDTO
 
getCorrelationIdLocation() - Method in class org.mockserver.async.asyncapi.AsyncApiMessage
The AsyncAPI correlation ID runtime expression (e.g.
getCreatedAt() - Method in class org.mockserver.netty.mcp.McpSession
 
getData() - Method in class org.mockserver.netty.mcp.JsonRpcMessage.JsonRpcError
 
getDescription() - Method in class org.mockserver.dashboard.model.DashboardLogEntryDTO
 
getDescription() - Method in class org.mockserver.netty.mcp.McpPromptRegistry.PromptArgument
 
getDescription() - Method in class org.mockserver.netty.mcp.McpPromptRegistry.PromptDefinition
 
getDescription() - Method in class org.mockserver.netty.mcp.McpResourceRegistry.ResourceDefinition
 
getDescription() - Method in class org.mockserver.netty.mcp.McpToolRegistry.ToolDefinition
 
getDescriptionProcessor() - Method in class org.mockserver.dashboard.model.DashboardLogEntryDTOGroup
 
getDetail() - Method in class org.mockserver.netty.mcp.McpContractTest.CheckResult
 
getDnsPort() - Method in class org.mockserver.integration.ClientAndServer
 
getDnsPort() - Method in class org.mockserver.netty.MockServer
 
getError() - Method in class org.mockserver.netty.mcp.JsonRpcMessage.JsonRpcResponse
 
getErrors() - Method in class org.mockserver.async.validation.AsyncApiSchemaValidator.ValidationResult
 
getEventLoopGroup() - Method in class org.mockserver.lifecycle.LifeCycle
 
getExchangeName() - Method in class org.mockserver.async.asyncapi.AmqpBinding
The exchange name to publish to, or null when not specified.
getExchangeType() - Method in class org.mockserver.async.asyncapi.AmqpBinding
The exchange type (direct/topic/fanout/headers), or null when not specified.
getExecutor() - Method in class org.mockserver.netty.mcp.McpSessionManager
Returns the executor used for MCP request processing.
getForwardClientEventLoopGroup() - Method in class org.mockserver.lifecycle.LifeCycle
 
getHandler() - Method in class org.mockserver.netty.mcp.McpToolRegistry.ToolDefinition
 
getHeaders() - Method in class org.mockserver.async.publish.PublishOptions
 
getHeaders() - Method in class org.mockserver.async.subscribe.RecordedMessage
 
getHttp3ActiveConnectionCount() - Method in class org.mockserver.netty.MockServer
Returns the current number of active HTTP/3 (QUIC) connections, or 0 if the HTTP/3 server is not running.
getHttp3Port() - Method in class org.mockserver.netty.MockServer
Returns the bound HTTP/3 (QUIC) UDP port, or -1 if the HTTP/3 server is not running.
getHttpRequest() - Method in class org.mockserver.dashboard.model.DashboardLogEntryDTO
 
getHttpRequests() - Method in class org.mockserver.dashboard.model.DashboardLogEntryDTO
 
getHttpResponse() - Method in class org.mockserver.dashboard.model.DashboardLogEntryDTO
 
getId() - Method in class org.mockserver.dashboard.model.DashboardLogEntryDTO
 
getId() - Method in class org.mockserver.netty.mcp.JsonRpcMessage.JsonRpcRequest
 
getId() - Method in class org.mockserver.netty.mcp.JsonRpcMessage.JsonRpcResponse
 
getInboundConnectionCount() - Method in class org.mockserver.netty.MockServer
Returns the number of inbound TCP connections this server currently holds open (every bound port; HTTP/3 connections are counted separately by MockServer.getHttp3ActiveConnectionCount()).
getInetSocketAddress() - Method in class org.mockserver.netty.unification.PortBinding
 
getInputSchema() - Method in class org.mockserver.netty.mcp.McpToolRegistry.ToolDefinition
 
getJsonrpc() - Method in class org.mockserver.netty.mcp.JsonRpcMessage.JsonRpcNotification
 
getJsonrpc() - Method in class org.mockserver.netty.mcp.JsonRpcMessage.JsonRpcRequest
 
getJsonrpc() - Method in class org.mockserver.netty.mcp.JsonRpcMessage.JsonRpcResponse
 
getKafkaKey() - Method in class org.mockserver.async.asyncapi.AsyncApiChannel
Kafka message key from message-level bindings, or null if not derivable.
getKafkaKey() - Method in class org.mockserver.async.asyncapi.AsyncApiMessage
Kafka message key from message-level bindings, or null if not derivable.
getKey() - Method in class org.mockserver.async.publish.PublishOptions
 
getKey() - Method in class org.mockserver.async.subscribe.RecordedMessage
 
getLastAccessedAt() - Method in class org.mockserver.netty.mcp.McpSession
 
getLastPublishFailure() - Method in class org.mockserver.async.AsyncApiMockOrchestrator
The failure message from the most recent scheduled publish cycle, or null if the last cycle succeeded.
getLocalPort() - Method in class org.mockserver.integration.ClientAndServer
 
getLocalPort() - Method in class org.mockserver.lifecycle.LifeCycle
 
getLocalPorts() - Method in class org.mockserver.integration.ClientAndServer
 
getLocalPorts() - Method in class org.mockserver.lifecycle.LifeCycle
 
getLogEntryDTOS() - Method in class org.mockserver.dashboard.model.DashboardLogEntryDTOGroup
 
getMaxHttpRequestLength() - Method in class org.mockserver.dashboard.serializers.DescriptionProcessor
 
getMaxLogEventLength() - Method in class org.mockserver.dashboard.serializers.DescriptionProcessor
 
getMaxOpenAPILength() - Method in class org.mockserver.dashboard.serializers.DescriptionProcessor
 
getMaxOpenAPIObjectLength() - Method in class org.mockserver.dashboard.serializers.DescriptionProcessor
 
getMcpSessionManager() - Method in class org.mockserver.netty.MockServerUnificationInitializer
 
getMessage() - Method in class org.mockserver.netty.mcp.JsonRpcMessage.JsonRpcError
 
getMessageFormat() - Method in class org.mockserver.dashboard.model.DashboardLogEntryDTO
 
getMessages() - Method in class org.mockserver.async.asyncapi.AsyncApiChannel
Returns all messages for this channel as a uniform list.
getMessages(String, JsonNode) - Method in class org.mockserver.netty.mcp.McpPromptRegistry
Build the messages for a named prompt, substituting {{argument}} placeholders with the supplied argument values.
getMethod() - Method in class org.mockserver.netty.mcp.JsonRpcMessage.JsonRpcNotification
 
getMethod() - Method in class org.mockserver.netty.mcp.JsonRpcMessage.JsonRpcRequest
 
getMimeType() - Method in class org.mockserver.netty.mcp.McpResourceRegistry.ResourceDefinition
 
getMissingArguments() - Method in exception org.mockserver.netty.mcp.McpPromptRegistry.MissingPromptArgumentsException
 
getMqttQos() - Method in class org.mockserver.async.asyncapi.AsyncApiChannel
MQTT QoS level (0, 1, or 2) from operation-level bindings, or null if not specified.
getMqttRetain() - Method in class org.mockserver.async.asyncapi.AsyncApiChannel
MQTT retain flag from operation-level bindings, or null if not specified.
getName() - Method in class org.mockserver.async.asyncapi.AsyncApiChannel
 
getName() - Method in class org.mockserver.async.asyncapi.AsyncApiMessage
The message name, or null for anonymous / unnamed messages.
getName() - Method in class org.mockserver.netty.mcp.McpPromptRegistry.PromptArgument
 
getName() - Method in class org.mockserver.netty.mcp.McpPromptRegistry.PromptDefinition
 
getName() - Method in class org.mockserver.netty.mcp.McpResourceRegistry.ResourceDefinition
 
getName() - Method in class org.mockserver.netty.mcp.McpToolRegistry.ToolDefinition
 
getOpenConnections() - Method in class org.mockserver.netty.connection.InboundConnectionLimiter
 
getOriginalDestination(Channel) - Static method in class org.mockserver.netty.proxy.SoOriginalDstHelper
Attempts to read the original destination of the connection associated with the given Netty channel.
getParams() - Method in class org.mockserver.netty.mcp.JsonRpcMessage.JsonRpcNotification
 
getParams() - Method in class org.mockserver.netty.mcp.JsonRpcMessage.JsonRpcRequest
 
getPassword() - Method in class org.mockserver.async.security.MqttSecurity
 
getPayload() - Method in class org.mockserver.async.serde.ConfluentWireFormat.Decoded
 
getPayload() - Method in class org.mockserver.async.subscribe.RecordedMessage
 
getPayloadExamples() - Method in class org.mockserver.async.asyncapi.AsyncApiChannel
Explicit examples found in the spec for the channel's message payload.
getPayloadExamples() - Method in class org.mockserver.async.asyncapi.AsyncApiMessage
Explicit examples found in the spec for this message's payload.
getPayloadSchema() - Method in class org.mockserver.async.asyncapi.AsyncApiChannel
The JSON Schema describing the payload (may be null if not present).
getPayloadSchema() - Method in class org.mockserver.async.asyncapi.AsyncApiMessage
The JSON Schema describing the payload (may be null if not present).
getPort() - Method in class org.mockserver.integration.ClientAndServer
 
getPort() - Method in class org.mockserver.lifecycle.LifeCycle
Deprecated.
use getLocalPort instead of getPort
getPort() - Method in class org.mockserver.netty.http3.Http3Server
Returns the bound UDP port, or -1 if not started.
getPortExtension() - Method in class org.mockserver.netty.unification.PortBinding
 
getPrompts() - Method in class org.mockserver.netty.mcp.McpPromptRegistry
 
getProtocolVersion() - Method in class org.mockserver.netty.mcp.McpContractTest.Report
 
getProtocolVersion() - Method in class org.mockserver.netty.mcp.McpSession
The MCP protocol version negotiated with the client during initialize (see McpRequestProcessor.negotiateProtocolVersion(String)), or null before initialize completes.
getQos() - Method in class org.mockserver.async.publish.Mqtt5MessagePublisher
 
getQos() - Method in class org.mockserver.async.publish.MqttMessagePublisher
 
getQos() - Method in class org.mockserver.async.publish.PublishOptions
 
getQueueName() - Method in class org.mockserver.async.asyncapi.AmqpBinding
The queue name (queue-based channels), or null when not specified.
getRecordedMessages(String) - Method in class org.mockserver.async.subscribe.AmqpMessageSubscriber
 
getRecordedMessages(String) - Method in class org.mockserver.async.subscribe.KafkaAvroMessageSubscriber
 
getRecordedMessages(String) - Method in class org.mockserver.async.subscribe.KafkaMessageSubscriber
 
getRecordedMessages(String) - Method in interface org.mockserver.async.subscribe.MessageSubscriber
Return all messages recorded on the given channel since subscription started (or since the last reset).
getRecordedMessages(String) - Method in class org.mockserver.async.subscribe.Mqtt5MessageSubscriber
 
getRecordedMessages(String) - Method in class org.mockserver.async.subscribe.MqttMessageSubscriber
Return all messages recorded on the given channel since subscription started (or since the last reset).
getRemoteAddress() - Method in class org.mockserver.integration.ClientAndServer
 
getRemoteAddress() - Method in class org.mockserver.netty.MockServer
 
getRequestsInFlight() - Method in class org.mockserver.lifecycle.LifeCycle
 
getRequestsInFlightSupplier() - Method in class org.mockserver.lifecycle.LifeCycle
 
getResources() - Method in class org.mockserver.netty.mcp.McpResourceRegistry
 
getResult() - Method in class org.mockserver.netty.mcp.JsonRpcMessage.JsonRpcResponse
 
getRetain() - Method in class org.mockserver.async.publish.PublishOptions
 
getRole() - Method in class org.mockserver.netty.mcp.McpPromptRegistry.PromptDefinition
 
getRoutingKey() - Method in class org.mockserver.async.asyncapi.AmqpBinding
The explicit routing key from the binding, or null.
getSaslJaasConfig() - Method in class org.mockserver.async.security.KafkaSecurity
 
getSaslMechanism() - Method in class org.mockserver.async.security.KafkaSecurity
 
getScheduler() - Method in class org.mockserver.lifecycle.LifeCycle
 
getSchemaById(int) - Method in class org.mockserver.async.serde.SchemaRegistryClient
Resolve an Avro schema's JSON text by its registered id.
getSchemaId() - Method in class org.mockserver.async.serde.ConfluentWireFormat.Decoded
 
getSecurityProtocol() - Method in class org.mockserver.async.security.KafkaSecurity
 
getServerName() - Method in class org.mockserver.netty.mcp.McpContractTest.Report
 
getServerVersion() - Method in class org.mockserver.netty.mcp.McpContractTest.Report
 
getSession(String) - Method in class org.mockserver.netty.mcp.McpSessionManager
 
getSessionId() - Method in class org.mockserver.netty.mcp.McpContractTest.ExchangeResult
 
getSessionId() - Method in class org.mockserver.netty.mcp.McpRequestProcessor.McpResult
Non-null only for initialize responses.
getSessionId() - Method in class org.mockserver.netty.mcp.McpSession
 
getSessionManager() - Method in class org.mockserver.netty.mcp.McpRequestProcessor
Returns the session manager used by this processor.
getSslKeyPassword() - Method in class org.mockserver.async.security.KafkaSecurity
 
getSslKeystoreLocation() - Method in class org.mockserver.async.security.KafkaSecurity
 
getSslKeystorePassword() - Method in class org.mockserver.async.security.KafkaSecurity
 
getSslProperties() - Method in class org.mockserver.async.security.MqttSecurity
Returns the SSL properties to pass through to Paho's MqttConnectOptions.setSSLProperties().
getSslTruststoreLocation() - Method in class org.mockserver.async.security.KafkaSecurity
 
getSslTruststorePassword() - Method in class org.mockserver.async.security.KafkaSecurity
 
getStatusCode() - Method in class org.mockserver.netty.mcp.McpContractTest.CheckResult
 
getStatusCode() - Method in class org.mockserver.netty.mcp.McpContractTest.ExchangeResult
 
getStatusCode() - Method in class org.mockserver.netty.mcp.McpRequestProcessor.McpResult
 
getStyle() - Method in class org.mockserver.dashboard.model.DashboardLogEntryDTO
 
getTemplate() - Method in class org.mockserver.netty.mcp.McpPromptRegistry.PromptDefinition
 
getThrowable() - Method in class org.mockserver.dashboard.model.DashboardLogEntryDTO
 
getTimestamp() - Method in class org.mockserver.async.subscribe.RecordedMessage
 
getTimestamp() - Method in class org.mockserver.dashboard.model.DashboardLogEntryDTO
 
getTitle() - Method in class org.mockserver.async.asyncapi.AsyncApiSpec
The title from info.title, or null if absent.
getTools() - Method in class org.mockserver.netty.mcp.McpToolRegistry
 
getTransportError() - Method in class org.mockserver.netty.mcp.McpContractTest.ExchangeResult
 
getType() - Method in class org.mockserver.dashboard.model.DashboardLogEntryDTO
 
getUri() - Method in class org.mockserver.netty.mcp.McpResourceRegistry.ResourceDefinition
 
getUsername() - Method in class org.mockserver.async.security.MqttSecurity
 
getValidationErrors() - Method in class org.mockserver.netty.mcp.McpContractTest.CheckResult
 
GrpcBidiReflectionHandler - Class in org.mockserver.netty.grpc
Per-stream handler for serving gRPC Server Reflection interactively over the bidirectional-streaming multiplex pipeline.
GrpcBidiReflectionHandler(GrpcServerReflectionHandler) - Constructor for class org.mockserver.netty.grpc.GrpcBidiReflectionHandler
Creates a new per-stream bidi reflection handler.
GrpcBidiRouterHandler - Class in org.mockserver.netty.grpc
Per-stream router that inspects the first Http2HeadersFrame to determine whether this stream is a true bidirectional-streaming gRPC method.
GrpcBidiRouterHandler(Configuration, GrpcProtoDescriptorStore, MockServerLogger, boolean, Certificate[], CallbackWebSocketServerHandler, DashboardWebSocketHandler, McpStreamableHttpHandler, TraceContextHandler, AltSvcHeaderHandler, GrpcToHttpResponseHandler, GrpcToHttpRequestHandler, HttpRequestHandler) - Constructor for class org.mockserver.netty.grpc.GrpcBidiRouterHandler
 
GrpcBidiRouterHandler(Configuration, GrpcProtoDescriptorStore, MockServerLogger, boolean, Certificate[], CallbackWebSocketServerHandler, DashboardWebSocketHandler, McpStreamableHttpHandler, TraceContextHandler, AltSvcHeaderHandler, GrpcToHttpResponseHandler, GrpcToHttpRequestHandler, HttpRequestHandler, HttpState) - Constructor for class org.mockserver.netty.grpc.GrpcBidiRouterHandler
 
GrpcBidiStreamHandler - Class in org.mockserver.netty.grpc
Per-stream handler for true bidirectional gRPC streaming.
GrpcBidiStreamHandler(Descriptors.MethodDescriptor, GrpcJsonMessageConverter, Function<String, List<String>>) - Constructor for class org.mockserver.netty.grpc.GrpcBidiStreamHandler
Phase 3a constructor: function-based responder (backward compatible).
GrpcBidiStreamHandler(Descriptors.MethodDescriptor, GrpcJsonMessageConverter, GrpcBidiResponse) - Constructor for class org.mockserver.netty.grpc.GrpcBidiStreamHandler
Phase 3b constructor: GrpcBidiResponse-driven (without completion callback).
GrpcBidiStreamHandler(Descriptors.MethodDescriptor, GrpcJsonMessageConverter, GrpcBidiResponse, Runnable) - Constructor for class org.mockserver.netty.grpc.GrpcBidiStreamHandler
Phase 3b constructor: GrpcBidiResponse-driven with completion callback.
GrpcBidiStreamHandler(Descriptors.MethodDescriptor, GrpcJsonMessageConverter, GrpcBidiResponse, Runnable, Configuration, String) - Constructor for class org.mockserver.netty.grpc.GrpcBidiStreamHandler
Phase 3b constructor: GrpcBidiResponse-driven with completion callback and inbound breakpoints.
GrpcBidiStreamHandler(Descriptors.MethodDescriptor, GrpcJsonMessageConverter, GrpcBidiResponse, Runnable, Configuration, String, WebSocketClientRegistry, String, String) - Constructor for class org.mockserver.netty.grpc.GrpcBidiStreamHandler
Phase 3b constructor: GrpcBidiResponse-driven with completion callback, inbound breakpoints, per-server WebSocket registry, and pre-resolved breakpoint identity from the outer caller.
grpcFrameBytes() - Method in class org.mockserver.netty.http3.GrpcHttp3Adapter.GrpcResponseParts
 
GrpcHttp3Adapter - Class in org.mockserver.netty.http3
Adapter that bridges gRPC request/response framing for the HTTP/3 path.
GrpcHttp3Adapter.GrpcResponseParts - Class in org.mockserver.netty.http3
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.
grpcMessage() - Method in class org.mockserver.netty.http3.GrpcHttp3Adapter.GrpcResponseParts
 
GrpcResponseParts(byte[], String, String) - Constructor for class org.mockserver.netty.http3.GrpcHttp3Adapter.GrpcResponseParts
 
grpcStatus() - Method in class org.mockserver.netty.http3.GrpcHttp3Adapter.GrpcResponseParts
 
GrpcToHttpRequestHandler - Class in org.mockserver.netty.grpc
 
GrpcToHttpRequestHandler(Configuration, MockServerLogger, GrpcProtoDescriptorStore) - Constructor for class org.mockserver.netty.grpc.GrpcToHttpRequestHandler
Preferred constructor: carries the live Configuration so maxGrpcMessageSize set on a Configuration instance (or via the DTO / PUT /mockserver/config) actually reaches enforcement, rather than only the static property store being consulted.
GrpcToHttpRequestHandler(MockServerLogger, GrpcProtoDescriptorStore) - Constructor for class org.mockserver.netty.grpc.GrpcToHttpRequestHandler
 
GrpcToHttpRequestHandler(MockServerLogger, GrpcProtoDescriptorStore, GrpcHealthCheckHandler) - Constructor for class org.mockserver.netty.grpc.GrpcToHttpRequestHandler
 
GrpcToHttpRequestHandler(MockServerLogger, GrpcProtoDescriptorStore, GrpcHealthCheckHandler, GrpcChaosRegistry, HttpQuotaRegistry) - Constructor for class org.mockserver.netty.grpc.GrpcToHttpRequestHandler
 
GrpcToHttpResponseHandler - Class in org.mockserver.netty.grpc
Converts a matched (JSON-bodied) HttpResponse back into a gRPC wire response: a length-prefixed protobuf frame plus a grpc-status trailer.
GrpcToHttpResponseHandler(MockServerLogger, GrpcProtoDescriptorStore) - Constructor for class org.mockserver.netty.grpc.GrpcToHttpResponseHandler
 

H

H2C_PREFACE - Static variable in class org.mockserver.netty.unification.PortUnificationHandler
 
H2C_PREFACE_LENGTH - Static variable in class org.mockserver.netty.unification.PortUnificationHandler
 
handleDelete(String) - Method in class org.mockserver.netty.mcp.McpRequestProcessor
Process an MCP DELETE request.
handleGet() - Method in class org.mockserver.netty.mcp.McpRequestProcessor
Process an MCP GET request (currently not supported -- returns 405).
handleOptions(boolean) - Method in class org.mockserver.netty.mcp.McpRequestProcessor
Process an MCP OPTIONS request (CORS preflight or method-not-allowed).
handlePost(String, String) - Method in class org.mockserver.netty.mcp.McpRequestProcessor
Process an MCP POST request.
handlePost(String, String, ControlPlaneAuthentication) - Method in class org.mockserver.netty.mcp.McpRequestProcessor
Process an MCP POST request, enforcing per-tool control-plane authorization for tools/call using the authenticated principal's verified scopes.
handlerAdded(ChannelHandlerContext) - Method in class org.mockserver.netty.connection.Http2StreamWriteStallHandler
 
handlerAdded(ChannelHandlerContext) - Method in class org.mockserver.netty.connection.InboundConnectionIdleHandler
 
handlerAdded(ChannelHandlerContext) - Method in class org.mockserver.netty.connection.WriteStallTimeoutHandler
 
handlerAdded(ChannelHandlerContext) - Method in class org.mockserver.netty.grpc.GrpcBidiReflectionHandler
 
handlerAdded(ChannelHandlerContext) - Method in class org.mockserver.netty.grpc.GrpcBidiStreamHandler
 
handlerAdded(ChannelHandlerContext) - Method in class org.mockserver.netty.http3.Http3StreamWriteStallHandler
 
handlerAdded(ChannelHandlerContext) - Method in class org.mockserver.netty.MockServerUnificationInitializer
 
handlerAdded(ChannelHandlerContext) - Method in class org.mockserver.netty.proxy.relay.LoopbackHttp2StreamErrorHandler
 
handlerAdded(ChannelHandlerContext) - Method in class org.mockserver.netty.proxy.relay.LoopbackRelaySignalHandler
 
handlerAdded(ChannelHandlerContext) - Method in class org.mockserver.netty.unification.ConnectionScopeHandler
 
handlerRemoved(ChannelHandlerContext) - Method in class org.mockserver.dashboard.DashboardWebSocketHandler
 
handlerRemoved(ChannelHandlerContext) - Method in class org.mockserver.netty.connection.Http2StreamWriteStallHandler
 
handlerRemoved(ChannelHandlerContext) - Method in class org.mockserver.netty.connection.WriteStallTimeoutHandler
 
handlerRemoved(ChannelHandlerContext) - Method in class org.mockserver.netty.http3.Http3ConnectUdpHandler
 
handlerRemoved(ChannelHandlerContext) - Method in class org.mockserver.netty.http3.Http3MockServerHandler
 
handlerRemoved(ChannelHandlerContext) - Method in class org.mockserver.netty.http3.Http3StreamWriteStallHandler
 
handlerRemoved(ChannelHandlerContext) - Method in class org.mockserver.netty.proxy.BinaryMessageGatherer
 
handlerRemoved(ChannelHandlerContext) - Method in class org.mockserver.netty.proxy.BinaryRequestProxyingHandler
 
handlerRemoved(ChannelHandlerContext) - Method in class org.mockserver.netty.proxy.ProxyProtocolOriginalDestinationHandler
 
handlerRemoved(ChannelHandlerContext) - Method in class org.mockserver.netty.unification.TcpChaosHandler
 
handlerRemoved0(ChannelHandlerContext) - Method in class org.mockserver.netty.unification.PortUnificationHandler
 
hasBody() - Method in class org.mockserver.netty.http3.GrpcHttp3Adapter.GrpcResponseParts
 
hasBody() - Method in class org.mockserver.netty.mcp.McpRequestProcessor.McpResult
 
hasRelay(Channel) - Static method in class org.mockserver.netty.proxy.relay.BinaryRelay
Whether this connection has a relay, which then holds the client back itself when MockServer's own reply leaves it not writable (BinaryRelay.answeredLocally(io.netty.channel.Channel, java.lang.String)).
hasStarted() - Method in class org.mockserver.integration.ClientAndServer
 
HEADER_SIZE - Static variable in class org.mockserver.async.serde.ConfluentWireFormat
Size in bytes of the wire-format header (magic byte + 4-byte schema id).
headers() - Method in class org.mockserver.netty.http3.Http3RequestBridge.ParsedHeaders
 
HealthCheck - Class in org.mockserver.cli
Readiness probe: PUT /mockserver/status on localhost, exit 0 only on HTTP 200.
HealthCheck() - Constructor for class org.mockserver.cli.HealthCheck
 
heldOnIpv4(int) - Static method in class org.mockserver.lifecycle.Ipv4UdpPortProbe
 
host - Variable in class org.mockserver.netty.proxy.relay.RelayConnectHandler
 
Http1RequestCutShort - Class in org.mockserver.netty.unification
What MockServer logs when an HTTP/1.1 connection closes, by its client's close or reset or otherwise, while a request's body is still arriving: one INFO entry with the request's method, path, query string and headers where the aggregator still holds them, and no stack trace, as an HTTP/2 stream that ends with its connection is logged by Http2StreamFaults.
HTTP2_ENABLED - Static variable in class org.mockserver.netty.unification.PortUnificationHandler
 
HTTP2_MAX_CONCURRENT_STREAMS - Static variable in class org.mockserver.netty.unification.PortUnificationHandler
The HTTP/2 SETTINGS_MAX_CONCURRENT_STREAMS MockServer advertises on every HTTP/2 connection, and which Netty enforces by refusing further streams with REFUSED_STREAM (AbstractHttp2ConnectionHandlerBuilder.enforceMaxActiveStreams → connection.remote().maxActiveStreams(...)).
Http2ConnectionExceptionHandler - Class in org.mockserver.netty.unification
The last handler of a direct HTTP/2 connection's pipeline.
Http2ConnectionExceptionHandler(MockServerLogger) - Constructor for class org.mockserver.netty.unification.Http2ConnectionExceptionHandler
 
http2Enabled(Channel) - Static method in class org.mockserver.netty.unification.PortUnificationHandler
 
Http2GoAwayEmitter - Class in org.mockserver.netty.unification
Emits an HTTP/2 GOAWAY frame on the connection carrying ctx so the client is told to stop opening new streams and drain — the graceful "this connection is going away" signal a server sends before a shutdown / preemption.
Http2MultiplexChildInitializer - Class in org.mockserver.netty.unification
Per-stream child initializer used with Http2MultiplexHandler to build the pipeline for every HTTP/2 stream.
Http2MultiplexChildInitializer(Configuration, LifeCycle, HttpState, HttpActionHandler, MockServerLogger, McpStreamableHttpHandler, boolean, Certificate[]) - Constructor for class org.mockserver.netty.unification.Http2MultiplexChildInitializer
 
Http2RequestHeaderLimit - Class in org.mockserver.netty.unification
Limits the header list of an HTTP/2 request to maxHeaderSize, as HTTP/1.1 limits its header section, and logs each request refused for it.
Http2StreamFaults - Class in org.mockserver.netty.unification
What MockServer logs when an HTTP/2 stream ends before it should, on a connection made straight to MockServer and on the client leg of a CONNECT or SOCKS tunnel alike, each once and with no stack trace: INFO for a request its client cancelled, or whose connection closed, before it was complete; WARN for an error of the stream's own, which Netty then resets the stream for with the error's code; WARN for a connection Netty closes because it had to be sent too many of those resets. See "HTTP/2 streams cut short" in docs/code/netty-pipeline.md for what bounds the entries of one connection.
Http2StreamTransportTimer - Class in org.mockserver.netty.connection
Times one HTTP/2 stream for mock_server_request_transport_duration_seconds: from its first HEADERS frame reaching the stream's channel to the write of the frame that ends the response stream completing.
Http2StreamTransportTimer() - Constructor for class org.mockserver.netty.connection.Http2StreamTransportTimer
 
Http2StreamWriteStallHandler - Class in org.mockserver.netty.connection
Resets an HTTP/2 stream whose response has data waiting in the connection's flow controller that the client has taken none of for responseWriteStallTimeoutMillis.
Http2StreamWriteStallHandler(long, MockServerLogger) - Constructor for class org.mockserver.netty.connection.Http2StreamWriteStallHandler
 
HTTP3 - Static variable in class org.mockserver.netty.unification.ClientTlsHandshakeFailureLog
 
Http3ConnectUdpHandler - Class in org.mockserver.netty.http3
HTTP/3 CONNECT-UDP (MASQUE, RFC 9298) relay handler.
Http3ConnectUdpHandler(Configuration, MockServerLogger) - Constructor for class org.mockserver.netty.http3.Http3ConnectUdpHandler
 
Http3ExceptionHandler - Class in org.mockserver.netty.http3
The last handler of an HTTP/3 connection's pipeline.
Http3GrpcBidiStreamHandler - Class in org.mockserver.netty.http3
Drives true bidirectional gRPC streaming over a single QUIC bidirectional stream (HTTP/3).
Http3GrpcBidiStreamHandler(ChannelHandlerContext, Descriptors.MethodDescriptor, GrpcJsonMessageConverter, GrpcBidiResponse, Runnable, MockServerLogger) - Constructor for class org.mockserver.netty.http3.Http3GrpcBidiStreamHandler
Constructs a bidi handler without inbound breakpoint support (default path).
Http3GrpcBidiStreamHandler(ChannelHandlerContext, Descriptors.MethodDescriptor, GrpcJsonMessageConverter, GrpcBidiResponse, Runnable, MockServerLogger, Configuration, String, String, String, WebSocketClientRegistry) - Constructor for class org.mockserver.netty.http3.Http3GrpcBidiStreamHandler
Constructs a bidi handler with optional inbound (client-to-server) breakpoint support.
Http3GrpcResponseWriter - Class in org.mockserver.netty.http3
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, plus any trailing metadata the expectation authored with withTrailer(...)).
Http3GrpcResponseWriter(Configuration, MockServerLogger, ChannelHandlerContext, GrpcProtoDescriptorStore, String, String) - Constructor for class org.mockserver.netty.http3.Http3GrpcResponseWriter
 
Http3GrpcResponseWriter(Configuration, MockServerLogger, ChannelHandlerContext, GrpcProtoDescriptorStore, String, String, WebSocketClientRegistry) - Constructor for class org.mockserver.netty.http3.Http3GrpcResponseWriter
 
Http3ListenerExceptionHandler - Class in org.mockserver.netty.http3
The last handler of the HTTP/3 UDP listener's pipeline, behind the QUIC codec, which takes no exception itself.
Http3ListenerExceptionHandler(MockServerLogger) - Constructor for class org.mockserver.netty.http3.Http3ListenerExceptionHandler
 
Http3MockServerHandler - Class in org.mockserver.netty.http3
HTTP/3 request stream handler that bridges incoming QUIC requests into MockServer's standard request-processing pipeline (expectation matching, actions, recording, proxy forwarding).
Http3MockServerHandler(Configuration, MockServerLogger, HttpState, HttpActionHandler, Metrics) - Constructor for class org.mockserver.netty.http3.Http3MockServerHandler
 
Http3MockServerHandler(Configuration, MockServerLogger, HttpState, HttpActionHandler, Metrics, McpRequestProcessor) - Constructor for class org.mockserver.netty.http3.Http3MockServerHandler
 
Http3NativeUnavailableException - Exception in org.mockserver.netty.http3
Thrown at start-up when http3Port is set but the QUIC native library cannot be loaded.
Http3NativeUnavailableException(int, Throwable) - Constructor for exception org.mockserver.netty.http3.Http3NativeUnavailableException
 
Http3RequestBridge - Class in org.mockserver.netty.http3
Converts between HTTP/3 frames and MockServer's HttpRequest/HttpResponse model.
Http3RequestBridge.ParsedHeaders - Class in org.mockserver.netty.http3
Parsed HTTP/3 pseudo-headers and regular headers.
Http3ResponseWriter - Class in org.mockserver.netty.http3
A ResponseWriter that serialises the MockServer HttpResponse as HTTP/3 frames and writes them to a QUIC stream channel.
Http3ResponseWriter(Configuration, MockServerLogger, ChannelHandlerContext) - Constructor for class org.mockserver.netty.http3.Http3ResponseWriter
 
Http3Server - Class in org.mockserver.netty.http3
HTTP/3 (QUIC) server for MockServer, integrated with the full request pipeline.
Http3Server() - Constructor for class org.mockserver.netty.http3.Http3Server
Legacy constructor for backwards compatibility (echo-only mode).
Http3Server(Configuration, MockServerLogger, HttpState, HttpActionHandler) - Constructor for class org.mockserver.netty.http3.Http3Server
Create an HTTP/3 server wired into MockServer's request pipeline (no MCP).
Http3Server(Configuration, MockServerLogger, HttpState, HttpActionHandler, LifeCycle, McpSessionManager) - Constructor for class org.mockserver.netty.http3.Http3Server
Create an HTTP/3 server wired into MockServer's request pipeline, with MCP support.
Http3StartupException - Exception in org.mockserver.netty.http3
Thrown at start-up when http3Port is set and the HTTP/3 server could not be started on it, so that MockServer does not run without a protocol it was configured to serve.
Http3StartupException(int, Throwable) - Constructor for exception org.mockserver.netty.http3.Http3StartupException
 
Http3StreamWriteStallHandler - Class in org.mockserver.netty.http3
Resets an HTTP/3 request stream (RESET_STREAM H3_INTERNAL_ERROR) when writes have been waiting on it for responseWriteStallTimeoutMillis and QUIC has taken none of them, so a client that stops reading a response cannot hold it, or a streamed response's upstream, indefinitely.
Http3StreamWriteStallHandler(long, MockServerLogger) - Constructor for class org.mockserver.netty.http3.Http3StreamWriteStallHandler
 
HttpConnectHandler - Class in org.mockserver.netty.proxy.connect
 
HttpConnectHandler(Configuration, LifeCycle, MockServerLogger, String, int) - Constructor for class org.mockserver.netty.proxy.connect.HttpConnectHandler
 
HttpContentLengthRemover - Class in org.mockserver.netty.unification
 
HttpContentLengthRemover() - Constructor for class org.mockserver.netty.unification.HttpContentLengthRemover
 
httpEnabled(Channel) - Static method in class org.mockserver.netty.unification.PortUnificationHandler
 
HttpExchangeTracker - Class in org.mockserver.netty.connection
Counts HTTP/1.1 exchanges in progress on a connection for InboundConnectionIdleHandler: an exchange starts when a request head is decoded and ends when the last part of its response has been written to the socket, so a delayed, paused or streaming response keeps the connection busy.
HttpRequestHandler - Class in org.mockserver.netty
 
HttpRequestHandler(Configuration, LifeCycle, HttpState, HttpActionHandler) - Constructor for class org.mockserver.netty.HttpRequestHandler
 
httpServerCodec(Configuration) - Static method in class org.mockserver.netty.unification.HttpServerCodecs
Without a bound on requests awaiting their response, as on 8.0.0: Netty's default of 128 would close a connection whose client pipelines more requests than that before the first is answered.
HttpServerCodecResponsePairing - Class in org.mockserver.netty.unification
Keeps HttpServerCodec pairing each response with the request it answers when an exchange ends without its response passing the codec's encoder.
HttpServerCodecResponsePairing() - Constructor for class org.mockserver.netty.unification.HttpServerCodecResponsePairing
 
HttpServerCodecs - Class in org.mockserver.netty.unification
The HttpServerCodec of an HTTP/1.1 connection a client opens, directly or through a CONNECT/SOCKS tunnel.
httpState - Variable in class org.mockserver.lifecycle.LifeCycle
 
HttpTransportTimer - Class in org.mockserver.netty.connection
Times each HTTP/1.1 exchange on a connection for mock_server_request_transport_duration_seconds: from the request head being decoded to the write of the last part of its response completing on the socket.
HttpTransportTimer() - Constructor for class org.mockserver.netty.connection.HttpTransportTimer
 

I

InboundConnectionActivity - Class in org.mockserver.netty.connection
What an inbound connection is doing, so InboundConnectionIdleHandler closes only connections that are genuinely quiet.
InboundConnectionActivity() - Constructor for class org.mockserver.netty.connection.InboundConnectionActivity
 
InboundConnectionIdleHandler - Class in org.mockserver.netty.connection
Closes an inbound connection that has read and written nothing for inboundConnectionIdleTimeoutMillis and has nothing in progress (see InboundConnectionActivity.isBusy(io.netty.channel.Channel)).
InboundConnectionIdleHandler(long, MockServerLogger) - Constructor for class org.mockserver.netty.connection.InboundConnectionIdleHandler
 
InboundConnectionLimiter - Class in org.mockserver.netty.connection
Counts the inbound connections a MockServer holds open and, when maxInboundConnections is set, refuses any connection accepted beyond it.
InboundConnectionLimiter(Configuration, MockServerLogger) - Constructor for class org.mockserver.netty.connection.InboundConnectionLimiter
 
InFlightRequest - Class in org.mockserver.netty
Per-request in-flight token used by the WS7.2 graceful-shutdown connection drain.
initChannel(Http2StreamChannel) - Method in class org.mockserver.netty.unification.Http2MultiplexChildInitializer
 
install(Channel) - Static method in class org.mockserver.netty.unification.BinaryAwareRecvByteBufAllocator
Wraps the channel's allocator.
installReAggregatingChain(ChannelPipeline, Configuration, MockServerLogger, boolean, Certificate[], Channel, CallbackWebSocketServerHandler, DashboardWebSocketHandler, McpStreamableHttpHandler, TraceContextHandler, AltSvcHeaderHandler, GrpcToHttpResponseHandler, GrpcToHttpRequestHandler, HttpRequestHandler) - Static method in class org.mockserver.netty.unification.Http2MultiplexChildInitializer
Installs the re-aggregating chain into the given pipeline: converts HTTP/2 stream frames back into FullHttpRequest/FullHttpResponse and adds the downstream handler chain (WebSocket, MCP, gRPC codec, request handler).
INSTANCE - Static variable in class org.mockserver.netty.connection.HttpExchangeTracker
 
INSTANCE - Static variable in class org.mockserver.netty.proxy.relay.LoopbackRelaySignalHandler
 
INSTANCE - Static variable in class org.mockserver.netty.unification.ConnectionScopeHandler
 
INSTANCE - Static variable in class org.mockserver.netty.unification.StreamAddressedContentHandler
 
INTERNAL_ERROR - Static variable in class org.mockserver.netty.mcp.JsonRpcMessage
 
invalid(String) - Static method in class org.mockserver.async.validation.AsyncApiSchemaValidator.ValidationResult
 
INVALID_PARAMS - Static variable in class org.mockserver.netty.mcp.JsonRpcMessage
 
INVALID_REQUEST - Static variable in class org.mockserver.netty.mcp.JsonRpcMessage
 
Ipv4UdpPortProbe - Class in org.mockserver.lifecycle
The UDP counterpart of the TCP listeners' LoopbackShadowProbe, for the HTTP/3 and DNS listeners.
ipv4WildcardConflict(int, String, String) - Static method in class org.mockserver.lifecycle.Ipv4UdpPortProbe
 
isAuthenticated(Configuration, MockServerLogger, HttpRequest, ResponseWriter) - Static method in class org.mockserver.netty.DataPlaneAuthenticationGate
Apply the data-plane authentication gate.
isEmpty() - Method in class org.mockserver.async.publish.PublishOptions
 
isEmpty() - Method in class org.mockserver.async.security.KafkaSecurity
Returns true when no security fields are set (all null or blank).
isEmpty() - Method in class org.mockserver.async.security.MqttSecurity
Returns true when no security fields are set.
isEnabled() - Method in class org.mockserver.netty.proxy.TransparentProxyInitializer
 
isExchangeDurable() - Method in class org.mockserver.async.asyncapi.AmqpBinding
 
isExempt(Channel) - Static method in class org.mockserver.netty.connection.WriteStallTimeoutHandler
 
isFailedHandshake(Throwable) - Static method in class org.mockserver.netty.unification.ClientTlsHandshakeFailureLog
Whether cause is or wraps a failed handshake of any TLS engine: OpenSSL's is a subclass of SSLHandshakeException.
isGrpcRequest(String) - Static method in class org.mockserver.netty.http3.GrpcHttp3Adapter
Detect whether the given content-type indicates a gRPC request.
isHealthy() - Method in class org.mockserver.async.subscribe.KafkaAvroMessageSubscriber
 
isHealthy() - Method in class org.mockserver.async.subscribe.KafkaMessageSubscriber
Returns false if the background poll loop has terminated because of an unexpected error (the subscriber is dead and will record no further messages).
isHealthy() - Method in class org.mockserver.async.subscribe.Mqtt5MessageSubscriber
Returns false if the MQTT callback has reported a disconnect.
isHealthy() - Method in class org.mockserver.async.subscribe.MqttMessageSubscriber
Returns false if the MQTT callback has reported a lost connection (the subscriber will record no further messages until reconnected); true otherwise.
isHttp2Enabled(Channel) - Static method in class org.mockserver.netty.unification.PortUnificationHandler
 
isHttpEnabled(Channel) - Static method in class org.mockserver.netty.unification.PortUnificationHandler
 
isIdPresent() - Method in class org.mockserver.netty.mcp.JsonRpcMessage.JsonRpcRequest
 
isInitialized() - Method in class org.mockserver.netty.mcp.McpSession
 
isMcpPath(String) - Static method in class org.mockserver.netty.mcp.McpRequestProcessor
Check if a path matches the MCP endpoint.
isMutatingTool(String) - Static method in class org.mockserver.netty.mcp.McpToolRegistry
Whether the named tool mutates control-plane state (and so requires the MUTATE role when control-plane authorization is enforced).
isNotification() - Method in class org.mockserver.netty.mcp.JsonRpcMessage.JsonRpcRequest
 
isPartialOrCompleteH2cPreface(ByteBuf, int) - Static method in class org.mockserver.netty.unification.PortUnificationHandler
Whether the readableBytes at buf's reader index are still a viable prefix of the h2c connection preface - true while they match the preface (whether the full 24 bytes have arrived yet or not), false as soon as they diverge from it.
isPassed() - Method in class org.mockserver.netty.mcp.McpContractTest.CheckResult
 
isPlatformSupported() - Method in class org.mockserver.netty.proxy.EbpfOriginalDestinationResolver
Returns true if the platform supports eBPF map operations: Linux OS, Netty epoll transport, and JNA.
isPortUnavailable() - Method in exception org.mockserver.netty.dns.DnsStartupException
 
isPortUnavailable() - Method in exception org.mockserver.netty.http3.Http3StartupException
 
isQueueDurable() - Method in class org.mockserver.async.asyncapi.AmqpBinding
 
isQuicAvailable() - Static method in class org.mockserver.netty.http3.Http3Server
Check whether the native QUIC transport is available on this platform.
isReading(Channel) - Static method in class org.mockserver.netty.unification.BinaryAwareRecvByteBufAllocator
Whether the channel is inside a read loop: from its first read until just before its channelReadComplete.
isRefusedRequestCutShort(Channel, Throwable) - Static method in class org.mockserver.netty.unification.Http2RequestHeaderLimit
Whether cause is the aggregator reporting the part of a request it held when the stream was reset for its trailers: expected, and already logged as the refusal, so not worth logging again.
isRelayLoopback(Channel) - Static method in class org.mockserver.netty.proxy.relay.RelayLoopbackAddresses
 
isRequestCutShort(MockServerLogger, ChannelHandlerContext, Throwable) - Static method in class org.mockserver.netty.unification.Http1RequestCutShort
Whether cause is the aggregator of an HTTP/1.1 connection that has closed reporting the part of a request it held, which this logs.
isRequestCutShort(MockServerLogger, Channel, Throwable) - Static method in class org.mockserver.netty.unification.Http2StreamFaults
Whether cause is the aggregator of a direct connection's stream reporting the part of a request it held when the stream closed, for a reason found here: an error already logged, the client's cancel or the connection's end, each of the last two logged here.
isRequired() - Method in class org.mockserver.netty.mcp.McpPromptRegistry.PromptArgument
 
isRunning() - Method in class org.mockserver.integration.ClientAndServer
 
isRunning() - Method in class org.mockserver.lifecycle.LifeCycle
 
isSocks4(ByteBuf, int) - Static method in class org.mockserver.netty.proxy.socks.SocksDetector
 
isSocks5(ByteBuf, int) - Static method in class org.mockserver.netty.proxy.socks.SocksDetector
 
isSslEnabledDownstream(Channel) - Static method in class org.mockserver.netty.unification.PortUnificationHandler
 
isSslEnabledUpstream(Channel) - Static method in class org.mockserver.netty.unification.PortUnificationHandler
 
isSupported() - Static method in class org.mockserver.netty.proxy.SoOriginalDstHelper
Returns true if the current OS is Linux, which is the only platform where SO_ORIGINAL_DST / conntrack-based original destination resolution is supported.
isSupported() - Method in class org.mockserver.netty.proxy.SoOriginalDstResolver
Returns true if this resolver can function on the current platform: Linux OS, Netty epoll transport available, and JNA native loadable.
isTlsDetectionDeferred(Channel) - Static method in class org.mockserver.netty.unification.PortUnificationHandler
 
isTracked(Channel) - Static method in class org.mockserver.netty.connection.InboundConnectionActivity
Whether an idle timeout is watching this connection, and so whether its HTTP exchanges need counting.
isValid() - Method in class org.mockserver.async.validation.AsyncApiSchemaValidator.ValidationResult
 
isValidFilter(String) - Static method in class org.mockserver.async.subscribe.MqttTopicFilter
 
isValidSession(String) - Method in class org.mockserver.netty.mcp.McpSessionManager
 
isWireFormat(byte[]) - Static method in class org.mockserver.async.serde.ConfluentWireFormat
 

J

JsonRpcError() - Constructor for class org.mockserver.netty.mcp.JsonRpcMessage.JsonRpcError
 
JsonRpcMessage - Class in org.mockserver.netty.mcp
 
JsonRpcMessage() - Constructor for class org.mockserver.netty.mcp.JsonRpcMessage
 
JsonRpcMessage.JsonRpcError - Class in org.mockserver.netty.mcp
 
JsonRpcMessage.JsonRpcNotification - Class in org.mockserver.netty.mcp
 
JsonRpcMessage.JsonRpcRequest - Class in org.mockserver.netty.mcp
 
JsonRpcMessage.JsonRpcResponse - Class in org.mockserver.netty.mcp
 
JsonRpcNotification() - Constructor for class org.mockserver.netty.mcp.JsonRpcMessage.JsonRpcNotification
 
JsonRpcRequest() - Constructor for class org.mockserver.netty.mcp.JsonRpcMessage.JsonRpcRequest
 
JsonRpcResponse() - Constructor for class org.mockserver.netty.mcp.JsonRpcMessage.JsonRpcResponse
 
jsonToAvro(Schema, String) - Static method in class org.mockserver.async.serde.AvroPayloadCodec
Encode a JSON payload as Avro binary for the given schema.

K

KafkaAvroMessagePublisher - Class in org.mockserver.async.publish
A MessagePublisher that publishes Avro messages to Kafka in the Confluent Schema Registry wire format (magic byte + schema id + Avro binary), so real Confluent Avro consumers can read them.
KafkaAvroMessagePublisher(String, KafkaSecurity, String, SchemaRegistryClient, int) - Constructor for class org.mockserver.async.publish.KafkaAvroMessagePublisher
 
KafkaAvroMessageSubscriber - Class in org.mockserver.async.subscribe
A MessageSubscriber that consumes Confluent wire-format Avro messages from Kafka and records them as JSON — the consume/verify counterpart of KafkaAvroMessagePublisher.
KafkaAvroMessageSubscriber(String, String, int, KafkaSecurity, SchemaRegistryClient, String) - Constructor for class org.mockserver.async.subscribe.KafkaAvroMessageSubscriber
 
KafkaAvroMessageSubscriber(String, String, int, KafkaSecurity, SchemaRegistryClient, String, int) - Constructor for class org.mockserver.async.subscribe.KafkaAvroMessageSubscriber
 
KafkaMessagePublisher - Class in org.mockserver.async.publish
A MessagePublisher that delegates to a Kafka KafkaProducer.
KafkaMessagePublisher(String) - Constructor for class org.mockserver.async.publish.KafkaMessagePublisher
Create a publisher connected to the given Kafka bootstrap servers using plaintext (no security).
KafkaMessagePublisher(String, KafkaSecurity) - Constructor for class org.mockserver.async.publish.KafkaMessagePublisher
Create a publisher connected to the given Kafka bootstrap servers with optional security configuration.
KafkaMessageSubscriber - Class in org.mockserver.async.subscribe
A MessageSubscriber that uses a Kafka KafkaConsumer to subscribe to topics and record received messages.
KafkaMessageSubscriber(String, String) - Constructor for class org.mockserver.async.subscribe.KafkaMessageSubscriber
Create a subscriber connected to the given Kafka bootstrap servers using plaintext (no security).
KafkaMessageSubscriber(String, String, int) - Constructor for class org.mockserver.async.subscribe.KafkaMessageSubscriber
Create a subscriber with a custom recorded-message cap per channel.
KafkaMessageSubscriber(String, String, int, KafkaSecurity) - Constructor for class org.mockserver.async.subscribe.KafkaMessageSubscriber
Create a subscriber with optional security configuration.
KafkaSecurity - Class in org.mockserver.async.security
Immutable carrier for Kafka security configuration (SASL and/or SSL).
KafkaSecurity.Builder - Class in org.mockserver.async.security
 
KafkaSecurityProperties - Class in org.mockserver.async.security
Utility for applying KafkaSecurity settings to Kafka client Properties.

L

length() - Method in interface org.mockserver.dashboard.serializers.Description
 
length() - Method in class org.mockserver.dashboard.serializers.LogMessageDescription
 
length() - Method in class org.mockserver.dashboard.serializers.ReceivedRequestDescription
 
length() - Method in class org.mockserver.dashboard.serializers.RequestDefinitionDescription
 
length() - Method in class org.mockserver.dashboard.serializers.RequestDefinitionObjectDescription
 
LengthPrefixMessageFramer - Class in org.mockserver.netty.proxy
Cuts a binary connection into messages that each carry their own length: offset bytes, then an unsigned length field of prefixBytes (1, 2, 4 or 8) in the byte order given, then the body.
LengthPrefixMessageFramer(int, MockServerLogger, int, int, ByteOrder, boolean) - Constructor for class org.mockserver.netty.proxy.LengthPrefixMessageFramer
 
LenientInboundHttp2StreamFrameCodec - Class in org.mockserver.netty.unification
A Http2StreamFrameToHttpObjectCodec that is lenient on the INBOUND (request) side but strict on the OUTBOUND (response) side.
LenientInboundHttp2StreamFrameCodec() - Constructor for class org.mockserver.netty.unification.LenientInboundHttp2StreamFrameCodec
 
LifeCycle - Class in org.mockserver.lifecycle
 
LifeCycle(Configuration) - Constructor for class org.mockserver.lifecycle.LifeCycle
 
limitComponents(CompositeByteBuf, int, int) - Static method in class org.mockserver.netty.http3.Http3RequestBridge
Keeps composite under componentLimit components when Http3RequestBridge.accumulateBody(io.netty.buffer.CompositeByteBuf, io.netty.handler.codec.http3.Http3DataFrame) alone does not, which takes pieces alternating between small and 16 KiB or more.
listenerAddress(String, int) - Static method in class org.mockserver.lifecycle.Ipv4UdpPortProbe
 
load(String) - Method in class org.mockserver.async.controlplane.AsyncApiControlPlaneImpl
Replaces whatever is loaded.
LOCAL_HOST_HEADERS - Static variable in class org.mockserver.netty.HttpRequestHandler
 
log(MockServerLogger, Configuration, String, SocketAddress, Throwable) - Method in class org.mockserver.netty.unification.ClientTlsHandshakeFailureLog
 
logClientAlert(MockServerLogger, Configuration, String, SocketAddress, int) - Method in class org.mockserver.netty.unification.ClientTlsHandshakeFailureLog
For a client that ended the handshake with a TLS alert of its own, which a QUIC server sees only as the client's close of the connection.
logLevel - Enum constant in enum class org.mockserver.cli.Main.Arguments
 
LogMessageDescription - Class in org.mockserver.dashboard.serializers
 
LogMessageDescription(String, String, DescriptionProcessor) - Constructor for class org.mockserver.dashboard.serializers.LogMessageDescription
 
logStyle(DashboardLogEntryDTO) - Method in class org.mockserver.dashboard.serializers.DashboardLogEntryDTOSerializer
 
longEnvironmentVariableName() - Method in enum class org.mockserver.cli.Main.Arguments
 
LoopbackHttp1ResponseErrorHandler - Class in org.mockserver.netty.proxy.relay
Answers the proxy client with a 502 when the CONNECT/SOCKS relay's HTTP/1.1 loopback fails to decode a response (a corrupt compressed body, one larger than maxRequestBodySize, or one the codec marks as failed) before its head has been relayed.
LoopbackHttp1ResponseErrorHandler(Channel) - Constructor for class org.mockserver.netty.proxy.relay.LoopbackHttp1ResponseErrorHandler
 
LoopbackHttp2ConnectionCloseHandler - Class in org.mockserver.netty.proxy.relay
Ends the proxy client's HTTP/2 streams at once when the CONNECT/SOCKS relay's HTTP/2 loopback connection closes, for any reason, instead of leaving them to Netty's 30 s graceful-shutdown timeout.
LoopbackHttp2ConnectionCloseHandler(MockServerLogger, Http2Connection, Channel, LoopbackHttp2StreamIdRemapper) - Constructor for class org.mockserver.netty.proxy.relay.LoopbackHttp2ConnectionCloseHandler
 
LoopbackHttp2StreamErrorHandler - Class in org.mockserver.netty.proxy.relay
Answers the proxy client's HTTP/2 stream when the CONNECT/SOCKS relay's HTTP/2 loopback stream for it ends without a response: the response failed to decode, passed maxRequestBodySize, or MockServer reset the stream.
LoopbackHttp2StreamErrorHandler(MockServerLogger, Http2Connection, LoopbackHttp2StreamIdRemapper, Channel) - Constructor for class org.mockserver.netty.proxy.relay.LoopbackHttp2StreamErrorHandler
 
LoopbackHttp2StreamIdRemapper - Class in org.mockserver.netty.proxy.relay
Gives each request the CONNECT/SOCKS relay writes to its HTTP/2 loopback a loopback stream id of its own, and puts the proxy client's stream id back on the response.
LoopbackHttp2StreamIdRemapper(MockServerLogger, Http2Connection, Channel) - Constructor for class org.mockserver.netty.proxy.relay.LoopbackHttp2StreamIdRemapper
 
loopbackReachesAnotherSocket(Channel) - Static method in class org.mockserver.lifecycle.Ipv4UdpPortProbe
The check after the bind, for a socket that took the port on 0.0.0.0 between Ipv4UdpPortProbe.shadowedOnIpv4(java.net.InetSocketAddress) and the server's bind: a datagram is sent to 127.0.0.1 on the bound port, and must arrive on boundChannel.
LoopbackRelaySignalHandler - Class in org.mockserver.netty.proxy.relay
On MockServer's side of an HTTP/1.1 relay loopback, after its codec: tells the tunnel's relay what the bytes on the loopback cannot.

M

MAGIC_BYTE - Static variable in class org.mockserver.async.serde.ConfluentWireFormat
The Confluent magic byte that prefixes every schema-registry-framed message.
main(String...) - Static method in class org.mockserver.cli.HealthCheck
 
main(String...) - Static method in class org.mockserver.cli.Main
Run the MockServer directly providing the arguments as specified below.
Main - Class in org.mockserver.cli
 
Main() - Constructor for class org.mockserver.cli.Main
 
Main.Arguments - Enum Class in org.mockserver.cli
 
markInitialized() - Method in class org.mockserver.netty.mcp.McpSession
 
markLongLived(Channel) - Static method in class org.mockserver.netty.connection.InboundConnectionActivity
Exempt a connection from the idle timeout for the rest of its life: it has become a WebSocket, a raw binary relay or the loopback leg of a tunnel, whose silences are legitimate and whose traffic is not HTTP exchanges.
matches(String, String) - Static method in class org.mockserver.async.subscribe.MqttTopicFilter
Match a concrete topic name against a topic filter.
MAX_BODY_CHARACTERS - Static variable in class org.mockserver.dashboard.model.DashboardBodyCap
 
MAX_LENGTH - Static variable in interface org.mockserver.dashboard.serializers.Description
 
maxMessageBytes() - Method in class org.mockserver.netty.proxy.BinaryMessageFramer
 
maxMessagesPerRead() - Method in class org.mockserver.netty.unification.BinaryAwareRecvByteBufAllocator
 
maxMessagesPerRead(int) - Method in class org.mockserver.netty.unification.BinaryAwareRecvByteBufAllocator
 
maxTokenLength() - Method in class org.mockserver.netty.http3.SourceAddressQuicTokenHandler
 
McpContractTest - Class in org.mockserver.netty.mcp
Deterministic conformance / contract tester for a target MCP (Model Context Protocol) server reachable over Streamable HTTP.
McpContractTest(ObjectMapper) - Constructor for class org.mockserver.netty.mcp.McpContractTest
 
McpContractTest.CheckResult - Class in org.mockserver.netty.mcp
Outcome of a single named conformance check.
McpContractTest.ExchangeResult - Class in org.mockserver.netty.mcp
Result of a single JSON-RPC exchange.
McpContractTest.JsonRpcExchange - Interface in org.mockserver.netty.mcp
One JSON-RPC exchange against the target server.
McpContractTest.Report - Class in org.mockserver.netty.mcp
Full conformance report.
McpPromptRegistry - Class in org.mockserver.netty.mcp
Registry of MCP prompts exposed by MockServer's own MCP server.
McpPromptRegistry() - Constructor for class org.mockserver.netty.mcp.McpPromptRegistry
 
McpPromptRegistry.MissingPromptArgumentsException - Exception in org.mockserver.netty.mcp
Thrown by McpPromptRegistry.getMessages(java.lang.String, com.fasterxml.jackson.databind.JsonNode) when a prompts/get call omits a required argument, which the MCP prompts specification answers with JSON-RPC error -32602 (invalid params).
McpPromptRegistry.PromptArgument - Class in org.mockserver.netty.mcp
 
McpPromptRegistry.PromptDefinition - Class in org.mockserver.netty.mcp
 
McpRequestProcessor - Class in org.mockserver.netty.mcp
Transport-neutral MCP (Model Context Protocol) JSON-RPC request processor.
McpRequestProcessor(HttpState, LifeCycle, McpSessionManager) - Constructor for class org.mockserver.netty.mcp.McpRequestProcessor
 
McpRequestProcessor.McpResult - Class in org.mockserver.netty.mcp
Result of processing an MCP request.
McpResourceRegistry - Class in org.mockserver.netty.mcp
 
McpResourceRegistry(HttpState) - Constructor for class org.mockserver.netty.mcp.McpResourceRegistry
 
McpResourceRegistry.ResourceDefinition - Class in org.mockserver.netty.mcp
 
McpResult(int, byte[], String) - Constructor for class org.mockserver.netty.mcp.McpRequestProcessor.McpResult
 
McpSession - Class in org.mockserver.netty.mcp
 
McpSession(String) - Constructor for class org.mockserver.netty.mcp.McpSession
 
McpSessionManager - Class in org.mockserver.netty.mcp
 
McpSessionManager(MockServerLogger) - Constructor for class org.mockserver.netty.mcp.McpSessionManager
 
McpStreamableHttpHandler - Class in org.mockserver.netty.mcp
Netty channel handler that intercepts MCP (Model Context Protocol) requests on the TCP (HTTP/1.1 and HTTP/2) path.
McpStreamableHttpHandler(HttpState, LifeCycle, McpSessionManager) - Constructor for class org.mockserver.netty.mcp.McpStreamableHttpHandler
 
McpToolRegistry - Class in org.mockserver.netty.mcp
 
McpToolRegistry(HttpState, LifeCycle) - Constructor for class org.mockserver.netty.mcp.McpToolRegistry
 
McpToolRegistry.ToolDefinition - Class in org.mockserver.netty.mcp
 
MESSAGE_OVERHEAD_CHARACTERS - Static variable in class org.mockserver.dashboard.model.DashboardBodyCap
 
messageBytes(ChannelHandlerContext, ByteBuf) - Method in class org.mockserver.netty.proxy.BinaryMessageFramer
How many bytes the message that starts at the reader index has, BinaryMessageFramer.NOT_YET_KNOWN while the bytes held cannot say, or anything after BinaryMessageFramer.refuse(io.netty.channel.ChannelHandlerContext, io.netty.buffer.ByteBuf, java.lang.String).
messageBytes(ChannelHandlerContext, ByteBuf) - Method in class org.mockserver.netty.proxy.LengthPrefixMessageFramer
 
messageBytes(ChannelHandlerContext, ByteBuf) - Method in class org.mockserver.netty.proxy.MysqlMessageFramer
 
messageBytes(ChannelHandlerContext, ByteBuf) - Method in class org.mockserver.netty.proxy.PostgresqlMessageFramer
 
messageBytes(ChannelHandlerContext, ByteBuf) - Method in class org.mockserver.netty.proxy.RedisMessageFramer
 
MessageExampleGenerator - Class in org.mockserver.async
Generates example JSON payloads for each channel in an AsyncApiSpec.
MessageExampleGenerator() - Constructor for class org.mockserver.async.MessageExampleGenerator
 
MessagePublisher - Interface in org.mockserver.async.publish
Publishes a message payload to a named channel (topic).
MessageSubscriber - Interface in org.mockserver.async.subscribe
Subscribes to a message broker channel and records received messages for later retrieval/verification — the consumer counterpart of MessagePublisher.
messageTaken(ByteBuf) - Method in class org.mockserver.netty.proxy.BinaryMessageFramer
Called with each whole message before it is passed on.
messageTaken(ByteBuf) - Method in class org.mockserver.netty.proxy.MysqlMessageFramer
 
messageTaken(ByteBuf) - Method in class org.mockserver.netty.proxy.PostgresqlMessageFramer
 
messageTaken(ByteBuf) - Method in class org.mockserver.netty.proxy.RedisMessageFramer
 
method() - Method in class org.mockserver.netty.http3.Http3RequestBridge.ParsedHeaders
 
METHOD_NOT_FOUND - Static variable in class org.mockserver.netty.mcp.JsonRpcMessage
 
MissingPromptArgumentsException(String, List<String>) - Constructor for exception org.mockserver.netty.mcp.McpPromptRegistry.MissingPromptArgumentsException
 
MockServer - Class in org.mockserver.netty
 
MockServer(Integer...) - Constructor for class org.mockserver.netty.MockServer
Start the instance using the ports provided
MockServer(Integer, String, Integer...) - Constructor for class org.mockserver.netty.MockServer
Start the instance using the ports provided
MockServer(Configuration, Integer...) - Constructor for class org.mockserver.netty.MockServer
Start the instance using the ports provided
MockServer(Configuration, Integer, String, Integer...) - Constructor for class org.mockserver.netty.MockServer
Start the instance using the ports provided
MockServer(Configuration, List<ProxyConfiguration>, Integer...) - Constructor for class org.mockserver.netty.MockServer
Start the instance using the ports provided configuring forwarded or proxied requests to go via an additional proxy
MockServer(Configuration, List<ProxyConfiguration>, String, Integer, Integer...) - Constructor for class org.mockserver.netty.MockServer
Start the instance using the ports provided configuring forwarded or proxied requests to go via an additional proxy
MockServer(Configuration, ProxyConfiguration, String, Integer, Integer...) - Constructor for class org.mockserver.netty.MockServer
Start the instance using the ports provided configuring forwarded or proxied requests to go via an additional proxy
MockServer(ProxyConfiguration, Integer...) - Constructor for class org.mockserver.netty.MockServer
Start the instance using the ports provided configuring forwarded or proxied requests to go via an additional proxy
MockServerIpTransparentHelper - Class in org.mockserver.netty.proxy
Wires the IP_TRANSPARENT socket option on the server bootstrap when TPROXY mode is enabled.
mockServerLogger - Variable in class org.mockserver.lifecycle.LifeCycle
 
mockServerLogger - Variable in class org.mockserver.netty.proxy.socks.SocksProxyHandler
 
mockServerLogger - Variable in class org.mockserver.netty.unification.PortUnificationHandler
 
MockServerUnificationInitializer - Class in org.mockserver.netty
 
MockServerUnificationInitializer(Configuration, LifeCycle, HttpState, HttpActionHandler, NettySslContextFactory) - Constructor for class org.mockserver.netty.MockServerUnificationInitializer
 
Mqtt5MessagePublisher - Class in org.mockserver.async.publish
A MessagePublisher that delegates to an MQTT v5 MqttClient.
Mqtt5MessagePublisher(String, String) - Constructor for class org.mockserver.async.publish.Mqtt5MessagePublisher
Create a v5 publisher connected to the given broker with default QoS (1) and no security.
Mqtt5MessagePublisher(String, String, int) - Constructor for class org.mockserver.async.publish.Mqtt5MessagePublisher
Create a v5 publisher connected to the given broker with a specific QoS and no security.
Mqtt5MessagePublisher(String, String, int, MqttSecurity) - Constructor for class org.mockserver.async.publish.Mqtt5MessagePublisher
Create a v5 publisher with optional security configuration.
Mqtt5MessageSubscriber - Class in org.mockserver.async.subscribe
A MessageSubscriber that uses an MQTT v5 MqttClient to subscribe to topics and record received messages — the v5 counterpart of MqttMessageSubscriber.
Mqtt5MessageSubscriber(String, String) - Constructor for class org.mockserver.async.subscribe.Mqtt5MessageSubscriber
Create a v5 subscriber connected to the given broker with no security.
Mqtt5MessageSubscriber(String, String, int) - Constructor for class org.mockserver.async.subscribe.Mqtt5MessageSubscriber
Create a v5 subscriber with a specific QoS and no security.
Mqtt5MessageSubscriber(String, String, int, int, MqttSecurity) - Constructor for class org.mockserver.async.subscribe.Mqtt5MessageSubscriber
Create a v5 subscriber with optional security configuration.
Mqtt5SecurityOptions - Class in org.mockserver.async.security
Utility for building an MQTT v5 MqttConnectionOptions from MqttSecurity configuration — the v5 counterpart of MqttSecurityOptions.
MqttMessagePublisher - Class in org.mockserver.async.publish
A MessagePublisher that delegates to an MQTT MqttClient.
MqttMessagePublisher(String, String) - Constructor for class org.mockserver.async.publish.MqttMessagePublisher
Create a publisher connected to the given MQTT broker with default QoS (1) and no security.
MqttMessagePublisher(String, String, int) - Constructor for class org.mockserver.async.publish.MqttMessagePublisher
Create a publisher connected to the given MQTT broker with a specific QoS and no security.
MqttMessagePublisher(String, String, int, MqttSecurity) - Constructor for class org.mockserver.async.publish.MqttMessagePublisher
Create a publisher connected to the given MQTT broker with optional security configuration.
MqttMessageSubscriber - Class in org.mockserver.async.subscribe
A MessageSubscriber that uses an MQTT MqttClient to subscribe to topics and record received messages.
MqttMessageSubscriber(String, String) - Constructor for class org.mockserver.async.subscribe.MqttMessageSubscriber
Create a subscriber connected to the given MQTT broker with no security.
MqttMessageSubscriber(String, String, int) - Constructor for class org.mockserver.async.subscribe.MqttMessageSubscriber
Create a subscriber with a specific QoS level and no security.
MqttMessageSubscriber(String, String, int, int) - Constructor for class org.mockserver.async.subscribe.MqttMessageSubscriber
Create a subscriber with a specific QoS level and recorded-message cap, no security.
MqttMessageSubscriber(String, String, int, int, MqttSecurity) - Constructor for class org.mockserver.async.subscribe.MqttMessageSubscriber
Create a subscriber with optional security configuration.
MqttSecurity - Class in org.mockserver.async.security
Immutable carrier for MQTT security configuration (username/password and/or SSL).
MqttSecurity.Builder - Class in org.mockserver.async.security
 
MqttSecurityOptions - Class in org.mockserver.async.security
Utility for building MqttConnectOptions from MqttSecurity configuration.
MqttTopicFilter - Class in org.mockserver.async.subscribe
Matching of concrete MQTT topic names against MQTT topic filters, per MQTT 3.1.1 §4.7 (the same wildcard semantics apply to MQTT 5).
MysqlMessageFramer - Class in org.mockserver.netty.proxy
Cuts a binary connection into the messages of the MySQL client/server protocol, as a client sends them.
MysqlMessageFramer(int, MockServerLogger) - Constructor for class org.mockserver.netty.proxy.MysqlMessageFramer
 

N

NETTY_SSL_CONTEXT_FACTORY - Static variable in class org.mockserver.netty.unification.PortUnificationHandler
 
NettyResponseWriter - Class in org.mockserver.netty.responsewriter
 
NettyResponseWriter(Configuration, MockServerLogger, ChannelHandlerContext, Scheduler) - Constructor for class org.mockserver.netty.responsewriter.NettyResponseWriter
 
NettyResponseWriter(Configuration, MockServerLogger, ChannelHandlerContext, Scheduler, InFlightRequest) - Constructor for class org.mockserver.netty.responsewriter.NettyResponseWriter
 
nettySslContextFactory(Channel) - Static method in class org.mockserver.netty.unification.PortUnificationHandler
 
newHandle() - Method in class org.mockserver.netty.unification.BinaryAwareRecvByteBufAllocator
 
none() - Static method in class org.mockserver.async.publish.PublishOptions
 
NOT_YET_KNOWN - Static variable in class org.mockserver.netty.proxy.BinaryMessageFramer
What BinaryMessageFramer.messageBytes(io.netty.channel.ChannelHandlerContext, io.netty.buffer.ByteBuf) answers while the bytes held cannot yet say how long the message is.

O

onChannelInactive() - Method in class org.mockserver.netty.http3.Http3GrpcBidiStreamHandler
The QUIC stream / connection was torn down.
onData(byte[]) - Method in class org.mockserver.netty.http3.Http3GrpcBidiStreamHandler
Feed inbound request bytes.
onInputClosed() - Method in class org.mockserver.netty.http3.Http3GrpcBidiStreamHandler
The client half-closed (END_STREAM).
OpenAPISpecHandler - Class in org.mockserver.netty
Serves the embedded OpenAPI specification at GET /mockserver/openapi.yaml
OpenAPISpecHandler() - Constructor for class org.mockserver.netty.OpenAPISpecHandler
 
openBeforeClientSpeaks(ChannelHandlerContext, InetSocketAddress, Configuration, MockServerLogger, Scheduler, NettyHttpClient, BinaryProxyListener) - Static method in class org.mockserver.netty.proxy.relay.BinaryRelay
Opens the upstream connection of a client that has sent nothing yet, so that a server that speaks first (forwardBinaryServerFirstWaitMillis) is heard: what it sends is relayed to the client as any upstream read is.
openUI() - Method in class org.mockserver.integration.ClientAndServer
Launch UI and wait the default period to allow the UI to launch and start collecting logs, this ensures that the log are visible in the UI even if MockServer is shutdown by a test shutdown function, such as After, AfterClass, AfterAll, etc
openUI(TimeUnit, long) - Method in class org.mockserver.integration.ClientAndServer
Launch UI and wait a specified period to allow the UI to launch and start collecting logs, this ensures that the log are visible in the UI even if MockServer is shutdown by a test shutdown function, such as After, AfterClass, AfterAll, etc
operationComplete(ChannelFuture) - Method in class org.mockserver.netty.InFlightRequest
 
org.mockserver.async - package org.mockserver.async
 
org.mockserver.async.asyncapi - package org.mockserver.async.asyncapi
 
org.mockserver.async.controlplane - package org.mockserver.async.controlplane
 
org.mockserver.async.publish - package org.mockserver.async.publish
 
org.mockserver.async.security - package org.mockserver.async.security
 
org.mockserver.async.serde - package org.mockserver.async.serde
 
org.mockserver.async.subscribe - package org.mockserver.async.subscribe
 
org.mockserver.async.validation - package org.mockserver.async.validation
 
org.mockserver.cli - package org.mockserver.cli
 
org.mockserver.dashboard - package org.mockserver.dashboard
 
org.mockserver.dashboard.model - package org.mockserver.dashboard.model
 
org.mockserver.dashboard.serializers - package org.mockserver.dashboard.serializers
 
org.mockserver.integration - package org.mockserver.integration
 
org.mockserver.lifecycle - package org.mockserver.lifecycle
 
org.mockserver.netty - package org.mockserver.netty
 
org.mockserver.netty.connection - package org.mockserver.netty.connection
 
org.mockserver.netty.dns - package org.mockserver.netty.dns
 
org.mockserver.netty.grpc - package org.mockserver.netty.grpc
 
org.mockserver.netty.http3 - package org.mockserver.netty.http3
 
org.mockserver.netty.mcp - package org.mockserver.netty.mcp
 
org.mockserver.netty.proxy - package org.mockserver.netty.proxy
 
org.mockserver.netty.proxy.connect - package org.mockserver.netty.proxy.connect
 
org.mockserver.netty.proxy.relay - package org.mockserver.netty.proxy.relay
 
org.mockserver.netty.proxy.socks - package org.mockserver.netty.proxy.socks
 
org.mockserver.netty.responsewriter - package org.mockserver.netty.responsewriter
 
org.mockserver.netty.unification - package org.mockserver.netty.unification
 
org.mockserver.netty.websocketregistry - package org.mockserver.netty.websocketregistry
 
originalBodyLength(Object) - Method in class org.mockserver.dashboard.model.DashboardLogEntryDTO
The full body length of a request or response of this entry (its own, or one of its message arguments) whose body the dashboard cut short, or null when it was sent whole.
originalLength(Object) - Method in class org.mockserver.dashboard.model.DashboardBodyCap.Sizes
The full body length of a message this cut short, or null when it was sent whole.

P

PacedLargeWriteHandler - Class in org.mockserver.netty.unification
Sends a large encoded HTTP/1.1 message to the socket in slices, writing the next slice only while the connection is writable.
PacedLargeWriteHandler() - Constructor for class org.mockserver.netty.unification.PacedLargeWriteHandler
 
parse(String) - Method in class org.mockserver.async.asyncapi.AsyncApiParser
Parse an AsyncAPI document from a string (auto-detects JSON vs YAML).
PARSE_ERROR - Static variable in class org.mockserver.netty.mcp.JsonRpcMessage
 
ParsedHeaders(String, String, String, String, List<Map.Entry<String, String>>, boolean) - Constructor for class org.mockserver.netty.http3.Http3RequestBridge.ParsedHeaders
 
parseHeaders(Http3HeadersFrame) - Static method in class org.mockserver.netty.http3.Http3RequestBridge
Extract pseudo-headers and regular headers from an HTTP/3 headers frame.
parseSchema(String) - Static method in class org.mockserver.async.serde.AvroPayloadCodec
Parse an Avro schema from its JSON text.
password(String) - Method in class org.mockserver.async.security.MqttSecurity.Builder
 
path() - Method in class org.mockserver.netty.http3.Http3RequestBridge.ParsedHeaders
 
port - Variable in class org.mockserver.netty.proxy.relay.RelayConnectHandler
 
PortBinding - Class in org.mockserver.netty.unification
 
PortBinding(InetSocketAddress, String) - Constructor for class org.mockserver.netty.unification.PortBinding
 
portCouldNotBeOpenedOrBound(int, Throwable) - Static method in exception org.mockserver.netty.dns.DnsStartupException
The channel for an explicit dnsPort could not be created, registered or bound; a bind the operating system refused is the usual case.
portFreeOnIpv4() - Static method in class org.mockserver.lifecycle.Ipv4UdpPortProbe
 
PortUnificationHandler - Class in org.mockserver.netty.unification
 
PortUnificationHandler(Configuration, LifeCycle, HttpState, HttpActionHandler, NettySslContextFactory, McpStreamableHttpHandler) - Constructor for class org.mockserver.netty.unification.PortUnificationHandler
 
PostgresqlMessageFramer - Class in org.mockserver.netty.proxy
Cuts a binary connection into the messages of the PostgreSQL frontend/backend protocol (version 3), as a client sends them.
PostgresqlMessageFramer(int, MockServerLogger) - Constructor for class org.mockserver.netty.proxy.PostgresqlMessageFramer
 
prepare(ChannelHandlerContext, InetSocketAddress, Configuration, MockServerLogger, Scheduler, NettyHttpClient, BinaryProxyListener) - Static method in class org.mockserver.netty.proxy.relay.BinaryRelay
Makes this connection's relay, if it has none yet, without opening its upstream connection, so that a message MockServer answers itself (matchBinaryExpectationsWhenProxying) is ordered and held back by it.
processHeadersBegin(ChannelHandlerContext, Http2Stream, Http2Headers, boolean, boolean, boolean) - Method in class org.mockserver.netty.proxy.relay.ExpectContinueInboundHttp2ToHttpAdapter
 
PromptArgument(String, String, boolean) - Constructor for class org.mockserver.netty.mcp.McpPromptRegistry.PromptArgument
 
PromptDefinition(String, String, List<McpPromptRegistry.PromptArgument>, String, String) - Constructor for class org.mockserver.netty.mcp.McpPromptRegistry.PromptDefinition
 
propagate(Channel, Channel) - Static method in class org.mockserver.netty.unification.ConnectionScopeHandler
Copies every connection-scoped attribute whose value is non-null from parent onto child.
protocolAllowsTlsHere() - Method in class org.mockserver.netty.proxy.BinaryMessageFramer
 
protocolAllowsTlsHere() - Method in class org.mockserver.netty.proxy.MysqlMessageFramer
 
PROXIED - Static variable in class org.mockserver.netty.proxy.relay.RelayConnectHandler
 
PROXIED_RESPONSE - Static variable in class org.mockserver.netty.proxy.relay.RelayConnectHandler
 
PROXIED_SECURE - Static variable in class org.mockserver.netty.proxy.relay.RelayConnectHandler
 
proxyClientFrameListener(Http2Connection, Http2FrameListener) - Method in class org.mockserver.netty.proxy.relay.LoopbackHttp2StreamErrorHandler
Wraps the proxy client's frame listener, and listens to its connection, so a client stream that ends without a whole response is reset on the loopback too, and the client's other streams carry on.
PROXYING - Static variable in class org.mockserver.netty.HttpRequestHandler
 
ProxyProtocolOriginalDestinationHandler - Class in org.mockserver.netty.proxy
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).
ProxyProtocolOriginalDestinationHandler(MockServerLogger) - Constructor for class org.mockserver.netty.proxy.ProxyProtocolOriginalDestinationHandler
 
proxyRemoteHost - Enum constant in enum class org.mockserver.cli.Main.Arguments
 
proxyRemotePort - Enum constant in enum class org.mockserver.cli.Main.Arguments
 
publish(String, String) - Method in class org.mockserver.async.publish.AmqpMessagePublisher
 
publish(String, String) - Method in class org.mockserver.async.publish.KafkaAvroMessagePublisher
 
publish(String, String) - Method in class org.mockserver.async.publish.KafkaMessagePublisher
 
publish(String, String) - Method in interface org.mockserver.async.publish.MessagePublisher
Publish the given payload to the specified channel with no key or headers.
publish(String, String) - Method in class org.mockserver.async.publish.Mqtt5MessagePublisher
 
publish(String, String) - Method in class org.mockserver.async.publish.MqttMessagePublisher
 
publish(String, String, String, Map<String, String>) - Method in class org.mockserver.async.publish.KafkaMessagePublisher
Publish a message with a specific key and optional headers.
publish(String, String, String, Map<String, String>) - Method in interface org.mockserver.async.publish.MessagePublisher
Publish the given payload with an optional key and headers.
publish(String, String, PublishOptions) - Method in class org.mockserver.async.publish.AmqpMessagePublisher
Publish a message to the AMQP destination derived from the channel's binding.
publish(String, String, PublishOptions) - Method in class org.mockserver.async.publish.KafkaAvroMessagePublisher
 
publish(String, String, PublishOptions) - Method in class org.mockserver.async.publish.KafkaMessagePublisher
Publish a message with per-message options from AsyncAPI bindings.
publish(String, String, PublishOptions) - Method in interface org.mockserver.async.publish.MessagePublisher
Publish the given payload with per-message options derived from AsyncAPI bindings.
publish(String, String, PublishOptions) - Method in class org.mockserver.async.publish.Mqtt5MessagePublisher
Publish with per-message options from AsyncAPI bindings.
publish(String, String, PublishOptions) - Method in class org.mockserver.async.publish.MqttMessagePublisher
Publish a message with per-message options from AsyncAPI bindings.
publishAll() - Method in class org.mockserver.async.AsyncApiMockOrchestrator
Publish the generated example message for each message in each channel, threading any AsyncAPI bindings (MQTT qos/retain, Kafka key) and correlation IDs as PublishOptions.
publishBytes(String, byte[]) - Method in class org.mockserver.async.publish.Mqtt5MessagePublisher
Publish a binary payload with no options.
publishBytes(String, byte[]) - Method in class org.mockserver.async.publish.MqttMessagePublisher
Publish a binary payload to the given channel.
PublishOptions - Class in org.mockserver.async.publish
Immutable carrier for per-message publish-time options extracted from AsyncAPI bindings.
PublishOptions(String, Integer, Boolean) - Constructor for class org.mockserver.async.publish.PublishOptions
Backward-compatible constructor — no headers.
PublishOptions(String, Integer, Boolean, Map<String, String>) - Constructor for class org.mockserver.async.publish.PublishOptions
Full constructor with headers.

Q

QUEUE - Enum constant in enum class org.mockserver.async.asyncapi.AmqpBinding.ChannelType
 

R

readAccumulatedBody(CompositeByteBuf) - Static method in class org.mockserver.netty.http3.Http3RequestBridge
Read the accumulated composite buffer into a byte array.
readMarker() - Method in class org.mockserver.netty.connection.HttpTransportTimer
The handler to add before the HTTP server codec, so the read-to-decode span starts at the read.
readResource(String) - Method in class org.mockserver.netty.mcp.McpResourceRegistry
 
readWholeMessages(Channel) - Static method in class org.mockserver.netty.unification.BinaryAwareRecvByteBufAllocator
Every later read of the channel is given BinaryAwareRecvByteBufAllocator.BINARY_READ_SIZE.
receivedRequestDescription(Object, Integer) - Method in class org.mockserver.dashboard.serializers.DescriptionProcessor
As DescriptionProcessor.description(Object), also describing a DNS query by its name and type, and a binary message by its length and first bytes in hex.
ReceivedRequestDescription - Class in org.mockserver.dashboard.serializers
A received request that has no method or path, such as a DNS query or a binary message, sent as its kind and a summary for the dashboard to lay out as it lays out an HTTP request's method and path.
ReceivedRequestDescription(String, String) - Constructor for class org.mockserver.dashboard.serializers.ReceivedRequestDescription
 
RecordedMessage - Class in org.mockserver.async.subscribe
An immutable record of a message received from a broker subscription.
RecordedMessage(String, String, String, Map<String, String>) - Constructor for class org.mockserver.async.subscribe.RecordedMessage
 
RedisMessageFramer - Class in org.mockserver.netty.proxy
Cuts a binary connection into the messages of the Redis serialization protocol (RESP2 and RESP3), as a client sends them: one complete top-level value with everything nested in it, or, when the first byte names no RESP type, one inline command up to and including its line feed.
RedisMessageFramer(int, MockServerLogger) - Constructor for class org.mockserver.netty.proxy.RedisMessageFramer
 
refuse(ChannelHandlerContext, ByteBuf, String) - Method in class org.mockserver.netty.proxy.BinaryMessageFramer
 
register(String, String) - Method in class org.mockserver.async.serde.SchemaRegistryClient
Register (idempotently) an Avro schema under the given subject and return its id.
registerIfAvailable() - Static method in class org.mockserver.async.controlplane.AsyncApiControlPlaneImpl
Register this implementation into the core registry, without a Configuration instance.
registerIfAvailable(Configuration) - Static method in class org.mockserver.async.controlplane.AsyncApiControlPlaneImpl
Register this implementation into the core registry.
registerListener(ExpectationsListener) - Method in class org.mockserver.integration.ClientAndServer
 
registerListener(ExpectationsListener) - Method in class org.mockserver.lifecycle.LifeCycle
 
registerListener(ExpectationsListener) - Method in class org.mockserver.netty.MockServer
 
registerListeners() - Method in class org.mockserver.dashboard.DashboardWebSocketHandler
 
RELAY - Static variable in class org.mockserver.netty.proxy.relay.UpstreamReply
 
RelayConnectHandler<T> - Class in org.mockserver.netty.proxy.relay
 
RelayConnectHandler(Configuration, LifeCycle, MockServerLogger, String, int) - Constructor for class org.mockserver.netty.proxy.relay.RelayConnectHandler
 
RelayLoopbackAddresses - Class in org.mockserver.netty.proxy.relay
The local addresses of the loopback connections RelayConnectHandler opens to MockServer, each with the proxy client's channel of its tunnel, so the accepting side can tell its own relay's loopback leg from a client that merely sends the same PROXIED_ preamble, and can reach the tunnel's other leg.
relayLoopbackHandler(MockServerLogger, Http2Connection, Http2FrameListener, Http2FrameLogger) - Static method in class org.mockserver.netty.unification.Http2RequestHeaderLimit
 
relayLoopbackSettings() - Static method in class org.mockserver.netty.unification.Http2RequestHeaderLimit
 
removeCodecSupport(ChannelHandlerContext) - Method in class org.mockserver.netty.proxy.connect.HttpConnectHandler
 
removeCodecSupport(ChannelHandlerContext) - Method in class org.mockserver.netty.proxy.relay.RelayConnectHandler
 
removeCodecSupport(ChannelHandlerContext) - Method in class org.mockserver.netty.proxy.socks.Socks4ConnectHandler
 
removeCodecSupport(ChannelHandlerContext) - Method in class org.mockserver.netty.proxy.socks.Socks5ConnectHandler
 
removeCodecSupport(ChannelHandlerContext) - Method in class org.mockserver.netty.proxy.socks.SocksConnectHandler
 
removeFrom(ChannelPipeline) - Static method in class org.mockserver.netty.connection.HttpTransportTimer
Removes the timer and its read marker, if present, for when the connection stops carrying HTTP/1.1.
removeFrom(ChannelPipeline) - Static method in class org.mockserver.netty.unification.HttpServerCodecResponsePairing
Removes both handlers, if present, for when the connection stops carrying HTTP/1.1 (a CONNECT or SOCKS tunnel).
removeHandler(ChannelPipeline, ChannelHandler) - Method in class org.mockserver.netty.proxy.relay.RelayConnectHandler
 
removeHandler(ChannelPipeline, Class<? extends ChannelHandler>) - Method in class org.mockserver.netty.proxy.relay.RelayConnectHandler
 
removeSession(String) - Method in class org.mockserver.netty.mcp.McpSessionManager
 
render(Body<?>, Object, UnaryOperator<Body<?>>) - Method in class org.mockserver.dashboard.model.DashboardBodyCap.Rendering
 
renderDashboard(ChannelHandlerContext, HttpRequest) - Method in class org.mockserver.dashboard.DashboardHandler
 
Rendering() - Constructor for class org.mockserver.dashboard.model.DashboardBodyCap.Rendering
 
renderOpenAPISpec(ChannelHandlerContext, HttpRequest) - Method in class org.mockserver.netty.OpenAPISpecHandler
 
replaceWith(byte[], long) - Static method in class org.mockserver.netty.proxy.relay.UpstreamReply
 
Report() - Constructor for class org.mockserver.netty.mcp.McpContractTest.Report
 
RequestDefinitionDescription - Class in org.mockserver.dashboard.serializers
 
RequestDefinitionDescription(String, String, DescriptionProcessor, boolean) - Constructor for class org.mockserver.dashboard.serializers.RequestDefinitionDescription
 
RequestDefinitionObjectDescription - Class in org.mockserver.dashboard.serializers
 
RequestDefinitionObjectDescription(String, Object, String, DescriptionProcessor) - Constructor for class org.mockserver.dashboard.serializers.RequestDefinitionObjectDescription
 
requestProcessingComplete() - Method in class org.mockserver.lifecycle.LifeCycle
Mark that a data-plane request has finished (its response has been written or the connection has otherwise completed).
requestProcessingStarted() - Method in class org.mockserver.lifecycle.LifeCycle
Mark that a data-plane request has started processing.
reset() - Method in class org.mockserver.async.controlplane.AsyncApiControlPlaneImpl
Takes the brokers out of the control plane and closes them on a daemon thread, waiting up to AsyncApiControlPlaneImpl.CLOSE_WAIT for that before returning; closes still running then finish in the background.
resolve(Channel) - Method in class org.mockserver.netty.proxy.CompositeOriginalDestinationResolver
Tries each strategy in order.
resolve(Channel) - Method in class org.mockserver.netty.proxy.ConntrackOriginalDestinationResolver
 
resolve(Channel) - Method in class org.mockserver.netty.proxy.DnsIntentOriginalDestinationResolver
 
resolve(Channel) - Method in class org.mockserver.netty.proxy.EbpfOriginalDestinationResolver
 
resolve(Channel) - Method in class org.mockserver.netty.proxy.SoOriginalDstResolver
Resolves the original destination for the given channel.
resolve(Channel) - Method in class org.mockserver.netty.proxy.TproxyOriginalDestinationResolver
Resolves the original destination by reading the channel's local address.
resolve(Channel) - Method in interface org.mockserver.netty.proxy.TransparentProxyHandler.OriginalDestinationResolver
 
resolveTargetHost(String) - Method in class org.mockserver.netty.proxy.TransparentProxyInitializer
Returns the forwarding host for a transparent proxy request.
resolveTargetPort(String, boolean) - Method in class org.mockserver.netty.proxy.TransparentProxyInitializer
Returns the forwarding port for a transparent proxy request.
ResourceDefinition(String, String, String, String, Supplier<JsonNode>) - Constructor for class org.mockserver.netty.mcp.McpResourceRegistry.ResourceDefinition
 
respondingDirectly() - Method in class org.mockserver.netty.responsewriter.NettyResponseWriter
 
ROUTING_KEY - Enum constant in enum class org.mockserver.async.asyncapi.AmqpBinding.ChannelType
 
run() - Method in class org.mockserver.netty.connection.Http2StreamWriteStallHandler
 
run() - Method in class org.mockserver.netty.connection.WriteStallTimeoutHandler
 
run(String, String, McpContractTest.JsonRpcExchange) - Method in class org.mockserver.netty.mcp.McpContractTest
Run the conformance suite against the target server.

S

saslJaasConfig(String) - Method in class org.mockserver.async.security.KafkaSecurity.Builder
 
saslMechanism(String) - Method in class org.mockserver.async.security.KafkaSecurity.Builder
 
scheduleDeadline(HttpRequest) - Method in class org.mockserver.netty.http3.Http3GrpcResponseWriter
Honours the client's grpc-timeout by scheduling a DEADLINE_EXCEEDED response.
SchemaRegistryClient - Class in org.mockserver.async.serde
A minimal client for the Confluent Schema Registry REST API — just the two operations MockServer needs, implemented over the JDK's HttpClient so no Confluent Community License artifacts are pulled in: SchemaRegistryClient.getSchemaById(int) — GET /schemas/ids/{id}, used on the consume/verify path to resolve the schema embedded in a Confluent wire-format message. SchemaRegistryClient.register(String, String) — POST /subjects/{subject}/versions, used on the publish path to obtain the schema id to frame messages with.
SchemaRegistryClient(String) - Constructor for class org.mockserver.async.serde.SchemaRegistryClient
 
scheme() - Method in class org.mockserver.netty.http3.Http3RequestBridge.ParsedHeaders
 
securityProtocol(String) - Method in class org.mockserver.async.security.KafkaSecurity.Builder
 
send(ObjectNode, String) - Method in interface org.mockserver.netty.mcp.McpContractTest.JsonRpcExchange
Send a single JSON-RPC message (request or notification) to the target server.
sendResponse(HttpRequest, HttpResponse) - Method in class org.mockserver.netty.http3.Http3GrpcResponseWriter
 
sendResponse(HttpRequest, HttpResponse) - Method in class org.mockserver.netty.http3.Http3ResponseWriter
 
sendResponse(HttpRequest, HttpResponse) - Method in class org.mockserver.netty.responsewriter.EarlyNettyResponseWriter
 
sendResponse(HttpRequest, HttpResponse) - Method in class org.mockserver.netty.responsewriter.NettyResponseWriter
 
serialize(Throwable, JsonGenerator, SerializerProvider) - Method in class org.mockserver.dashboard.serializers.ThrowableSerializer
 
serialize(DashboardLogEntryDTOGroup, JsonGenerator, SerializerProvider) - Method in class org.mockserver.dashboard.serializers.DashboardLogEntryDTOGroupSerializer
 
serialize(DashboardLogEntryDTO, JsonGenerator, SerializerProvider) - Method in class org.mockserver.dashboard.serializers.DashboardLogEntryDTOSerializer
 
serialize(Description, JsonGenerator, SerializerProvider) - Method in class org.mockserver.dashboard.serializers.DescriptionSerializer
 
server - Variable in class org.mockserver.netty.proxy.socks.SocksProxyHandler
 
serverCouldNotStart(int, Throwable) - Static method in exception org.mockserver.netty.dns.DnsStartupException
 
serverPort - Enum constant in enum class org.mockserver.cli.Main.Arguments
 
serverServerBootstrap - Variable in class org.mockserver.lifecycle.LifeCycle
 
serverSettings(Configuration) - Static method in class org.mockserver.netty.unification.Http2RequestHeaderLimit
 
setArguments(Object...) - Method in class org.mockserver.dashboard.model.DashboardLogEntryDTO
 
setBecause(String) - Method in class org.mockserver.dashboard.model.DashboardLogEntryDTO
 
setCode(int) - Method in class org.mockserver.netty.mcp.JsonRpcMessage.JsonRpcError
 
setCorrelationId(String) - Method in class org.mockserver.dashboard.model.DashboardLogEntryDTO
 
setData(JsonNode) - Method in class org.mockserver.netty.mcp.JsonRpcMessage.JsonRpcError
 
setDescription(Description) - Method in class org.mockserver.dashboard.model.DashboardLogEntryDTO
 
setError(JsonRpcMessage.JsonRpcError) - Method in class org.mockserver.netty.mcp.JsonRpcMessage.JsonRpcResponse
 
setHttpRequests(RequestDefinition[]) - Method in class org.mockserver.dashboard.model.DashboardLogEntryDTO
 
setHttpResponse(HttpResponse) - Method in class org.mockserver.dashboard.model.DashboardLogEntryDTO
 
setId(Object) - Method in class org.mockserver.netty.mcp.JsonRpcMessage.JsonRpcRequest
 
setId(Object) - Method in class org.mockserver.netty.mcp.JsonRpcMessage.JsonRpcResponse
 
setId(String) - Method in class org.mockserver.dashboard.model.DashboardLogEntryDTO
 
setIdPresent(boolean) - Method in class org.mockserver.netty.mcp.JsonRpcMessage.JsonRpcRequest
 
setJsonrpc(String) - Method in class org.mockserver.netty.mcp.JsonRpcMessage.JsonRpcNotification
 
setJsonrpc(String) - Method in class org.mockserver.netty.mcp.JsonRpcMessage.JsonRpcRequest
 
setJsonrpc(String) - Method in class org.mockserver.netty.mcp.JsonRpcMessage.JsonRpcResponse
 
setLogEventListener(Consumer<LogEntry>) - Static method in class org.mockserver.integration.ClientAndServer
 
setMessage(String) - Method in class org.mockserver.netty.mcp.JsonRpcMessage.JsonRpcError
 
setMessageFormat(String) - Method in class org.mockserver.dashboard.model.DashboardLogEntryDTO
 
setMethod(String) - Method in class org.mockserver.netty.mcp.JsonRpcMessage.JsonRpcNotification
 
setMethod(String) - Method in class org.mockserver.netty.mcp.JsonRpcMessage.JsonRpcRequest
 
setParams(JsonNode) - Method in class org.mockserver.netty.mcp.JsonRpcMessage.JsonRpcNotification
 
setParams(JsonNode) - Method in class org.mockserver.netty.mcp.JsonRpcMessage.JsonRpcRequest
 
setProtocolVersion(String) - Method in class org.mockserver.netty.mcp.McpSession
 
setProxyingRequest(ChannelHandlerContext, Boolean) - Static method in class org.mockserver.netty.HttpRequestHandler
 
setResult(JsonNode) - Method in class org.mockserver.netty.mcp.JsonRpcMessage.JsonRpcResponse
 
setStyle(Map<String, String>) - Method in class org.mockserver.dashboard.model.DashboardLogEntryDTO
 
setThrowable(String[]) - Method in class org.mockserver.dashboard.model.DashboardLogEntryDTO
 
setTimestamp(String) - Method in class org.mockserver.dashboard.model.DashboardLogEntryDTO
 
setType(LogEntry.LogMessageType) - Method in class org.mockserver.dashboard.model.DashboardLogEntryDTO
 
shadowedOnIpv4(int) - Static method in class org.mockserver.lifecycle.Ipv4UdpPortProbe
 
shadowedOnIpv4(InetSocketAddress) - Static method in class org.mockserver.lifecycle.Ipv4UdpPortProbe
Only a wildcard bind is checked: a bind of one address fails against a socket on 0.0.0.0:port, and a socket on one address is sent every datagram for that address.
shortEnvironmentVariableName() - Method in enum class org.mockserver.cli.Main.Arguments
 
shownBodyLength(Object) - Method in class org.mockserver.dashboard.model.DashboardLogEntryDTO
How many characters of a request's or response's body this entry sends (after any cut), or null for a message that is not one of this entry's.
shownLength(Object) - Method in class org.mockserver.dashboard.model.DashboardBodyCap.Sizes
How many characters of a message's body this sends, as measured when it was capped, or null when the message was not capped here.
shutdown() - Method in class org.mockserver.netty.mcp.McpSessionManager
Shuts down the MCP executor gracefully.
size() - Method in class org.mockserver.async.subscribe.BoundedMessageStore
Return the current number of messages in the store.
size() - Method in class org.mockserver.netty.mcp.McpSessionManager
 
Sizes() - Constructor for class org.mockserver.dashboard.model.DashboardBodyCap.Sizes
 
snapshot() - Method in class org.mockserver.async.subscribe.BoundedMessageStore
Return a snapshot copy of all messages currently in the store.
Socks4ConnectHandler - Class in org.mockserver.netty.proxy.socks
 
Socks4ConnectHandler(Configuration, MockServerLogger, LifeCycle, String, int) - Constructor for class org.mockserver.netty.proxy.socks.Socks4ConnectHandler
 
Socks4ProxyHandler - Class in org.mockserver.netty.proxy.socks
 
Socks4ProxyHandler(Configuration, MockServerLogger, LifeCycle) - Constructor for class org.mockserver.netty.proxy.socks.Socks4ProxyHandler
 
Socks5ConnectHandler - Class in org.mockserver.netty.proxy.socks
 
Socks5ConnectHandler(Configuration, MockServerLogger, LifeCycle, String, int) - Constructor for class org.mockserver.netty.proxy.socks.Socks5ConnectHandler
 
Socks5ProxyHandler - Class in org.mockserver.netty.proxy.socks
 
Socks5ProxyHandler(Configuration, MockServerLogger, LifeCycle) - Constructor for class org.mockserver.netty.proxy.socks.Socks5ProxyHandler
 
SocksConnectHandler<T> - Class in org.mockserver.netty.proxy.socks
 
SocksConnectHandler(Configuration, MockServerLogger, LifeCycle, String, int) - Constructor for class org.mockserver.netty.proxy.socks.SocksConnectHandler
 
SocksDetector - Class in org.mockserver.netty.proxy.socks
This class is expected to be used from within a ReplayingDecoder, or with enough bytes available.
SocksProxyHandler<T> - Class in org.mockserver.netty.proxy.socks
 
SocksProxyHandler(Configuration, MockServerLogger, LifeCycle) - Constructor for class org.mockserver.netty.proxy.socks.SocksProxyHandler
 
SoOriginalDstHelper - Class in org.mockserver.netty.proxy
Reads the original destination of an intercepted TCP connection on Linux.
SoOriginalDstResolver - Class in org.mockserver.netty.proxy
Resolves the original destination of a transparently intercepted TCP connection by calling getsockopt(fd, SOL_IP, SO_ORIGINAL_DST, ...) via JNA on Linux.
SoOriginalDstResolver() - Constructor for class org.mockserver.netty.proxy.SoOriginalDstResolver
 
SourceAddressQuicTokenHandler - Class in org.mockserver.netty.http3
Source-address-validating QUIC retry token handler (stateless retry, RFC 9000 §8.1).
SourceAddressQuicTokenHandler() - Constructor for class org.mockserver.netty.http3.SourceAddressQuicTokenHandler
Create a handler with a fresh random secret.
sslKeyPassword(String) - Method in class org.mockserver.async.security.KafkaSecurity.Builder
 
sslKeystoreLocation(String) - Method in class org.mockserver.async.security.KafkaSecurity.Builder
 
sslKeystorePassword(String) - Method in class org.mockserver.async.security.KafkaSecurity.Builder
 
sslProperties(Map<String, String>) - Method in class org.mockserver.async.security.MqttSecurity.Builder
 
sslTruststoreLocation(String) - Method in class org.mockserver.async.security.KafkaSecurity.Builder
 
sslTruststorePassword(String) - Method in class org.mockserver.async.security.KafkaSecurity.Builder
 
start(int) - Method in class org.mockserver.netty.http3.Http3Server
Start the HTTP/3 server on the given UDP port.
start(HttpRequest) - Method in class org.mockserver.netty.http3.Http3GrpcBidiStreamHandler
Write the initial response HEADERS and any eager messages.
startClientAndServer(Integer...) - Static method in class org.mockserver.integration.ClientAndServer
 
startClientAndServer(String, Integer, Integer...) - Static method in class org.mockserver.integration.ClientAndServer
 
startClientAndServer(List<Integer>) - Static method in class org.mockserver.integration.ClientAndServer
 
startClientAndServer(Configuration, Integer...) - Static method in class org.mockserver.integration.ClientAndServer
 
startClientAndServer(Configuration, String, Integer, Integer...) - Static method in class org.mockserver.integration.ClientAndServer
 
startClientAndServer(Configuration, List<Integer>) - Static method in class org.mockserver.integration.ClientAndServer
 
started(LifeCycle) - Static method in class org.mockserver.netty.InFlightRequest
Increment the in-flight counter and return a token whose InFlightRequest.complete() will decrement it exactly once.
startedServer(List<Integer>) - Method in class org.mockserver.lifecycle.LifeCycle
 
startPublishing(long) - Method in class org.mockserver.async.AsyncApiMockOrchestrator
Start periodic publishing at the given interval.
status() - Method in class org.mockserver.async.controlplane.AsyncApiControlPlaneImpl
 
stop() - Method in class org.mockserver.async.AsyncApiMockOrchestrator
Stop periodic publishing, waiting for an in-flight publish to finish.
stop() - Method in class org.mockserver.integration.ClientAndServer
 
stop() - Method in class org.mockserver.lifecycle.LifeCycle
 
stop() - Method in class org.mockserver.netty.http3.Http3Server
Stop the HTTP/3 server and release resources.
stopAsync() - Method in class org.mockserver.integration.ClientAndServer
 
stopAsync() - Method in class org.mockserver.lifecycle.LifeCycle
 
stopAsync() - Method in class org.mockserver.netty.MockServer
 
strategyCount() - Method in class org.mockserver.netty.proxy.CompositeOriginalDestinationResolver
Returns the number of strategies in this chain (useful for testing).
StreamAddressedContentHandler - Class in org.mockserver.netty.unification
Translates a StreamAddressedHttpContent into the child-channel equivalent when a streaming response is written on an Http2MultiplexHandler child channel.
StreamAddressedContentHandler() - Constructor for class org.mockserver.netty.unification.StreamAddressedContentHandler
 
subscribe(String) - Method in class org.mockserver.async.subscribe.AmqpMessageSubscriber
 
subscribe(String) - Method in class org.mockserver.async.subscribe.KafkaAvroMessageSubscriber
 
subscribe(String) - Method in class org.mockserver.async.subscribe.KafkaMessageSubscriber
 
subscribe(String) - Method in interface org.mockserver.async.subscribe.MessageSubscriber
Start subscribing to the given channel.
subscribe(String) - Method in class org.mockserver.async.subscribe.Mqtt5MessageSubscriber
 
subscribe(String) - Method in class org.mockserver.async.subscribe.MqttMessageSubscriber
 
success(Object, JsonNode) - Static method in class org.mockserver.netty.mcp.JsonRpcMessage.JsonRpcResponse
 
successResponse(Object) - Method in class org.mockserver.netty.proxy.connect.HttpConnectHandler
 
successResponse(Object) - Method in class org.mockserver.netty.proxy.relay.RelayConnectHandler
 
successResponse(Object) - Method in class org.mockserver.netty.proxy.socks.Socks4ConnectHandler
 
successResponse(Object) - Method in class org.mockserver.netty.proxy.socks.Socks5ConnectHandler
 
SUPPORTED_PLATFORMS - Static variable in exception org.mockserver.netty.http3.Http3NativeUnavailableException
 
systemPropertyName() - Method in enum class org.mockserver.cli.Main.Arguments
 

T

TCP - Static variable in class org.mockserver.netty.unification.ClientTlsHandshakeFailureLog
 
TcpChaosHandler - Class in org.mockserver.netty.unification
Netty ChannelDuplexHandler that injects raw TCP-layer faults before HTTP decoding, based on the TcpChaosProfile registered in TcpChaosRegistry for the connection's remote host.
TcpChaosHandler() - Constructor for class org.mockserver.netty.unification.TcpChaosHandler
 
ThrowableSerializer - Class in org.mockserver.dashboard.serializers
 
ThrowableSerializer() - Constructor for class org.mockserver.dashboard.serializers.ThrowableSerializer
 
TLS_DETECTION_DEFERRED - Static variable in class org.mockserver.netty.unification.PortUnificationHandler
 
TLS_ENABLED_DOWNSTREAM - Static variable in class org.mockserver.netty.unification.PortUnificationHandler
 
TLS_ENABLED_UPSTREAM - Static variable in class org.mockserver.netty.unification.PortUnificationHandler
 
tlsMayStartHere() - Method in class org.mockserver.netty.proxy.BinaryMessageFramer
Whether a TLS handshake may begin with the next byte read: only at a message boundary, and only where the protocol lets one begin.
toHttp3DataFrame(HttpResponse) - Static method in class org.mockserver.netty.http3.Http3RequestBridge
Convert the body of a MockServer HttpResponse into an HTTP/3 data frame.
toHttp3HeadersFrame(HttpResponse) - Static method in class org.mockserver.netty.http3.Http3RequestBridge
Convert a MockServer HttpResponse into an HTTP/3 headers frame.
toHttp3HeadersFrame(HttpResponse, boolean) - Static method in class org.mockserver.netty.http3.Http3RequestBridge
As Http3RequestBridge.toHttp3HeadersFrame(HttpResponse), additionally dropping content-length when streaming is true.
toHttp3TrailersFrame(HttpResponse) - Static method in class org.mockserver.netty.http3.Http3RequestBridge
Build a trailing HTTP/3 HEADERS frame from the response trailers, or null when the response carries no trailers.
toHttpRequest(String, String, String, String, List<Map.Entry<String, String>>, byte[]) - Static method in class org.mockserver.netty.http3.Http3RequestBridge
Build a MockServer HttpRequest from the HTTP/3 pseudo-headers and accumulated body bytes.
toHttpRequest(String, String, String, String, List<Map.Entry<String, String>>, ByteBuf) - Static method in class org.mockserver.netty.http3.Http3RequestBridge
As Http3RequestBridge.toHttpRequest(String, String, String, String, List, byte[]), but reads the accumulated request body from the ByteBuf it was accumulated into, copying it once.
toHttpRequest(String, String, String, String, List<Map.Entry<String, String>>, ByteBuf, ByteBuf) - Static method in class org.mockserver.netty.http3.Http3RequestBridge
As Http3RequestBridge.toHttpRequest(String, String, String, String, List, ByteBuf), unless decompressedBody (the body Http3RequestDecompressor decompressed) is non-null: the request is then the one HTTP/1.1's decompressor, aggregator and request mapper build.
toObject() - Method in interface org.mockserver.dashboard.serializers.Description
 
toObject() - Method in class org.mockserver.dashboard.serializers.LogMessageDescription
 
toObject() - Method in class org.mockserver.dashboard.serializers.ReceivedRequestDescription
 
toObject() - Method in class org.mockserver.dashboard.serializers.RequestDefinitionDescription
 
toObject() - Method in class org.mockserver.dashboard.serializers.RequestDefinitionObjectDescription
 
ToolDefinition(String, String, JsonNode, Function<JsonNode, JsonNode>) - Constructor for class org.mockserver.netty.mcp.McpToolRegistry.ToolDefinition
 
toPublishOptions() - Method in class org.mockserver.async.asyncapi.AsyncApiChannel
Build a PublishOptions from the parsed bindings on this channel.
toString() - Method in class org.mockserver.async.asyncapi.AmqpBinding
 
toString() - Method in class org.mockserver.async.publish.PublishOptions
 
toString() - Method in class org.mockserver.async.subscribe.RecordedMessage
 
touch() - Method in class org.mockserver.netty.mcp.McpSession
 
TproxyOriginalDestinationResolver - Class in org.mockserver.netty.proxy
Resolves the original destination of a transparently intercepted TCP connection using the TPROXY (IP_TRANSPARENT) mechanism.
TproxyOriginalDestinationResolver(Configuration) - Constructor for class org.mockserver.netty.proxy.TproxyOriginalDestinationResolver
Creates a TPROXY resolver that checks whether TPROXY mode is active via the given configuration.
TRACE_CONTEXT - Static variable in class org.mockserver.netty.unification.TraceContextHandler
Delegates to the shared constant in mockserver-core so both the Netty handler and the core action handler use the same attribute key.
TraceContextHandler - Class in org.mockserver.netty.unification
Netty handler that extracts W3C traceparent / tracestate headers from inbound HttpRequest objects and stores the parsed W3CTraceContext as a channel attribute, replacing (or clearing) any context from an earlier request on the same connection.
TraceContextHandler(Configuration) - Constructor for class org.mockserver.netty.unification.TraceContextHandler
 
trackConnectionClose(Channel) - Method in class org.mockserver.netty.InFlightRequest
Register the channel closeFuture safety net for this token: if the channel closes before a response is produced, InFlightRequest.complete() still fires so the drain counter decrements.
tracksReplies(Channel) - Static method in class org.mockserver.netty.proxy.relay.BinaryRelay
Whether this connection's relay knows where the upstream's reply to each message ends, so a reply can be dropped or replaced: one relayed with a protocol's framing (binaryMessageFraming POSTGRESQL) whose tracking has not been given up on a malformed upstream message.
transformGrpcRequest(HttpRequest, GrpcProtoDescriptorStore) - Static method in class org.mockserver.netty.http3.GrpcHttp3Adapter
Transform a gRPC request for the MockServer matching pipeline: decode the gRPC length-prefixed message(s), convert protobuf to JSON via the descriptor store, and tag the request with service/method markers.
transformGrpcResponse(HttpResponse, String, String, GrpcProtoDescriptorStore) - Static method in class org.mockserver.netty.http3.GrpcHttp3Adapter
Convert the response from the matching pipeline back to a gRPC-framed response.
TRANSPARENT_ORIGINAL_DST_RESOLVED - Static variable in class org.mockserver.netty.proxy.TransparentProxyHandler
Channel attribute indicating the transparent proxy original destination was resolved via SO_ORIGINAL_DST / conntrack (as opposed to Host header).
TransparentProxyHandler - Class in org.mockserver.netty.proxy
A Netty channel handler that resolves the original destination for transparently intercepted connections and stores it as the HttpActionHandler.REMOTE_SOCKET channel attribute.
TransparentProxyHandler(Configuration, MockServerLogger) - Constructor for class org.mockserver.netty.proxy.TransparentProxyHandler
 
TransparentProxyHandler(Configuration, MockServerLogger, TransparentProxyHandler.OriginalDestinationResolver) - Constructor for class org.mockserver.netty.proxy.TransparentProxyHandler
Constructor with injectable resolver for unit testing.
TransparentProxyHandler.OriginalDestinationResolver - Interface in org.mockserver.netty.proxy
Strategy interface for resolving the original destination.
TransparentProxyInitializer - Class in org.mockserver.netty.proxy
Utility for transparent HTTP proxy mode — provides Host-header parsing helpers and an TransparentProxyInitializer.isEnabled() configuration check.
TransparentProxyInitializer(Configuration, MockServerLogger) - Constructor for class org.mockserver.netty.proxy.TransparentProxyInitializer
 
transportError(String) - Static method in class org.mockserver.netty.mcp.McpContractTest.ExchangeResult
 
truncationMarker(String, Object, long, boolean) - Static method in class org.mockserver.dashboard.model.DashboardBodyCap
What the dashboard needs to say a body was cut and to load it whole: the log entry it belongs to, which of the entry's messages it is, and the full and shown lengths.
tunnelServerHandler(Configuration, MockServerLogger, Http2Connection, Http2FrameListener, Http2FrameLogger, boolean) - Static method in class org.mockserver.netty.unification.Http2RequestHeaderLimit
 

U

UNDECIDED_PROTOCOL_WAIT_MILLIS - Static variable in class org.mockserver.netty.unification.PortUnificationHandler
How long first bytes that are only the start of a known protocol are held once the client falls silent, before they are taken for what they are.
unsubscribe(String) - Method in class org.mockserver.async.subscribe.AmqpMessageSubscriber
 
unsubscribe(String) - Method in class org.mockserver.async.subscribe.KafkaAvroMessageSubscriber
 
unsubscribe(String) - Method in class org.mockserver.async.subscribe.KafkaMessageSubscriber
 
unsubscribe(String) - Method in interface org.mockserver.async.subscribe.MessageSubscriber
Stop subscribing to the given channel.
unsubscribe(String) - Method in class org.mockserver.async.subscribe.Mqtt5MessageSubscriber
 
unsubscribe(String) - Method in class org.mockserver.async.subscribe.MqttMessageSubscriber
 
updated(List<Expectation>) - Method in interface org.mockserver.lifecycle.ExpectationsListener
 
updated(MockServerEventLog) - Method in class org.mockserver.dashboard.DashboardWebSocketHandler
 
updated(RequestMatchers, MockServerMatcherNotifier.Cause) - Method in class org.mockserver.dashboard.DashboardWebSocketHandler
 
UpstreamProxyRelayHandler - Class in org.mockserver.netty.proxy.relay
 
UpstreamProxyRelayHandler(MockServerLogger, Channel, Channel, String, int, int) - Constructor for class org.mockserver.netty.proxy.relay.UpstreamProxyRelayHandler
 
UpstreamReply - Class in org.mockserver.netty.proxy.relay
What a relay does with the upstream's reply to one message it forwards: relays it to the client (the default), drops it, or drops it and writes other bytes to the client in its place once it has ended.
userEventTriggered(ChannelHandlerContext, Object) - Method in class org.mockserver.netty.connection.HttpExchangeTracker
 
userEventTriggered(ChannelHandlerContext, Object) - Method in class org.mockserver.netty.connection.HttpTransportTimer
 
userEventTriggered(ChannelHandlerContext, Object) - Method in class org.mockserver.netty.connection.InboundConnectionIdleHandler
 
userEventTriggered(ChannelHandlerContext, Object) - Method in class org.mockserver.netty.http3.Http3ExceptionHandler
 
userEventTriggered(ChannelHandlerContext, Object) - Method in class org.mockserver.netty.proxy.BinaryRequestProxyingHandler
A binary client that turns TLS on part way through reaches here once its server certificate is chosen, before anything it sends over TLS is decrypted: the relay then starts TLS with the upstream on the same connection.
userEventTriggered(ChannelHandlerContext, Object) - Method in class org.mockserver.netty.proxy.relay.LoopbackRelaySignalHandler
 
userEventTriggered(ChannelHandlerContext, Object) - Method in class org.mockserver.netty.unification.LenientInboundHttp2StreamFrameCodec
 
username(String) - Method in class org.mockserver.async.security.MqttSecurity.Builder
 

V

valid() - Static method in class org.mockserver.async.validation.AsyncApiSchemaValidator.ValidationResult
 
validate(String, JsonNode) - Method in class org.mockserver.async.validation.AsyncApiSchemaValidator
Validate that the given JSON payload conforms to the given JSON Schema.
validateToken(ByteBuf, InetSocketAddress) - Method in class org.mockserver.netty.http3.SourceAddressQuicTokenHandler
 
valueOf(String) - Static method in enum class org.mockserver.async.asyncapi.AmqpBinding.ChannelType
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.mockserver.cli.Main.Arguments
Returns the enum constant of this class with the specified name.
values() - Static method in enum class org.mockserver.async.asyncapi.AmqpBinding.ChannelType
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.mockserver.cli.Main.Arguments
Returns an array containing the constants of this enum class, in the order they are declared.
verify(String) - Method in class org.mockserver.async.controlplane.AsyncApiControlPlaneImpl
 

W

workerGroup - Variable in class org.mockserver.lifecycle.LifeCycle
 
write(ChannelHandlerContext, Object, ChannelPromise) - Method in class org.mockserver.netty.connection.Http2StreamTransportTimer
 
write(ChannelHandlerContext, Object, ChannelPromise) - Method in class org.mockserver.netty.connection.HttpExchangeTracker
 
write(ChannelHandlerContext, Object, ChannelPromise) - Method in class org.mockserver.netty.connection.HttpTransportTimer
 
write(ChannelHandlerContext, Object, ChannelPromise) - Method in class org.mockserver.netty.grpc.GrpcToHttpResponseHandler
Releases the pending record when a response is written that this encoder will never see.
write(ChannelHandlerContext, Object, ChannelPromise) - Method in class org.mockserver.netty.http3.Http3StreamWriteStallHandler
 
write(ChannelHandlerContext, Object, ChannelPromise) - Method in class org.mockserver.netty.proxy.relay.LoopbackHttp2StreamIdRemapper
 
write(ChannelHandlerContext, Object, ChannelPromise) - Method in class org.mockserver.netty.unification.AltSvcHeaderHandler
 
write(ChannelHandlerContext, Object, ChannelPromise) - Method in class org.mockserver.netty.unification.LenientInboundHttp2StreamFrameCodec
 
write(ChannelHandlerContext, Object, ChannelPromise) - Method in class org.mockserver.netty.unification.PacedLargeWriteHandler
 
write(ChannelHandlerContext, Object, ChannelPromise) - Method in class org.mockserver.netty.unification.StreamAddressedContentHandler
 
write(ChannelHandlerContext, Object, ChannelPromise) - Method in class org.mockserver.netty.unification.TraceContextHandler
 
writeGrpcStreamResponse(GrpcStreamResponse, HttpRequest) - Method in class org.mockserver.netty.http3.Http3GrpcResponseWriter
Write a server-streaming gRPC response over HTTP/3: an initial HEADERS frame (:status=200, content-type=application/grpc, plus any configured headers), one DATA frame per message honouring per-message Delay, then a trailing HEADERS frame carrying grpc-status / grpc-message, followed by a QUIC stream output shutdown (or connection close when configured).
writeHeaders(ChannelHandlerContext, int, Http2Headers, int, boolean, ChannelPromise) - Method in class org.mockserver.netty.unification.ExtensionHeaderStrippingHttp2ConnectionEncoder
 
writeHeaders(ChannelHandlerContext, int, Http2Headers, int, short, boolean, int, boolean, ChannelPromise) - Method in class org.mockserver.netty.unification.ExtensionHeaderStrippingHttp2ConnectionEncoder
 
WriteStallTimeoutHandler - Class in org.mockserver.netty.connection
Closes an inbound connection when bytes have been waiting for its client for responseWriteStallTimeoutMillis and the client has taken none of them, so a client that stops reading cannot hold what is queued for it (and, for a streamed response, its upstream connection) indefinitely.
WriteStallTimeoutHandler(long, MockServerLogger) - Constructor for class org.mockserver.netty.connection.WriteStallTimeoutHandler
 
writeStreamError(long) - Method in class org.mockserver.netty.http3.Http3ResponseWriter
Reset the QUIC stream with the supplied HTTP/3 error code (RESET_STREAM, RFC 9114 section 4.1).
writeToken(ByteBuf, ByteBuf, InetSocketAddress) - Method in class org.mockserver.netty.http3.SourceAddressQuicTokenHandler
 
A B C D E F G H I J K L M N O P Q R S T U V W 
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form