diff options
Diffstat (limited to 'src/main/java/org/onap')
7 files changed, 1 insertions, 21 deletions
diff --git a/src/main/java/org/onap/dmaap/mr/dme/client/HeaderReplyHandler.java b/src/main/java/org/onap/dmaap/mr/dme/client/HeaderReplyHandler.java index da0ba62..9197ca4 100644 --- a/src/main/java/org/onap/dmaap/mr/dme/client/HeaderReplyHandler.java +++ b/src/main/java/org/onap/dmaap/mr/dme/client/HeaderReplyHandler.java @@ -22,8 +22,6 @@ package org.onap.dmaap.mr.dme.client; -import java.util.Map; - import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -31,13 +29,8 @@ import com.att.aft.dme2.api.util.DME2ExchangeFaultContext; import com.att.aft.dme2.api.util.DME2ExchangeReplyHandler; import com.att.aft.dme2.api.util.DME2ExchangeResponseContext; import org.onap.dmaap.mr.client.MRClientFactory; -import org.onap.dmaap.mr.client.impl.MRSimplerBatchPublisher; - - - - - public class HeaderReplyHandler implements DME2ExchangeReplyHandler { +public class HeaderReplyHandler implements DME2ExchangeReplyHandler { private Logger fLog = LoggerFactory.getLogger ( this.getClass().getName () ); diff --git a/src/main/java/org/onap/dmaap/mr/dme/client/PreferredRouteReplyHandler.java b/src/main/java/org/onap/dmaap/mr/dme/client/PreferredRouteReplyHandler.java index 967ccf3..70e0d1b 100644 --- a/src/main/java/org/onap/dmaap/mr/dme/client/PreferredRouteReplyHandler.java +++ b/src/main/java/org/onap/dmaap/mr/dme/client/PreferredRouteReplyHandler.java @@ -22,7 +22,6 @@ package org.onap.dmaap.mr.dme.client; import java.io.File; import java.io.FileWriter; -import java.io.InputStream; import org.slf4j.Logger; import org.slf4j.LoggerFactory; diff --git a/src/main/java/org/onap/dmaap/mr/dme/client/SimpleExamplePublisher.java b/src/main/java/org/onap/dmaap/mr/dme/client/SimpleExamplePublisher.java index edb3994..de0d461 100644 --- a/src/main/java/org/onap/dmaap/mr/dme/client/SimpleExamplePublisher.java +++ b/src/main/java/org/onap/dmaap/mr/dme/client/SimpleExamplePublisher.java @@ -24,18 +24,11 @@ package org.onap.dmaap.mr.dme.client; import java.io.IOException; -import java.util.List; import java.util.Map; - -import java.util.concurrent.TimeUnit; - import javax.ws.rs.core.MultivaluedMap; - import org.json.JSONObject; - import org.onap.dmaap.mr.client.MRBatchingPublisher; import org.onap.dmaap.mr.client.MRClientFactory; -import org.onap.dmaap.mr.client.MRPublisher.message; /** * An example of how to use the Java publisher. diff --git a/src/main/java/org/onap/dmaap/mr/test/clients/SamplePublisher.java b/src/main/java/org/onap/dmaap/mr/test/clients/SamplePublisher.java index 29d7f85..5f8768c 100644 --- a/src/main/java/org/onap/dmaap/mr/test/clients/SamplePublisher.java +++ b/src/main/java/org/onap/dmaap/mr/test/clients/SamplePublisher.java @@ -30,7 +30,6 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.onap.dmaap.mr.client.MRBatchingPublisher; -import org.onap.dmaap.mr.client.MRClientFactory; import org.onap.dmaap.mr.client.MRClientBuilders.PublisherBuilder; import org.onap.dmaap.mr.client.MRPublisher.message; diff --git a/src/main/java/org/onap/dmaap/mr/test/clients/SimpleExamplePublisher.java b/src/main/java/org/onap/dmaap/mr/test/clients/SimpleExamplePublisher.java index 770d916..50fd22c 100644 --- a/src/main/java/org/onap/dmaap/mr/test/clients/SimpleExamplePublisher.java +++ b/src/main/java/org/onap/dmaap/mr/test/clients/SimpleExamplePublisher.java @@ -26,7 +26,6 @@ import java.io.File; import java.io.FileReader; import java.io.FileWriter; import java.io.IOException; -import java.io.PrintWriter; import java.util.List; import java.util.Properties; import java.util.concurrent.TimeUnit; diff --git a/src/main/java/org/onap/dmaap/mr/test/clients/SimpleExamplePublisherWithResponse.java b/src/main/java/org/onap/dmaap/mr/test/clients/SimpleExamplePublisherWithResponse.java index 33d1164..d2b77ef 100644 --- a/src/main/java/org/onap/dmaap/mr/test/clients/SimpleExamplePublisherWithResponse.java +++ b/src/main/java/org/onap/dmaap/mr/test/clients/SimpleExamplePublisherWithResponse.java @@ -24,9 +24,7 @@ import java.io.File; import java.io.FileReader; import java.io.FileWriter; import java.io.IOException; -import java.util.List; import java.util.Properties; -import java.util.concurrent.TimeUnit; import org.json.JSONObject; import org.onap.dmaap.mr.client.MRBatchingPublisher; import org.onap.dmaap.mr.client.MRClientFactory; diff --git a/src/main/java/org/onap/dmaap/mr/tools/MessageCommand.java b/src/main/java/org/onap/dmaap/mr/tools/MessageCommand.java index 5016c95..451aed5 100644 --- a/src/main/java/org/onap/dmaap/mr/tools/MessageCommand.java +++ b/src/main/java/org/onap/dmaap/mr/tools/MessageCommand.java @@ -34,7 +34,6 @@ import com.att.nsa.cmdtool.CommandNotReadyException; import org.onap.dmaap.mr.client.MRBatchingPublisher; import org.onap.dmaap.mr.client.MRClientFactory; import org.onap.dmaap.mr.client.MRConsumer; -import org.onap.dmaap.mr.client.MRClientBuilders.PublisherBuilder; import org.onap.dmaap.mr.client.MRPublisher.message; public class MessageCommand implements Command<MRCommandContext> |