diff options
| author |   elinuxhenrik <henrik.b.andersson@est.tech> | 2018-09-26 16:03:45 +0200 |
|---|---|---|
| committer | elinuxhenrik <henrik.b.andersson@est.tech> | 2018-09-27 14:30:56 +0200 |
| commit | 263d1a481bd5378e59b804425bc8a9bdc9bebb9a (patch) | |
| tree | 4825c45fbccf1f99e3765417118c8a74bd9fe990 /datafile-commons/src/main/java | |
| parent | d1e9b1e4004faf059c2505ef9ab561bf19472b98 (diff) | |
Fix delivery to DataRouter
The messages to the DataRouter was not actually sent.
Change-Id: I5748ee0cc19a5049ca4d965caefb5cdf2204419f
Issue-ID: DCAEGEN2-841
Signed-off-by: elinuxhenrik <henrik.b.andersson@est.tech>
Diffstat (limited to 'datafile-commons/src/main/java')
2 files changed, 12 insertions, 2 deletions
diff --git a/datafile-commons/src/main/java/org/onap/dcaegen2/collectors/datafile/model/ConsumerDmaapModel.java b/datafile-commons/src/main/java/org/onap/dcaegen2/collectors/datafile/model/ConsumerDmaapModel.java index 94e7ccd7..d9c146f1 100644 --- a/datafile-commons/src/main/java/org/onap/dcaegen2/collectors/datafile/model/ConsumerDmaapModel.java +++ b/datafile-commons/src/main/java/org/onap/dcaegen2/collectors/datafile/model/ConsumerDmaapModel.java @@ -16,11 +16,11 @@ package org.onap.dcaegen2.collectors.datafile.model; +import com.google.gson.annotations.SerializedName; + import org.immutables.gson.Gson; import org.immutables.value.Value; -import com.google.gson.annotations.SerializedName; - /** * @author <a href="mailto:przemyslaw.wasala@nokia.com">Przemysław Wąsala</a> on 5/8/18 * @author <a href="mailto:henrik.b.andersson@est.tech">Henrik Andersson</a> @@ -30,6 +30,9 @@ import com.google.gson.annotations.SerializedName; @Gson.TypeAdapters public interface ConsumerDmaapModel { + @SerializedName("name") + String getName(); + @SerializedName("location") String getLocation(); diff --git a/datafile-commons/src/main/java/org/onap/dcaegen2/collectors/datafile/model/ConsumerDmaapModelForUnitTest.java b/datafile-commons/src/main/java/org/onap/dcaegen2/collectors/datafile/model/ConsumerDmaapModelForUnitTest.java index 103a70e8..62e6b1bf 100644 --- a/datafile-commons/src/main/java/org/onap/dcaegen2/collectors/datafile/model/ConsumerDmaapModelForUnitTest.java +++ b/datafile-commons/src/main/java/org/onap/dcaegen2/collectors/datafile/model/ConsumerDmaapModelForUnitTest.java @@ -17,12 +17,14 @@ package org.onap.dcaegen2.collectors.datafile.model; public class ConsumerDmaapModelForUnitTest implements ConsumerDmaapModel { + private final String name; private final String location; private final String compression; private final String fileFormatType; private final String fileFormatVersion; public ConsumerDmaapModelForUnitTest() { + this.name = "A20161224.1030-1045.bin.gz"; this.location = "target/A20161224.1030-1045.bin.gz"; this.compression = "gzip"; this.fileFormatType = "org.3GPP.32.435#measCollec"; @@ -30,6 +32,11 @@ public class ConsumerDmaapModelForUnitTest implements ConsumerDmaapModel { } @Override + public String getName() { + return name; + } + + @Override public String getLocation() { return location; } |