vertx / io.vertx.kotlin.ext.stomp / io.vertx.ext.stomp.StompClientConnection / subscribeAwait

subscribeAwait

suspend fun StompClientConnection.subscribeAwait(destination: String, handler: (Frame) -> Unit): String

Suspending version of method io.vertx.ext.stomp.StompClientConnection.subscribe

Parameters

destination - the destination, must not be null

handler - the handler invoked when a message is received on the given destination. Must not be null.

Return

String

NOTE: This function has been automatically generated from io.vertx.ext.stomp.StompClientConnection using Vert.x codegen.

suspend fun StompClientConnection.subscribeAwait(destination: String, headers: Map<String, String>, handler: (Frame) -> Unit): String

Suspending version of method io.vertx.ext.stomp.StompClientConnection.subscribe

Parameters

destination - the destination, must not be null

headers - the headers to configure the subscription. It may contain the ack header to configure the acknowledgment policy. If the given set of headers contains the id header, this value is used as subscription id.

handler - the handler invoked when a message is received on the given destination. Must not be null.

Return

String

NOTE: This function has been automatically generated from io.vertx.ext.stomp.StompClientConnection using Vert.x codegen.