public final class DataRouterSinkParser implements StreamFromGsonParser<DataRouterSink> {
private final Gson gson;
- public static DataRouterSinkParser create() {
- return new DataRouterSinkParser(gsonInstance());
- }
-
private DataRouterSinkParser(Gson gson) {
this.gson = gson;
}
+ public static DataRouterSinkParser create() {
+ return new DataRouterSinkParser(gsonInstance());
+ }
+
@Override
public DataRouterSink unsafeParse(RawDataStream<JsonObject> input) {
assertStreamType(input, DATA_ROUTER_TYPE, DataStreamDirection.SINK);
public final class DataRouterSourceParser implements StreamFromGsonParser<DataRouterSource> {
private final Gson gson;
- public static DataRouterSourceParser create() {
- return new DataRouterSourceParser(gsonInstance());
- }
-
private DataRouterSourceParser(Gson gson) {
this.gson = gson;
}
+ public static DataRouterSourceParser create() {
+ return new DataRouterSourceParser(gsonInstance());
+ }
+
@Override
public DataRouterSource unsafeParse(RawDataStream<JsonObject> input) {
assertStreamType(input, DATA_ROUTER_TYPE, DataStreamDirection.SOURCE);
public class GsonMessageRouterSink extends GsonMessageRouter implements MessageRouterSink {
GsonMessageRouterSink(
- String name, @NotNull MessageRouterDmaapInfo dmaapInfo,
+ String name,
+ @NotNull MessageRouterDmaapInfo dmaapInfo,
@Nullable AafCredentials aafCredentials) {
super(name, dmaapInfo, aafCredentials);
}
public class GsonMessageRouterSource extends GsonMessageRouter implements MessageRouterSource {
GsonMessageRouterSource(
- String name, @NotNull MessageRouterDmaapInfo dmaapInfo,
+ String name,
+ @NotNull MessageRouterDmaapInfo dmaapInfo,
@Nullable AafCredentials aafCredentials) {
super(name, dmaapInfo, aafCredentials);
}
@Gson.TypeAdapters
@Value.Immutable
public interface MessageRouterDmaapInfo {
-
@SerializedName("topic_url")
String topicUrl();
private final Gson gson;
- public static MessageRouterSinkParser create() {
- return new MessageRouterSinkParser(gsonInstance());
- }
-
private MessageRouterSinkParser(Gson gson) {
this.gson = gson;
}
+ public static MessageRouterSinkParser create() {
+ return new MessageRouterSinkParser(gsonInstance());
+ }
+
@Override
public MessageRouterSink unsafeParse(RawDataStream<JsonObject> input) {
assertStreamType(input, MESSAGE_ROUTER_TYPE, DataStreamDirection.SINK);
public final class MessageRouterSourceParser implements StreamFromGsonParser<MessageRouterSource> {
private final Gson gson;
- public static MessageRouterSourceParser create() {
- return new MessageRouterSourceParser(gsonInstance());
- }
-
private MessageRouterSourceParser(Gson gson) {
this.gson = gson;
}
+ public static MessageRouterSourceParser create() {
+ return new MessageRouterSourceParser(gsonInstance());
+ }
+
@Override
public MessageRouterSource unsafeParse(RawDataStream<JsonObject> input) {
assertStreamType(input, MESSAGE_ROUTER_TYPE, DataStreamDirection.SOURCE);
public final class KafkaSinkParser implements StreamFromGsonParser<KafkaSink> {
private final Gson gson;
- public static KafkaSinkParser create() {
- return new KafkaSinkParser(gsonInstance());
- }
-
private KafkaSinkParser(Gson gson) {
this.gson = gson;
}
+ public static KafkaSinkParser create() {
+ return new KafkaSinkParser(gsonInstance());
+ }
+
@Override
public KafkaSink unsafeParse(RawDataStream<JsonObject> input) {
assertStreamType(input, KAFKA_TYPE, DataStreamDirection.SINK);
public final class KafkaSourceParser implements StreamFromGsonParser<KafkaSource> {
private final Gson gson;
- public static KafkaSourceParser create() {
- return new KafkaSourceParser(gsonInstance());
- }
-
private KafkaSourceParser(Gson gson) {
this.gson = gson;
}
+ public static KafkaSourceParser create() {
+ return new KafkaSourceParser(gsonInstance());
+ }
+
@Override
public KafkaSource unsafeParse(RawDataStream<JsonObject> input) {
assertStreamType(input, KAFKA_TYPE, DataStreamDirection.SOURCE);
package org.onap.dcaegen2.services.sdk.rest.services.cbs.client.model.streams.dmaap;
-
-import org.immutables.gson.Gson;
import org.immutables.value.Value;
import org.onap.dcaegen2.services.sdk.rest.services.annotations.ExperimentalApi;
import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.model.streams.SinkStream;
package org.onap.dcaegen2.services.sdk.rest.services.cbs.client.model.streams.dmaap;
-
-import org.immutables.gson.Gson;
import org.immutables.value.Value;
import org.onap.dcaegen2.services.sdk.rest.services.annotations.ExperimentalApi;
import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.model.streams.SourceStream;
Code Review / dcaegen2 / services / sdk.git / commitdiff