send
context(ec: ExecContext, _: QueryExecutor)
suspend fun send(message: String, headers: Map<String, String> = emptyMap(), delay: Duration = 0.seconds): EitherThrowable<Long>(source)
suspend fun send(message: String, headers: Map<String, String> = emptyMap(), delay: Duration = 0.seconds): EitherThrowable<Long>(source)
context(ec: ExecContext, _: QueryExecutor)
suspend fun send(headers: Map<String, String> = emptyMap(), delay: Duration = 0.seconds, supplier: () -> String): EitherThrowable<Long>(source)
suspend fun send(headers: Map<String, String> = emptyMap(), delay: Duration = 0.seconds, supplier: () -> String): EitherThrowable<Long>(source)