@JsonInclude(JsonInclude.Include.NON_NULL)
@JsonIgnoreProperties(ignoreUnknown = true)
public class DmaapOutgoingMessage extends DmaapMessage{
- private final static String defaultCambriaPartition = "MSO";
+ private static final String defaultCambriaPartition = "MSO";
public DmaapOutgoingMessage() {
super();
//@formatter:off
@SuppressWarnings("nls")
- private final static String TEMPLATE = "{\"input\": {\"common-request-header\": {\"service-request-id\": \"%s\"},\"config-payload\": {\"config-url\": \"%s\",\"config-json\":\"%s\"}}}";
+ private static final String TEMPLATE = "{\"input\": {\"common-request-header\": {\"service-request-id\": \"%s\"},\"config-payload\": {\"config-url\": \"%s\",\"config-json\":\"%s\"}}}";
//@formatter:on
/**
import java.util.LinkedList;
import java.util.List;
import java.util.Map;
-import java.net.URI;
import java.util.*;
import java.util.zip.ZipEntry;
import java.util.zip.ZipInputStream;
//@formatter:off
@SuppressWarnings("nls")
- private final static String TEMPLATE = "{\"input\": %s}";
+ private static final String TEMPLATE = "{\"input\": %s}";
//@formatter:on
@Override
package org.onap.appc.listener.demo.model;
import java.io.Serializable;
-import java.util.Collection;
import org.json.JSONObject;
import org.onap.appc.listener.util.Mapper;
- };
+ }
@JsonIgnoreProperties(ignoreUnknown = true)
public static class Streams {
this.activeStreams = activeStreams;
}
- };
+ }
}
import java.util.Collection;
import java.util.Set;
-import org.onap.appc.adapter.message.Consumer;
-import org.onap.appc.adapter.message.Producer;
-
public interface MessageAdapterFactory {
// TODO: how do you configure the MessageService type?