7476e9765b78e797111fb49d7eec3c3e6e8efef5
[dcaegen2/services/sdk.git] /
1 /*
2  * ============LICENSE_START====================================
3  * DCAEGEN2-SERVICES-SDK
4  * =========================================================
5  * Copyright (C) 2019 Nokia. All rights reserved.
6  * =========================================================
7  * Licensed under the Apache License, Version 2.0 (the "License");
8  * you may not use this file except in compliance with the License.
9  * You may obtain a copy of the License at
10  *
11  *       http://www.apache.org/licenses/LICENSE-2.0
12  *
13  * Unless required by applicable law or agreed to in writing, software
14  * distributed under the License is distributed on an "AS IS" BASIS,
15  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
16  * See the License for the specific language governing permissions and
17  * limitations under the License.
18  * ============LICENSE_END=====================================
19  */
20
21 package org.onap.dcaegen2.services.sdk.rest.services.cbs.client.api.streams;
22
23 import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.impl.streams.gson.dmaap.dr.DataRouterSinkParser;
24 import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.impl.streams.gson.dmaap.dr.DataRouterSourceParser;
25 import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.impl.streams.gson.dmaap.mr.MessageRouterSinkParser;
26 import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.impl.streams.gson.dmaap.mr.MessageRouterSourceParser;
27 import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.impl.streams.gson.kafka.KafkaSinkParser;
28 import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.impl.streams.gson.kafka.KafkaSourceParser;
29 import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.model.streams.dmaap.*;
30
31 /**
32  * Factory methods for GSON-based {@code StreamParser}s
33  *
34  * @author <a href="mailto:piotr.jaszczyk@nokia.com">Piotr Jaszczyk</a>
35  * @since 1.1.4
36  */
37 public final class StreamFromGsonParsers {
38
39     private StreamFromGsonParsers() {
40     }
41
42     /**
43      * Creates a stream parser capable of parsing Kafka sinks.
44      *
45      * @return a stream parser
46      */
47     public static StreamFromGsonParser<KafkaSink> kafkaSinkParser() {
48         return KafkaSinkParser.create();
49     }
50
51     /**
52      * Creates a stream parser capable of parsing Kafka sources.
53      *
54      * @return a stream parser
55      */
56     public static StreamFromGsonParser<KafkaSource> kafkaSourceParser() {
57         return KafkaSourceParser.create();
58     }
59
60     /**
61      * Creates a stream parser capable of parsing DMaaP Message Router sinks.
62      *
63      * @return a stream parser
64      */
65     public static StreamFromGsonParser<MessageRouterSink> messageRouterSinkParser() {
66         return MessageRouterSinkParser.create();
67     }
68
69     /**
70      * Creates a stream parser capable of parsing DMaaP Message Router sources.
71      *
72      * @return a stream parser
73      */
74     public static StreamFromGsonParser<MessageRouterSource> messageRouterSourceParser() {
75         return MessageRouterSourceParser.create();
76     }
77
78     /**
79      * Creates a stream parser capable of parsing DMaaP Data Router sinks.
80      *
81      * @return a stream parser
82      */
83     public static StreamFromGsonParser<DataRouterSink> dataRouterSinkParser() {
84         return DataRouterSinkParser.create();
85     }
86
87     /**
88      * Creates a stream parser capable of parsing DMaaP Data Router sources.
89      *
90      * @return a stream parser
91      */
92     public static StreamFromGsonParser<DataRouterSource> dataRouterSourceParser() {
93         return DataRouterSourceParser.create();
94     }
95 }