Skip to content

Commit

Permalink
feat(api): Move from .json() to .toJsonObject() in WithEventBus…
Browse files Browse the repository at this point in the history 
… trait
  • Loading branch information
@fussel178
fussel178 authored and Ludwig Richter committed Mar 23, 2022
1 parent 97a171a commit 81c4d09
Showing 1 changed file with 36 additions and 36 deletions.
72 changes: 36 additions & 36 deletions ...es/telestion-api/src/main/java/de/wuespace/telestion/api/verticle/trait/WithEventBus.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -36,9 +36,9 @@
*/
public interface WithEventBus extends Verticle {

///
/// PUBLISH SECTION
///
///////////////////////////////////////////////////////////////////////////
// publish section
///////////////////////////////////////////////////////////////////////////

/**
* @see io.vertx.core.eventbus.EventBus#publish(String, Object)
Expand Down Expand Up @@ -92,51 +92,51 @@ default void publish(String address, Object message, HeaderInformation... header
* @see io.vertx.core.eventbus.EventBus#publish(String, Object)
*/
default void publish(String address, JsonMessage message) {
publish(address, message.json());
publish(address, message.toJsonObject());
}

/**
* @see io.vertx.core.eventbus.EventBus#publish(String, Object, DeliveryOptions)
*/
default void publish(String address, JsonMessage message, DeliveryOptions options) {
publish(address, message.json(), options);
publish(address, message.toJsonObject(), options);
}

/**
* @param headers the headers that should be sent with the message
* @see io.vertx.core.eventbus.EventBus#publish(String, Object, DeliveryOptions)
*/
default void publish(String address, JsonMessage message, DeliveryOptions options, MultiMap... headers) {
publish(address, message.json(), options, headers);
publish(address, message.toJsonObject(), options, headers);
}

/**
* @param headers the headers that should be sent with the message
* @see io.vertx.core.eventbus.EventBus#publish(String, Object, DeliveryOptions)
*/
default void publish(String address, JsonMessage message, DeliveryOptions options, HeaderInformation... headers) {
publish(address, message.json(), options, headers);
publish(address, message.toJsonObject(), options, headers);
}

/**
* @param headers the headers that should be sent with the message
* @see io.vertx.core.eventbus.EventBus#publish(String, Object)
*/
default void publish(String address, JsonMessage message, MultiMap... headers) {
publish(address, message.json(), headers);
publish(address, message.toJsonObject(), headers);
}

/**
* @param headers the headers that should be sent with the message
* @see io.vertx.core.eventbus.EventBus#publish(String, Object)
*/
default void publish(String address, JsonMessage message, HeaderInformation... headers) {
publish(address, message.json(), headers);
publish(address, message.toJsonObject(), headers);
}

///
/// SEND SECTION
///
///////////////////////////////////////////////////////////////////////////
// send section
///////////////////////////////////////////////////////////////////////////

/**
* @see io.vertx.core.eventbus.EventBus#send(String, Object)
Expand Down Expand Up @@ -190,51 +190,51 @@ default void send(String address, Object message, HeaderInformation... headers)
* @see io.vertx.core.eventbus.EventBus#send(String, Object)
*/
default void send(String address, JsonMessage message) {
send(address, message.json());
send(address, message.toJsonObject());
}

/**
* @see io.vertx.core.eventbus.EventBus#send(String, Object, DeliveryOptions)
*/
default void send(String address, JsonMessage message, DeliveryOptions options) {
send(address, message.json(), options);
send(address, message.toJsonObject(), options);
}

/**
* @param headers the headers that should be sent with the message
* @see io.vertx.core.eventbus.EventBus#send(String, Object, DeliveryOptions)
*/
default void send(String address, JsonMessage message, DeliveryOptions options, MultiMap... headers) {
send(address, message.json(), options, headers);
send(address, message.toJsonObject(), options, headers);
}

/**
* @param headers the headers that should be sent with the message
* @see io.vertx.core.eventbus.EventBus#send(String, Object, DeliveryOptions)
*/
default void send(String address, JsonMessage message, DeliveryOptions options, HeaderInformation... headers) {
send(address, message.json(), options, headers);
send(address, message.toJsonObject(), options, headers);
}

/**
* @param headers the headers that should be sent with the message
* @see io.vertx.core.eventbus.EventBus#send(String, Object)
*/
default void send(String address, JsonMessage message, MultiMap... headers) {
send(address, message.json(), headers);
send(address, message.toJsonObject(), headers);
}

/**
* @param headers the headers that should be sent with the message
* @see io.vertx.core.eventbus.EventBus#send(String, Object)
*/
default void send(String address, JsonMessage message, HeaderInformation... headers) {
send(address, message.json(), headers);
send(address, message.toJsonObject(), headers);
}

///
/// REQUEST SECTION
///
///////////////////////////////////////////////////////////////////////////
// request section
///////////////////////////////////////////////////////////////////////////

/**
* @see io.vertx.core.eventbus.EventBus#request(String, Object)
Expand Down Expand Up @@ -296,14 +296,14 @@ default <T> Future<Message<T>> request(String address, Object request, HeaderInf
* @see io.vertx.core.eventbus.EventBus#request(String, Object)
*/
default <T> Future<Message<T>> request(String address, JsonMessage message) {
return request(address, message.json());
return request(address, message.toJsonObject());
}

/**
* @see io.vertx.core.eventbus.EventBus#request(String, Object, DeliveryOptions)
*/
default <T> Future<Message<T>> request(String address, JsonMessage message, DeliveryOptions options) {
return request(address, message.json(), options);
return request(address, message.toJsonObject(), options);
}

/**
Expand All @@ -315,7 +315,7 @@ default <T> Future<Message<T>> request(
JsonMessage message,
DeliveryOptions options,
MultiMap... requestHeaders) {
return request(address, message.json(), options, requestHeaders);
return request(address, message.toJsonObject(), options, requestHeaders);
}

/**
Expand All @@ -327,23 +327,23 @@ default <T> Future<Message<T>> request(
JsonMessage message,
DeliveryOptions options,
HeaderInformation... requestHeaders) {
return request(address, message.json(), options, requestHeaders);
return request(address, message.toJsonObject(), options, requestHeaders);
}

/**
* @param requestHeaders the headers that should be sent with the request message
* @see io.vertx.core.eventbus.EventBus#request(String, Object)
*/
default <T> Future<Message<T>> request(String address, JsonMessage message, MultiMap... requestHeaders) {
return request(address, message.json(), requestHeaders);
return request(address, message.toJsonObject(), requestHeaders);
}

/**
* @param requestHeaders the headers that should be sent with the request message
* @see io.vertx.core.eventbus.EventBus#request(String, Object)
*/
default <T> Future<Message<T>> request(String address, JsonMessage message, HeaderInformation... requestHeaders) {
return request(address, message.json(), requestHeaders);
return request(address, message.toJsonObject(), requestHeaders);
}

/**
Expand Down Expand Up @@ -431,7 +431,7 @@ default <V extends JsonMessage, T extends JsonObject> Future<DecodedMessage<V, T
String address,
JsonMessage request,
Class<V> responseType) {
return request(address, request.json(), responseType);
return request(address, request.toJsonObject(), responseType);
}

/**
Expand All @@ -443,7 +443,7 @@ default <V extends JsonMessage, T extends JsonObject> Future<DecodedMessage<V, T
JsonMessage request,
Class<V> responseType,
DeliveryOptions options) {
return request(address, request.json(), responseType, options);
return request(address, request.toJsonObject(), responseType, options);
}

/**
Expand All @@ -457,7 +457,7 @@ default <V extends JsonMessage, T extends JsonObject> Future<DecodedMessage<V, T
Class<V> responseType,
DeliveryOptions options,
MultiMap... requestHeaders) {
return request(address, request.json(), responseType, options, requestHeaders);
return request(address, request.toJsonObject(), responseType, options, requestHeaders);
}

/**
Expand All @@ -471,7 +471,7 @@ default <V extends JsonMessage, T extends JsonObject> Future<DecodedMessage<V, T
Class<V> responseType,
DeliveryOptions options,
HeaderInformation... requestHeaders) {
return request(address, request.json(), responseType, options, requestHeaders);
return request(address, request.toJsonObject(), responseType, options, requestHeaders);
}

/**
Expand All @@ -484,7 +484,7 @@ default <V extends JsonMessage, T extends JsonObject> Future<DecodedMessage<V, T
JsonMessage request,
Class<V> responseType,
MultiMap... requestHeaders) {
return request(address, request.json(), responseType, requestHeaders);
return request(address, request.toJsonObject(), responseType, requestHeaders);
}

/**
Expand All @@ -497,12 +497,12 @@ default <V extends JsonMessage, T extends JsonObject> Future<DecodedMessage<V, T
JsonMessage request,
Class<V> responseType,
HeaderInformation... requestHeaders) {
return request(address, request.json(), responseType, requestHeaders);
return request(address, request.toJsonObject(), responseType, requestHeaders);
}

///
/// REGISTER SECTION
///
///////////////////////////////////////////////////////////////////////////
// register section
///////////////////////////////////////////////////////////////////////////

/**
* @see io.vertx.core.eventbus.EventBus#consumer(String, Handler)
Expand Down

0 comments on commit 81c4d09

Please sign in to comment.