Uses of Interface
io.vertx.core.Handler
-
-
Uses of Handler in io.vertx.amqp
Methods in io.vertx.amqp with parameters of type Handler Modifier and Type Method Description AmqpReceiverAmqpReceiver. endHandler(Handler<Void> endHandler)AmqpConnectionAmqpConnection. exceptionHandler(Handler<Throwable> handler)Registers a handler called on disconnection.AmqpReceiverAmqpReceiver. exceptionHandler(Handler<Throwable> handler)AmqpSenderAmqpSender. exceptionHandler(Handler<Throwable> handler)AmqpReceiverAmqpReceiver. handler(Handler<AmqpMessage> handler) -
Uses of Handler in io.vertx.cassandra
Methods in io.vertx.cassandra with parameters of type Handler Modifier and Type Method Description CassandraRowStreamCassandraRowStream. endHandler(Handler<Void> handler)CassandraRowStreamCassandraRowStream. exceptionHandler(Handler<Throwable> handler)CassandraRowStreamCassandraRowStream. handler(Handler<com.datastax.oss.driver.api.core.cql.Row> handler) -
Uses of Handler in io.vertx.circuitbreaker
Methods in io.vertx.circuitbreaker with parameters of type Handler Modifier and Type Method Description CircuitBreakerCircuitBreaker. closeHandler(Handler<Void> handler)Sets aHandlerto be invoked when the circuit breaker state switches to closed.<T> Future<T>CircuitBreaker. execute(Handler<Promise<T>> command)Same asCircuitBreaker.executeWithFallback(Handler, Function)but using the circuit breaker default fallback.<T> CircuitBreakerCircuitBreaker. executeAndReport(Promise<T> resultPromise, Handler<Promise<T>> command)Same asCircuitBreaker.executeAndReportWithFallback(Promise, Handler, Function)but using the circuit breaker default fallback.<T> CircuitBreakerCircuitBreaker. executeAndReportWithFallback(Promise<T> resultPromise, Handler<Promise<T>> command, Function<Throwable,T> fallback)Executes the given operation with the circuit breaker control.<T> Future<T>CircuitBreaker. executeWithFallback(Handler<Promise<T>> command, Function<Throwable,T> fallback)Executes the given operation with the circuit breaker control.CircuitBreakerCircuitBreaker. halfOpenHandler(Handler<Void> handler)Sets aHandlerto be invoked when the circuit breaker state switches to half-open.CircuitBreakerCircuitBreaker. openHandler(Handler<Void> handler)Sets aHandlerto be invoked when the circuit breaker state switches to open. -
Uses of Handler in io.vertx.config
Methods in io.vertx.config with parameters of type Handler Modifier and Type Method Description voidConfigRetriever. listen(Handler<ConfigChange> listener)Registers a listener receiving configuration changes.ConfigRetrieverConfigRetriever. setBeforeScanHandler(Handler<Void> handler)Registers a handler called before every scan. -
Uses of Handler in io.vertx.config.spi.utils
Methods in io.vertx.config.spi.utils with parameters of type Handler Modifier and Type Method Description voidFileSet. buildConfiguration(List<File> files, Handler<AsyncResult<JsonObject>> handler)Iterates over the given set of files, and for each matching file, computes the resulting configuration. -
Uses of Handler in io.vertx.core
Methods in io.vertx.core that return Handler Modifier and Type Method Description Handler<Throwable>Context. exceptionHandler()Handler<Throwable>Vertx. exceptionHandler()Methods in io.vertx.core with parameters of type Handler Modifier and Type Method Description default Future<T>Future. andThen(Handler<AsyncResult<T>> handler)Invokes the givenhandlerupon completion.ContextContext. exceptionHandler(Handler<Throwable> handler)Set an exception handler called when the context runs an action throwing an uncaught throwable.VertxVertx. exceptionHandler(Handler<Throwable> handler)Set a default exception handler forContext, set onContext.exceptionHandler(Handler)at creation.static <T> Future<T>Future. future(Handler<Promise<T>> handler)Create a promise and pass it to thehandler, and then returns this future's promise.CompositeFutureCompositeFuture. onComplete(Handler<AsyncResult<CompositeFuture>> handler)default Future<T>Future. onComplete(Handler<? super T> successHandler, Handler<? super Throwable> failureHandler)Add handlers to be notified on succeeded result and failed result.Future<T>Future. onComplete(Handler<AsyncResult<T>> handler)Add a handler to be notified of the result.default CompositeFutureCompositeFuture. onFailure(Handler<? super Throwable> handler)default Future<T>Future. onFailure(Handler<? super Throwable> handler)Add a handler to be notified of the failed result.default CompositeFutureCompositeFuture. onSuccess(Handler<? super CompositeFuture> handler)default Future<T>Future. onSuccess(Handler<? super T> handler)Add a handler to be notified of the succeeded result.voidContext. runOnContext(Handler<Void> action)Run the specified action asynchronously on the same context, some time after the current execution has completed.voidVertx. runOnContext(Handler<Void> action)Puts the handler on the event queue for the current context so it will be run asynchronously ASAP after all preceeding events have been handled.longVertx. setPeriodic(long initialDelay, long delay, Handler<Long> handler)Set a periodic timer to fire everydelaymilliseconds with initial delay, at which pointhandlerwill be called with the id of the timer.default longVertx. setPeriodic(long delay, Handler<Long> handler)Set a periodic timer to fire everydelaymilliseconds, at which pointhandlerwill be called with the id of the timer.longVertx. setTimer(long delay, Handler<Long> handler)Set a one-shot timer to fire afterdelaymilliseconds, at which pointhandlerwill be called with the id of the timer. -
Uses of Handler in io.vertx.core.datagram
Methods in io.vertx.core.datagram with parameters of type Handler Modifier and Type Method Description DatagramSocketDatagramSocket. exceptionHandler(Handler<Throwable> handler)DatagramSocketDatagramSocket. handler(Handler<DatagramPacket> handler) -
Uses of Handler in io.vertx.core.eventbus
Methods in io.vertx.core.eventbus with parameters of type Handler Modifier and Type Method Description <T> EventBusEventBus. addInboundInterceptor(Handler<DeliveryContext<T>> interceptor)Add an interceptor that will be called whenever a message is received by Vert.x<T> EventBusEventBus. addOutboundInterceptor(Handler<DeliveryContext<T>> interceptor)Add an interceptor that will be called whenever a message is sent from Vert.x<T> MessageConsumer<T>EventBus. consumer(MessageConsumerOptions options, Handler<Message<T>> handler)Create a consumer and register it against the specified options address.<T> MessageConsumer<T>EventBus. consumer(String address, Handler<Message<T>> handler)Create a consumer and register it against the specified address.MessageConsumer<T>MessageConsumer. endHandler(Handler<Void> endHandler)MessageConsumer<T>MessageConsumer. exceptionHandler(Handler<Throwable> handler)MessageConsumer<T>MessageConsumer. handler(Handler<Message<T>> handler)<T> MessageConsumer<T>EventBus. localConsumer(String address, Handler<Message<T>> handler)LikeEventBus.consumer(String, Handler)but the address won't be propagated across the cluster.<T> EventBusEventBus. removeInboundInterceptor(Handler<DeliveryContext<T>> interceptor)Remove an interceptor that was added byEventBus.addInboundInterceptor(Handler)<T> EventBusEventBus. removeOutboundInterceptor(Handler<DeliveryContext<T>> interceptor)Remove an interceptor that was added byEventBus.addOutboundInterceptor(Handler) -
Uses of Handler in io.vertx.core.file
Methods in io.vertx.core.file with parameters of type Handler Modifier and Type Method Description AsyncFileAsyncFile. drainHandler(Handler<Void> handler)AsyncFileAsyncFile. endHandler(Handler<Void> endHandler)AsyncFileAsyncFile. exceptionHandler(Handler<Throwable> handler)Set an exception handler on the read stream and on the write stream.AsyncFileAsyncFile. handler(Handler<Buffer> handler) -
Uses of Handler in io.vertx.core.http
Fields in io.vertx.core.http declared as Handler Modifier and Type Field Description static Handler<HttpServerRequest>HttpServerRequest. DEFAULT_INVALID_REQUEST_HANDLERThe default invalid request handler, it uses theHttpServerRequest.decoderResult()cause and the request information to determine the status code of the response to be sent.Methods in io.vertx.core.http that return Handler Modifier and Type Method Description Handler<HttpServerRequest>HttpServer. requestHandler()Handler<ServerWebSocket>HttpServer. webSocketHandler()Methods in io.vertx.core.http with parameters of type Handler Modifier and Type Method Description ClientWebSocketClientWebSocket. binaryMessageHandler(Handler<Buffer> handler)WebSocketWebSocket. binaryMessageHandler(Handler<Buffer> handler)WebSocketBaseWebSocketBase. binaryMessageHandler(Handler<Buffer> handler)Set a binary message handler on the connection.HttpServerResponseHttpServerResponse. bodyEndHandler(Handler<Void> handler)Provides a handler that will be called after the last part of the body is written to the wire.default HttpClientResponseHttpClientResponse. bodyHandler(Handler<Buffer> bodyHandler)Convenience method for receiving the entire request body in one piece.default HttpServerRequestHttpServerRequest. bodyHandler(Handler<Buffer> bodyHandler)Convenience method for receiving the entire request body in one piece.ClientWebSocketClientWebSocket. closeHandler(Handler<Void> handler)HttpConnectionHttpConnection. closeHandler(Handler<Void> handler)Set a close handler.HttpServerResponseHttpServerResponse. closeHandler(Handler<Void> handler)Set a close handler for the response, this is called when the underlying connection is closed and the response was still using the connection.ServerWebSocketServerWebSocket. closeHandler(Handler<Void> handler)WebSocketWebSocket. closeHandler(Handler<Void> handler)WebSocketBaseWebSocketBase. closeHandler(Handler<Void> handler)Set a close handler.HttpServerHttpServer. connectionHandler(Handler<HttpConnection> handler)Set a connection handler for the server.HttpClientRequestHttpClientRequest. continueHandler(Handler<Void> handler)If you send an HTTP request with the headerExpectset to the value100-continueand the server responds with an interim HTTP response with a status code of100and a Continue handler has been set using this method, then thehandlerwill be called.HttpClientResponseHttpClientResponse. customFrameHandler(Handler<HttpFrame> handler)Set an custom frame handler.HttpServerRequestHttpServerRequest. customFrameHandler(Handler<HttpFrame> handler)Set a custom frame handler.ClientWebSocketClientWebSocket. drainHandler(Handler<Void> handler)HttpClientRequestHttpClientRequest. drainHandler(Handler<Void> handler)HttpServerResponseHttpServerResponse. drainHandler(Handler<Void> handler)ServerWebSocketServerWebSocket. drainHandler(Handler<Void> handler)WebSocketWebSocket. drainHandler(Handler<Void> handler)WebSocketBaseWebSocketBase. drainHandler(Handler<Void> handler)HttpClientRequestHttpClientRequest. earlyHintsHandler(Handler<MultiMap> handler)If the server responds with an interim HTTP response with a status code of103and a Early Hints handler has been set using this method, then thehandlerwill be called.ClientWebSocketClientWebSocket. endHandler(Handler<Void> endHandler)HttpClientResponseHttpClientResponse. endHandler(Handler<Void> endHandler)HttpServerFileUploadHttpServerFileUpload. endHandler(Handler<Void> endHandler)HttpServerRequestHttpServerRequest. endHandler(Handler<Void> endHandler)HttpServerResponseHttpServerResponse. endHandler(Handler<Void> handler)Set an end handler for the response.ServerWebSocketServerWebSocket. endHandler(Handler<Void> endHandler)WebSocketWebSocket. endHandler(Handler<Void> endHandler)WebSocketBaseWebSocketBase. endHandler(Handler<Void> endHandler)ClientWebSocketClientWebSocket. exceptionHandler(Handler<Throwable> handler)HttpClientRequestHttpClientRequest. exceptionHandler(Handler<Throwable> handler)HttpClientResponseHttpClientResponse. exceptionHandler(Handler<Throwable> handler)HttpConnectionHttpConnection. exceptionHandler(Handler<Throwable> handler)Set an handler called when a connection error happensHttpServerHttpServer. exceptionHandler(Handler<Throwable> handler)Set an exception handler called for socket errors happening before the HTTP connection is established, e.g during the TLS handshake.HttpServerFileUploadHttpServerFileUpload. exceptionHandler(Handler<Throwable> handler)HttpServerRequestHttpServerRequest. exceptionHandler(Handler<Throwable> handler)HttpServerResponseHttpServerResponse. exceptionHandler(Handler<Throwable> handler)ServerWebSocketServerWebSocket. exceptionHandler(Handler<Throwable> handler)WebSocketWebSocket. exceptionHandler(Handler<Throwable> handler)WebSocketBaseWebSocketBase. exceptionHandler(Handler<Throwable> handler)ClientWebSocketClientWebSocket. frameHandler(Handler<WebSocketFrame> handler)ServerWebSocketServerWebSocket. frameHandler(Handler<WebSocketFrame> handler)WebSocketWebSocket. frameHandler(Handler<WebSocketFrame> handler)WebSocketBaseWebSocketBase. frameHandler(Handler<WebSocketFrame> handler)Set a frame handler on the connection.HttpConnectionHttpConnection. goAwayHandler(Handler<GoAway> handler)Set an handler called when a GOAWAY frame is received.ClientWebSocketClientWebSocket. handler(Handler<Buffer> handler)HttpClientResponseHttpClientResponse. handler(Handler<Buffer> handler)HttpServerFileUploadHttpServerFileUpload. handler(Handler<Buffer> handler)HttpServerRequestHttpServerRequest. handler(Handler<Buffer> handler)ServerWebSocketServerWebSocket. handler(Handler<Buffer> handler)WebSocketWebSocket. handler(Handler<Buffer> handler)WebSocketBaseWebSocketBase. handler(Handler<Buffer> handler)HttpServerResponseHttpServerResponse. headersEndHandler(Handler<Void> handler)Provide a handler that will be called just before the headers are written to the wire.HttpServerHttpServer. invalidRequestHandler(Handler<HttpServerRequest> handler)Set ahandlerfor handling invalid requests.HttpConnectionHttpConnection. pingHandler(Handler<Buffer> handler)Set an handler notified when a PING frame is received from the remote endpoint.ClientWebSocketClientWebSocket. pongHandler(Handler<Buffer> handler)WebSocketWebSocket. pongHandler(Handler<Buffer> handler)WebSocketBaseWebSocketBase. pongHandler(Handler<Buffer> handler)Set a pong frame handler on the connection.HttpClientRequestHttpClientRequest. pushHandler(Handler<HttpClientRequest> handler)Set a push handler for this request.HttpConnectionHttpConnection. remoteSettingsHandler(Handler<Http2Settings> handler)Set an handler that is called when remote endpointHttp2Settingsare updated.HttpServerHttpServer. requestHandler(Handler<HttpServerRequest> handler)Set the request handler for the server torequestHandler.HttpConnectionHttpConnection. shutdownHandler(Handler<Void> handler)Set ahandlernotified when the HTTP connection is shutdown: the client or server will close the connection within a certain amount of time.WebSocketWebSocket. shutdownHandler(Handler<Void> handler)WebSocketBaseWebSocketBase. shutdownHandler(Handler<Void> handler)Set ahandlernotified when the WebSocket is shutdown: the client or server will close the connection within a certain amount of time.HttpClientResponseHttpClientResponse. streamPriorityHandler(Handler<StreamPriority> handler)Set an handler for stream priority changes.HttpServerRequestHttpServerRequest. streamPriorityHandler(Handler<StreamPriority> handler)Set an handler for stream priority changesClientWebSocketClientWebSocket. textMessageHandler(Handler<String> handler)WebSocketWebSocket. textMessageHandler(Handler<String> handler)WebSocketBaseWebSocketBase. textMessageHandler(Handler<String> handler)Set a text message handler on the connection.HttpServerRequestHttpServerRequest. uploadHandler(Handler<HttpServerFileUpload> uploadHandler)Set an upload handler.HttpServerHttpServer. webSocketHandler(Handler<ServerWebSocket> handler)Set the WebSocket handler for the server towsHandler.HttpServerHttpServer. webSocketHandshakeHandler(Handler<ServerWebSocketHandshake> handler)Set a handler for WebSocket handshake.HttpClientBuilderHttpClientBuilder. withConnectHandler(Handler<HttpConnection> handler)Set a connection handler for the client. -
Uses of Handler in io.vertx.core.net
Methods in io.vertx.core.net that return Handler Modifier and Type Method Description Handler<NetSocket>NetServer. connectHandler()Methods in io.vertx.core.net with parameters of type Handler Modifier and Type Method Description NetSocketNetSocket. closeHandler(Handler<Void> handler)Set ahandlernotified when the socket is closedNetServerNetServer. connectHandler(Handler<NetSocket> handler)Supply a connect handler for this server.NetSocketNetSocket. drainHandler(Handler<Void> handler)NetSocketNetSocket. endHandler(Handler<Void> endHandler)Set an end handler.NetServerNetServer. exceptionHandler(Handler<Throwable> handler)Set an exception handler called for socket errors happening before the connection is passed to theNetServer.connectHandler(io.vertx.core.Handler<io.vertx.core.net.NetSocket>), e.g during the TLS handshake.NetSocketNetSocket. exceptionHandler(Handler<Throwable> handler)NetSocketNetSocket. handler(Handler<Buffer> handler)NetSocketNetSocket. shutdownHandler(Handler<Void> handler)Set ahandlernotified when the socket is shutdown: the client or server will close the connection within a certain amount of time. -
Uses of Handler in io.vertx.core.parsetools
Subinterfaces of Handler in io.vertx.core.parsetools Modifier and Type Interface Description interfaceJsonParserA parser class which allows to incrementally parse json elements and emit json parse events instead of parsing a json element fully.interfaceRecordParserA helper class which allows you to easily parse protocols which are delimited by a sequence of bytes, or fixed size records.Methods in io.vertx.core.parsetools with parameters of type Handler Modifier and Type Method Description JsonParserJsonParser. endHandler(Handler<Void> endHandler)RecordParserRecordParser. endHandler(Handler<Void> endHandler)JsonParserJsonParser. exceptionHandler(Handler<Throwable> handler)RecordParserRecordParser. exceptionHandler(Handler<Throwable> handler)JsonParserJsonParser. handler(Handler<JsonEvent> handler)RecordParserRecordParser. handler(Handler<Buffer> handler)static RecordParserRecordParser. newDelimited(Buffer delim, Handler<Buffer> output)LikeRecordParser.newDelimited(Buffer)but set theoutputthat will receive whole records which have been parsed.static RecordParserRecordParser. newDelimited(String delim, Handler<Buffer> output)LikeRecordParser.newDelimited(String)but set theoutputthat will receive whole records which have been parsed.static RecordParserRecordParser. newFixed(int size, Handler<Buffer> output)LikeRecordParser.newFixed(int)but set theoutputthat will receive whole records which have been parsed.voidRecordParser. setOutput(Handler<Buffer> output) -
Uses of Handler in io.vertx.core.streams
Methods in io.vertx.core.streams with parameters of type Handler Modifier and Type Method Description WriteStream<T>WriteStream. drainHandler(Handler<Void> handler)Set a drain handler on the stream.ReadStream<T>ReadStream. endHandler(Handler<Void> endHandler)Set an end handler.ReadStream<T>ReadStream. exceptionHandler(Handler<Throwable> handler)Set an exception handler on the read stream.StreamBaseStreamBase. exceptionHandler(Handler<Throwable> handler)Set an exception handler.WriteStream<T>WriteStream. exceptionHandler(Handler<Throwable> handler)Set an exception handler on the write stream.ReadStream<T>ReadStream. handler(Handler<T> handler)Set a data handler. -
Uses of Handler in io.vertx.db2client
Methods in io.vertx.db2client with parameters of type Handler Modifier and Type Method Description static SqlClientDB2Builder. client(Handler<ClientBuilder<SqlClient>> handler)Build a client backed by a connection pool with the specifiedblockargument.DB2ConnectionDB2Connection. closeHandler(Handler<Void> handler)DB2ConnectionDB2Connection. exceptionHandler(Handler<Throwable> handler)static PoolDB2Builder. pool(Handler<ClientBuilder<Pool>> block)Build a pool with the specifiedblockargument. -
Uses of Handler in io.vertx.db2client.spi
Methods in io.vertx.db2client.spi with parameters of type Handler Modifier and Type Method Description PoolDB2Driver. newPool(Vertx vertx, Supplier<Future<DB2ConnectOptions>> databases, PoolOptions poolOptions, NetClientOptions transportOptions, Handler<SqlConnection> connectHandler, io.vertx.core.internal.CloseFuture closeFuture) -
Uses of Handler in io.vertx.ext.auth.audit
Methods in io.vertx.ext.auth.audit that return Handler Modifier and Type Method Description default <T> Handler<AsyncResult<T>>SecurityAudit. auditHandlerFor(Marker marker) -
Uses of Handler in io.vertx.ext.auth.oauth2
Methods in io.vertx.ext.auth.oauth2 with parameters of type Handler Modifier and Type Method Description OAuth2AuthOAuth2Auth. missingKeyHandler(Handler<String> handler)Handled to be called when a key (mentioned on a JWT) is missing from the current config. -
Uses of Handler in io.vertx.ext.cluster.infinispan
Subinterfaces of Handler in io.vertx.ext.cluster.infinispan Modifier and Type Interface Description interfaceClusterHealthCheckA helper to create Vert.x clusterHealthChecksprocedures. -
Uses of Handler in io.vertx.ext.consul
Methods in io.vertx.ext.consul with parameters of type Handler Modifier and Type Method Description Watch<T>Watch. setHandler(Handler<WatchResult<T>> handler)Set the result handler. -
Uses of Handler in io.vertx.ext.eventbus.bridge.tcp
Methods in io.vertx.ext.eventbus.bridge.tcp with parameters of type Handler Modifier and Type Method Description static TcpEventBusBridgeTcpEventBusBridge. create(Vertx vertx, BridgeOptions options, NetServerOptions netServerOptions, Handler<BridgeEvent> eventHandler) -
Uses of Handler in io.vertx.ext.healthchecks
Methods in io.vertx.ext.healthchecks with parameters of type Handler Modifier and Type Method Description HealthChecksHealthChecks. invoke(Handler<JsonObject> resultHandler)Invokes the registered procedures and computes the outcome.HealthChecksHealthChecks. register(String name, long timeout, Handler<Promise<Status>> procedure)Registers a health check procedure.HealthChecksHealthChecks. register(String name, Handler<Promise<Status>> procedure)Registers a health check procedure. -
Uses of Handler in io.vertx.ext.reactivestreams
Methods in io.vertx.ext.reactivestreams with parameters of type Handler Modifier and Type Method Description ReactiveWriteStream<T>ReactiveWriteStream. drainHandler(Handler<Void> handler)ReactiveReadStream<T>ReactiveReadStream. endHandler(Handler<Void> endHandler)ReactiveReadStream<T>ReactiveReadStream. exceptionHandler(Handler<Throwable> handler)ReactiveWriteStream<T>ReactiveWriteStream. exceptionHandler(Handler<Throwable> handler)ReactiveReadStream<T>ReactiveReadStream. handler(Handler<T> handler) -
Uses of Handler in io.vertx.ext.shell
Methods in io.vertx.ext.shell with parameters of type Handler Modifier and Type Method Description voidShellServer. shellHandler(Handler<Shell> shellHandler)Called when a new shell is created. -
Uses of Handler in io.vertx.ext.shell.command
Methods in io.vertx.ext.shell.command with parameters of type Handler Modifier and Type Method Description CommandProcessCommandProcess. backgroundHandler(Handler<Void> handler)Set a background handler, this handler is called when the command is running and put to background.CommandBuilderCommandBuilder. completionHandler(Handler<Completion> handler)Set the command completion handler, the completion handler when the user asks for contextual command line completion, usually hitting the tab key.CommandProcessCommandProcess. endHandler(Handler<Void> handler)Set an end handler, this handler is called when the command is ended, for instance the command is running and the shell closes.CommandProcessCommandProcess. foregroundHandler(Handler<Void> handler)Set a foreground handler, this handler is called when the command is running and put to foreground.CommandProcessCommandProcess. interruptHandler(Handler<Void> handler)Set an interrupt handler, this handler is called when the command is interrupted, for instance user pressCtrl-C.CommandBuilderCommandBuilder. processHandler(Handler<CommandProcess> handler)Set the command process handler, the process handler is called when the command is executed.CommandProcessCommandProcess. resizehandler(Handler<Void> handler)CommandProcessCommandProcess. resumeHandler(Handler<Void> handler)Set a resume handler, this handler is called when the command is resumed, for instance user typesbgorfgto resume the command.CommandProcessCommandProcess. stdinHandler(Handler<String> handler)CommandProcessCommandProcess. suspendHandler(Handler<Void> handler)Set a suspend handler, this handler is called when the command is suspended, for instance user pressCtrl-Z. -
Uses of Handler in io.vertx.ext.shell.spi
Methods in io.vertx.ext.shell.spi with parameters of type Handler Modifier and Type Method Description voidCommandResolverFactory. resolver(Vertx vertx, Handler<AsyncResult<CommandResolver>> resolveHandler)Obtain a command resolver for a Vert.x instance. -
Uses of Handler in io.vertx.ext.shell.system
Methods in io.vertx.ext.shell.system with parameters of type Handler Modifier and Type Method Description voidJobController. close(Handler<Void> completionHandler)Close the controller and terminate all the underlying jobs, a closed controller does not accept anymore jobs.booleanProcess. interrupt(Handler<Void> completionHandler)Attempt to interrupt the process.voidProcess. resume(boolean foreground, Handler<Void> completionHandler)Suspend the process.default voidProcess. resume(Handler<Void> completionHandler)Suspend the process.JobJob. statusUpdateHandler(Handler<ExecStatus> handler)Set an handler called when the job terminates.voidProcess. suspend(Handler<Void> completionHandler)Resume the process.voidProcess. terminate(Handler<Void> completionHandler)Terminate the process.ProcessProcess. terminatedHandler(Handler<Integer> handler)Set an handler for being notified when the process terminates.voidProcess. toBackground(Handler<Void> completionHandler)Set the process in background.voidProcess. toForeground(Handler<Void> completionHandler)Set the process in foreground. -
Uses of Handler in io.vertx.ext.shell.term
Subinterfaces of Handler in io.vertx.ext.shell.term Modifier and Type Interface Description interfaceSockJSTermHandlerMethods in io.vertx.ext.shell.term with parameters of type Handler Modifier and Type Method Description TermTerm. closeHandler(Handler<Void> handler)Set a handler that will be called when the terminal is closed.voidTerm. readline(String prompt, Handler<String> lineHandler)Prompt the user a line of text.voidTerm. readline(String prompt, Handler<String> lineHandler, Handler<Completion> completionHandler)Prompt the user a line of text, providing a completion handler to handle user's completion.TermTerm. resizehandler(Handler<Void> handler)TtyTty. resizehandler(Handler<Void> handler)Set a resize handler, the handler is called when the tty size changes.TermTerm. stdinHandler(Handler<String> handler)TtyTty. stdinHandler(Handler<String> handler)Set a stream handler on the standard input to read the data.PtyPty. stdoutHandler(Handler<String> handler)Set the standard out handler of the pseudo terminal.SockJSTermHandlerSockJSTermHandler. termHandler(Handler<Term> handler)TermServerTermServer. termHandler(Handler<Term> handler)Set the term handler that will receive incoming client connections. -
Uses of Handler in io.vertx.ext.stomp
Subinterfaces of Handler in io.vertx.ext.stomp Modifier and Type Interface Description interfaceStompServerHandlerSTOMP server handler implements the behavior of the STOMP server when a specific event occurs.Classes in io.vertx.ext.stomp that implement Handler Modifier and Type Class Description classDefaultAbortHandlerSTOMP compliant actions executed when receiving aABORTframe.classDefaultAckHandlerSTOMP compliant actions executed when receiving aACKframe.classDefaultBeginHandlerSTOMP compliant actions executed when receiving aBEGINframe.classDefaultCommitHandlerSTOMP compliant actions executed when receiving aCOMMITframe.classDefaultConnectHandlerSTOMP compliant actions executed when receiving aCONNECTframe.classDefaultNackHandlerSTOMP compliant actions executed when receiving aNACKsf.frame().classDefaultSendHandlerSTOMP compliant actions executed when receiving aSENDsf.frame().classDefaultSubscribeHandlerSTOMP compliant actions executed when receiving aSUBSCRIBEframe.classDefaultUnsubscribeHandlerSTOMP compliant actions executed when receiving aUNSUBSCRIBEframe.Methods in io.vertx.ext.stomp that return Handler Modifier and Type Method Description Handler<ServerWebSocket>StompServer. webSocketHandler()Gets theHandlerable to manage web socket connections.Handler<ServerWebSocketHandshake>StompServer. webSocketHandshakeHandler()Gets theHandlerable to manage web socket connection handshakes.Methods in io.vertx.ext.stomp with parameters of type Handler Modifier and Type Method Description StompServerHandlerStompServerHandler. abortHandler(Handler<ServerFrame> handler)Configures the action to execute when aABORTframe is received.StompServerHandlerStompServerHandler. ackHandler(Handler<ServerFrame> handler)Configures the action to execute when aACKframe is received.StompServerHandlerStompServerHandler. beginHandler(Handler<ServerFrame> handler)Configures the action to execute when aBEGINframe is received.StompClientConnectionStompClientConnection. closeHandler(Handler<StompClientConnection> handler)Sets a handler notified when the STOMP connection is closed.StompServerHandlerStompServerHandler. closeHandler(Handler<StompServerConnection> handler)Configures the action to execute when a connection with the client is closed.StompServerHandlerStompServerHandler. commitHandler(Handler<ServerFrame> handler)Configures the action to execute when aCOMMITframe is received.voidStompServerConnection. configureHeartbeat(long ping, long pong, Handler<StompServerConnection> pingHandler)Configures the heartbeat.StompServerHandlerStompServerHandler. connectHandler(Handler<ServerFrame> handler)Configures the action to execute when aCONNECTframe is received.StompClientConnectionStompClientConnection. connectionDroppedHandler(Handler<StompClientConnection> handler)Sets a handler notified when the server does not respond to apingrequest in time.StompServerHandlerStompServerHandler. disconnectHandler(Handler<ServerFrame> handler)Configures the action to execute when aDISCONNECTframe is received.StompClientStompClient. errorFrameHandler(Handler<Frame> handler)A general error frame handler.StompClientConnectionStompClientConnection. errorHandler(Handler<Frame> handler)Sets a handler notified when anERRORframe is received by the client.StompClientStompClient. exceptionHandler(Handler<Throwable> handler)Sets an exception handler notified for TCP-level errors.StompClientConnectionStompClientConnection. exceptionHandler(Handler<Throwable> exceptionHandler)Configures the exception handler notified upon TCP-level errors.StompServerHandlerStompServerHandler. nackHandler(Handler<ServerFrame> handler)Configures the action to execute when aNACKframe is received.StompServerHandlerStompServerHandler. onAckHandler(Handler<Acknowledgement> handler)Configures the action to execute when messages are acknowledged.StompServerHandlerStompServerHandler. onNackHandler(Handler<Acknowledgement> handler)Configures the action to execute when messages are not acknowledged.StompClientConnectionStompClientConnection. pingHandler(Handler<StompClientConnection> handler)Sets a handler that let customize the behavior when a ping needs to be sent to the server.StompServerHandlerStompServerHandler. pingHandler(Handler<StompServerConnection> handler)Allows customizing the action to do when the server needs to send a `PING` to the client.StompClientStompClient. receivedFrameHandler(Handler<Frame> handler)Configures a received handler that gets notified when a STOMP frame is received by the client.StompClientConnectionStompClientConnection. receivedFrameHandler(Handler<Frame> handler)Configures a received handler that get notified when a STOMP frame is received by the client.StompServerHandlerStompServerHandler. receivedFrameHandler(Handler<ServerFrame> handler)Configures a handler that get notified when a STOMP frame is received by the server.StompServerHandlerStompServerHandler. sendHandler(Handler<ServerFrame> handler)Configures the action to execute when aSENDframe is received.StompServerHandlerStompServerHandler. stompHandler(Handler<ServerFrame> handler)Configures the action to execute when aSTOMPframe is received.Future<String>StompClientConnection. subscribe(String destination, Handler<Frame> handler)Subscribes to the given destination.Future<String>StompClientConnection. subscribe(String destination, Map<String,String> headers, Handler<Frame> handler)Subscribes to the given destination.StompServerHandlerStompServerHandler. subscribeHandler(Handler<ServerFrame> handler)Configures the action to execute when aSUBSCRIBEframe is received.StompServerHandlerStompServerHandler. unsubscribeHandler(Handler<ServerFrame> handler)Configures the action to execute when aUNSUBSCRIBEframe is received.StompClientStompClient. writingFrameHandler(Handler<Frame> handler)Configures a writing handler that gets notified when a STOMP frame is written on the wire.StompClientConnectionStompClientConnection. writingFrameHandler(Handler<Frame> handler)Configures a handler notified when a frame is going to be written on the wire.StompServerStompServer. writingFrameHandler(Handler<ServerFrame> handler)Configures the handler that is invoked every time a frame is going to be written to the "wire". -
Uses of Handler in io.vertx.ext.unit
Methods in io.vertx.ext.unit that return Handler Modifier and Type Method Description <T> Handler<AsyncResult<T>>TestContext. asyncAssertFailure()Creates and returns a new async handler, the returned handler controls the completion of the test.<T> Handler<AsyncResult<T>>TestContext. asyncAssertFailure(Handler<Throwable> causeHandler)Creates and returns a new async handler, the returned handler controls the completion of the test.<T> Handler<AsyncResult<T>>TestContext. asyncAssertSuccess()Creates and returns a new async handler, the returned handler controls the completion of the test.<T> Handler<AsyncResult<T>>TestContext. asyncAssertSuccess(Handler<T> resultHandler)Creates and returns a new async handler, the returned handler controls the completion of the test.Handler<Throwable>TestContext. exceptionHandler()Methods in io.vertx.ext.unit with parameters of type Handler Modifier and Type Method Description TestSuiteTestSuite. after(Handler<TestContext> callback)Set a callback executed after the tests.TestSuiteTestSuite. afterEach(Handler<TestContext> callback)Set a callback executed after each test and before the suiteaftercallback.<T> Handler<AsyncResult<T>>TestContext. asyncAssertFailure(Handler<Throwable> causeHandler)Creates and returns a new async handler, the returned handler controls the completion of the test.<T> Handler<AsyncResult<T>>TestContext. asyncAssertSuccess(Handler<T> resultHandler)Creates and returns a new async handler, the returned handler controls the completion of the test.TestSuiteTestSuite. before(Handler<TestContext> callback)Set a callback executed before the tests.TestSuiteTestSuite. beforeEach(Handler<TestContext> callback)Set a callback executed before each test and after the suitebeforecallback.static TestCaseTestCase. create(String name, Handler<TestContext> testCase)Create a test case.voidCompletion. handler(Handler<AsyncResult<T>> completionHandler)Completion handler to receive a completion signal when this completions completes.TestSuiteTestSuite. test(String name, int repeat, Handler<TestContext> testCase)Add a new test case to the suite.TestSuiteTestSuite. test(String name, Handler<TestContext> testCase)Add a new test case to the suite.TestContextTestContext. verify(Handler<Void> block)Execute the provided handler, which may contain assertions, possibly from any third-party assertion framework. -
Uses of Handler in io.vertx.ext.unit.collect
Methods in io.vertx.ext.unit.collect that return Handler Modifier and Type Method Description Handler<Message<JsonObject>>EventBusCollector. asMessageHandler()Methods in io.vertx.ext.unit.collect with parameters of type Handler Modifier and Type Method Description static EventBusCollectorEventBusCollector. create(Vertx vertx, Handler<TestSuiteReport> reporter) -
Uses of Handler in io.vertx.ext.unit.report
Methods in io.vertx.ext.unit.report with parameters of type Handler Modifier and Type Method Description TestCaseReportTestCaseReport. endHandler(Handler<TestResult> handler)Set a callback for completion, the specifiedhandleris invoked when the test exec has completed.TestSuiteReportTestSuiteReport. endHandler(Handler<Void> endHandler)TestSuiteReportTestSuiteReport. exceptionHandler(Handler<Throwable> handler)Set an exception handler, the exception handler reports the test suite errors, it can be called mulitple times before the test ends.TestSuiteReportTestSuiteReport. handler(Handler<TestCaseReport> handler) -
Uses of Handler in io.vertx.ext.web
Subinterfaces of Handler in io.vertx.ext.web Modifier and Type Interface Description interfaceRouterA router receives request from anHttpServerand routes it to the first matchingRoutethat it contains.Methods in io.vertx.ext.web with parameters of type Handler Modifier and Type Method Description intRoutingContext. addBodyEndHandler(Handler<Void> handler)Provides a handler that will be called after the last part of the body is written to the wire.intRoutingContext. addEndHandler(Handler<AsyncResult<Void>> handler)Add an end handler for the request/response context.intRoutingContext. addHeadersEndHandler(Handler<Void> handler)Add a handler that will be called just before headers are written to the response.RouteRoute. blockingHandler(Handler<RoutingContext> requestHandler)LikeRoute.blockingHandler(Handler, boolean)called with ordered = trueRouteRoute. blockingHandler(Handler<RoutingContext> requestHandler, boolean ordered)Specify a blocking request handler for the route.RouterRouter. errorHandler(int statusCode, Handler<RoutingContext> errorHandler)Specify an handler to handle an error for a particular status code.RouteRoute. failureHandler(Handler<RoutingContext> failureHandler)Append a failure handler to the route failure handlers list.RouteRoute. handler(Handler<RoutingContext> requestHandler)Append a request handler to the route handlers list.RouterRouter. modifiedHandler(Handler<Router> handler)When a Router routes are changed this handler is notified. -
Uses of Handler in io.vertx.ext.web.api.service
Subinterfaces of Handler in io.vertx.ext.web.api.service Modifier and Type Interface Description interfaceOpenAPIRouterHandlerinterfaceRouteToEBServiceHandlerHandler that proxy the request to an event bus endpoint, waits for the reply and then writes the HTTP response. -
Uses of Handler in io.vertx.ext.web.client
Methods in io.vertx.ext.web.client with parameters of type Handler Modifier and Type Method Description OAuth2WebClientOAuth2WebClient. addInterceptor(Handler<io.vertx.ext.web.client.impl.HttpContext<?>> interceptor)WebClientWebClient. addInterceptor(Handler<io.vertx.ext.web.client.impl.HttpContext<?>> interceptor)Add interceptor in the chain.WebClientSessionWebClientSession. addInterceptor(Handler<io.vertx.ext.web.client.impl.HttpContext<?>> interceptor) -
Uses of Handler in io.vertx.ext.web.client.spi
Methods in io.vertx.ext.web.client.spi with parameters of type Handler Modifier and Type Method Description default voidCacheStore. delete(io.vertx.ext.web.client.impl.cache.CacheKey key, Handler<AsyncResult<Void>> handler)Delete all variations of a key from the cache.default voidCacheStore. flush(Handler<AsyncResult<Void>> handler)Delete all entries from the cache.default voidCacheStore. get(io.vertx.ext.web.client.impl.cache.CacheKey key, Handler<AsyncResult<io.vertx.ext.web.client.impl.cache.CachedHttpResponse>> handler)Retrieve a cached response.default voidCacheStore. set(io.vertx.ext.web.client.impl.cache.CacheKey key, io.vertx.ext.web.client.impl.cache.CachedHttpResponse response, Handler<AsyncResult<io.vertx.ext.web.client.impl.cache.CachedHttpResponse>> handler)Add a response in the cache with the given key. -
Uses of Handler in io.vertx.ext.web.codec.spi
Subinterfaces of Handler in io.vertx.ext.web.codec.spi Modifier and Type Interface Description interfaceBodyStream<T>The body stream decodes aWriteStreaminto the aTinstance. -
Uses of Handler in io.vertx.ext.web.handler
Subinterfaces of Handler in io.vertx.ext.web.handler Modifier and Type Interface Description interfaceAPIKeyHandlerAn authentication handler that provides API Key support.interfaceAuthenticationHandlerBase interface for auth handlers.interfaceAuthorizationHandlerBase interface for authorization handlers that provide authorization support.interfaceBasicAuthHandlerAn auth handler that provides HTTP Basic Authentication support.interfaceBodyHandlerA handler which gathers the entire request body and sets it on theRoutingContext.interfaceChainAuthHandlerAn auth handler that chains to a sequence of handlers.interfaceCorsHandlerA handler which implements server side http://www.w3.org/TR/cors/[CORS] support for Vert.x-Web.interfaceCSPHandlerContent Security Policy (CSP) is an added layer of security that helps to detect and mitigate certain types of attacks, including Cross Site Scripting (XSS) and data injection attacks.interfaceCSRFHandlerThis handler adds a CSRF token to requests which mutate state.interfaceDigestAuthHandlerAn auth handler that provides HTTP Basic Authentication support.interfaceErrorHandlerA pretty error handler for rendering error pages.interfaceFaviconHandlerA handler that serves favicons.interfaceFormLoginHandlerHandler that handles login from a form on a custom login page.interfaceHSTSHandlerHTTP Strict Transport Security (HSTS) RFC6797.interfaceInputTrustHandlerBase input trust interface for handlers that verify the trust of the request.interfaceJWTAuthHandlerAn auth handler that provides JWT Authentication support.interfaceLoggerHandlerA handler which logs request information to the Vert.x logger.interfaceMethodOverrideHandlerinterfaceMultiTenantHandlerA handler which selectively executes another handler if a precondition is met.interfaceOAuth2AuthHandlerAn auth handler that provides OAuth2 Authentication support.interfaceOtpAuthHandlerAn auth handler that provides One Time Password (Multi-Factor) Authentication support.interfacePlatformHandlerBase platform interface for handlers that provide functionality to the application platform.interfaceProtocolUpgradeHandlerBase interface for handlers that perform protocol upgrades.interfaceRedirectAuthHandlerAn auth handler that's used to handle auth by redirecting user to a custom login page.interfaceResponseContentTypeHandlerA handler which sets the response content type automatically according to the bestAcceptheader match.interfaceResponseTimeHandlerHandler which adds a header `x-response-time` in the response of matching requests containing the time taken in ms to process the request.interfaceSecurityAuditLoggerHandlerA handler that logs security audit events.interfaceSecurityPolicyHandlerBase security policy interface for handlers that provide HTTP security related headers.interfaceSessionHandlerA handler that maintains aSessionfor each browser session.interfaceSimpleAuthenticationHandlerA user customizable authentication handler.interfaceStaticHandlerA handler for serving static resources from the file system or classpath.interfaceTemplateHandlerA handler which renders responses using a template engine and where the template name is selected from the URI path.interfaceTimeoutHandlerHandler that will timeout requests if the response has not been written after a certain time.interfaceWebAuthn4JHandlerAn auth handler that provides FIDO2 WebAuthN Relay Party support.interfaceXFrameHandlerThe X-Frame-Options HTTP response header can be used to indicate whether or not a browser should be allowed to render a page in a<frame>,<iframe>,<embed>or<object>.Methods in io.vertx.ext.web.handler with parameters of type Handler Modifier and Type Method Description MultiTenantHandlerMultiTenantHandler. addDefaultHandler(Handler<RoutingContext> handler)Add a default handler for the case when no tenant was matched.MultiTenantHandlerMultiTenantHandler. addTenantHandler(String tenant, Handler<RoutingContext> handler)Add a handler for a given tenant to this handler. -
Uses of Handler in io.vertx.ext.web.handler.graphql
Subinterfaces of Handler in io.vertx.ext.web.handler.graphql Modifier and Type Interface Description interfaceGraphQLHandlerARoutehandler for GraphQL requests.Methods in io.vertx.ext.web.handler.graphql with parameters of type Handler Modifier and Type Method Description GraphQLHandlerBuilderGraphQLHandlerBuilder. beforeExecute(Handler<ExecutionInputBuilderWithContext<RoutingContext>> beforeExecuteHandler)Set a callback to invoke before executing a GraphQL query. -
Uses of Handler in io.vertx.ext.web.handler.graphql.ws
Subinterfaces of Handler in io.vertx.ext.web.handler.graphql.ws Modifier and Type Interface Description interfaceGraphQLWSHandlerA handler for the GraphQL over WebSocket Protocol.Methods in io.vertx.ext.web.handler.graphql.ws with parameters of type Handler Modifier and Type Method Description GraphQLWSHandlerBuilderGraphQLWSHandlerBuilder. beforeExecute(Handler<ExecutionInputBuilderWithContext<Message>> beforeExecuteHandler)Set a callback to invoke before executing a GraphQL query.GraphQLWSHandlerBuilderGraphQLWSHandlerBuilder. onConnectionInit(Handler<ConnectionInitEvent> connectionInitHandler)Customize the connection initHandler.GraphQLWSHandlerBuilderGraphQLWSHandlerBuilder. onMessage(Handler<Message> messageHandler)Customize the messageHandler.GraphQLWSHandlerBuilderGraphQLWSHandlerBuilder. onSocketEnd(Handler<ServerWebSocket> endHandler)Customize the endHandler. -
Uses of Handler in io.vertx.ext.web.handler.sockjs
Methods in io.vertx.ext.web.handler.sockjs with parameters of type Handler Modifier and Type Method Description RouterSockJSHandler. bridge(AuthorizationProvider authorizationProvider, SockJSBridgeOptions bridgeOptions, Handler<BridgeEvent> bridgeEventHandler)LikeSockJSHandler.bridge(SockJSBridgeOptions)but specifying a handler that will receive bridge events.default RouterSockJSHandler. bridge(SockJSBridgeOptions bridgeOptions, Handler<BridgeEvent> bridgeEventHandler)LikeSockJSHandler.bridge(SockJSBridgeOptions)but specifying a handler that will receive bridge events.SockJSSocketSockJSSocket. closeHandler(Handler<Void> closeHandler)SockJSSocketSockJSSocket. drainHandler(Handler<Void> handler)SockJSSocketSockJSSocket. endHandler(Handler<Void> endHandler)SockJSSocketSockJSSocket. exceptionHandler(Handler<Throwable> handler)SockJSSocketSockJSSocket. handler(Handler<Buffer> handler)RouterSockJSHandler. socketHandler(Handler<SockJSSocket> handler)Set a SockJS socket handler. -
Uses of Handler in io.vertx.ext.web.healthchecks
Subinterfaces of Handler in io.vertx.ext.web.healthchecks Modifier and Type Interface Description interfaceHealthCheckHandlerA Vert.x Web handler on which you register health check procedure.Methods in io.vertx.ext.web.healthchecks with parameters of type Handler Modifier and Type Method Description HealthCheckHandlerHealthCheckHandler. register(String name, long timeout, Handler<Promise<Status>> procedure)Registers a health check procedure.HealthCheckHandlerHealthCheckHandler. register(String name, Handler<Promise<Status>> procedure)Registers a health check procedure. -
Uses of Handler in io.vertx.ext.web.openapi.router
Methods in io.vertx.ext.web.openapi.router that return types with arguments of type Handler Modifier and Type Method Description List<Handler<RoutingContext>>OpenAPIRoute. getFailureHandlers()List<Handler<RoutingContext>>OpenAPIRoute. getHandlers()Methods in io.vertx.ext.web.openapi.router with parameters of type Handler Modifier and Type Method Description OpenAPIRouteOpenAPIRoute. addFailureHandler(Handler<RoutingContext> handler)Adds a failure handler for this routeOpenAPIRouteOpenAPIRoute. addHandler(Handler<RoutingContext> handler)Adds a handler for this route which is executed after the security and validation handlers defined in the contractRouterBuilderRouterBuilder. rootHandler(Handler<RoutingContext> rootHandler)Add global handler to be applied prior toRouterbeing generated. -
Uses of Handler in io.vertx.ext.web.proxy.handler
Subinterfaces of Handler in io.vertx.ext.web.proxy.handler Modifier and Type Interface Description interfaceProxyHandler -
Uses of Handler in io.vertx.ext.web.validation
Subinterfaces of Handler in io.vertx.ext.web.validation Modifier and Type Interface Description interfaceValidationHandler -
Uses of Handler in io.vertx.grpc
Methods in io.vertx.grpc with parameters of type Handler Modifier and Type Method Description VertxChannelBuilderVertxChannelBuilder. useSsl(Handler<ClientOptionsBase> handler)VertxServerBuilderVertxServerBuilder. useSsl(Handler<HttpServerOptions> handler) -
Uses of Handler in io.vertx.grpc.client
Methods in io.vertx.grpc.client with parameters of type Handler Modifier and Type Method Description GrpcClientRequest<Req,Resp>GrpcClientRequest. drainHandler(Handler<Void> handler)GrpcClientResponse<Req,Resp>GrpcClientResponse. endHandler(Handler<Void> handler)GrpcClientResponse<Req,Resp>GrpcClientResponse. errorHandler(Handler<GrpcError> handler)GrpcClientRequest<Req,Resp>GrpcClientRequest. exceptionHandler(Handler<Throwable> handler)GrpcClientResponse<Req,Resp>GrpcClientResponse. exceptionHandler(Handler<Throwable> handler)GrpcClientResponse<Req,Resp>GrpcClientResponse. handler(Handler<Resp> handler)GrpcClientResponse<Req,Resp>GrpcClientResponse. messageHandler(Handler<GrpcMessage> handler) -
Uses of Handler in io.vertx.grpc.common
Methods in io.vertx.grpc.common with parameters of type Handler Modifier and Type Method Description GrpcWriteStream<T>GrpcWriteStream. drainHandler(Handler<Void> handler)GrpcReadStream<T>GrpcReadStream. endHandler(Handler<Void> handler)GrpcReadStream<T>GrpcReadStream. errorHandler(Handler<GrpcError> handler)Set a handler to be notified with gRPC errors.GrpcReadStream<T>GrpcReadStream. exceptionHandler(Handler<Throwable> handler)GrpcWriteStream<T>GrpcWriteStream. exceptionHandler(Handler<Throwable> handler)GrpcReadStream<T>GrpcReadStream. handler(Handler<T> handler)GrpcReadStream<T>GrpcReadStream. invalidMessageHandler(Handler<InvalidMessageException> handler)Set a message handler that is reported with invalid message errors.GrpcReadStream<T>GrpcReadStream. messageHandler(Handler<GrpcMessage> handler)Set a handler to be notified with incoming encoded messages. -
Uses of Handler in io.vertx.grpc.server
Subinterfaces of Handler in io.vertx.grpc.server Modifier and Type Interface Description interfaceGrpcServerA gRPC server based on Vert.x HTTP server.Methods in io.vertx.grpc.server with parameters of type Handler Modifier and Type Method Description <Req,Resp>
ServiceBuilderServiceBuilder. bind(ServiceMethod<Req,Resp> serviceMethod, Handler<GrpcServerRequest<Req,Resp>> handler)Bind a service method call handler that handles any call made to the server for thefullMethodNamemethod.GrpcServerGrpcServer. callHandler(Handler<GrpcServerRequest<Buffer,Buffer>> handler)Set a call handler that handles any call made to the server.<Req,Resp>
GrpcServerGrpcServer. callHandler(ServiceMethod<Req,Resp> serviceMethod, Handler<GrpcServerRequest<Req,Resp>> handler)Set a service method call handler that handles any call made to the server for thefullMethodNameservice method.GrpcServerResponse<Req,Resp>GrpcServerResponse. drainHandler(Handler<Void> handler)GrpcServerRequest<Req,Resp>GrpcServerRequest. endHandler(Handler<Void> endHandler)GrpcServerRequest<Req,Resp>GrpcServerRequest. errorHandler(Handler<GrpcError> handler)GrpcServerRequest<Req,Resp>GrpcServerRequest. exceptionHandler(Handler<Throwable> handler)GrpcServerResponse<Req,Resp>GrpcServerResponse. exceptionHandler(Handler<Throwable> handler)GrpcServerRequest<Req,Resp>GrpcServerRequest. handler(Handler<Req> handler)GrpcServerRequest<Req,Resp>GrpcServerRequest. messageHandler(Handler<GrpcMessage> handler) -
Uses of Handler in io.vertx.grpc.stub
Methods in io.vertx.grpc.stub with parameters of type Handler Modifier and Type Method Description WriteStream<T>GrpcWriteStream. drainHandler(Handler<Void> hndlr)WriteStream<T>GrpcWriteStream. exceptionHandler(Handler<Throwable> hndlr)static <I,O>
ReadStream<O>ClientCalls. manyToMany(io.vertx.core.internal.ContextInternal ctx, Handler<WriteStream<I>> requestHandler, Function<StreamObserver<O>,StreamObserver<I>> delegate)static <I,O>
ReadStream<O>ClientCalls. manyToMany(io.vertx.core.internal.ContextInternal ctx, Handler<WriteStream<I>> requestHandler, Function<StreamObserver<O>,StreamObserver<I>> delegate, Handler<Throwable> exceptionHandler)static <I,O>
ReadStream<O>ClientCalls. manyToMany(io.vertx.core.internal.ContextInternal ctx, Handler<WriteStream<I>> requestHandler, Function<StreamObserver<O>,StreamObserver<I>> delegate, Handler<O> handler, Handler<Void> endHandler, Handler<Throwable> exceptionHandler)static <I,O>
Future<O>ClientCalls. manyToOne(io.vertx.core.internal.ContextInternal ctx, Handler<WriteStream<I>> requestHandler, Function<StreamObserver<O>,StreamObserver<I>> delegate)static <I,O>
ReadStream<O>ClientCalls. oneToMany(io.vertx.core.internal.ContextInternal ctx, I request, BiConsumer<I,StreamObserver<O>> delegate, Handler<O> handler, Handler<Void> endHandler, Handler<Throwable> exceptionHandler) -
Uses of Handler in io.vertx.grpcio.client
Methods in io.vertx.grpcio.client with parameters of type Handler Modifier and Type Method Description default <Req,Resp,T>
Future<T>GrpcIoClient. call(MethodDescriptor<Req,Resp> service, Handler<GrpcClientRequest<Req,Resp>> requestHandler, Function<GrpcClientResponse<Req,Resp>,Future<T>> resultFn)LikeGrpcIoClient.call(Address, MethodDescriptor, Handler, Function)with the default remote server.default <Req,Resp,T>
Future<T>GrpcIoClient. call(Address server, MethodDescriptor<Req,Resp> service, Handler<GrpcClientRequest<Req,Resp>> requestHandler, Function<GrpcClientResponse<Req,Resp>,Future<T>> resultFn)Call theservicegRPC service hosted byserver. -
Uses of Handler in io.vertx.grpcio.server
Subinterfaces of Handler in io.vertx.grpcio.server Modifier and Type Interface Description interfaceGrpcIoServerA gRPC server based on Vert.x HTTP server.Methods in io.vertx.grpcio.server with parameters of type Handler Modifier and Type Method Description <Req,Resp>
GrpcIoServerGrpcIoServer. callHandler(MethodDescriptor<Req,Resp> methodDesc, Handler<GrpcServerRequest<Req,Resp>> handler)Set a service method call handler that handles any call made to the server for theMethodDescriptorservice method.GrpcIoServerGrpcIoServer. callHandler(Handler<GrpcServerRequest<Buffer,Buffer>> handler) -
Uses of Handler in io.vertx.httpproxy
Subinterfaces of Handler in io.vertx.httpproxy Modifier and Type Interface Description interfaceHttpProxyHandles the HTTP reverse proxy logic between the user agent and the origin.Methods in io.vertx.httpproxy with parameters of type Handler Modifier and Type Method Description ProxyInterceptorBuilderProxyInterceptorBuilder. transformingQueryParams(Handler<MultiMap> updater)Apply modifications to the query parameters.ProxyInterceptorBuilderProxyInterceptorBuilder. transformingRequestHeaders(Handler<MultiMap> requestHeadersUpdater)Apply callbacks to change the request headers when the proxy receives them.ProxyInterceptorBuilderProxyInterceptorBuilder. transformingResponseHeaders(Handler<MultiMap> responseHeadersUpdater)Apply callbacks to change the response headers when the proxy receives them. -
Uses of Handler in io.vertx.junit5
Methods in io.vertx.junit5 that return Handler Modifier and Type Method Description <T> Handler<AsyncResult<T>>VertxTestContext. completing()Deprecated.UseVertxTestContext.succeedingThenComplete()instead.<T> Handler<AsyncResult<T>>VertxTestContext. failing()Deprecated.UseVertxTestContext.failingThenComplete()orVertxTestContext.failing(Handler), for examplefailing(e -> checkpoint.flag()),failing(e -> { more testing code }), orfailing(e -> {}).<T> Handler<AsyncResult<T>>VertxTestContext. failing(Handler<Throwable> nextHandler)Create an asynchronous result handler that expects a failure, and passes the exception to another handler.<T> Handler<AsyncResult<T>>VertxTestContext. failingThenComplete()Create an asynchronous result handler that expects a failure to then complete the test context.<T> Handler<AsyncResult<T>>VertxTestContext. succeeding(Handler<T> nextHandler)Create an asynchronous result handler that expects a success, and passes the value to another handler.<T> Handler<AsyncResult<T>>VertxTestContext. succeedingThenComplete()Create an asynchronous result handler that expects a success to then complete the test context.Methods in io.vertx.junit5 with parameters of type Handler Modifier and Type Method Description <T> Handler<AsyncResult<T>>VertxTestContext. failing(Handler<Throwable> nextHandler)Create an asynchronous result handler that expects a failure, and passes the exception to another handler.<T> Handler<AsyncResult<T>>VertxTestContext. succeeding(Handler<T> nextHandler)Create an asynchronous result handler that expects a success, and passes the value to another handler. -
Uses of Handler in io.vertx.kafka.client.consumer
Methods in io.vertx.kafka.client.consumer with parameters of type Handler Modifier and Type Method Description KafkaConsumer<K,V>KafkaConsumer. batchHandler(Handler<KafkaConsumerRecords<K,V>> handler)Set the handler to be used when batches of messages are fetched from the Kafka server.KafkaReadStream<K,V>KafkaReadStream. batchHandler(Handler<org.apache.kafka.clients.consumer.ConsumerRecords<K,V>> handler)Set the handler that will be called when a new batch of records is returned from Kafka.KafkaConsumer<K,V>KafkaConsumer. endHandler(Handler<Void> endHandler)KafkaReadStream<K,V>KafkaReadStream. endHandler(Handler<Void> endHandler)KafkaConsumer<K,V>KafkaConsumer. exceptionHandler(Handler<Throwable> handler)KafkaReadStream<K,V>KafkaReadStream. exceptionHandler(Handler<Throwable> handler)KafkaConsumer<K,V>KafkaConsumer. handler(Handler<KafkaConsumerRecord<K,V>> handler)KafkaReadStream<K,V>KafkaReadStream. handler(Handler<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>> handler)KafkaConsumer<K,V>KafkaConsumer. partitionsAssignedHandler(Handler<Set<TopicPartition>> handler)Set the handler called when topic partitions are assigned to the consumerKafkaReadStream<K,V>KafkaReadStream. partitionsAssignedHandler(Handler<Set<org.apache.kafka.common.TopicPartition>> handler)Set the handler called when topic partitions are assigned to the consumerKafkaConsumer<K,V>KafkaConsumer. partitionsRevokedHandler(Handler<Set<TopicPartition>> handler)Set the handler called when topic partitions are revoked to the consumerKafkaReadStream<K,V>KafkaReadStream. partitionsRevokedHandler(Handler<Set<org.apache.kafka.common.TopicPartition>> handler)Set the handler called when topic partitions are revoked to the consumer -
Uses of Handler in io.vertx.kafka.client.producer
Methods in io.vertx.kafka.client.producer with parameters of type Handler Modifier and Type Method Description KafkaProducer<K,V>KafkaProducer. drainHandler(Handler<Void> handler)KafkaWriteStream<K,V>KafkaWriteStream. drainHandler(Handler<Void> handler)KafkaProducer<K,V>KafkaProducer. exceptionHandler(Handler<Throwable> handler)KafkaWriteStream<K,V>KafkaWriteStream. exceptionHandler(Handler<Throwable> handler) -
Uses of Handler in io.vertx.lang.reactivex
Methods in io.vertx.lang.reactivex that return Handler Modifier and Type Method Description static <CORE,REACTIVE>
Handler<CORE>Helper. convertHandler(Handler<REACTIVE> rxHandler, Function<CORE,REACTIVE> mapper)Convert a handler for a generated reactive type to a handler for the corresponding core type.Methods in io.vertx.lang.reactivex with parameters of type Handler Modifier and Type Method Description static <CORE,REACTIVE>
Handler<CORE>Helper. convertHandler(Handler<REACTIVE> rxHandler, Function<CORE,REACTIVE> mapper)Convert a handler for a generated reactive type to a handler for the corresponding core type. -
Uses of Handler in io.vertx.lang.rxjava3
Methods in io.vertx.lang.rxjava3 that return Handler Modifier and Type Method Description static <CORE,REACTIVE>
Handler<CORE>Helper. convertHandler(Handler<REACTIVE> rxHandler, Function<CORE,REACTIVE> mapper)Convert a handler for a generated reactive type to a handler for the corresponding core type.Methods in io.vertx.lang.rxjava3 with parameters of type Handler Modifier and Type Method Description static <CORE,REACTIVE>
Handler<CORE>Helper. convertHandler(Handler<REACTIVE> rxHandler, Function<CORE,REACTIVE> mapper)Convert a handler for a generated reactive type to a handler for the corresponding core type. -
Uses of Handler in io.vertx.micrometer
Methods in io.vertx.micrometer that return Handler Modifier and Type Method Description static Handler<HttpServerRequest>PrometheusRequestHandler. create()Creates a handler with a new PrometheusMeterRegistry and the default metrics endpoint ("/metrics").static Handler<HttpServerRequest>PrometheusRequestHandler. create(io.micrometer.prometheusmetrics.PrometheusMeterRegistry registry)Creates a handler with the specified PrometheusMeterRegistry and the default metrics endpoint ("/metrics").static Handler<HttpServerRequest>PrometheusRequestHandler. create(io.micrometer.prometheusmetrics.PrometheusMeterRegistry registry, String metricsEndpoint)Creates a handler with the specified PrometheusMeterRegistry and metrics endpoint.static Handler<RoutingContext>PrometheusScrapingHandler. create()Creates a Vert.x WebRoutehandler for Prometheus metrics scraping.static Handler<RoutingContext>PrometheusScrapingHandler. create(io.micrometer.prometheusmetrics.PrometheusMeterRegistry registry)Creates a Vert.x WebRoutehandler for Prometheus metrics scraping.static Handler<RoutingContext>PrometheusScrapingHandler. create(String registryName)Creates a Vert.x WebRoutehandler for Prometheus metrics scraping. -
Uses of Handler in io.vertx.mqtt
Methods in io.vertx.mqtt with parameters of type Handler Modifier and Type Method Description MqttClientMqttClient. authenticationExchangeHandler(Handler<MqttAuthenticationExchangeMessage> authenticationExchangeHandler)Sets handler which will be called after AUTH packet receivingMqttEndpointMqttEndpoint. authenticationExchangeHandler(Handler<MqttAuthenticationExchangeMessage> handler)Set the auth handler on the MQTT endpoint.MqttClientMqttClient. closeHandler(Handler<Void> closeHandler)Set a handler that will be called when the connection with server is closedMqttEndpointMqttEndpoint. closeHandler(Handler<Void> handler)Set a close handler.MqttEndpointMqttEndpoint. disconnectHandler(Handler<Void> handler)Set a disconnect handler on the MQTT endpoint.MqttEndpointMqttEndpoint. disconnectMessageHandler(Handler<MqttDisconnectMessage> handler)Set a disconnect handler on the MQTT endpoint.MqttServerMqttServer. endpointHandler(Handler<MqttEndpoint> handler)Set the endpoint handler for the server.MqttClientMqttClient. exceptionHandler(Handler<Throwable> handler)Set an exception handler for the client, that will be called when an error happens in internal netty structures.MqttEndpointMqttEndpoint. exceptionHandler(Handler<Throwable> handler)Set an exception handler.MqttServerMqttServer. exceptionHandler(Handler<Throwable> handler)Set an exception handler for the server, that will be called when an error happens independantly of an acceptedMqttEndpoint, like a rejected connectionMqttEndpointMqttEndpoint. pingHandler(Handler<Void> handler)Set the pingreq handler on the MQTT endpoint.MqttClientMqttClient. pingResponseHandler(Handler<Void> pingResponseHandler)Sets handler which will be called after PINGRESP packet receivingMqttEndpointMqttEndpoint. publishAcknowledgeHandler(Handler<Integer> handler)Set the puback handler on the MQTT endpoint.MqttEndpointMqttEndpoint. publishAcknowledgeMessageHandler(Handler<MqttPubAckMessage> handler)Set the puback handler on the MQTT endpoint.MqttClientMqttClient. publishCompletionExpirationHandler(Handler<Integer> publishCompletionExpirationHandler)Sets a handler which will be called when the client does not receive a PUBACK or PUBREC/PUBCOMP for a message published using QoS 1 or 2 respectively.MqttClientMqttClient. publishCompletionHandler(Handler<Integer> publishCompletionHandler)Sets a handler which will be called each time the publishing of a message has been completed.MqttEndpointMqttEndpoint. publishCompletionHandler(Handler<Integer> handler)Set the pubcomp handler on the MQTT endpoint.MqttEndpointMqttEndpoint. publishCompletionMessageHandler(Handler<MqttPubCompMessage> handler)Set the pubcomp handler on the MQTT endpoint.MqttClientMqttClient. publishCompletionUnknownPacketIdHandler(Handler<Integer> publishCompletionPhantomHandler)Sets a handler which will be called when the client receives a PUBACK/PUBREC/PUBCOMP with an unknown packet ID.MqttClientMqttClient. publishHandler(Handler<MqttPublishMessage> publishHandler)Sets handler which will be called each time server publish something to clientMqttEndpointMqttEndpoint. publishHandler(Handler<MqttPublishMessage> handler)Set the publish handler on the MQTT endpoint.MqttEndpointMqttEndpoint. publishReceivedHandler(Handler<Integer> handler)Set the pubrec handler on the MQTT endpoint.MqttEndpointMqttEndpoint. publishReceivedMessageHandler(Handler<MqttPubRecMessage> handler)Set the pubrec handler on the MQTT endpoint.MqttEndpointMqttEndpoint. publishReleaseHandler(Handler<Integer> handler)Set the pubrel handler on the MQTT endpoint.MqttEndpointMqttEndpoint. publishReleaseMessageHandler(Handler<MqttPubRelMessage> handler)Set the pubrel handler on the MQTT endpoint.MqttClientMqttClient. subscribeCompletionHandler(Handler<MqttSubAckMessage> subscribeCompletionHandler)Sets handler which will be called after SUBACK packet receivingMqttEndpointMqttEndpoint. subscribeHandler(Handler<MqttSubscribeMessage> handler)Set a subscribe handler on the MQTT endpoint.MqttClientMqttClient. unsubscribeCompletionHandler(Handler<Integer> unsubscribeCompletionHandler)Sets handler which will be called after UNSUBACK packet receivingMqttEndpointMqttEndpoint. unsubscribeHandler(Handler<MqttUnsubscribeMessage> handler)Set a unsubscribe handler on the MQTT endpoint. -
Uses of Handler in io.vertx.mssqlclient
Methods in io.vertx.mssqlclient with parameters of type Handler Modifier and Type Method Description MSSQLConnectionMSSQLConnection. closeHandler(Handler<Void> handler)Set an handler called when the connection is closed.MSSQLConnectionMSSQLConnection. exceptionHandler(Handler<Throwable> handler)Set an handler called with connection errors.MSSQLConnectionMSSQLConnection. infoHandler(Handler<MSSQLInfo> handler)Set a handler called when the connection receives an informational message from the server.static PoolMSSQLBuilder. pool(Handler<ClientBuilder<Pool>> block)Build a pool with the specifiedblockargument. -
Uses of Handler in io.vertx.mssqlclient.spi
Methods in io.vertx.mssqlclient.spi with parameters of type Handler Modifier and Type Method Description PoolMSSQLDriver. newPool(Vertx vertx, Supplier<Future<MSSQLConnectOptions>> databases, PoolOptions options, NetClientOptions transportOptions, Handler<SqlConnection> connectHandler, io.vertx.core.internal.CloseFuture closeFuture) -
Uses of Handler in io.vertx.mysqlclient
Methods in io.vertx.mysqlclient with parameters of type Handler Modifier and Type Method Description static SqlClientMySQLBuilder. client(Handler<ClientBuilder<SqlClient>> handler)Build a client backed by a connection pool with the specifiedblockargument.MySQLConnectionMySQLConnection. closeHandler(Handler<Void> handler)Set an handler called when the connection is closed.MySQLConnectionMySQLConnection. exceptionHandler(Handler<Throwable> handler)Set an handler called with connection errors.static PoolMySQLBuilder. pool(Handler<ClientBuilder<Pool>> block)Build a pool with the specifiedblockargument. -
Uses of Handler in io.vertx.mysqlclient.spi
Methods in io.vertx.mysqlclient.spi with parameters of type Handler Modifier and Type Method Description PoolMySQLDriver. newPool(Vertx vertx, Supplier<Future<MySQLConnectOptions>> databases, PoolOptions options, NetClientOptions transportOptions, Handler<SqlConnection> connectHandler, io.vertx.core.internal.CloseFuture closeFuture) -
Uses of Handler in io.vertx.oracleclient
Methods in io.vertx.oracleclient with parameters of type Handler Modifier and Type Method Description OracleConnectionOracleConnection. closeHandler(Handler<Void> handler)Set an handler called when the connection is closed.OracleConnectionOracleConnection. exceptionHandler(Handler<Throwable> handler)Set an handler called with connection errors.static PoolOracleBuilder. pool(Handler<ClientBuilder<Pool>> block)Build a pool with the specifiedblockargument. -
Uses of Handler in io.vertx.oracleclient.spi
Methods in io.vertx.oracleclient.spi with parameters of type Handler Modifier and Type Method Description PoolOracleDriver. newPool(Vertx vertx, Supplier<Future<OracleConnectOptions>> databases, PoolOptions options, NetClientOptions transportOptions, Handler<SqlConnection> connectHandler, io.vertx.core.internal.CloseFuture closeFuture) -
Uses of Handler in io.vertx.pgclient
Methods in io.vertx.pgclient with parameters of type Handler Modifier and Type Method Description static SqlClientPgBuilder. client(Handler<ClientBuilder<SqlClient>> handler)Build a client backed by a connection pool with the specifiedblockargument.PgConnectionPgConnection. closeHandler(Handler<Void> handler)Set an handler called when the connection is closed.PgConnectionPgConnection. exceptionHandler(Handler<Throwable> handler)Set an handler called with connection errors.PgConnectionPgConnection. noticeHandler(Handler<PgNotice> handler)Set a handler called when the connection receives a notice from the server.PgConnectionPgConnection. notificationHandler(Handler<PgNotification> handler)Set a handler called when the connection receives notification on a channel.static PoolPgBuilder. pool(Handler<ClientBuilder<Pool>> block)Build a pool with the specifiedblockargument. -
Uses of Handler in io.vertx.pgclient.pubsub
Methods in io.vertx.pgclient.pubsub with parameters of type Handler Modifier and Type Method Description PgSubscriberPgSubscriber. closeHandler(Handler<Void> handler)Set an handler called when the subscriber is closed.PgChannelPgChannel. endHandler(Handler<Void> endHandler)Set an handler to be called when no more notifications will be received.PgChannelPgChannel. exceptionHandler(Handler<Throwable> handler)PgChannelPgChannel. handler(Handler<String> handler)Set or unset an handler to be called when a the channel is notified by Postgres.PgChannelPgChannel. subscribeHandler(Handler<Void> handler)Set an handler called when the the channel get subscribed. -
Uses of Handler in io.vertx.pgclient.spi
Methods in io.vertx.pgclient.spi with parameters of type Handler Modifier and Type Method Description PoolPgDriver. newPool(Vertx vertx, Supplier<Future<PgConnectOptions>> databases, PoolOptions poolOptions, NetClientOptions transportOptions, Handler<SqlConnection> connectHandler, io.vertx.core.internal.CloseFuture closeFuture) -
Uses of Handler in io.vertx.rabbitmq
Methods in io.vertx.rabbitmq with parameters of type Handler Modifier and Type Method Description voidRabbitMQClient. addConnectionEstablishedCallback(Handler<Promise<Void>> connectionEstablishedCallback)Set a callback to be called whenever a new connection is established.Future<Void>RabbitMQClient. basicPublishWithDeliveryTag(String exchange, String routingKey, com.rabbitmq.client.BasicProperties properties, Buffer body, Handler<Long> deliveryTagHandler)Publish a message.RabbitMQConsumerRabbitMQConsumer. endHandler(Handler<Void> endHandler)Set an end handler.RabbitMQConsumerRabbitMQConsumer. exceptionHandler(Handler<Throwable> exceptionHandler)Set an exception handler on the read stream.RabbitMQConsumerRabbitMQConsumer. handler(Handler<RabbitMQMessage> messageArrived)Set a message handler. -
Uses of Handler in io.vertx.reactivex
Methods in io.vertx.reactivex with parameters of type Handler Modifier and Type Method Description static <T> CompletableObserverCompletableHelper. toObserver(Handler<AsyncResult<T>> handler)Adapts an Vert.xHandler<AsyncResult<T>>to an RxJava2SingleObserver.static <T> MaybeObserver<T>MaybeHelper. toObserver(Handler<AsyncResult<T>> handler)Adapts an Vert.xHandler<AsyncResult<T>>to an RxJava2MaybeObserver.static <T> SingleObserver<T>SingleHelper. toObserver(Handler<AsyncResult<T>> handler)Adapts an Vert.xHandler<AsyncResult<T>>to an RxJava2SingleObserver.Method parameters in io.vertx.reactivex with type arguments of type Handler Modifier and Type Method Description static CompletableCompletableHelper. toCompletable(Consumer<Handler<AsyncResult<Void>>> handler)Returns aCompletablethat, when subscribed, uses the providedhandlerto adapt a callback-based asynchronous method.static <T> Maybe<T>MaybeHelper. toMaybe(Consumer<Handler<AsyncResult<T>>> handler)Returns aMaybethat, when subscribed, uses the providedhandlerto adapt a callback-based asynchronous method.static <T> Single<T>SingleHelper. toSingle(Consumer<Handler<AsyncResult<T>>> handler)Returns aSinglethat, when subscribed, uses the providedhandlerto adapt a callback-based asynchronous method. -
Uses of Handler in io.vertx.reactivex.amqp
Methods in io.vertx.reactivex.amqp with parameters of type Handler Modifier and Type Method Description WriteStream<AmqpMessage>AmqpSender. drainHandler(Handler<Void> handler)Set a drain handler on the stream.AmqpReceiverAmqpReceiver. endHandler(Handler<Void> endHandler)AmqpConnectionAmqpConnection. exceptionHandler(Handler<Throwable> handler)Registers a handler called on disconnection.AmqpReceiverAmqpReceiver. exceptionHandler(Handler<Throwable> handler)AmqpSenderAmqpSender. exceptionHandler(Handler<Throwable> handler)AmqpReceiverAmqpReceiver. handler(Handler<AmqpMessage> handler) -
Uses of Handler in io.vertx.reactivex.cassandra
Methods in io.vertx.reactivex.cassandra with parameters of type Handler Modifier and Type Method Description CassandraRowStreamCassandraRowStream. endHandler(Handler<Void> handler)CassandraRowStreamCassandraRowStream. exceptionHandler(Handler<Throwable> handler)CassandraRowStreamCassandraRowStream. handler(Handler<com.datastax.oss.driver.api.core.cql.Row> handler) -
Uses of Handler in io.vertx.reactivex.circuitbreaker
Methods in io.vertx.reactivex.circuitbreaker with parameters of type Handler Modifier and Type Method Description CircuitBreakerCircuitBreaker. closeHandler(Handler<Void> handler)Sets a to be invoked when the circuit breaker state switches to closed.<T> Future<T>CircuitBreaker. execute(Handler<Promise<T>> command)Same asCircuitBreaker.executeWithFallback(io.vertx.core.Handler<io.vertx.reactivex.core.Promise<T>>, java.util.function.Function<java.lang.Throwable, T>)but using the circuit breaker .<T> CircuitBreakerCircuitBreaker. executeAndReport(Promise<T> resultPromise, Handler<Promise<T>> command)<T> CircuitBreakerCircuitBreaker. executeAndReportWithFallback(Promise<T> resultPromise, Handler<Promise<T>> command, Function<Throwable,T> fallback)Executes the given operation with the circuit breaker control.<T> Future<T>CircuitBreaker. executeWithFallback(Handler<Promise<T>> command, Function<Throwable,T> fallback)Executes the given operation with the circuit breaker control.CircuitBreakerCircuitBreaker. halfOpenHandler(Handler<Void> handler)Sets a to be invoked when the circuit breaker state switches to half-open.CircuitBreakerCircuitBreaker. openHandler(Handler<Void> handler)Sets a to be invoked when the circuit breaker state switches to open.<T> Single<T>CircuitBreaker. rxExecute(Handler<Promise<T>> command)Same asCircuitBreaker.executeWithFallback(io.vertx.core.Handler<io.vertx.reactivex.core.Promise<T>>, java.util.function.Function<java.lang.Throwable, T>)but using the circuit breaker .<T> Single<T>CircuitBreaker. rxExecuteWithFallback(Handler<Promise<T>> command, Function<Throwable,T> fallback)Executes the given operation with the circuit breaker control. -
Uses of Handler in io.vertx.reactivex.config
Methods in io.vertx.reactivex.config with parameters of type Handler Modifier and Type Method Description voidConfigRetriever. listen(Handler<ConfigChange> listener)Registers a listener receiving configuration changes.ConfigRetrieverConfigRetriever. setBeforeScanHandler(Handler<Void> handler)Registers a handler called before every scan. -
Uses of Handler in io.vertx.reactivex.core
Methods in io.vertx.reactivex.core with parameters of type Handler Modifier and Type Method Description ContextContext. exceptionHandler(Handler<Throwable> handler)Set an exception handler called when the context runs an action throwing an uncaught throwable.VertxVertx. exceptionHandler(Handler<Throwable> handler)Set a default exception handler forContext, set onContext.exceptionHandler(io.vertx.core.Handler<java.lang.Throwable>)at creation.voidContext. runOnContext(Handler<Void> action)Run the specified action asynchronously on the same context, some time after the current execution has completed.voidVertx. runOnContext(Handler<Void> action)Puts the handler on the event queue for the current context so it will be run asynchronously ASAP after all preceeding events have been handled.longVertx. setPeriodic(long initialDelay, long delay, Handler<Long> handler)Set a periodic timer to fire everydelaymilliseconds with initial delay, at which pointhandlerwill be called with the id of the timer.longVertx. setPeriodic(long delay, Handler<Long> handler)Set a periodic timer to fire everydelaymilliseconds, at which pointhandlerwill be called with the id of the timer.longVertx. setTimer(long delay, Handler<Long> handler)Set a one-shot timer to fire afterdelaymilliseconds, at which pointhandlerwill be called with the id of the timer. -
Uses of Handler in io.vertx.reactivex.core.datagram
Methods in io.vertx.reactivex.core.datagram with parameters of type Handler Modifier and Type Method Description DatagramSocketDatagramSocket. exceptionHandler(Handler<Throwable> handler)DatagramSocketDatagramSocket. handler(Handler<DatagramPacket> handler) -
Uses of Handler in io.vertx.reactivex.core.eventbus
Methods in io.vertx.reactivex.core.eventbus with parameters of type Handler Modifier and Type Method Description <T> EventBusEventBus. addInboundInterceptor(Handler<DeliveryContext<T>> interceptor)Add an interceptor that will be called whenever a message is received by Vert.x<T> EventBusEventBus. addOutboundInterceptor(Handler<DeliveryContext<T>> interceptor)Add an interceptor that will be called whenever a message is sent from Vert.x<T> MessageConsumer<T>EventBus. consumer(MessageConsumerOptions options, Handler<Message<T>> handler)Create a consumer and register it against the specified options address.<T> MessageConsumer<T>EventBus. consumer(String address, Handler<Message<T>> handler)Create a consumer and register it against the specified address.MessageConsumer<T>MessageConsumer. endHandler(Handler<Void> endHandler)MessageConsumer<T>MessageConsumer. exceptionHandler(Handler<Throwable> handler)MessageConsumer<T>MessageConsumer. handler(Handler<Message<T>> handler)<T> MessageConsumer<T>EventBus. localConsumer(String address, Handler<Message<T>> handler)LikeEventBus.consumer(io.vertx.core.eventbus.MessageConsumerOptions)but the address won't be propagated across the cluster.<T> EventBusEventBus. removeInboundInterceptor(Handler<DeliveryContext<T>> interceptor)Remove an interceptor that was added byEventBus.addInboundInterceptor(io.vertx.core.Handler<io.vertx.reactivex.core.eventbus.DeliveryContext<T>>)<T> EventBusEventBus. removeOutboundInterceptor(Handler<DeliveryContext<T>> interceptor)Remove an interceptor that was added byEventBus.addOutboundInterceptor(io.vertx.core.Handler<io.vertx.reactivex.core.eventbus.DeliveryContext<T>>) -
Uses of Handler in io.vertx.reactivex.core.file
Methods in io.vertx.reactivex.core.file with parameters of type Handler Modifier and Type Method Description AsyncFileAsyncFile. drainHandler(Handler<Void> handler)AsyncFileAsyncFile. endHandler(Handler<Void> endHandler)AsyncFileAsyncFile. exceptionHandler(Handler<Throwable> handler)Set an exception handler on the read stream and on the write stream.AsyncFileAsyncFile. handler(Handler<Buffer> handler) -
Uses of Handler in io.vertx.reactivex.core.http
Methods in io.vertx.reactivex.core.http with parameters of type Handler Modifier and Type Method Description ClientWebSocketClientWebSocket. binaryMessageHandler(Handler<Buffer> handler)WebSocketWebSocket. binaryMessageHandler(Handler<Buffer> handler)WebSocketBaseWebSocketBase. binaryMessageHandler(Handler<Buffer> handler)Set a binary message handler on the connection.HttpServerResponseHttpServerResponse. bodyEndHandler(Handler<Void> handler)Provides a handler that will be called after the last part of the body is written to the wire.HttpClientResponseHttpClientResponse. bodyHandler(Handler<Buffer> bodyHandler)Convenience method for receiving the entire request body in one piece.HttpServerRequestHttpServerRequest. bodyHandler(Handler<Buffer> bodyHandler)Convenience method for receiving the entire request body in one piece.ClientWebSocketClientWebSocket. closeHandler(Handler<Void> handler)HttpConnectionHttpConnection. closeHandler(Handler<Void> handler)Set a close handler.HttpServerResponseHttpServerResponse. closeHandler(Handler<Void> handler)Set a close handler for the response, this is called when the underlying connection is closed and the response was still using the connection.ServerWebSocketServerWebSocket. closeHandler(Handler<Void> handler)WebSocketWebSocket. closeHandler(Handler<Void> handler)WebSocketBaseWebSocketBase. closeHandler(Handler<Void> handler)Set a close handler.HttpServerHttpServer. connectionHandler(Handler<HttpConnection> handler)Set a connection handler for the server.HttpClientRequestHttpClientRequest. continueHandler(Handler<Void> handler)If you send an HTTP request with the headerExpectset to the value100-continueand the server responds with an interim HTTP response with a status code of100and a Continue handler has been set using this method, then thehandlerwill be called.HttpClientResponseHttpClientResponse. customFrameHandler(Handler<HttpFrame> handler)Set an custom frame handler.HttpServerRequestHttpServerRequest. customFrameHandler(Handler<HttpFrame> handler)Set a custom frame handler.ClientWebSocketClientWebSocket. drainHandler(Handler<Void> handler)HttpClientRequestHttpClientRequest. drainHandler(Handler<Void> handler)HttpServerResponseHttpServerResponse. drainHandler(Handler<Void> handler)ServerWebSocketServerWebSocket. drainHandler(Handler<Void> handler)WebSocketWebSocket. drainHandler(Handler<Void> handler)WebSocketBaseWebSocketBase. drainHandler(Handler<Void> handler)HttpClientRequestHttpClientRequest. earlyHintsHandler(Handler<MultiMap> handler)If the server responds with an interim HTTP response with a status code of103and a Early Hints handler has been set using this method, then thehandlerwill be called.ClientWebSocketClientWebSocket. endHandler(Handler<Void> endHandler)HttpClientResponseHttpClientResponse. endHandler(Handler<Void> endHandler)HttpServerFileUploadHttpServerFileUpload. endHandler(Handler<Void> endHandler)HttpServerRequestHttpServerRequest. endHandler(Handler<Void> endHandler)HttpServerResponseHttpServerResponse. endHandler(Handler<Void> handler)Set an end handler for the response.ServerWebSocketServerWebSocket. endHandler(Handler<Void> endHandler)WebSocketWebSocket. endHandler(Handler<Void> endHandler)WebSocketBaseWebSocketBase. endHandler(Handler<Void> endHandler)ClientWebSocketClientWebSocket. exceptionHandler(Handler<Throwable> handler)HttpClientRequestHttpClientRequest. exceptionHandler(Handler<Throwable> handler)HttpClientResponseHttpClientResponse. exceptionHandler(Handler<Throwable> handler)HttpConnectionHttpConnection. exceptionHandler(Handler<Throwable> handler)Set an handler called when a connection error happensHttpServerHttpServer. exceptionHandler(Handler<Throwable> handler)Set an exception handler called for socket errors happening before the HTTP connection is established, e.g during the TLS handshake.HttpServerFileUploadHttpServerFileUpload. exceptionHandler(Handler<Throwable> handler)HttpServerRequestHttpServerRequest. exceptionHandler(Handler<Throwable> handler)HttpServerResponseHttpServerResponse. exceptionHandler(Handler<Throwable> handler)ServerWebSocketServerWebSocket. exceptionHandler(Handler<Throwable> handler)WebSocketWebSocket. exceptionHandler(Handler<Throwable> handler)WebSocketBaseWebSocketBase. exceptionHandler(Handler<Throwable> handler)ClientWebSocketClientWebSocket. frameHandler(Handler<WebSocketFrame> handler)ServerWebSocketServerWebSocket. frameHandler(Handler<WebSocketFrame> handler)WebSocketWebSocket. frameHandler(Handler<WebSocketFrame> handler)WebSocketBaseWebSocketBase. frameHandler(Handler<WebSocketFrame> handler)Set a frame handler on the connection.HttpConnectionHttpConnection. goAwayHandler(Handler<GoAway> handler)Set an handler called when a frame is received.ClientWebSocketClientWebSocket. handler(Handler<Buffer> handler)HttpClientResponseHttpClientResponse. handler(Handler<Buffer> handler)HttpServerFileUploadHttpServerFileUpload. handler(Handler<Buffer> handler)HttpServerRequestHttpServerRequest. handler(Handler<Buffer> handler)ServerWebSocketServerWebSocket. handler(Handler<Buffer> handler)WebSocketWebSocket. handler(Handler<Buffer> handler)WebSocketBaseWebSocketBase. handler(Handler<Buffer> handler)HttpServerResponseHttpServerResponse. headersEndHandler(Handler<Void> handler)Provide a handler that will be called just before the headers are written to the wire.HttpServerHttpServer. invalidRequestHandler(Handler<HttpServerRequest> handler)Set ahandlerfor handling invalid requests.HttpConnectionHttpConnection. pingHandler(Handler<Buffer> handler)Set an handler notified when a frame is received from the remote endpoint.ClientWebSocketClientWebSocket. pongHandler(Handler<Buffer> handler)WebSocketWebSocket. pongHandler(Handler<Buffer> handler)WebSocketBaseWebSocketBase. pongHandler(Handler<Buffer> handler)Set a pong frame handler on the connection.HttpClientRequestHttpClientRequest. pushHandler(Handler<HttpClientRequest> handler)Set a push handler for this request.HttpConnectionHttpConnection. remoteSettingsHandler(Handler<Http2Settings> handler)Set an handler that is called when remote endpointHttp2Settingsare updated.HttpServerHttpServer. requestHandler(Handler<HttpServerRequest> handler)Set the request handler for the server torequestHandler.HttpConnectionHttpConnection. shutdownHandler(Handler<Void> handler)Set ahandlernotified when the HTTP connection is shutdown: the client or server will close the connection within a certain amount of time.WebSocketWebSocket. shutdownHandler(Handler<Void> handler)WebSocketBaseWebSocketBase. shutdownHandler(Handler<Void> handler)Set ahandlernotified when the WebSocket is shutdown: the client or server will close the connection within a certain amount of time.HttpClientResponseHttpClientResponse. streamPriorityHandler(Handler<StreamPriority> handler)Set an handler for stream priority changes.HttpServerRequestHttpServerRequest. streamPriorityHandler(Handler<StreamPriority> handler)Set an handler for stream priority changesClientWebSocketClientWebSocket. textMessageHandler(Handler<String> handler)WebSocketWebSocket. textMessageHandler(Handler<String> handler)WebSocketBaseWebSocketBase. textMessageHandler(Handler<String> handler)Set a text message handler on the connection.HttpServerRequestHttpServerRequest. uploadHandler(Handler<HttpServerFileUpload> uploadHandler)Set an upload handler.HttpServerHttpServer. webSocketHandler(Handler<ServerWebSocket> handler)Set the WebSocket handler for the server towsHandler.HttpServerHttpServer. webSocketHandshakeHandler(Handler<ServerWebSocketHandshake> handler)Set a handler for WebSocket handshake.HttpClientBuilderHttpClientBuilder. withConnectHandler(Handler<HttpConnection> handler)Set a connection handler for the client. -
Uses of Handler in io.vertx.reactivex.core.net
Methods in io.vertx.reactivex.core.net with parameters of type Handler Modifier and Type Method Description NetSocketNetSocket. closeHandler(Handler<Void> handler)Set ahandlernotified when the socket is closedNetServerNetServer. connectHandler(Handler<NetSocket> handler)Supply a connect handler for this server.NetSocketNetSocket. drainHandler(Handler<Void> handler)NetSocketNetSocket. endHandler(Handler<Void> endHandler)This handler might be called after the close handler when the socket is paused and there are still buffers to deliver.NetSocketNetSocket. exceptionHandler(Handler<Throwable> handler)NetSocketNetSocket. handler(Handler<Buffer> handler)NetSocketNetSocket. shutdownHandler(Handler<Void> handler)Set ahandlernotified when the socket is shutdown: the client or server will close the connection within a certain amount of time. -
Uses of Handler in io.vertx.reactivex.core.parsetools
Classes in io.vertx.reactivex.core.parsetools that implement Handler Modifier and Type Class Description classJsonParserA parser class which allows to incrementally parse json elements and emit json parse events instead of parsing a json element fully.classRecordParserA helper class which allows you to easily parse protocols which are delimited by a sequence of bytes, or fixed size records.Methods in io.vertx.reactivex.core.parsetools with parameters of type Handler Modifier and Type Method Description JsonParserJsonParser. endHandler(Handler<Void> endHandler)RecordParserRecordParser. endHandler(Handler<Void> endHandler)JsonParserJsonParser. exceptionHandler(Handler<Throwable> handler)RecordParserRecordParser. exceptionHandler(Handler<Throwable> handler)JsonParserJsonParser. handler(Handler<JsonEvent> handler)RecordParserRecordParser. handler(Handler<Buffer> handler)static RecordParserRecordParser. newDelimited(Buffer delim, Handler<Buffer> output)LikeRecordParser.newDelimited(java.lang.String, io.vertx.core.Handler<io.vertx.core.buffer.Buffer>)but set theoutputthat will receive whole records which have been parsed.static RecordParserRecordParser. newDelimited(String delim, Handler<Buffer> output)LikeRecordParser.newDelimited(java.lang.String, io.vertx.core.Handler<io.vertx.core.buffer.Buffer>)but set theoutputthat will receive whole records which have been parsed.static RecordParserRecordParser. newFixed(int size, Handler<Buffer> output)LikeRecordParser.newFixed(int)but set theoutputthat will receive whole records which have been parsed.voidRecordParser. setOutput(Handler<Buffer> output) -
Uses of Handler in io.vertx.reactivex.core.streams
Methods in io.vertx.reactivex.core.streams with parameters of type Handler Modifier and Type Method Description WriteStream<T>WriteStream. drainHandler(Handler<Void> handler)Set a drain handler on the stream.ReadStream<T>ReadStream. endHandler(Handler<Void> endHandler)Set an end handler.ReadStream<T>ReadStream. exceptionHandler(Handler<Throwable> handler)Set an exception handler on the read stream.StreamBaseStreamBase. exceptionHandler(Handler<Throwable> handler)Set an exception handler.WriteStream<T>WriteStream. exceptionHandler(Handler<Throwable> handler)Set an exception handler on the write stream.ReadStream<T>ReadStream. handler(Handler<T> handler)Set a data handler. -
Uses of Handler in io.vertx.reactivex.db2client
Methods in io.vertx.reactivex.db2client with parameters of type Handler Modifier and Type Method Description static SqlClientDB2Builder. client(Handler<ClientBuilder<SqlClient>> handler)Build a client backed by a connection pool with the specifiedblockargument.DB2ConnectionDB2Connection. closeHandler(Handler<Void> handler)DB2ConnectionDB2Connection. exceptionHandler(Handler<Throwable> handler)static PoolDB2Builder. pool(Handler<ClientBuilder<Pool>> block)Build a pool with the specifiedblockargument. -
Uses of Handler in io.vertx.reactivex.ext.auth.audit
Methods in io.vertx.reactivex.ext.auth.audit that return Handler Modifier and Type Method Description <T> Handler<AsyncResult<T>>SecurityAudit. auditHandlerFor(Marker marker) -
Uses of Handler in io.vertx.reactivex.ext.auth.oauth2
Methods in io.vertx.reactivex.ext.auth.oauth2 with parameters of type Handler Modifier and Type Method Description OAuth2AuthOAuth2Auth. missingKeyHandler(Handler<String> handler)Handled to be called when a key (mentioned on a JWT) is missing from the current config. -
Uses of Handler in io.vertx.reactivex.ext.consul
Methods in io.vertx.reactivex.ext.consul with parameters of type Handler Modifier and Type Method Description Watch<T>Watch. setHandler(Handler<WatchResult<T>> handler)Set the result handler. -
Uses of Handler in io.vertx.reactivex.ext.eventbus.bridge.tcp
Methods in io.vertx.reactivex.ext.eventbus.bridge.tcp with parameters of type Handler Modifier and Type Method Description static TcpEventBusBridgeTcpEventBusBridge. create(Vertx vertx, BridgeOptions options, NetServerOptions netServerOptions, Handler<BridgeEvent> eventHandler) -
Uses of Handler in io.vertx.reactivex.ext.healthchecks
Methods in io.vertx.reactivex.ext.healthchecks with parameters of type Handler Modifier and Type Method Description HealthChecksHealthChecks. invoke(Handler<JsonObject> resultHandler)Invokes the registered procedures and computes the outcome.HealthChecksHealthChecks. register(String name, long timeout, Handler<Promise<Status>> procedure)Registers a health check procedure.HealthChecksHealthChecks. register(String name, Handler<Promise<Status>> procedure)Registers a health check procedure. -
Uses of Handler in io.vertx.reactivex.ext.stomp
Classes in io.vertx.reactivex.ext.stomp that implement Handler Modifier and Type Class Description classStompServerHandlerSTOMP server handler implements the behavior of the STOMP server when a specific event occurs.Methods in io.vertx.reactivex.ext.stomp that return Handler Modifier and Type Method Description Handler<ServerWebSocket>StompServer. webSocketHandler()Gets the able to manage web socket connections.Handler<ServerWebSocketHandshake>StompServer. webSocketHandshakeHandler()Gets the able to manage web socket connection handshakes.Methods in io.vertx.reactivex.ext.stomp with parameters of type Handler Modifier and Type Method Description StompServerHandlerStompServerHandler. abortHandler(Handler<ServerFrame> handler)Configures the action to execute when aABORTframe is received.StompServerHandlerStompServerHandler. ackHandler(Handler<ServerFrame> handler)Configures the action to execute when aACKframe is received.StompServerHandlerStompServerHandler. beginHandler(Handler<ServerFrame> handler)Configures the action to execute when aBEGINframe is received.StompClientConnectionStompClientConnection. closeHandler(Handler<StompClientConnection> handler)Sets a handler notified when the STOMP connection is closed.StompServerHandlerStompServerHandler. closeHandler(Handler<StompServerConnection> handler)Configures the action to execute when a connection with the client is closed.StompServerHandlerStompServerHandler. commitHandler(Handler<ServerFrame> handler)Configures the action to execute when aCOMMITframe is received.voidStompServerConnection. configureHeartbeat(long ping, long pong, Handler<StompServerConnection> pingHandler)Configures the heartbeat.StompServerHandlerStompServerHandler. connectHandler(Handler<ServerFrame> handler)Configures the action to execute when aCONNECTframe is received.StompClientConnectionStompClientConnection. connectionDroppedHandler(Handler<StompClientConnection> handler)Sets a handler notified when the server does not respond to apingrequest in time.StompServerHandlerStompServerHandler. disconnectHandler(Handler<ServerFrame> handler)Configures the action to execute when aDISCONNECTframe is received.StompClientStompClient. errorFrameHandler(Handler<Frame> handler)A general error frame handler.StompClientConnectionStompClientConnection. errorHandler(Handler<Frame> handler)Sets a handler notified when anERRORframe is received by the client.StompClientStompClient. exceptionHandler(Handler<Throwable> handler)Sets an exception handler notified for TCP-level errors.StompClientConnectionStompClientConnection. exceptionHandler(Handler<Throwable> exceptionHandler)Configures the exception handler notified upon TCP-level errors.StompServerHandlerStompServerHandler. nackHandler(Handler<ServerFrame> handler)Configures the action to execute when aNACKframe is received.StompServerHandlerStompServerHandler. onAckHandler(Handler<Acknowledgement> handler)Configures the action to execute when messages are acknowledged.StompServerHandlerStompServerHandler. onNackHandler(Handler<Acknowledgement> handler)Configures the action to execute when messages are not acknowledged.StompClientConnectionStompClientConnection. pingHandler(Handler<StompClientConnection> handler)Sets a handler that let customize the behavior when a ping needs to be sent to the server.StompServerHandlerStompServerHandler. pingHandler(Handler<StompServerConnection> handler)Allows customizing the action to do when the server needs to send a `PING` to the client.StompClientStompClient. receivedFrameHandler(Handler<Frame> handler)Configures a received handler that gets notified when a STOMP frame is received by the client.StompClientConnectionStompClientConnection. receivedFrameHandler(Handler<Frame> handler)Configures a received handler that get notified when a STOMP frame is received by the client.StompServerHandlerStompServerHandler. receivedFrameHandler(Handler<ServerFrame> handler)Configures a handler that get notified when a STOMP frame is received by the server.Single<String>StompClientConnection. rxSubscribe(String destination, Handler<Frame> handler)Subscribes to the given destination.Single<String>StompClientConnection. rxSubscribe(String destination, Map<String,String> headers, Handler<Frame> handler)Subscribes to the given destination.StompServerHandlerStompServerHandler. sendHandler(Handler<ServerFrame> handler)Configures the action to execute when aSENDframe is received.StompServerHandlerStompServerHandler. stompHandler(Handler<ServerFrame> handler)Configures the action to execute when aSTOMPframe is received.Future<String>StompClientConnection. subscribe(String destination, Handler<Frame> handler)Subscribes to the given destination.Future<String>StompClientConnection. subscribe(String destination, Map<String,String> headers, Handler<Frame> handler)Subscribes to the given destination.StompServerHandlerStompServerHandler. subscribeHandler(Handler<ServerFrame> handler)Configures the action to execute when aSUBSCRIBEframe is received.StompServerHandlerStompServerHandler. unsubscribeHandler(Handler<ServerFrame> handler)Configures the action to execute when aUNSUBSCRIBEframe is received.StompClientStompClient. writingFrameHandler(Handler<Frame> handler)Configures a writing handler that gets notified when a STOMP frame is written on the wire.StompClientConnectionStompClientConnection. writingFrameHandler(Handler<Frame> handler)Configures a handler notified when a frame is going to be written on the wire.StompServerStompServer. writingFrameHandler(Handler<ServerFrame> handler)Configures the handler that is invoked every time a frame is going to be written to the "wire". -
Uses of Handler in io.vertx.reactivex.ext.unit
Methods in io.vertx.reactivex.ext.unit that return Handler Modifier and Type Method Description <T> Handler<AsyncResult<T>>TestContext. asyncAssertFailure()Creates and returns a new async handler, the returned handler controls the completion of the test.<T> Handler<AsyncResult<T>>TestContext. asyncAssertFailure(Handler<Throwable> causeHandler)Creates and returns a new async handler, the returned handler controls the completion of the test.<T> Handler<AsyncResult<T>>TestContext. asyncAssertSuccess()Creates and returns a new async handler, the returned handler controls the completion of the test.<T> Handler<AsyncResult<T>>TestContext. asyncAssertSuccess(Handler<T> resultHandler)Creates and returns a new async handler, the returned handler controls the completion of the test.Handler<Throwable>TestContext. exceptionHandler()Methods in io.vertx.reactivex.ext.unit with parameters of type Handler Modifier and Type Method Description TestSuiteTestSuite. after(Handler<TestContext> callback)Set a callback executed after the tests.TestSuiteTestSuite. afterEach(Handler<TestContext> callback)Set a callback executed after each test and before the suiteaftercallback.<T> Handler<AsyncResult<T>>TestContext. asyncAssertFailure(Handler<Throwable> causeHandler)Creates and returns a new async handler, the returned handler controls the completion of the test.<T> Handler<AsyncResult<T>>TestContext. asyncAssertSuccess(Handler<T> resultHandler)Creates and returns a new async handler, the returned handler controls the completion of the test.TestSuiteTestSuite. before(Handler<TestContext> callback)Set a callback executed before the tests.TestSuiteTestSuite. beforeEach(Handler<TestContext> callback)Set a callback executed before each test and after the suitebeforecallback.static TestCaseTestCase. create(String name, Handler<TestContext> testCase)Create a test case.voidAsync. handler(Handler<AsyncResult<Void>> completionHandler)Completion handler to receive a completion signal when this completions completes.voidCompletion. handler(Handler<AsyncResult<T>> completionHandler)Completion handler to receive a completion signal when this completions completes.voidTestCompletion. handler(Handler<AsyncResult<Void>> completionHandler)Completion handler to receive a completion signal when this completions completes.TestSuiteTestSuite. test(String name, int repeat, Handler<TestContext> testCase)Add a new test case to the suite.TestSuiteTestSuite. test(String name, Handler<TestContext> testCase)Add a new test case to the suite.TestContextTestContext. verify(Handler<Void> block)Execute the provided handler, which may contain assertions, possibly from any third-party assertion framework. -
Uses of Handler in io.vertx.reactivex.ext.unit.collect
Methods in io.vertx.reactivex.ext.unit.collect with parameters of type Handler Modifier and Type Method Description static EventBusCollectorEventBusCollector. create(Vertx vertx, Handler<TestSuiteReport> reporter) -
Uses of Handler in io.vertx.reactivex.ext.unit.report
Methods in io.vertx.reactivex.ext.unit.report with parameters of type Handler Modifier and Type Method Description TestCaseReportTestCaseReport. endHandler(Handler<TestResult> handler)Set a callback for completion, the specifiedhandleris invoked when the test exec has completed.TestSuiteReportTestSuiteReport. endHandler(Handler<Void> endHandler)TestSuiteReportTestSuiteReport. exceptionHandler(Handler<Throwable> handler)Set an exception handler, the exception handler reports the test suite errors, it can be called mulitple times before the test ends.TestSuiteReportTestSuiteReport. handler(Handler<TestCaseReport> handler) -
Uses of Handler in io.vertx.reactivex.ext.web
Classes in io.vertx.reactivex.ext.web that implement Handler Modifier and Type Class Description classRouterA router receives request from anHttpServerand routes it to the first matchingRoutethat it contains.Methods in io.vertx.reactivex.ext.web with parameters of type Handler Modifier and Type Method Description intRoutingContext. addBodyEndHandler(Handler<Void> handler)Provides a handler that will be called after the last part of the body is written to the wire.intRoutingContext. addEndHandler(Handler<AsyncResult<Void>> handler)Add an end handler for the request/response context.intRoutingContext. addHeadersEndHandler(Handler<Void> handler)Add a handler that will be called just before headers are written to the response.RouteRoute. blockingHandler(Handler<RoutingContext> requestHandler)LikeRoute.blockingHandler(io.vertx.core.Handler<io.vertx.reactivex.ext.web.RoutingContext>)called with ordered = trueRouteRoute. blockingHandler(Handler<RoutingContext> requestHandler, boolean ordered)Specify a blocking request handler for the route.RouterRouter. errorHandler(int statusCode, Handler<RoutingContext> errorHandler)Specify an handler to handle an error for a particular status code.RouteRoute. failureHandler(Handler<RoutingContext> failureHandler)Append a failure handler to the route failure handlers list.RouteRoute. handler(Handler<RoutingContext> requestHandler)Append a request handler to the route handlers list.RouterRouter. modifiedHandler(Handler<Router> handler)When a Router routes are changed this handler is notified. -
Uses of Handler in io.vertx.reactivex.ext.web.handler
Subinterfaces of Handler in io.vertx.reactivex.ext.web.handler Modifier and Type Interface Description interfaceAuthenticationHandlerBase interface for auth handlers.interfaceInputTrustHandlerBase input trust interface for handlers that verify the trust of the request.interfacePlatformHandlerBase platform interface for handlers that provide functionality to the application platform.interfaceProtocolUpgradeHandlerBase interface for handlers that perform protocol upgrades.interfaceSecurityPolicyHandlerBase security policy interface for handlers that provide HTTP security related headers.Classes in io.vertx.reactivex.ext.web.handler that implement Handler Modifier and Type Class Description classAPIKeyHandlerAn authentication handler that provides API Key support.classAuthorizationHandlerBase interface for authorization handlers that provide authorization support.classBasicAuthHandlerAn auth handler that provides HTTP Basic Authentication support.classBodyHandlerA handler which gathers the entire request body and sets it on the .classChainAuthHandlerAn auth handler that chains to a sequence of handlers.classCorsHandlerA handler which implements server side http://www.w3.org/TR/cors/[CORS] support for Vert.x-Web.classCSPHandlerContent Security Policy (CSP) is an added layer of security that helps to detect and mitigate certain types of attacks, including Cross Site Scripting (XSS) and data injection attacks.classCSRFHandlerThis handler adds a CSRF token to requests which mutate state.classDigestAuthHandlerAn auth handler that provides HTTP Basic Authentication support.classErrorHandlerA pretty error handler for rendering error pages.classFaviconHandlerA handler that serves favicons.classFormLoginHandlerHandler that handles login from a form on a custom login page.classHSTSHandlerHTTP Strict Transport Security (HSTS) RFC6797.classJWTAuthHandlerAn auth handler that provides JWT Authentication support.classLoggerHandlerA handler which logs request information to the Vert.x logger.classMethodOverrideHandlerNOTE: This class has been automatically generated from theoriginalnon RX-ified interface using Vert.x codegen.classMultiTenantHandlerA handler which selectively executes another handler if a precondition is met.classOAuth2AuthHandlerAn auth handler that provides OAuth2 Authentication support.classOtpAuthHandlerAn auth handler that provides One Time Password (Multi-Factor) Authentication support.classRedirectAuthHandlerAn auth handler that's used to handle auth by redirecting user to a custom login page.classResponseContentTypeHandlerA handler which sets the response content type automatically according to the bestAcceptheader match.classResponseTimeHandlerHandler which adds a header `x-response-time` in the response of matching requests containing the time taken in ms to process the request.classSecurityAuditLoggerHandlerA handler that logs security audit events.classSessionHandlerA handler that maintains aSessionfor each browser session.classSimpleAuthenticationHandlerA user customizable authentication handler.classStaticHandlerA handler for serving static resources from the file system or classpath.classTemplateHandlerA handler which renders responses using a template engine and where the template name is selected from the URI path.classTimeoutHandlerHandler that will timeout requests if the response has not been written after a certain time.classWebAuthn4JHandlerAn auth handler that provides FIDO2 WebAuthN Relay Party support.classXFrameHandlerThe X-Frame-Options HTTP response header can be used to indicate whether or not a browser should be allowed to render a page in a,,or.Methods in io.vertx.reactivex.ext.web.handler with parameters of type Handler Modifier and Type Method Description MultiTenantHandlerMultiTenantHandler. addDefaultHandler(Handler<RoutingContext> handler)Add a default handler for the case when no tenant was matched.MultiTenantHandlerMultiTenantHandler. addTenantHandler(String tenant, Handler<RoutingContext> handler)Add a handler for a given tenant to this handler. -
Uses of Handler in io.vertx.reactivex.ext.web.handler.graphql
Classes in io.vertx.reactivex.ext.web.handler.graphql that implement Handler Modifier and Type Class Description classGraphQLHandlerARoutehandler for GraphQL requests.Methods in io.vertx.reactivex.ext.web.handler.graphql with parameters of type Handler Modifier and Type Method Description GraphQLHandlerBuilderGraphQLHandlerBuilder. beforeExecute(Handler<ExecutionInputBuilderWithContext<RoutingContext>> beforeExecuteHandler)Set a callback to invoke before executing a GraphQL query. -
Uses of Handler in io.vertx.reactivex.ext.web.handler.graphql.ws
Classes in io.vertx.reactivex.ext.web.handler.graphql.ws that implement Handler Modifier and Type Class Description classGraphQLWSHandlerA handler for the GraphQL over WebSocket Protocol.Methods in io.vertx.reactivex.ext.web.handler.graphql.ws with parameters of type Handler Modifier and Type Method Description GraphQLWSHandlerBuilderGraphQLWSHandlerBuilder. beforeExecute(Handler<ExecutionInputBuilderWithContext<Message>> beforeExecuteHandler)Set a callback to invoke before executing a GraphQL query.GraphQLWSHandlerBuilderGraphQLWSHandlerBuilder. onConnectionInit(Handler<ConnectionInitEvent> connectionInitHandler)Customize the connection init .GraphQLWSHandlerBuilderGraphQLWSHandlerBuilder. onMessage(Handler<Message> messageHandler)Customize the message .GraphQLWSHandlerBuilderGraphQLWSHandlerBuilder. onSocketEnd(Handler<ServerWebSocket> endHandler)Customize the end . -
Uses of Handler in io.vertx.reactivex.ext.web.handler.sockjs
Methods in io.vertx.reactivex.ext.web.handler.sockjs with parameters of type Handler Modifier and Type Method Description RouterSockJSHandler. bridge(SockJSBridgeOptions bridgeOptions, Handler<BridgeEvent> bridgeEventHandler)LikeSockJSHandler.bridge(io.vertx.ext.web.handler.sockjs.SockJSBridgeOptions)but specifying a handler that will receive bridge events.RouterSockJSHandler. bridge(AuthorizationProvider authorizationProvider, SockJSBridgeOptions bridgeOptions, Handler<BridgeEvent> bridgeEventHandler)LikeSockJSHandler.bridge(io.vertx.ext.web.handler.sockjs.SockJSBridgeOptions)but specifying a handler that will receive bridge events.SockJSSocketSockJSSocket. closeHandler(Handler<Void> closeHandler)SockJSSocketSockJSSocket. drainHandler(Handler<Void> handler)SockJSSocketSockJSSocket. endHandler(Handler<Void> endHandler)SockJSSocketSockJSSocket. exceptionHandler(Handler<Throwable> handler)SockJSSocketSockJSSocket. handler(Handler<Buffer> handler)RouterSockJSHandler. socketHandler(Handler<SockJSSocket> handler)Set a SockJS socket handler. -
Uses of Handler in io.vertx.reactivex.ext.web.healthchecks
Classes in io.vertx.reactivex.ext.web.healthchecks that implement Handler Modifier and Type Class Description classHealthCheckHandlerA Vert.x Web handler on which you register health check procedure.Methods in io.vertx.reactivex.ext.web.healthchecks with parameters of type Handler Modifier and Type Method Description HealthCheckHandlerHealthCheckHandler. register(String name, long timeout, Handler<Promise<Status>> procedure)Registers a health check procedure.HealthCheckHandlerHealthCheckHandler. register(String name, Handler<Promise<Status>> procedure)Registers a health check procedure. -
Uses of Handler in io.vertx.reactivex.ext.web.openapi.router
Methods in io.vertx.reactivex.ext.web.openapi.router with parameters of type Handler Modifier and Type Method Description OpenAPIRouteOpenAPIRoute. addFailureHandler(Handler<RoutingContext> handler)Adds a failure handler for this routeOpenAPIRouteOpenAPIRoute. addHandler(Handler<RoutingContext> handler)Adds a handler for this route which is executed after the security and validation handlers defined in the contractRouterBuilderRouterBuilder. rootHandler(Handler<RoutingContext> rootHandler)Add global handler to be applied prior to being generated. -
Uses of Handler in io.vertx.reactivex.ext.web.validation
Classes in io.vertx.reactivex.ext.web.validation that implement Handler Modifier and Type Class Description classValidationHandler -
Uses of Handler in io.vertx.reactivex.grpc.client
Methods in io.vertx.reactivex.grpc.client with parameters of type Handler Modifier and Type Method Description GrpcClientRequest<Req,Resp>GrpcClientRequest. drainHandler(Handler<Void> handler)GrpcClientResponse<Req,Resp>GrpcClientResponse. endHandler(Handler<Void> handler)GrpcClientResponse<Req,Resp>GrpcClientResponse. errorHandler(Handler<GrpcError> handler)GrpcClientRequest<Req,Resp>GrpcClientRequest. exceptionHandler(Handler<Throwable> handler)GrpcClientResponse<Req,Resp>GrpcClientResponse. exceptionHandler(Handler<Throwable> handler)GrpcClientResponse<Req,Resp>GrpcClientResponse. handler(Handler<Resp> handler)GrpcReadStream<Resp>GrpcClientResponse. invalidMessageHandler(Handler<InvalidMessageException> handler)Set a message handler that is reported with invalid message errors.GrpcClientResponse<Req,Resp>GrpcClientResponse. messageHandler(Handler<GrpcMessage> handler) -
Uses of Handler in io.vertx.reactivex.grpc.common
Methods in io.vertx.reactivex.grpc.common with parameters of type Handler Modifier and Type Method Description GrpcWriteStream<T>GrpcWriteStream. drainHandler(Handler<Void> handler)GrpcReadStream<T>GrpcReadStream. endHandler(Handler<Void> handler)GrpcReadStream<T>GrpcReadStream. errorHandler(Handler<GrpcError> handler)Set a handler to be notified with gRPC errors.GrpcReadStream<T>GrpcReadStream. exceptionHandler(Handler<Throwable> handler)GrpcWriteStream<T>GrpcWriteStream. exceptionHandler(Handler<Throwable> handler)GrpcReadStream<T>GrpcReadStream. handler(Handler<T> handler)GrpcReadStream<T>GrpcReadStream. invalidMessageHandler(Handler<InvalidMessageException> handler)Set a message handler that is reported with invalid message errors.GrpcReadStream<T>GrpcReadStream. messageHandler(Handler<GrpcMessage> handler)Set a handler to be notified with incoming encoded messages. -
Uses of Handler in io.vertx.reactivex.grpc.server
Classes in io.vertx.reactivex.grpc.server that implement Handler Modifier and Type Class Description classGrpcServerA gRPC server based on Vert.x HTTP server.Methods in io.vertx.reactivex.grpc.server with parameters of type Handler Modifier and Type Method Description GrpcServerGrpcServer. callHandler(Handler<GrpcServerRequest<Buffer,Buffer>> handler)Set a call handler that handles any call made to the server.<Req,Resp>
GrpcServerGrpcServer. callHandler(ServiceMethod<Req,Resp> serviceMethod, Handler<GrpcServerRequest<Req,Resp>> handler)Set a service method call handler that handles any call made to the server for thefullMethodNameservice method.GrpcServerResponse<Req,Resp>GrpcServerResponse. drainHandler(Handler<Void> handler)GrpcServerRequest<Req,Resp>GrpcServerRequest. endHandler(Handler<Void> endHandler)GrpcServerRequest<Req,Resp>GrpcServerRequest. errorHandler(Handler<GrpcError> handler)GrpcServerRequest<Req,Resp>GrpcServerRequest. exceptionHandler(Handler<Throwable> handler)GrpcServerResponse<Req,Resp>GrpcServerResponse. exceptionHandler(Handler<Throwable> handler)GrpcServerRequest<Req,Resp>GrpcServerRequest. handler(Handler<Req> handler)GrpcReadStream<Req>GrpcServerRequest. invalidMessageHandler(Handler<InvalidMessageException> handler)Set a message handler that is reported with invalid message errors.GrpcServerRequest<Req,Resp>GrpcServerRequest. messageHandler(Handler<GrpcMessage> handler) -
Uses of Handler in io.vertx.reactivex.kafka.client.consumer
Methods in io.vertx.reactivex.kafka.client.consumer with parameters of type Handler Modifier and Type Method Description KafkaConsumer<K,V>KafkaConsumer. batchHandler(Handler<KafkaConsumerRecords<K,V>> handler)Set the handler to be used when batches of messages are fetched from the Kafka server.KafkaConsumer<K,V>KafkaConsumer. endHandler(Handler<Void> endHandler)KafkaConsumer<K,V>KafkaConsumer. exceptionHandler(Handler<Throwable> handler)KafkaConsumer<K,V>KafkaConsumer. handler(Handler<KafkaConsumerRecord<K,V>> handler)KafkaConsumer<K,V>KafkaConsumer. partitionsAssignedHandler(Handler<Set<TopicPartition>> handler)Set the handler called when topic partitions are assigned to the consumerKafkaConsumer<K,V>KafkaConsumer. partitionsRevokedHandler(Handler<Set<TopicPartition>> handler)Set the handler called when topic partitions are revoked to the consumer -
Uses of Handler in io.vertx.reactivex.kafka.client.producer
Methods in io.vertx.reactivex.kafka.client.producer with parameters of type Handler Modifier and Type Method Description KafkaProducer<K,V>KafkaProducer. drainHandler(Handler<Void> handler)KafkaProducer<K,V>KafkaProducer. exceptionHandler(Handler<Throwable> handler) -
Uses of Handler in io.vertx.reactivex.micrometer
Methods in io.vertx.reactivex.micrometer that return Handler Modifier and Type Method Description static Handler<HttpServerRequest>PrometheusRequestHandler. create()Creates a handler with a new PrometheusMeterRegistry and the default metrics endpoint ("/metrics").static Handler<HttpServerRequest>PrometheusRequestHandler. create(io.micrometer.prometheusmetrics.PrometheusMeterRegistry registry)Creates a handler with the specified PrometheusMeterRegistry and the default metrics endpoint ("/metrics").static Handler<HttpServerRequest>PrometheusRequestHandler. create(io.micrometer.prometheusmetrics.PrometheusMeterRegistry registry, String metricsEndpoint)Creates a handler with the specified PrometheusMeterRegistry and metrics endpoint.static Handler<RoutingContext>PrometheusScrapingHandler. create()Creates a Vert.x WebRoutehandler for Prometheus metrics scraping.static Handler<RoutingContext>PrometheusScrapingHandler. create(io.micrometer.prometheusmetrics.PrometheusMeterRegistry registry)Creates a Vert.x WebRoutehandler for Prometheus metrics scraping.static Handler<RoutingContext>PrometheusScrapingHandler. create(String registryName)Creates a Vert.x WebRoutehandler for Prometheus metrics scraping. -
Uses of Handler in io.vertx.reactivex.mqtt
Methods in io.vertx.reactivex.mqtt with parameters of type Handler Modifier and Type Method Description MqttClientMqttClient. authenticationExchangeHandler(Handler<MqttAuthenticationExchangeMessage> authenticationExchangeHandler)Sets handler which will be called after AUTH packet receivingMqttEndpointMqttEndpoint. authenticationExchangeHandler(Handler<MqttAuthenticationExchangeMessage> handler)Set the auth handler on the MQTT endpoint.MqttClientMqttClient. closeHandler(Handler<Void> closeHandler)Set a handler that will be called when the connection with server is closedMqttEndpointMqttEndpoint. closeHandler(Handler<Void> handler)Set a close handler.MqttEndpointMqttEndpoint. disconnectHandler(Handler<Void> handler)Set a disconnect handler on the MQTT endpoint.MqttEndpointMqttEndpoint. disconnectMessageHandler(Handler<MqttDisconnectMessage> handler)Set a disconnect handler on the MQTT endpoint.MqttServerMqttServer. endpointHandler(Handler<MqttEndpoint> handler)Set the endpoint handler for the server.MqttClientMqttClient. exceptionHandler(Handler<Throwable> handler)Set an exception handler for the client, that will be called when an error happens in internal netty structures.MqttEndpointMqttEndpoint. exceptionHandler(Handler<Throwable> handler)Set an exception handler.MqttServerMqttServer. exceptionHandler(Handler<Throwable> handler)Set an exception handler for the server, that will be called when an error happens independantly of an acceptedMqttEndpoint, like a rejected connectionMqttEndpointMqttEndpoint. pingHandler(Handler<Void> handler)Set the pingreq handler on the MQTT endpoint.MqttClientMqttClient. pingResponseHandler(Handler<Void> pingResponseHandler)Sets handler which will be called after PINGRESP packet receivingMqttEndpointMqttEndpoint. publishAcknowledgeHandler(Handler<Integer> handler)Set the puback handler on the MQTT endpoint.MqttEndpointMqttEndpoint. publishAcknowledgeMessageHandler(Handler<MqttPubAckMessage> handler)Set the puback handler on the MQTT endpoint.MqttClientMqttClient. publishCompletionExpirationHandler(Handler<Integer> publishCompletionExpirationHandler)Sets a handler which will be called when the client does not receive a PUBACK or PUBREC/PUBCOMP for a message published using QoS 1 or 2 respectively.MqttClientMqttClient. publishCompletionHandler(Handler<Integer> publishCompletionHandler)Sets a handler which will be called each time the publishing of a message has been completed.MqttEndpointMqttEndpoint. publishCompletionHandler(Handler<Integer> handler)Set the pubcomp handler on the MQTT endpoint.MqttEndpointMqttEndpoint. publishCompletionMessageHandler(Handler<MqttPubCompMessage> handler)Set the pubcomp handler on the MQTT endpoint.MqttClientMqttClient. publishCompletionUnknownPacketIdHandler(Handler<Integer> publishCompletionPhantomHandler)Sets a handler which will be called when the client receives a PUBACK/PUBREC/PUBCOMP with an unknown packet ID.MqttClientMqttClient. publishHandler(Handler<MqttPublishMessage> publishHandler)Sets handler which will be called each time server publish something to clientMqttEndpointMqttEndpoint. publishHandler(Handler<MqttPublishMessage> handler)Set the publish handler on the MQTT endpoint.MqttEndpointMqttEndpoint. publishReceivedHandler(Handler<Integer> handler)Set the pubrec handler on the MQTT endpoint.MqttEndpointMqttEndpoint. publishReceivedMessageHandler(Handler<MqttPubRecMessage> handler)Set the pubrec handler on the MQTT endpoint.MqttEndpointMqttEndpoint. publishReleaseHandler(Handler<Integer> handler)Set the pubrel handler on the MQTT endpoint.MqttEndpointMqttEndpoint. publishReleaseMessageHandler(Handler<MqttPubRelMessage> handler)Set the pubrel handler on the MQTT endpoint.MqttClientMqttClient. subscribeCompletionHandler(Handler<MqttSubAckMessage> subscribeCompletionHandler)Sets handler which will be called after SUBACK packet receivingMqttEndpointMqttEndpoint. subscribeHandler(Handler<MqttSubscribeMessage> handler)Set a subscribe handler on the MQTT endpoint.MqttClientMqttClient. unsubscribeCompletionHandler(Handler<Integer> unsubscribeCompletionHandler)Sets handler which will be called after UNSUBACK packet receivingMqttEndpointMqttEndpoint. unsubscribeHandler(Handler<MqttUnsubscribeMessage> handler)Set a unsubscribe handler on the MQTT endpoint. -
Uses of Handler in io.vertx.reactivex.mssqlclient
Methods in io.vertx.reactivex.mssqlclient with parameters of type Handler Modifier and Type Method Description MSSQLConnectionMSSQLConnection. closeHandler(Handler<Void> handler)MSSQLConnectionMSSQLConnection. exceptionHandler(Handler<Throwable> handler)MSSQLConnectionMSSQLConnection. infoHandler(Handler<MSSQLInfo> handler)Set a handler called when the connection receives an informational message from the server.static PoolMSSQLBuilder. pool(Handler<ClientBuilder<Pool>> block)Build a pool with the specifiedblockargument. -
Uses of Handler in io.vertx.reactivex.mysqlclient
Methods in io.vertx.reactivex.mysqlclient with parameters of type Handler Modifier and Type Method Description static SqlClientMySQLBuilder. client(Handler<ClientBuilder<SqlClient>> handler)Build a client backed by a connection pool with the specifiedblockargument.MySQLConnectionMySQLConnection. closeHandler(Handler<Void> handler)MySQLConnectionMySQLConnection. exceptionHandler(Handler<Throwable> handler)static PoolMySQLBuilder. pool(Handler<ClientBuilder<Pool>> block)Build a pool with the specifiedblockargument. -
Uses of Handler in io.vertx.reactivex.oracleclient
Methods in io.vertx.reactivex.oracleclient with parameters of type Handler Modifier and Type Method Description OracleConnectionOracleConnection. closeHandler(Handler<Void> handler)OracleConnectionOracleConnection. exceptionHandler(Handler<Throwable> handler)static PoolOracleBuilder. pool(Handler<ClientBuilder<Pool>> block)Build a pool with the specifiedblockargument. -
Uses of Handler in io.vertx.reactivex.pgclient
Methods in io.vertx.reactivex.pgclient with parameters of type Handler Modifier and Type Method Description static SqlClientPgBuilder. client(Handler<ClientBuilder<SqlClient>> handler)Build a client backed by a connection pool with the specifiedblockargument.PgConnectionPgConnection. closeHandler(Handler<Void> handler)PgConnectionPgConnection. exceptionHandler(Handler<Throwable> handler)PgConnectionPgConnection. noticeHandler(Handler<PgNotice> handler)Set a handler called when the connection receives a notice from the server.PgConnectionPgConnection. notificationHandler(Handler<PgNotification> handler)Set a handler called when the connection receives notification on a channel.static PoolPgBuilder. pool(Handler<ClientBuilder<Pool>> block)Build a pool with the specifiedblockargument. -
Uses of Handler in io.vertx.reactivex.pgclient.pubsub
Methods in io.vertx.reactivex.pgclient.pubsub with parameters of type Handler Modifier and Type Method Description PgSubscriberPgSubscriber. closeHandler(Handler<Void> handler)Set an handler called when the subscriber is closed.PgChannelPgChannel. endHandler(Handler<Void> endHandler)Set an handler to be called when no more notifications will be received.PgChannelPgChannel. exceptionHandler(Handler<Throwable> handler)PgChannelPgChannel. handler(Handler<String> handler)Set or unset an handler to be called when a the channel is notified by Postgres.PgChannelPgChannel. subscribeHandler(Handler<Void> handler)Set an handler called when the the channel get subscribed. -
Uses of Handler in io.vertx.reactivex.rabbitmq
Methods in io.vertx.reactivex.rabbitmq with parameters of type Handler Modifier and Type Method Description Future<Void>RabbitMQClient. basicPublishWithDeliveryTag(String exchange, String routingKey, com.rabbitmq.client.BasicProperties properties, Buffer body, Handler<Long> deliveryTagHandler)Publish a message.RabbitMQConsumerRabbitMQConsumer. endHandler(Handler<Void> endHandler)Set an end handler.RabbitMQConsumerRabbitMQConsumer. exceptionHandler(Handler<Throwable> exceptionHandler)Set an exception handler on the read stream.RabbitMQConsumerRabbitMQConsumer. handler(Handler<RabbitMQMessage> messageArrived)Set a message handler.CompletableRabbitMQClient. rxBasicPublishWithDeliveryTag(String exchange, String routingKey, com.rabbitmq.client.BasicProperties properties, Buffer body, Handler<Long> deliveryTagHandler)Publish a message. -
Uses of Handler in io.vertx.reactivex.redis.client
Methods in io.vertx.reactivex.redis.client with parameters of type Handler Modifier and Type Method Description RedisConnectionRedisConnection. endHandler(Handler<Void> endHandler)RedisConnectionRedisConnection. exceptionHandler(Handler<Throwable> handler)RedisConnectionRedisConnection. handler(Handler<Response> handler) -
Uses of Handler in io.vertx.reactivex.servicediscovery.spi
Methods in io.vertx.reactivex.servicediscovery.spi with parameters of type Handler Modifier and Type Method Description voidServiceExporter. close(Handler<Void> closeHandler)Close the exportervoidServiceImporter. close(Handler<Void> closeHandler)Closes the importer -
Uses of Handler in io.vertx.reactivex.sqlclient
Methods in io.vertx.reactivex.sqlclient with parameters of type Handler Modifier and Type Method Description SqlConnectionSqlConnection. closeHandler(Handler<Void> handler)Set an handler called when the connection is closed.RowStream<T>RowStream. endHandler(Handler<Void> endHandler)RowStream<T>RowStream. exceptionHandler(Handler<Throwable> handler)SqlConnectionSqlConnection. exceptionHandler(Handler<Throwable> handler)Set an handler called with connection errors.RowStream<T>RowStream. handler(Handler<T> handler)ClientBuilder<C>ClientBuilder. withConnectHandler(Handler<SqlConnection> handler)Set a handler called when the pool has established a connection to the database. -
Uses of Handler in io.vertx.redis.client
Classes in io.vertx.redis.client that implement Handler Modifier and Type Class Description classEventBusHandlerA handler that can be installed on a Redis connection usingRedisConnection.handler(Handler)in order to consume subscription messages and send them on the Vert.x event bus.Methods in io.vertx.redis.client with parameters of type Handler Modifier and Type Method Description RedisConnectionRedisConnection. endHandler(Handler<Void> endHandler)Set an end handler.RedisConnectionRedisConnection. exceptionHandler(Handler<Throwable> handler)Set an exception handler on the read stream.RedisConnectionRedisConnection. handler(Handler<Response> handler)Set a data handler. -
Uses of Handler in io.vertx.rxjava3
Methods in io.vertx.rxjava3 with parameters of type Handler Modifier and Type Method Description static <T> CompletableObserverCompletableHelper. toObserver(Handler<AsyncResult<T>> handler)Adapts an Vert.xHandler<AsyncResult<T>>to an RxJava2SingleObserver.static <T> MaybeObserver<T>MaybeHelper. toObserver(Handler<AsyncResult<T>> handler)Adapts an Vert.xHandler<AsyncResult<T>>to an RxJava2MaybeObserver.static <T> SingleObserver<T>SingleHelper. toObserver(Handler<AsyncResult<T>> handler)Adapts an Vert.xHandler<AsyncResult<T>>to an RxJava2SingleObserver.Method parameters in io.vertx.rxjava3 with type arguments of type Handler Modifier and Type Method Description static CompletableCompletableHelper. toCompletable(Consumer<Handler<AsyncResult<Void>>> handler)Returns aCompletablethat, when subscribed, uses the providedhandlerto adapt a callback-based asynchronous method.static <T> Maybe<T>MaybeHelper. toMaybe(Consumer<Handler<AsyncResult<T>>> handler)Returns aMaybethat, when subscribed, uses the providedhandlerto adapt a callback-based asynchronous method.static <T> Single<T>SingleHelper. toSingle(Consumer<Handler<AsyncResult<T>>> handler)Returns aSinglethat, when subscribed, uses the providedhandlerto adapt a callback-based asynchronous method. -
Uses of Handler in io.vertx.rxjava3.amqp
Methods in io.vertx.rxjava3.amqp with parameters of type Handler Modifier and Type Method Description WriteStream<AmqpMessage>AmqpSender. drainHandler(Handler<Void> handler)Set a drain handler on the stream.AmqpReceiverAmqpReceiver. endHandler(Handler<Void> endHandler)AmqpConnectionAmqpConnection. exceptionHandler(Handler<Throwable> handler)Registers a handler called on disconnection.AmqpReceiverAmqpReceiver. exceptionHandler(Handler<Throwable> handler)AmqpSenderAmqpSender. exceptionHandler(Handler<Throwable> handler)AmqpReceiverAmqpReceiver. handler(Handler<AmqpMessage> handler) -
Uses of Handler in io.vertx.rxjava3.cassandra
Methods in io.vertx.rxjava3.cassandra with parameters of type Handler Modifier and Type Method Description CassandraRowStreamCassandraRowStream. endHandler(Handler<Void> handler)CassandraRowStreamCassandraRowStream. exceptionHandler(Handler<Throwable> handler)CassandraRowStreamCassandraRowStream. handler(Handler<com.datastax.oss.driver.api.core.cql.Row> handler) -
Uses of Handler in io.vertx.rxjava3.circuitbreaker
Methods in io.vertx.rxjava3.circuitbreaker with parameters of type Handler Modifier and Type Method Description CircuitBreakerCircuitBreaker. closeHandler(Handler<Void> handler)Sets a to be invoked when the circuit breaker state switches to closed.<T> Single<T>CircuitBreaker. execute(Handler<Promise<T>> command)Same asCircuitBreaker.executeWithFallback(io.vertx.core.Handler<io.vertx.rxjava3.core.Promise<T>>, java.util.function.Function<java.lang.Throwable, T>)but using the circuit breaker .<T> CircuitBreakerCircuitBreaker. executeAndReport(Promise<T> resultPromise, Handler<Promise<T>> command)<T> CircuitBreakerCircuitBreaker. executeAndReportWithFallback(Promise<T> resultPromise, Handler<Promise<T>> command, Function<Throwable,T> fallback)Executes the given operation with the circuit breaker control.<T> Single<T>CircuitBreaker. executeWithFallback(Handler<Promise<T>> command, Function<Throwable,T> fallback)Executes the given operation with the circuit breaker control.CircuitBreakerCircuitBreaker. halfOpenHandler(Handler<Void> handler)Sets a to be invoked when the circuit breaker state switches to half-open.CircuitBreakerCircuitBreaker. openHandler(Handler<Void> handler)Sets a to be invoked when the circuit breaker state switches to open.<T> Single<T>CircuitBreaker. rxExecute(Handler<Promise<T>> command)Same asCircuitBreaker.executeWithFallback(io.vertx.core.Handler<io.vertx.rxjava3.core.Promise<T>>, java.util.function.Function<java.lang.Throwable, T>)but using the circuit breaker .<T> Single<T>CircuitBreaker. rxExecuteWithFallback(Handler<Promise<T>> command, Function<Throwable,T> fallback)Executes the given operation with the circuit breaker control. -
Uses of Handler in io.vertx.rxjava3.config
Methods in io.vertx.rxjava3.config with parameters of type Handler Modifier and Type Method Description voidConfigRetriever. listen(Handler<ConfigChange> listener)Registers a listener receiving configuration changes.ConfigRetrieverConfigRetriever. setBeforeScanHandler(Handler<Void> handler)Registers a handler called before every scan. -
Uses of Handler in io.vertx.rxjava3.core
Methods in io.vertx.rxjava3.core with parameters of type Handler Modifier and Type Method Description ContextContext. exceptionHandler(Handler<Throwable> handler)Set an exception handler called when the context runs an action throwing an uncaught throwable.VertxVertx. exceptionHandler(Handler<Throwable> handler)Set a default exception handler forContext, set onContext.exceptionHandler(io.vertx.core.Handler<java.lang.Throwable>)at creation.voidContext. runOnContext(Handler<Void> action)Run the specified action asynchronously on the same context, some time after the current execution has completed.voidVertx. runOnContext(Handler<Void> action)Puts the handler on the event queue for the current context so it will be run asynchronously ASAP after all preceeding events have been handled.longVertx. setPeriodic(long initialDelay, long delay, Handler<Long> handler)Set a periodic timer to fire everydelaymilliseconds with initial delay, at which pointhandlerwill be called with the id of the timer.longVertx. setPeriodic(long delay, Handler<Long> handler)Set a periodic timer to fire everydelaymilliseconds, at which pointhandlerwill be called with the id of the timer.longVertx. setTimer(long delay, Handler<Long> handler)Set a one-shot timer to fire afterdelaymilliseconds, at which pointhandlerwill be called with the id of the timer. -
Uses of Handler in io.vertx.rxjava3.core.datagram
Methods in io.vertx.rxjava3.core.datagram with parameters of type Handler Modifier and Type Method Description DatagramSocketDatagramSocket. exceptionHandler(Handler<Throwable> handler)DatagramSocketDatagramSocket. handler(Handler<DatagramPacket> handler) -
Uses of Handler in io.vertx.rxjava3.core.eventbus
Methods in io.vertx.rxjava3.core.eventbus with parameters of type Handler Modifier and Type Method Description <T> EventBusEventBus. addInboundInterceptor(Handler<DeliveryContext<T>> interceptor)Add an interceptor that will be called whenever a message is received by Vert.x<T> EventBusEventBus. addOutboundInterceptor(Handler<DeliveryContext<T>> interceptor)Add an interceptor that will be called whenever a message is sent from Vert.x<T> MessageConsumer<T>EventBus. consumer(MessageConsumerOptions options, Handler<Message<T>> handler)Create a consumer and register it against the specified options address.<T> MessageConsumer<T>EventBus. consumer(String address, Handler<Message<T>> handler)Create a consumer and register it against the specified address.MessageConsumer<T>MessageConsumer. endHandler(Handler<Void> endHandler)MessageConsumer<T>MessageConsumer. exceptionHandler(Handler<Throwable> handler)MessageConsumer<T>MessageConsumer. handler(Handler<Message<T>> handler)<T> MessageConsumer<T>EventBus. localConsumer(String address, Handler<Message<T>> handler)LikeEventBus.consumer(io.vertx.core.eventbus.MessageConsumerOptions)but the address won't be propagated across the cluster.<T> EventBusEventBus. removeInboundInterceptor(Handler<DeliveryContext<T>> interceptor)Remove an interceptor that was added byEventBus.addInboundInterceptor(io.vertx.core.Handler<io.vertx.rxjava3.core.eventbus.DeliveryContext<T>>)<T> EventBusEventBus. removeOutboundInterceptor(Handler<DeliveryContext<T>> interceptor)Remove an interceptor that was added byEventBus.addOutboundInterceptor(io.vertx.core.Handler<io.vertx.rxjava3.core.eventbus.DeliveryContext<T>>) -
Uses of Handler in io.vertx.rxjava3.core.file
Methods in io.vertx.rxjava3.core.file with parameters of type Handler Modifier and Type Method Description AsyncFileAsyncFile. drainHandler(Handler<Void> handler)AsyncFileAsyncFile. endHandler(Handler<Void> endHandler)AsyncFileAsyncFile. exceptionHandler(Handler<Throwable> handler)Set an exception handler on the read stream and on the write stream.AsyncFileAsyncFile. handler(Handler<Buffer> handler) -
Uses of Handler in io.vertx.rxjava3.core.http
Methods in io.vertx.rxjava3.core.http with parameters of type Handler Modifier and Type Method Description ClientWebSocketClientWebSocket. binaryMessageHandler(Handler<Buffer> handler)WebSocketWebSocket. binaryMessageHandler(Handler<Buffer> handler)WebSocketBaseWebSocketBase. binaryMessageHandler(Handler<Buffer> handler)Set a binary message handler on the connection.HttpServerResponseHttpServerResponse. bodyEndHandler(Handler<Void> handler)Provides a handler that will be called after the last part of the body is written to the wire.HttpClientResponseHttpClientResponse. bodyHandler(Handler<Buffer> bodyHandler)Convenience method for receiving the entire request body in one piece.HttpServerRequestHttpServerRequest. bodyHandler(Handler<Buffer> bodyHandler)Convenience method for receiving the entire request body in one piece.ClientWebSocketClientWebSocket. closeHandler(Handler<Void> handler)HttpConnectionHttpConnection. closeHandler(Handler<Void> handler)Set a close handler.HttpServerResponseHttpServerResponse. closeHandler(Handler<Void> handler)Set a close handler for the response, this is called when the underlying connection is closed and the response was still using the connection.ServerWebSocketServerWebSocket. closeHandler(Handler<Void> handler)WebSocketWebSocket. closeHandler(Handler<Void> handler)WebSocketBaseWebSocketBase. closeHandler(Handler<Void> handler)Set a close handler.HttpServerHttpServer. connectionHandler(Handler<HttpConnection> handler)Set a connection handler for the server.HttpClientRequestHttpClientRequest. continueHandler(Handler<Void> handler)If you send an HTTP request with the headerExpectset to the value100-continueand the server responds with an interim HTTP response with a status code of100and a Continue handler has been set using this method, then thehandlerwill be called.HttpClientResponseHttpClientResponse. customFrameHandler(Handler<HttpFrame> handler)Set an custom frame handler.HttpServerRequestHttpServerRequest. customFrameHandler(Handler<HttpFrame> handler)Set a custom frame handler.ClientWebSocketClientWebSocket. drainHandler(Handler<Void> handler)HttpClientRequestHttpClientRequest. drainHandler(Handler<Void> handler)HttpServerResponseHttpServerResponse. drainHandler(Handler<Void> handler)ServerWebSocketServerWebSocket. drainHandler(Handler<Void> handler)WebSocketWebSocket. drainHandler(Handler<Void> handler)WebSocketBaseWebSocketBase. drainHandler(Handler<Void> handler)HttpClientRequestHttpClientRequest. earlyHintsHandler(Handler<MultiMap> handler)If the server responds with an interim HTTP response with a status code of103and a Early Hints handler has been set using this method, then thehandlerwill be called.ClientWebSocketClientWebSocket. endHandler(Handler<Void> endHandler)HttpClientResponseHttpClientResponse. endHandler(Handler<Void> endHandler)HttpServerFileUploadHttpServerFileUpload. endHandler(Handler<Void> endHandler)HttpServerRequestHttpServerRequest. endHandler(Handler<Void> endHandler)HttpServerResponseHttpServerResponse. endHandler(Handler<Void> handler)Set an end handler for the response.ServerWebSocketServerWebSocket. endHandler(Handler<Void> endHandler)WebSocketWebSocket. endHandler(Handler<Void> endHandler)WebSocketBaseWebSocketBase. endHandler(Handler<Void> endHandler)ClientWebSocketClientWebSocket. exceptionHandler(Handler<Throwable> handler)HttpClientRequestHttpClientRequest. exceptionHandler(Handler<Throwable> handler)HttpClientResponseHttpClientResponse. exceptionHandler(Handler<Throwable> handler)HttpConnectionHttpConnection. exceptionHandler(Handler<Throwable> handler)Set an handler called when a connection error happensHttpServerHttpServer. exceptionHandler(Handler<Throwable> handler)Set an exception handler called for socket errors happening before the HTTP connection is established, e.g during the TLS handshake.HttpServerFileUploadHttpServerFileUpload. exceptionHandler(Handler<Throwable> handler)HttpServerRequestHttpServerRequest. exceptionHandler(Handler<Throwable> handler)HttpServerResponseHttpServerResponse. exceptionHandler(Handler<Throwable> handler)ServerWebSocketServerWebSocket. exceptionHandler(Handler<Throwable> handler)WebSocketWebSocket. exceptionHandler(Handler<Throwable> handler)WebSocketBaseWebSocketBase. exceptionHandler(Handler<Throwable> handler)ClientWebSocketClientWebSocket. frameHandler(Handler<WebSocketFrame> handler)ServerWebSocketServerWebSocket. frameHandler(Handler<WebSocketFrame> handler)WebSocketWebSocket. frameHandler(Handler<WebSocketFrame> handler)WebSocketBaseWebSocketBase. frameHandler(Handler<WebSocketFrame> handler)Set a frame handler on the connection.HttpConnectionHttpConnection. goAwayHandler(Handler<GoAway> handler)Set an handler called when a frame is received.ClientWebSocketClientWebSocket. handler(Handler<Buffer> handler)HttpClientResponseHttpClientResponse. handler(Handler<Buffer> handler)HttpServerFileUploadHttpServerFileUpload. handler(Handler<Buffer> handler)HttpServerRequestHttpServerRequest. handler(Handler<Buffer> handler)ServerWebSocketServerWebSocket. handler(Handler<Buffer> handler)WebSocketWebSocket. handler(Handler<Buffer> handler)WebSocketBaseWebSocketBase. handler(Handler<Buffer> handler)HttpServerResponseHttpServerResponse. headersEndHandler(Handler<Void> handler)Provide a handler that will be called just before the headers are written to the wire.HttpServerHttpServer. invalidRequestHandler(Handler<HttpServerRequest> handler)Set ahandlerfor handling invalid requests.HttpConnectionHttpConnection. pingHandler(Handler<Buffer> handler)Set an handler notified when a frame is received from the remote endpoint.ClientWebSocketClientWebSocket. pongHandler(Handler<Buffer> handler)WebSocketWebSocket. pongHandler(Handler<Buffer> handler)WebSocketBaseWebSocketBase. pongHandler(Handler<Buffer> handler)Set a pong frame handler on the connection.HttpClientRequestHttpClientRequest. pushHandler(Handler<HttpClientRequest> handler)Set a push handler for this request.HttpConnectionHttpConnection. remoteSettingsHandler(Handler<Http2Settings> handler)Set an handler that is called when remote endpointHttp2Settingsare updated.HttpServerHttpServer. requestHandler(Handler<HttpServerRequest> handler)Set the request handler for the server torequestHandler.HttpConnectionHttpConnection. shutdownHandler(Handler<Void> handler)Set ahandlernotified when the HTTP connection is shutdown: the client or server will close the connection within a certain amount of time.WebSocketWebSocket. shutdownHandler(Handler<Void> handler)WebSocketBaseWebSocketBase. shutdownHandler(Handler<Void> handler)Set ahandlernotified when the WebSocket is shutdown: the client or server will close the connection within a certain amount of time.HttpClientResponseHttpClientResponse. streamPriorityHandler(Handler<StreamPriority> handler)Set an handler for stream priority changes.HttpServerRequestHttpServerRequest. streamPriorityHandler(Handler<StreamPriority> handler)Set an handler for stream priority changesClientWebSocketClientWebSocket. textMessageHandler(Handler<String> handler)WebSocketWebSocket. textMessageHandler(Handler<String> handler)WebSocketBaseWebSocketBase. textMessageHandler(Handler<String> handler)Set a text message handler on the connection.HttpServerRequestHttpServerRequest. uploadHandler(Handler<HttpServerFileUpload> uploadHandler)Set an upload handler.HttpServerHttpServer. webSocketHandler(Handler<ServerWebSocket> handler)Set the WebSocket handler for the server towsHandler.HttpServerHttpServer. webSocketHandshakeHandler(Handler<ServerWebSocketHandshake> handler)Set a handler for WebSocket handshake.HttpClientBuilderHttpClientBuilder. withConnectHandler(Handler<HttpConnection> handler)Set a connection handler for the client. -
Uses of Handler in io.vertx.rxjava3.core.net
Methods in io.vertx.rxjava3.core.net with parameters of type Handler Modifier and Type Method Description NetSocketNetSocket. closeHandler(Handler<Void> handler)Set ahandlernotified when the socket is closedNetServerNetServer. connectHandler(Handler<NetSocket> handler)Supply a connect handler for this server.NetSocketNetSocket. drainHandler(Handler<Void> handler)NetSocketNetSocket. endHandler(Handler<Void> endHandler)This handler might be called after the close handler when the socket is paused and there are still buffers to deliver.NetSocketNetSocket. exceptionHandler(Handler<Throwable> handler)NetSocketNetSocket. handler(Handler<Buffer> handler)NetSocketNetSocket. shutdownHandler(Handler<Void> handler)Set ahandlernotified when the socket is shutdown: the client or server will close the connection within a certain amount of time. -
Uses of Handler in io.vertx.rxjava3.core.parsetools
Classes in io.vertx.rxjava3.core.parsetools that implement Handler Modifier and Type Class Description classJsonParserA parser class which allows to incrementally parse json elements and emit json parse events instead of parsing a json element fully.classRecordParserA helper class which allows you to easily parse protocols which are delimited by a sequence of bytes, or fixed size records.Methods in io.vertx.rxjava3.core.parsetools with parameters of type Handler Modifier and Type Method Description JsonParserJsonParser. endHandler(Handler<Void> endHandler)RecordParserRecordParser. endHandler(Handler<Void> endHandler)JsonParserJsonParser. exceptionHandler(Handler<Throwable> handler)RecordParserRecordParser. exceptionHandler(Handler<Throwable> handler)JsonParserJsonParser. handler(Handler<JsonEvent> handler)RecordParserRecordParser. handler(Handler<Buffer> handler)static RecordParserRecordParser. newDelimited(Buffer delim, Handler<Buffer> output)LikeRecordParser.newDelimited(java.lang.String, io.vertx.core.Handler<io.vertx.core.buffer.Buffer>)but set theoutputthat will receive whole records which have been parsed.static RecordParserRecordParser. newDelimited(String delim, Handler<Buffer> output)LikeRecordParser.newDelimited(java.lang.String, io.vertx.core.Handler<io.vertx.core.buffer.Buffer>)but set theoutputthat will receive whole records which have been parsed.static RecordParserRecordParser. newFixed(int size, Handler<Buffer> output)LikeRecordParser.newFixed(int)but set theoutputthat will receive whole records which have been parsed.voidRecordParser. setOutput(Handler<Buffer> output) -
Uses of Handler in io.vertx.rxjava3.core.streams
Methods in io.vertx.rxjava3.core.streams with parameters of type Handler Modifier and Type Method Description WriteStream<T>WriteStream. drainHandler(Handler<Void> handler)Set a drain handler on the stream.ReadStream<T>ReadStream. endHandler(Handler<Void> endHandler)Set an end handler.ReadStream<T>ReadStream. exceptionHandler(Handler<Throwable> handler)Set an exception handler on the read stream.StreamBaseStreamBase. exceptionHandler(Handler<Throwable> handler)Set an exception handler.WriteStream<T>WriteStream. exceptionHandler(Handler<Throwable> handler)Set an exception handler on the write stream.ReadStream<T>ReadStream. handler(Handler<T> handler)Set a data handler. -
Uses of Handler in io.vertx.rxjava3.db2client
Methods in io.vertx.rxjava3.db2client with parameters of type Handler Modifier and Type Method Description static SqlClientDB2Builder. client(Handler<ClientBuilder<SqlClient>> handler)Build a client backed by a connection pool with the specifiedblockargument.DB2ConnectionDB2Connection. closeHandler(Handler<Void> handler)DB2ConnectionDB2Connection. exceptionHandler(Handler<Throwable> handler)static PoolDB2Builder. pool(Handler<ClientBuilder<Pool>> block)Build a pool with the specifiedblockargument. -
Uses of Handler in io.vertx.rxjava3.ext.auth.audit
Methods in io.vertx.rxjava3.ext.auth.audit that return Handler Modifier and Type Method Description <T> Handler<AsyncResult<T>>SecurityAudit. auditHandlerFor(Marker marker) -
Uses of Handler in io.vertx.rxjava3.ext.auth.oauth2
Methods in io.vertx.rxjava3.ext.auth.oauth2 with parameters of type Handler Modifier and Type Method Description OAuth2AuthOAuth2Auth. missingKeyHandler(Handler<String> handler)Handled to be called when a key (mentioned on a JWT) is missing from the current config. -
Uses of Handler in io.vertx.rxjava3.ext.consul
Methods in io.vertx.rxjava3.ext.consul with parameters of type Handler Modifier and Type Method Description Watch<T>Watch. setHandler(Handler<WatchResult<T>> handler)Set the result handler. -
Uses of Handler in io.vertx.rxjava3.ext.eventbus.bridge.tcp
Methods in io.vertx.rxjava3.ext.eventbus.bridge.tcp with parameters of type Handler Modifier and Type Method Description static TcpEventBusBridgeTcpEventBusBridge. create(Vertx vertx, BridgeOptions options, NetServerOptions netServerOptions, Handler<BridgeEvent> eventHandler) -
Uses of Handler in io.vertx.rxjava3.ext.healthchecks
Methods in io.vertx.rxjava3.ext.healthchecks with parameters of type Handler Modifier and Type Method Description HealthChecksHealthChecks. invoke(Handler<JsonObject> resultHandler)Invokes the registered procedures and computes the outcome.HealthChecksHealthChecks. register(String name, long timeout, Handler<Promise<Status>> procedure)Registers a health check procedure.HealthChecksHealthChecks. register(String name, Handler<Promise<Status>> procedure)Registers a health check procedure. -
Uses of Handler in io.vertx.rxjava3.ext.stomp
Classes in io.vertx.rxjava3.ext.stomp that implement Handler Modifier and Type Class Description classStompServerHandlerSTOMP server handler implements the behavior of the STOMP server when a specific event occurs.Methods in io.vertx.rxjava3.ext.stomp that return Handler Modifier and Type Method Description Handler<ServerWebSocket>StompServer. webSocketHandler()Gets the able to manage web socket connections.Handler<ServerWebSocketHandshake>StompServer. webSocketHandshakeHandler()Gets the able to manage web socket connection handshakes.Methods in io.vertx.rxjava3.ext.stomp with parameters of type Handler Modifier and Type Method Description StompServerHandlerStompServerHandler. abortHandler(Handler<ServerFrame> handler)Configures the action to execute when aABORTframe is received.StompServerHandlerStompServerHandler. ackHandler(Handler<ServerFrame> handler)Configures the action to execute when aACKframe is received.StompServerHandlerStompServerHandler. beginHandler(Handler<ServerFrame> handler)Configures the action to execute when aBEGINframe is received.StompClientConnectionStompClientConnection. closeHandler(Handler<StompClientConnection> handler)Sets a handler notified when the STOMP connection is closed.StompServerHandlerStompServerHandler. closeHandler(Handler<StompServerConnection> handler)Configures the action to execute when a connection with the client is closed.StompServerHandlerStompServerHandler. commitHandler(Handler<ServerFrame> handler)Configures the action to execute when aCOMMITframe is received.voidStompServerConnection. configureHeartbeat(long ping, long pong, Handler<StompServerConnection> pingHandler)Configures the heartbeat.StompServerHandlerStompServerHandler. connectHandler(Handler<ServerFrame> handler)Configures the action to execute when aCONNECTframe is received.StompClientConnectionStompClientConnection. connectionDroppedHandler(Handler<StompClientConnection> handler)Sets a handler notified when the server does not respond to apingrequest in time.StompServerHandlerStompServerHandler. disconnectHandler(Handler<ServerFrame> handler)Configures the action to execute when aDISCONNECTframe is received.StompClientStompClient. errorFrameHandler(Handler<Frame> handler)A general error frame handler.StompClientConnectionStompClientConnection. errorHandler(Handler<Frame> handler)Sets a handler notified when anERRORframe is received by the client.StompClientStompClient. exceptionHandler(Handler<Throwable> handler)Sets an exception handler notified for TCP-level errors.StompClientConnectionStompClientConnection. exceptionHandler(Handler<Throwable> exceptionHandler)Configures the exception handler notified upon TCP-level errors.StompServerHandlerStompServerHandler. nackHandler(Handler<ServerFrame> handler)Configures the action to execute when aNACKframe is received.StompServerHandlerStompServerHandler. onAckHandler(Handler<Acknowledgement> handler)Configures the action to execute when messages are acknowledged.StompServerHandlerStompServerHandler. onNackHandler(Handler<Acknowledgement> handler)Configures the action to execute when messages are not acknowledged.StompClientConnectionStompClientConnection. pingHandler(Handler<StompClientConnection> handler)Sets a handler that let customize the behavior when a ping needs to be sent to the server.StompServerHandlerStompServerHandler. pingHandler(Handler<StompServerConnection> handler)Allows customizing the action to do when the server needs to send a `PING` to the client.StompClientStompClient. receivedFrameHandler(Handler<Frame> handler)Configures a received handler that gets notified when a STOMP frame is received by the client.StompClientConnectionStompClientConnection. receivedFrameHandler(Handler<Frame> handler)Configures a received handler that get notified when a STOMP frame is received by the client.StompServerHandlerStompServerHandler. receivedFrameHandler(Handler<ServerFrame> handler)Configures a handler that get notified when a STOMP frame is received by the server.Single<String>StompClientConnection. rxSubscribe(String destination, Handler<Frame> handler)Subscribes to the given destination.Single<String>StompClientConnection. rxSubscribe(String destination, Map<String,String> headers, Handler<Frame> handler)Subscribes to the given destination.StompServerHandlerStompServerHandler. sendHandler(Handler<ServerFrame> handler)Configures the action to execute when aSENDframe is received.StompServerHandlerStompServerHandler. stompHandler(Handler<ServerFrame> handler)Configures the action to execute when aSTOMPframe is received.Single<String>StompClientConnection. subscribe(String destination, Handler<Frame> handler)Subscribes to the given destination.Single<String>StompClientConnection. subscribe(String destination, Map<String,String> headers, Handler<Frame> handler)Subscribes to the given destination.StompServerHandlerStompServerHandler. subscribeHandler(Handler<ServerFrame> handler)Configures the action to execute when aSUBSCRIBEframe is received.StompServerHandlerStompServerHandler. unsubscribeHandler(Handler<ServerFrame> handler)Configures the action to execute when aUNSUBSCRIBEframe is received.StompClientStompClient. writingFrameHandler(Handler<Frame> handler)Configures a writing handler that gets notified when a STOMP frame is written on the wire.StompClientConnectionStompClientConnection. writingFrameHandler(Handler<Frame> handler)Configures a handler notified when a frame is going to be written on the wire.StompServerStompServer. writingFrameHandler(Handler<ServerFrame> handler)Configures the handler that is invoked every time a frame is going to be written to the "wire". -
Uses of Handler in io.vertx.rxjava3.ext.unit
Methods in io.vertx.rxjava3.ext.unit that return Handler Modifier and Type Method Description <T> Handler<AsyncResult<T>>TestContext. asyncAssertFailure()Creates and returns a new async handler, the returned handler controls the completion of the test.<T> Handler<AsyncResult<T>>TestContext. asyncAssertFailure(Handler<Throwable> causeHandler)Creates and returns a new async handler, the returned handler controls the completion of the test.<T> Handler<AsyncResult<T>>TestContext. asyncAssertSuccess()Creates and returns a new async handler, the returned handler controls the completion of the test.<T> Handler<AsyncResult<T>>TestContext. asyncAssertSuccess(Handler<T> resultHandler)Creates and returns a new async handler, the returned handler controls the completion of the test.Handler<Throwable>TestContext. exceptionHandler()Methods in io.vertx.rxjava3.ext.unit with parameters of type Handler Modifier and Type Method Description TestSuiteTestSuite. after(Handler<TestContext> callback)Set a callback executed after the tests.TestSuiteTestSuite. afterEach(Handler<TestContext> callback)Set a callback executed after each test and before the suiteaftercallback.<T> Handler<AsyncResult<T>>TestContext. asyncAssertFailure(Handler<Throwable> causeHandler)Creates and returns a new async handler, the returned handler controls the completion of the test.<T> Handler<AsyncResult<T>>TestContext. asyncAssertSuccess(Handler<T> resultHandler)Creates and returns a new async handler, the returned handler controls the completion of the test.TestSuiteTestSuite. before(Handler<TestContext> callback)Set a callback executed before the tests.TestSuiteTestSuite. beforeEach(Handler<TestContext> callback)Set a callback executed before each test and after the suitebeforecallback.static TestCaseTestCase. create(String name, Handler<TestContext> testCase)Create a test case.voidAsync. handler(Handler<AsyncResult<Void>> completionHandler)Completion handler to receive a completion signal when this completions completes.voidCompletion. handler(Handler<AsyncResult<T>> completionHandler)Completion handler to receive a completion signal when this completions completes.voidTestCompletion. handler(Handler<AsyncResult<Void>> completionHandler)Completion handler to receive a completion signal when this completions completes.TestSuiteTestSuite. test(String name, int repeat, Handler<TestContext> testCase)Add a new test case to the suite.TestSuiteTestSuite. test(String name, Handler<TestContext> testCase)Add a new test case to the suite.TestContextTestContext. verify(Handler<Void> block)Execute the provided handler, which may contain assertions, possibly from any third-party assertion framework. -
Uses of Handler in io.vertx.rxjava3.ext.unit.collect
Methods in io.vertx.rxjava3.ext.unit.collect with parameters of type Handler Modifier and Type Method Description static EventBusCollectorEventBusCollector. create(Vertx vertx, Handler<TestSuiteReport> reporter) -
Uses of Handler in io.vertx.rxjava3.ext.unit.report
Methods in io.vertx.rxjava3.ext.unit.report with parameters of type Handler Modifier and Type Method Description TestCaseReportTestCaseReport. endHandler(Handler<TestResult> handler)Set a callback for completion, the specifiedhandleris invoked when the test exec has completed.TestSuiteReportTestSuiteReport. endHandler(Handler<Void> endHandler)TestSuiteReportTestSuiteReport. exceptionHandler(Handler<Throwable> handler)Set an exception handler, the exception handler reports the test suite errors, it can be called mulitple times before the test ends.TestSuiteReportTestSuiteReport. handler(Handler<TestCaseReport> handler) -
Uses of Handler in io.vertx.rxjava3.ext.web
Classes in io.vertx.rxjava3.ext.web that implement Handler Modifier and Type Class Description classRouterA router receives request from anHttpServerand routes it to the first matchingRoutethat it contains.Methods in io.vertx.rxjava3.ext.web with parameters of type Handler Modifier and Type Method Description intRoutingContext. addBodyEndHandler(Handler<Void> handler)Provides a handler that will be called after the last part of the body is written to the wire.intRoutingContext. addEndHandler(Handler<AsyncResult<Void>> handler)Add an end handler for the request/response context.intRoutingContext. addHeadersEndHandler(Handler<Void> handler)Add a handler that will be called just before headers are written to the response.RouteRoute. blockingHandler(Handler<RoutingContext> requestHandler)LikeRoute.blockingHandler(io.vertx.core.Handler<io.vertx.rxjava3.ext.web.RoutingContext>)called with ordered = trueRouteRoute. blockingHandler(Handler<RoutingContext> requestHandler, boolean ordered)Specify a blocking request handler for the route.RouterRouter. errorHandler(int statusCode, Handler<RoutingContext> errorHandler)Specify an handler to handle an error for a particular status code.RouteRoute. failureHandler(Handler<RoutingContext> failureHandler)Append a failure handler to the route failure handlers list.RouteRoute. handler(Handler<RoutingContext> requestHandler)Append a request handler to the route handlers list.RouterRouter. modifiedHandler(Handler<Router> handler)When a Router routes are changed this handler is notified. -
Uses of Handler in io.vertx.rxjava3.ext.web.handler
Subinterfaces of Handler in io.vertx.rxjava3.ext.web.handler Modifier and Type Interface Description interfaceAuthenticationHandlerBase interface for auth handlers.interfaceInputTrustHandlerBase input trust interface for handlers that verify the trust of the request.interfacePlatformHandlerBase platform interface for handlers that provide functionality to the application platform.interfaceProtocolUpgradeHandlerBase interface for handlers that perform protocol upgrades.interfaceSecurityPolicyHandlerBase security policy interface for handlers that provide HTTP security related headers.Classes in io.vertx.rxjava3.ext.web.handler that implement Handler Modifier and Type Class Description classAPIKeyHandlerAn authentication handler that provides API Key support.classAuthorizationHandlerBase interface for authorization handlers that provide authorization support.classBasicAuthHandlerAn auth handler that provides HTTP Basic Authentication support.classBodyHandlerA handler which gathers the entire request body and sets it on the .classChainAuthHandlerAn auth handler that chains to a sequence of handlers.classCorsHandlerA handler which implements server side http://www.w3.org/TR/cors/[CORS] support for Vert.x-Web.classCSPHandlerContent Security Policy (CSP) is an added layer of security that helps to detect and mitigate certain types of attacks, including Cross Site Scripting (XSS) and data injection attacks.classCSRFHandlerThis handler adds a CSRF token to requests which mutate state.classDigestAuthHandlerAn auth handler that provides HTTP Basic Authentication support.classErrorHandlerA pretty error handler for rendering error pages.classFaviconHandlerA handler that serves favicons.classFormLoginHandlerHandler that handles login from a form on a custom login page.classHSTSHandlerHTTP Strict Transport Security (HSTS) RFC6797.classJWTAuthHandlerAn auth handler that provides JWT Authentication support.classLoggerHandlerA handler which logs request information to the Vert.x logger.classMethodOverrideHandlerNOTE: This class has been automatically generated from theoriginalnon RX-ified interface using Vert.x codegen.classMultiTenantHandlerA handler which selectively executes another handler if a precondition is met.classOAuth2AuthHandlerAn auth handler that provides OAuth2 Authentication support.classOtpAuthHandlerAn auth handler that provides One Time Password (Multi-Factor) Authentication support.classRedirectAuthHandlerAn auth handler that's used to handle auth by redirecting user to a custom login page.classResponseContentTypeHandlerA handler which sets the response content type automatically according to the bestAcceptheader match.classResponseTimeHandlerHandler which adds a header `x-response-time` in the response of matching requests containing the time taken in ms to process the request.classSecurityAuditLoggerHandlerA handler that logs security audit events.classSessionHandlerA handler that maintains aSessionfor each browser session.classSimpleAuthenticationHandlerA user customizable authentication handler.classStaticHandlerA handler for serving static resources from the file system or classpath.classTemplateHandlerA handler which renders responses using a template engine and where the template name is selected from the URI path.classTimeoutHandlerHandler that will timeout requests if the response has not been written after a certain time.classWebAuthn4JHandlerAn auth handler that provides FIDO2 WebAuthN Relay Party support.classXFrameHandlerThe X-Frame-Options HTTP response header can be used to indicate whether or not a browser should be allowed to render a page in a,,or.Methods in io.vertx.rxjava3.ext.web.handler with parameters of type Handler Modifier and Type Method Description MultiTenantHandlerMultiTenantHandler. addDefaultHandler(Handler<RoutingContext> handler)Add a default handler for the case when no tenant was matched.MultiTenantHandlerMultiTenantHandler. addTenantHandler(String tenant, Handler<RoutingContext> handler)Add a handler for a given tenant to this handler. -
Uses of Handler in io.vertx.rxjava3.ext.web.handler.graphql
Classes in io.vertx.rxjava3.ext.web.handler.graphql that implement Handler Modifier and Type Class Description classGraphQLHandlerARoutehandler for GraphQL requests.Methods in io.vertx.rxjava3.ext.web.handler.graphql with parameters of type Handler Modifier and Type Method Description GraphQLHandlerBuilderGraphQLHandlerBuilder. beforeExecute(Handler<ExecutionInputBuilderWithContext<RoutingContext>> beforeExecuteHandler)Set a callback to invoke before executing a GraphQL query. -
Uses of Handler in io.vertx.rxjava3.ext.web.handler.graphql.ws
Classes in io.vertx.rxjava3.ext.web.handler.graphql.ws that implement Handler Modifier and Type Class Description classGraphQLWSHandlerA handler for the GraphQL over WebSocket Protocol.Methods in io.vertx.rxjava3.ext.web.handler.graphql.ws with parameters of type Handler Modifier and Type Method Description GraphQLWSHandlerBuilderGraphQLWSHandlerBuilder. beforeExecute(Handler<ExecutionInputBuilderWithContext<Message>> beforeExecuteHandler)Set a callback to invoke before executing a GraphQL query.GraphQLWSHandlerBuilderGraphQLWSHandlerBuilder. onConnectionInit(Handler<ConnectionInitEvent> connectionInitHandler)Customize the connection init .GraphQLWSHandlerBuilderGraphQLWSHandlerBuilder. onMessage(Handler<Message> messageHandler)Customize the message .GraphQLWSHandlerBuilderGraphQLWSHandlerBuilder. onSocketEnd(Handler<ServerWebSocket> endHandler)Customize the end . -
Uses of Handler in io.vertx.rxjava3.ext.web.handler.sockjs
Methods in io.vertx.rxjava3.ext.web.handler.sockjs with parameters of type Handler Modifier and Type Method Description RouterSockJSHandler. bridge(SockJSBridgeOptions bridgeOptions, Handler<BridgeEvent> bridgeEventHandler)LikeSockJSHandler.bridge(io.vertx.ext.web.handler.sockjs.SockJSBridgeOptions)but specifying a handler that will receive bridge events.RouterSockJSHandler. bridge(AuthorizationProvider authorizationProvider, SockJSBridgeOptions bridgeOptions, Handler<BridgeEvent> bridgeEventHandler)LikeSockJSHandler.bridge(io.vertx.ext.web.handler.sockjs.SockJSBridgeOptions)but specifying a handler that will receive bridge events.SockJSSocketSockJSSocket. closeHandler(Handler<Void> closeHandler)SockJSSocketSockJSSocket. drainHandler(Handler<Void> handler)SockJSSocketSockJSSocket. endHandler(Handler<Void> endHandler)SockJSSocketSockJSSocket. exceptionHandler(Handler<Throwable> handler)SockJSSocketSockJSSocket. handler(Handler<Buffer> handler)RouterSockJSHandler. socketHandler(Handler<SockJSSocket> handler)Set a SockJS socket handler. -
Uses of Handler in io.vertx.rxjava3.ext.web.healthchecks
Classes in io.vertx.rxjava3.ext.web.healthchecks that implement Handler Modifier and Type Class Description classHealthCheckHandlerA Vert.x Web handler on which you register health check procedure.Methods in io.vertx.rxjava3.ext.web.healthchecks with parameters of type Handler Modifier and Type Method Description HealthCheckHandlerHealthCheckHandler. register(String name, long timeout, Handler<Promise<Status>> procedure)Registers a health check procedure.HealthCheckHandlerHealthCheckHandler. register(String name, Handler<Promise<Status>> procedure)Registers a health check procedure. -
Uses of Handler in io.vertx.rxjava3.ext.web.openapi.router
Methods in io.vertx.rxjava3.ext.web.openapi.router with parameters of type Handler Modifier and Type Method Description OpenAPIRouteOpenAPIRoute. addFailureHandler(Handler<RoutingContext> handler)Adds a failure handler for this routeOpenAPIRouteOpenAPIRoute. addHandler(Handler<RoutingContext> handler)Adds a handler for this route which is executed after the security and validation handlers defined in the contractRouterBuilderRouterBuilder. rootHandler(Handler<RoutingContext> rootHandler)Add global handler to be applied prior to being generated. -
Uses of Handler in io.vertx.rxjava3.ext.web.proxy.handler
Classes in io.vertx.rxjava3.ext.web.proxy.handler that implement Handler Modifier and Type Class Description classProxyHandlerNOTE: This class has been automatically generated from theoriginalnon RX-ified interface using Vert.x codegen. -
Uses of Handler in io.vertx.rxjava3.ext.web.validation
Classes in io.vertx.rxjava3.ext.web.validation that implement Handler Modifier and Type Class Description classValidationHandler -
Uses of Handler in io.vertx.rxjava3.grpc.client
Methods in io.vertx.rxjava3.grpc.client with parameters of type Handler Modifier and Type Method Description GrpcClientRequest<Req,Resp>GrpcClientRequest. drainHandler(Handler<Void> handler)GrpcClientResponse<Req,Resp>GrpcClientResponse. endHandler(Handler<Void> handler)GrpcClientResponse<Req,Resp>GrpcClientResponse. errorHandler(Handler<GrpcError> handler)GrpcClientRequest<Req,Resp>GrpcClientRequest. exceptionHandler(Handler<Throwable> handler)GrpcClientResponse<Req,Resp>GrpcClientResponse. exceptionHandler(Handler<Throwable> handler)GrpcClientResponse<Req,Resp>GrpcClientResponse. handler(Handler<Resp> handler)GrpcReadStream<Resp>GrpcClientResponse. invalidMessageHandler(Handler<InvalidMessageException> handler)Set a message handler that is reported with invalid message errors.GrpcClientResponse<Req,Resp>GrpcClientResponse. messageHandler(Handler<GrpcMessage> handler) -
Uses of Handler in io.vertx.rxjava3.grpc.common
Methods in io.vertx.rxjava3.grpc.common with parameters of type Handler Modifier and Type Method Description GrpcWriteStream<T>GrpcWriteStream. drainHandler(Handler<Void> handler)GrpcReadStream<T>GrpcReadStream. endHandler(Handler<Void> handler)GrpcReadStream<T>GrpcReadStream. errorHandler(Handler<GrpcError> handler)Set a handler to be notified with gRPC errors.GrpcReadStream<T>GrpcReadStream. exceptionHandler(Handler<Throwable> handler)GrpcWriteStream<T>GrpcWriteStream. exceptionHandler(Handler<Throwable> handler)GrpcReadStream<T>GrpcReadStream. handler(Handler<T> handler)GrpcReadStream<T>GrpcReadStream. invalidMessageHandler(Handler<InvalidMessageException> handler)Set a message handler that is reported with invalid message errors.GrpcReadStream<T>GrpcReadStream. messageHandler(Handler<GrpcMessage> handler)Set a handler to be notified with incoming encoded messages. -
Uses of Handler in io.vertx.rxjava3.grpc.server
Classes in io.vertx.rxjava3.grpc.server that implement Handler Modifier and Type Class Description classGrpcServerA gRPC server based on Vert.x HTTP server.Methods in io.vertx.rxjava3.grpc.server with parameters of type Handler Modifier and Type Method Description GrpcServerGrpcServer. callHandler(Handler<GrpcServerRequest<Buffer,Buffer>> handler)Set a call handler that handles any call made to the server.<Req,Resp>
GrpcServerGrpcServer. callHandler(ServiceMethod<Req,Resp> serviceMethod, Handler<GrpcServerRequest<Req,Resp>> handler)Set a service method call handler that handles any call made to the server for thefullMethodNameservice method.GrpcServerResponse<Req,Resp>GrpcServerResponse. drainHandler(Handler<Void> handler)GrpcServerRequest<Req,Resp>GrpcServerRequest. endHandler(Handler<Void> endHandler)GrpcServerRequest<Req,Resp>GrpcServerRequest. errorHandler(Handler<GrpcError> handler)GrpcServerRequest<Req,Resp>GrpcServerRequest. exceptionHandler(Handler<Throwable> handler)GrpcServerResponse<Req,Resp>GrpcServerResponse. exceptionHandler(Handler<Throwable> handler)GrpcServerRequest<Req,Resp>GrpcServerRequest. handler(Handler<Req> handler)GrpcReadStream<Req>GrpcServerRequest. invalidMessageHandler(Handler<InvalidMessageException> handler)Set a message handler that is reported with invalid message errors.GrpcServerRequest<Req,Resp>GrpcServerRequest. messageHandler(Handler<GrpcMessage> handler) -
Uses of Handler in io.vertx.rxjava3.httpproxy
Classes in io.vertx.rxjava3.httpproxy that implement Handler Modifier and Type Class Description classHttpProxyHandles the HTTP reverse proxy logic between the user agent and the origin.Methods in io.vertx.rxjava3.httpproxy with parameters of type Handler Modifier and Type Method Description ProxyInterceptorBuilderProxyInterceptorBuilder. transformingQueryParams(Handler<MultiMap> updater)Apply modifications to the query parameters.ProxyInterceptorBuilderProxyInterceptorBuilder. transformingRequestHeaders(Handler<MultiMap> requestHeadersUpdater)Apply callbacks to change the request headers when the proxy receives them.ProxyInterceptorBuilderProxyInterceptorBuilder. transformingResponseHeaders(Handler<MultiMap> responseHeadersUpdater)Apply callbacks to change the response headers when the proxy receives them. -
Uses of Handler in io.vertx.rxjava3.kafka.client.consumer
Methods in io.vertx.rxjava3.kafka.client.consumer with parameters of type Handler Modifier and Type Method Description KafkaConsumer<K,V>KafkaConsumer. batchHandler(Handler<KafkaConsumerRecords<K,V>> handler)Set the handler to be used when batches of messages are fetched from the Kafka server.KafkaConsumer<K,V>KafkaConsumer. endHandler(Handler<Void> endHandler)KafkaConsumer<K,V>KafkaConsumer. exceptionHandler(Handler<Throwable> handler)KafkaConsumer<K,V>KafkaConsumer. handler(Handler<KafkaConsumerRecord<K,V>> handler)KafkaConsumer<K,V>KafkaConsumer. partitionsAssignedHandler(Handler<Set<TopicPartition>> handler)Set the handler called when topic partitions are assigned to the consumerKafkaConsumer<K,V>KafkaConsumer. partitionsRevokedHandler(Handler<Set<TopicPartition>> handler)Set the handler called when topic partitions are revoked to the consumer -
Uses of Handler in io.vertx.rxjava3.kafka.client.producer
Methods in io.vertx.rxjava3.kafka.client.producer with parameters of type Handler Modifier and Type Method Description KafkaProducer<K,V>KafkaProducer. drainHandler(Handler<Void> handler)KafkaProducer<K,V>KafkaProducer. exceptionHandler(Handler<Throwable> handler) -
Uses of Handler in io.vertx.rxjava3.micrometer
Methods in io.vertx.rxjava3.micrometer that return Handler Modifier and Type Method Description static Handler<HttpServerRequest>PrometheusRequestHandler. create()Creates a handler with a new PrometheusMeterRegistry and the default metrics endpoint ("/metrics").static Handler<HttpServerRequest>PrometheusRequestHandler. create(io.micrometer.prometheusmetrics.PrometheusMeterRegistry registry)Creates a handler with the specified PrometheusMeterRegistry and the default metrics endpoint ("/metrics").static Handler<HttpServerRequest>PrometheusRequestHandler. create(io.micrometer.prometheusmetrics.PrometheusMeterRegistry registry, String metricsEndpoint)Creates a handler with the specified PrometheusMeterRegistry and metrics endpoint.static Handler<RoutingContext>PrometheusScrapingHandler. create()Creates a Vert.x WebRoutehandler for Prometheus metrics scraping.static Handler<RoutingContext>PrometheusScrapingHandler. create(io.micrometer.prometheusmetrics.PrometheusMeterRegistry registry)Creates a Vert.x WebRoutehandler for Prometheus metrics scraping.static Handler<RoutingContext>PrometheusScrapingHandler. create(String registryName)Creates a Vert.x WebRoutehandler for Prometheus metrics scraping. -
Uses of Handler in io.vertx.rxjava3.mqtt
Methods in io.vertx.rxjava3.mqtt with parameters of type Handler Modifier and Type Method Description MqttClientMqttClient. authenticationExchangeHandler(Handler<MqttAuthenticationExchangeMessage> authenticationExchangeHandler)Sets handler which will be called after AUTH packet receivingMqttEndpointMqttEndpoint. authenticationExchangeHandler(Handler<MqttAuthenticationExchangeMessage> handler)Set the auth handler on the MQTT endpoint.MqttClientMqttClient. closeHandler(Handler<Void> closeHandler)Set a handler that will be called when the connection with server is closedMqttEndpointMqttEndpoint. closeHandler(Handler<Void> handler)Set a close handler.MqttEndpointMqttEndpoint. disconnectHandler(Handler<Void> handler)Set a disconnect handler on the MQTT endpoint.MqttEndpointMqttEndpoint. disconnectMessageHandler(Handler<MqttDisconnectMessage> handler)Set a disconnect handler on the MQTT endpoint.MqttServerMqttServer. endpointHandler(Handler<MqttEndpoint> handler)Set the endpoint handler for the server.MqttClientMqttClient. exceptionHandler(Handler<Throwable> handler)Set an exception handler for the client, that will be called when an error happens in internal netty structures.MqttEndpointMqttEndpoint. exceptionHandler(Handler<Throwable> handler)Set an exception handler.MqttServerMqttServer. exceptionHandler(Handler<Throwable> handler)Set an exception handler for the server, that will be called when an error happens independantly of an acceptedMqttEndpoint, like a rejected connectionMqttEndpointMqttEndpoint. pingHandler(Handler<Void> handler)Set the pingreq handler on the MQTT endpoint.MqttClientMqttClient. pingResponseHandler(Handler<Void> pingResponseHandler)Sets handler which will be called after PINGRESP packet receivingMqttEndpointMqttEndpoint. publishAcknowledgeHandler(Handler<Integer> handler)Set the puback handler on the MQTT endpoint.MqttEndpointMqttEndpoint. publishAcknowledgeMessageHandler(Handler<MqttPubAckMessage> handler)Set the puback handler on the MQTT endpoint.MqttClientMqttClient. publishCompletionExpirationHandler(Handler<Integer> publishCompletionExpirationHandler)Sets a handler which will be called when the client does not receive a PUBACK or PUBREC/PUBCOMP for a message published using QoS 1 or 2 respectively.MqttClientMqttClient. publishCompletionHandler(Handler<Integer> publishCompletionHandler)Sets a handler which will be called each time the publishing of a message has been completed.MqttEndpointMqttEndpoint. publishCompletionHandler(Handler<Integer> handler)Set the pubcomp handler on the MQTT endpoint.MqttEndpointMqttEndpoint. publishCompletionMessageHandler(Handler<MqttPubCompMessage> handler)Set the pubcomp handler on the MQTT endpoint.MqttClientMqttClient. publishCompletionUnknownPacketIdHandler(Handler<Integer> publishCompletionPhantomHandler)Sets a handler which will be called when the client receives a PUBACK/PUBREC/PUBCOMP with an unknown packet ID.MqttClientMqttClient. publishHandler(Handler<MqttPublishMessage> publishHandler)Sets handler which will be called each time server publish something to clientMqttEndpointMqttEndpoint. publishHandler(Handler<MqttPublishMessage> handler)Set the publish handler on the MQTT endpoint.MqttEndpointMqttEndpoint. publishReceivedHandler(Handler<Integer> handler)Set the pubrec handler on the MQTT endpoint.MqttEndpointMqttEndpoint. publishReceivedMessageHandler(Handler<MqttPubRecMessage> handler)Set the pubrec handler on the MQTT endpoint.MqttEndpointMqttEndpoint. publishReleaseHandler(Handler<Integer> handler)Set the pubrel handler on the MQTT endpoint.MqttEndpointMqttEndpoint. publishReleaseMessageHandler(Handler<MqttPubRelMessage> handler)Set the pubrel handler on the MQTT endpoint.MqttClientMqttClient. subscribeCompletionHandler(Handler<MqttSubAckMessage> subscribeCompletionHandler)Sets handler which will be called after SUBACK packet receivingMqttEndpointMqttEndpoint. subscribeHandler(Handler<MqttSubscribeMessage> handler)Set a subscribe handler on the MQTT endpoint.MqttClientMqttClient. unsubscribeCompletionHandler(Handler<Integer> unsubscribeCompletionHandler)Sets handler which will be called after UNSUBACK packet receivingMqttEndpointMqttEndpoint. unsubscribeHandler(Handler<MqttUnsubscribeMessage> handler)Set a unsubscribe handler on the MQTT endpoint. -
Uses of Handler in io.vertx.rxjava3.mssqlclient
Methods in io.vertx.rxjava3.mssqlclient with parameters of type Handler Modifier and Type Method Description MSSQLConnectionMSSQLConnection. closeHandler(Handler<Void> handler)MSSQLConnectionMSSQLConnection. exceptionHandler(Handler<Throwable> handler)MSSQLConnectionMSSQLConnection. infoHandler(Handler<MSSQLInfo> handler)Set a handler called when the connection receives an informational message from the server.static PoolMSSQLBuilder. pool(Handler<ClientBuilder<Pool>> block)Build a pool with the specifiedblockargument. -
Uses of Handler in io.vertx.rxjava3.mysqlclient
Methods in io.vertx.rxjava3.mysqlclient with parameters of type Handler Modifier and Type Method Description static SqlClientMySQLBuilder. client(Handler<ClientBuilder<SqlClient>> handler)Build a client backed by a connection pool with the specifiedblockargument.MySQLConnectionMySQLConnection. closeHandler(Handler<Void> handler)MySQLConnectionMySQLConnection. exceptionHandler(Handler<Throwable> handler)static PoolMySQLBuilder. pool(Handler<ClientBuilder<Pool>> block)Build a pool with the specifiedblockargument. -
Uses of Handler in io.vertx.rxjava3.oracleclient
Methods in io.vertx.rxjava3.oracleclient with parameters of type Handler Modifier and Type Method Description OracleConnectionOracleConnection. closeHandler(Handler<Void> handler)OracleConnectionOracleConnection. exceptionHandler(Handler<Throwable> handler)static PoolOracleBuilder. pool(Handler<ClientBuilder<Pool>> block)Build a pool with the specifiedblockargument. -
Uses of Handler in io.vertx.rxjava3.pgclient
Methods in io.vertx.rxjava3.pgclient with parameters of type Handler Modifier and Type Method Description static SqlClientPgBuilder. client(Handler<ClientBuilder<SqlClient>> handler)Build a client backed by a connection pool with the specifiedblockargument.PgConnectionPgConnection. closeHandler(Handler<Void> handler)PgConnectionPgConnection. exceptionHandler(Handler<Throwable> handler)PgConnectionPgConnection. noticeHandler(Handler<PgNotice> handler)Set a handler called when the connection receives a notice from the server.PgConnectionPgConnection. notificationHandler(Handler<PgNotification> handler)Set a handler called when the connection receives notification on a channel.static PoolPgBuilder. pool(Handler<ClientBuilder<Pool>> block)Build a pool with the specifiedblockargument. -
Uses of Handler in io.vertx.rxjava3.pgclient.pubsub
Methods in io.vertx.rxjava3.pgclient.pubsub with parameters of type Handler Modifier and Type Method Description PgSubscriberPgSubscriber. closeHandler(Handler<Void> handler)Set an handler called when the subscriber is closed.PgChannelPgChannel. endHandler(Handler<Void> endHandler)Set an handler to be called when no more notifications will be received.PgChannelPgChannel. exceptionHandler(Handler<Throwable> handler)PgChannelPgChannel. handler(Handler<String> handler)Set or unset an handler to be called when a the channel is notified by Postgres.PgChannelPgChannel. subscribeHandler(Handler<Void> handler)Set an handler called when the the channel get subscribed. -
Uses of Handler in io.vertx.rxjava3.rabbitmq
Methods in io.vertx.rxjava3.rabbitmq with parameters of type Handler Modifier and Type Method Description CompletableRabbitMQClient. basicPublishWithDeliveryTag(String exchange, String routingKey, com.rabbitmq.client.BasicProperties properties, Buffer body, Handler<Long> deliveryTagHandler)Publish a message.RabbitMQConsumerRabbitMQConsumer. endHandler(Handler<Void> endHandler)Set an end handler.RabbitMQConsumerRabbitMQConsumer. exceptionHandler(Handler<Throwable> exceptionHandler)Set an exception handler on the read stream.RabbitMQConsumerRabbitMQConsumer. handler(Handler<RabbitMQMessage> messageArrived)Set a message handler.CompletableRabbitMQClient. rxBasicPublishWithDeliveryTag(String exchange, String routingKey, com.rabbitmq.client.BasicProperties properties, Buffer body, Handler<Long> deliveryTagHandler)Publish a message. -
Uses of Handler in io.vertx.rxjava3.redis.client
Methods in io.vertx.rxjava3.redis.client with parameters of type Handler Modifier and Type Method Description RedisConnectionRedisConnection. endHandler(Handler<Void> endHandler)RedisConnectionRedisConnection. exceptionHandler(Handler<Throwable> handler)RedisConnectionRedisConnection. handler(Handler<Response> handler) -
Uses of Handler in io.vertx.rxjava3.servicediscovery.spi
Methods in io.vertx.rxjava3.servicediscovery.spi with parameters of type Handler Modifier and Type Method Description voidServiceExporter. close(Handler<Void> closeHandler)Close the exportervoidServiceImporter. close(Handler<Void> closeHandler)Closes the importer -
Uses of Handler in io.vertx.rxjava3.sqlclient
Methods in io.vertx.rxjava3.sqlclient with parameters of type Handler Modifier and Type Method Description SqlConnectionSqlConnection. closeHandler(Handler<Void> handler)Set an handler called when the connection is closed.RowStream<T>RowStream. endHandler(Handler<Void> endHandler)RowStream<T>RowStream. exceptionHandler(Handler<Throwable> handler)SqlConnectionSqlConnection. exceptionHandler(Handler<Throwable> handler)Set an handler called with connection errors.RowStream<T>RowStream. handler(Handler<T> handler)ClientBuilder<C>ClientBuilder. withConnectHandler(Handler<SqlConnection> handler)Set a handler called when the pool has established a connection to the database. -
Uses of Handler in io.vertx.servicediscovery.backend.redis
Methods in io.vertx.servicediscovery.backend.redis with parameters of type Handler Modifier and Type Method Description voidRedisBackendService. getRecord(String uuid, Handler<AsyncResult<Record>> resultHandler)voidRedisBackendService. getRecords(Handler<AsyncResult<List<Record>>> resultHandler)voidRedisBackendService. remove(Record record, Handler<AsyncResult<Record>> resultHandler)voidRedisBackendService. remove(String uuid, Handler<AsyncResult<Record>> resultHandler)voidRedisBackendService. store(Record record, Handler<AsyncResult<Record>> resultHandler)voidRedisBackendService. update(Record record, Handler<AsyncResult<Void>> resultHandler) -
Uses of Handler in io.vertx.servicediscovery.consul
Methods in io.vertx.servicediscovery.consul with parameters of type Handler Modifier and Type Method Description voidConsulServiceImporter. close(Handler<Void> completionHandler) -
Uses of Handler in io.vertx.servicediscovery.docker
Methods in io.vertx.servicediscovery.docker with parameters of type Handler Modifier and Type Method Description voidDockerLinksServiceImporter. close(Handler<Void> completionHandler) -
Uses of Handler in io.vertx.servicediscovery.kubernetes
Methods in io.vertx.servicediscovery.kubernetes with parameters of type Handler Modifier and Type Method Description voidKubernetesServiceImporter. close(Handler<Void> completionHandler) -
Uses of Handler in io.vertx.servicediscovery.spi
Methods in io.vertx.servicediscovery.spi with parameters of type Handler Modifier and Type Method Description voidServiceExporter. close(Handler<Void> closeHandler)Close the exporterdefault voidServiceImporter. close(Handler<Void> closeHandler)Closes the importervoidServiceDiscoveryBackend. getRecord(String uuid, Handler<AsyncResult<Record>> resultHandler)Get the record with the given uuid.voidServiceDiscoveryBackend. getRecords(Handler<AsyncResult<List<Record>>> resultHandler)Gets all the recordsvoidServiceDiscoveryBackend. remove(Record record, Handler<AsyncResult<Record>> resultHandler)Removes a record.voidServiceDiscoveryBackend. remove(String uuid, Handler<AsyncResult<Record>> resultHandler)Removes a records based on its UUID.voidServiceDiscoveryBackend. store(Record record, Handler<AsyncResult<Record>> resultHandler)Stores a record.voidServiceDiscoveryBackend. update(Record record, Handler<AsyncResult<Void>> resultHandler)Updates a record -
Uses of Handler in io.vertx.servicediscovery.zookeeper
Methods in io.vertx.servicediscovery.zookeeper with parameters of type Handler Modifier and Type Method Description voidZookeeperServiceImporter. close(Handler<Void> closeHandler) -
Uses of Handler in io.vertx.serviceproxy
Classes in io.vertx.serviceproxy that implement Handler Modifier and Type Class Description classProxyHandlerMethods in io.vertx.serviceproxy that return Handler Modifier and Type Method Description static <T> Handler<AsyncResult<T>>HelperUtils. createHandler(Message msg, boolean includeDebugInfo)static Handler<AsyncResult<List<Character>>>HelperUtils. createListCharHandler(Message msg, boolean includeDebugInfo)static <T> Handler<AsyncResult<List<T>>>HelperUtils. createListHandler(Message msg, boolean includeDebugInfo)static Handler<AsyncResult<Map<String,Character>>>HelperUtils. createMapCharHandler(Message msg, boolean includeDebugInfo)static <T> Handler<AsyncResult<Map<String,T>>>HelperUtils. createMapHandler(Message msg, boolean includeDebugInfo)static Handler<AsyncResult<Set<Character>>>HelperUtils. createSetCharHandler(Message msg, boolean includeDebugInfo)static <T> Handler<AsyncResult<Set<T>>>HelperUtils. createSetHandler(Message msg, boolean includeDebugInfo) -
Uses of Handler in io.vertx.spi.cluster.hazelcast
Methods in io.vertx.spi.cluster.hazelcast that return Handler Modifier and Type Method Description static Handler<Promise<Status>>ClusterHealthCheck. createProcedure(Vertx vertx)Creates a ready-to-use Vert.x clusterHealthChecksprocedure. -
Uses of Handler in io.vertx.sqlclient
Methods in io.vertx.sqlclient with parameters of type Handler Modifier and Type Method Description SqlConnectionSqlConnection. closeHandler(Handler<Void> handler)Set an handler called when the connection is closed.RowStream<T>RowStream. endHandler(Handler<Void> endHandler)RowStream<T>RowStream. exceptionHandler(Handler<Throwable> handler)SqlConnectionSqlConnection. exceptionHandler(Handler<Throwable> handler)Set an handler called with connection errors.RowStream<T>RowStream. handler(Handler<T> handler)static PoolClientBuilder. pool(Driver<?> driver, Handler<ClientBuilder<Pool>> block)Build a pool with the specifiedblockargument andDriverTheblockargument is usually a lambda that configures the provided builderClientBuilder<C>ClientBuilder. withConnectHandler(Handler<SqlConnection> handler)Set a handler called when the pool has established a connection to the database. -
Uses of Handler in io.vertx.sqlclient.spi
Methods in io.vertx.sqlclient.spi with parameters of type Handler Modifier and Type Method Description default PoolDriver. createPool(Vertx vertx, Supplier<Future<C>> databases, PoolOptions poolOptions, NetClientOptions transportOptions, Handler<SqlConnection> connectHandler)Create a connection pool to the database configured with the givenconnectOptionsandpoolOptions.PoolDriver. newPool(Vertx vertx, Supplier<Future<C>> databases, PoolOptions options, NetClientOptions transportOptions, Handler<SqlConnection> connectHandler, io.vertx.core.internal.CloseFuture closeFuture)Create a connection pool to the database configured with the givenconnectOptionsandpoolOptions.
-