package io.vertx.groovy.ext.stomp;
public class StompClientConnection_GroovyExtension {
public static io.vertx.ext.stomp.StompClientConnection send(io.vertx.ext.stomp.StompClientConnection j_receiver, java.util.Map<String, java.lang.String> headers, io.vertx.core.buffer.Buffer body, io.vertx.core.Handler<java.util.Map<String, Object>> receiptHandler) {
io.vertx.core.impl.ConversionHelper.fromObject(j_receiver.send(headers != null ? headers.entrySet().stream().collect(java.util.stream.Collectors.toMap(java.util.Map.Entry::getKey, entry -> entry.getValue())) : null,
body,
receiptHandler != null ? event -> receiptHandler.handle(event != null ? io.vertx.core.impl.ConversionHelper.fromJsonObject(event.toJson()) : null) : null));
return j_receiver;
}
public static io.vertx.ext.stomp.StompClientConnection send(io.vertx.ext.stomp.StompClientConnection j_receiver, java.lang.String destination, io.vertx.core.buffer.Buffer body, io.vertx.core.Handler<java.util.Map<String, Object>> receiptHandler) {
io.vertx.core.impl.ConversionHelper.fromObject(j_receiver.send(destination,
body,
receiptHandler != null ? event -> receiptHandler.handle(event != null ? io.vertx.core.impl.ConversionHelper.fromJsonObject(event.toJson()) : null) : null));
return j_receiver;
}
public static io.vertx.ext.stomp.StompClientConnection send(io.vertx.ext.stomp.StompClientConnection j_receiver, java.util.Map<String, Object> frame) {
io.vertx.core.impl.ConversionHelper.fromObject(j_receiver.send(frame != null ? new io.vertx.ext.stomp.Frame(io.vertx.core.impl.ConversionHelper.toJsonObject(frame)) : null));
return j_receiver;
}
public static io.vertx.ext.stomp.StompClientConnection send(io.vertx.ext.stomp.StompClientConnection j_receiver, java.util.Map<String, Object> frame, io.vertx.core.Handler<java.util.Map<String, Object>> receiptHandler) {
io.vertx.core.impl.ConversionHelper.fromObject(j_receiver.send(frame != null ? new io.vertx.ext.stomp.Frame(io.vertx.core.impl.ConversionHelper.toJsonObject(frame)) : null,
receiptHandler != null ? event -> receiptHandler.handle(event != null ? io.vertx.core.impl.ConversionHelper.fromJsonObject(event.toJson()) : null) : null));
return j_receiver;
}
public static io.vertx.ext.stomp.StompClientConnection send(io.vertx.ext.stomp.StompClientConnection j_receiver, java.lang.String destination, java.util.Map<String, java.lang.String> headers, io.vertx.core.buffer.Buffer body, io.vertx.core.Handler<java.util.Map<String, Object>> receiptHandler) {
io.vertx.core.impl.ConversionHelper.fromObject(j_receiver.send(destination,
headers != null ? headers.entrySet().stream().collect(java.util.stream.Collectors.toMap(java.util.Map.Entry::getKey, entry -> entry.getValue())) : null,
body,
receiptHandler != null ? event -> receiptHandler.handle(event != null ? io.vertx.core.impl.ConversionHelper.fromJsonObject(event.toJson()) : null) : null));
return j_receiver;
}
public static java.lang.String subscribe(io.vertx.ext.stomp.StompClientConnection j_receiver, java.lang.String destination, io.vertx.core.Handler<java.util.Map<String, Object>> handler) {
return j_receiver.subscribe(destination,
handler != null ? event -> handler.handle(event != null ? io.vertx.core.impl.ConversionHelper.fromJsonObject(event.toJson()) : null) : null);
}
public static java.lang.String subscribe(io.vertx.ext.stomp.StompClientConnection j_receiver, java.lang.String destination, io.vertx.core.Handler<java.util.Map<String, Object>> handler, io.vertx.core.Handler<java.util.Map<String, Object>> receiptHandler) {
return j_receiver.subscribe(destination,
handler != null ? event -> handler.handle(event != null ? io.vertx.core.impl.ConversionHelper.fromJsonObject(event.toJson()) : null) : null,
receiptHandler != null ? event -> receiptHandler.handle(event != null ? io.vertx.core.impl.ConversionHelper.fromJsonObject(event.toJson()) : null) : null);
}
public static java.lang.String subscribe(io.vertx.ext.stomp.StompClientConnection j_receiver, java.lang.String destination, java.util.Map<String, java.lang.String> headers, io.vertx.core.Handler<java.util.Map<String, Object>> handler) {
return j_receiver.subscribe(destination,
headers != null ? headers.entrySet().stream().collect(java.util.stream.Collectors.toMap(java.util.Map.Entry::getKey, entry -> entry.getValue())) : null,
handler != null ? event -> handler.handle(event != null ? io.vertx.core.impl.ConversionHelper.fromJsonObject(event.toJson()) : null) : null);
}
public static java.lang.String subscribe(io.vertx.ext.stomp.StompClientConnection j_receiver, java.lang.String destination, java.util.Map<String, java.lang.String> headers, io.vertx.core.Handler<java.util.Map<String, Object>> handler, io.vertx.core.Handler<java.util.Map<String, Object>> receiptHandler) {
return j_receiver.subscribe(destination,
headers != null ? headers.entrySet().stream().collect(java.util.stream.Collectors.toMap(java.util.Map.Entry::getKey, entry -> entry.getValue())) : null,
handler != null ? event -> handler.handle(event != null ? io.vertx.core.impl.ConversionHelper.fromJsonObject(event.toJson()) : null) : null,
receiptHandler != null ? event -> receiptHandler.handle(event != null ? io.vertx.core.impl.ConversionHelper.fromJsonObject(event.toJson()) : null) : null);
}
public static io.vertx.ext.stomp.StompClientConnection unsubscribe(io.vertx.ext.stomp.StompClientConnection j_receiver, java.lang.String destination, io.vertx.core.Handler<java.util.Map<String, Object>> receiptHandler) {
io.vertx.core.impl.ConversionHelper.fromObject(j_receiver.unsubscribe(destination,
receiptHandler != null ? event -> receiptHandler.handle(event != null ? io.vertx.core.impl.ConversionHelper.fromJsonObject(event.toJson()) : null) : null));
return j_receiver;
}
public static io.vertx.ext.stomp.StompClientConnection unsubscribe(io.vertx.ext.stomp.StompClientConnection j_receiver, java.lang.String destination, java.util.Map<String, java.lang.String> headers, io.vertx.core.Handler<java.util.Map<String, Object>> receiptHandler) {
io.vertx.core.impl.ConversionHelper.fromObject(j_receiver.unsubscribe(destination,
headers != null ? headers.entrySet().stream().collect(java.util.stream.Collectors.toMap(java.util.Map.Entry::getKey, entry -> entry.getValue())) : null,
receiptHandler != null ? event -> receiptHandler.handle(event != null ? io.vertx.core.impl.ConversionHelper.fromJsonObject(event.toJson()) : null) : null));
return j_receiver;
}
public static io.vertx.ext.stomp.StompClientConnection errorHandler(io.vertx.ext.stomp.StompClientConnection j_receiver, io.vertx.core.Handler<java.util.Map<String, Object>> handler) {
io.vertx.core.impl.ConversionHelper.fromObject(j_receiver.errorHandler(handler != null ? event -> handler.handle(event != null ? io.vertx.core.impl.ConversionHelper.fromJsonObject(event.toJson()) : null) : null));
return j_receiver;
}
public static io.vertx.ext.stomp.StompClientConnection beginTX(io.vertx.ext.stomp.StompClientConnection j_receiver, java.lang.String id, io.vertx.core.Handler<java.util.Map<String, Object>> receiptHandler) {
io.vertx.core.impl.ConversionHelper.fromObject(j_receiver.beginTX(id,
receiptHandler != null ? event -> receiptHandler.handle(event != null ? io.vertx.core.impl.ConversionHelper.fromJsonObject(event.toJson()) : null) : null));
return j_receiver;
}
public static io.vertx.ext.stomp.StompClientConnection beginTX(io.vertx.ext.stomp.StompClientConnection j_receiver, java.lang.String id, java.util.Map<String, java.lang.String> headers, io.vertx.core.Handler<java.util.Map<String, Object>> receiptHandler) {
io.vertx.core.impl.ConversionHelper.fromObject(j_receiver.beginTX(id,
headers != null ? headers.entrySet().stream().collect(java.util.stream.Collectors.toMap(java.util.Map.Entry::getKey, entry -> entry.getValue())) : null,
receiptHandler != null ? event -> receiptHandler.handle(event != null ? io.vertx.core.impl.ConversionHelper.fromJsonObject(event.toJson()) : null) : null));
return j_receiver;
}
public static io.vertx.ext.stomp.StompClientConnection commit(io.vertx.ext.stomp.StompClientConnection j_receiver, java.lang.String id, io.vertx.core.Handler<java.util.Map<String, Object>> receiptHandler) {
io.vertx.core.impl.ConversionHelper.fromObject(j_receiver.commit(id,
receiptHandler != null ? event -> receiptHandler.handle(event != null ? io.vertx.core.impl.ConversionHelper.fromJsonObject(event.toJson()) : null) : null));
return j_receiver;
}
public static io.vertx.ext.stomp.StompClientConnection commit(io.vertx.ext.stomp.StompClientConnection j_receiver, java.lang.String id, java.util.Map<String, java.lang.String> headers, io.vertx.core.Handler<java.util.Map<String, Object>> receiptHandler) {
io.vertx.core.impl.ConversionHelper.fromObject(j_receiver.commit(id,
headers != null ? headers.entrySet().stream().collect(java.util.stream.Collectors.toMap(java.util.Map.Entry::getKey, entry -> entry.getValue())) : null,
receiptHandler != null ? event -> receiptHandler.handle(event != null ? io.vertx.core.impl.ConversionHelper.fromJsonObject(event.toJson()) : null) : null));
return j_receiver;
}
public static io.vertx.ext.stomp.StompClientConnection abort(io.vertx.ext.stomp.StompClientConnection j_receiver, java.lang.String id, io.vertx.core.Handler<java.util.Map<String, Object>> receiptHandler) {
io.vertx.core.impl.ConversionHelper.fromObject(j_receiver.abort(id,
receiptHandler != null ? event -> receiptHandler.handle(event != null ? io.vertx.core.impl.ConversionHelper.fromJsonObject(event.toJson()) : null) : null));
return j_receiver;
}
public static io.vertx.ext.stomp.StompClientConnection abort(io.vertx.ext.stomp.StompClientConnection j_receiver, java.lang.String id, java.util.Map<String, java.lang.String> headers, io.vertx.core.Handler<java.util.Map<String, Object>> receiptHandler) {
io.vertx.core.impl.ConversionHelper.fromObject(j_receiver.abort(id,
headers != null ? headers.entrySet().stream().collect(java.util.stream.Collectors.toMap(java.util.Map.Entry::getKey, entry -> entry.getValue())) : null,
receiptHandler != null ? event -> receiptHandler.handle(event != null ? io.vertx.core.impl.ConversionHelper.fromJsonObject(event.toJson()) : null) : null));
return j_receiver;
}
public static io.vertx.ext.stomp.StompClientConnection disconnect(io.vertx.ext.stomp.StompClientConnection j_receiver, io.vertx.core.Handler<java.util.Map<String, Object>> receiptHandler) {
io.vertx.core.impl.ConversionHelper.fromObject(j_receiver.disconnect(receiptHandler != null ? event -> receiptHandler.handle(event != null ? io.vertx.core.impl.ConversionHelper.fromJsonObject(event.toJson()) : null) : null));
return j_receiver;
}
public static io.vertx.ext.stomp.StompClientConnection disconnect(io.vertx.ext.stomp.StompClientConnection j_receiver, java.util.Map<String, Object> frame) {
io.vertx.core.impl.ConversionHelper.fromObject(j_receiver.disconnect(frame != null ? new io.vertx.ext.stomp.Frame(io.vertx.core.impl.ConversionHelper.toJsonObject(frame)) : null));
return j_receiver;
}
public static io.vertx.ext.stomp.StompClientConnection disconnect(io.vertx.ext.stomp.StompClientConnection j_receiver, java.util.Map<String, Object> frame, io.vertx.core.Handler<java.util.Map<String, Object>> receiptHandler) {
io.vertx.core.impl.ConversionHelper.fromObject(j_receiver.disconnect(frame != null ? new io.vertx.ext.stomp.Frame(io.vertx.core.impl.ConversionHelper.toJsonObject(frame)) : null,
receiptHandler != null ? event -> receiptHandler.handle(event != null ? io.vertx.core.impl.ConversionHelper.fromJsonObject(event.toJson()) : null) : null));
return j_receiver;
}
public static io.vertx.ext.stomp.StompClientConnection ack(io.vertx.ext.stomp.StompClientConnection j_receiver, java.lang.String id, io.vertx.core.Handler<java.util.Map<String, Object>> receiptHandler) {
io.vertx.core.impl.ConversionHelper.fromObject(j_receiver.ack(id,
receiptHandler != null ? event -> receiptHandler.handle(event != null ? io.vertx.core.impl.ConversionHelper.fromJsonObject(event.toJson()) : null) : null));
return j_receiver;
}
public static io.vertx.ext.stomp.StompClientConnection nack(io.vertx.ext.stomp.StompClientConnection j_receiver, java.lang.String id, io.vertx.core.Handler<java.util.Map<String, Object>> receiptHandler) {
io.vertx.core.impl.ConversionHelper.fromObject(j_receiver.nack(id,
receiptHandler != null ? event -> receiptHandler.handle(event != null ? io.vertx.core.impl.ConversionHelper.fromJsonObject(event.toJson()) : null) : null));
return j_receiver;
}
public static io.vertx.ext.stomp.StompClientConnection ack(io.vertx.ext.stomp.StompClientConnection j_receiver, java.lang.String id, java.lang.String txId, io.vertx.core.Handler<java.util.Map<String, Object>> receiptHandler) {
io.vertx.core.impl.ConversionHelper.fromObject(j_receiver.ack(id,
txId,
receiptHandler != null ? event -> receiptHandler.handle(event != null ? io.vertx.core.impl.ConversionHelper.fromJsonObject(event.toJson()) : null) : null));
return j_receiver;
}
public static io.vertx.ext.stomp.StompClientConnection nack(io.vertx.ext.stomp.StompClientConnection j_receiver, java.lang.String id, java.lang.String txId, io.vertx.core.Handler<java.util.Map<String, Object>> receiptHandler) {
io.vertx.core.impl.ConversionHelper.fromObject(j_receiver.nack(id,
txId,
receiptHandler != null ? event -> receiptHandler.handle(event != null ? io.vertx.core.impl.ConversionHelper.fromJsonObject(event.toJson()) : null) : null));
return j_receiver;
}
public static io.vertx.ext.stomp.StompClientConnection receivedFrameHandler(io.vertx.ext.stomp.StompClientConnection j_receiver, io.vertx.core.Handler<java.util.Map<String, Object>> handler) {
io.vertx.core.impl.ConversionHelper.fromObject(j_receiver.receivedFrameHandler(handler != null ? event -> handler.handle(event != null ? io.vertx.core.impl.ConversionHelper.fromJsonObject(event.toJson()) : null) : null));
return j_receiver;
}
public static io.vertx.ext.stomp.StompClientConnection writingFrameHandler(io.vertx.ext.stomp.StompClientConnection j_receiver, io.vertx.core.Handler<java.util.Map<String, Object>> handler) {
io.vertx.core.impl.ConversionHelper.fromObject(j_receiver.writingFrameHandler(handler != null ? event -> handler.handle(event != null ? io.vertx.core.impl.ConversionHelper.fromJsonObject(event.toJson()) : null) : null));
return j_receiver;
}
}