package org.onap.dmaap.mr.dme.client;
-import java.util.Map;
-
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
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 () );
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;
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.
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;
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;
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;
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>
package org.onap.dmaap.mr.client;
import static org.junit.Assert.assertTrue;
-
-import java.util.concurrent.TimeUnit;
-
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
import java.util.ArrayList;
import java.util.Collection;
-import java.util.concurrent.TimeUnit;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
-
-import org.onap.dmaap.mr.client.HostSelector;
-import org.onap.dmaap.mr.client.MRClient;
import org.onap.dmaap.mr.client.MRClientBuilders;
public class MRClientBuildersTest {
import org.junit.Test;
import org.mockito.Mockito;
-import com.att.aft.dme2.internal.jersey.core.spi.factory.ResponseImpl;
-
public class DMaapClientUtilTest {
Builder builder;
import org.junit.Before;
import org.junit.Test;
import org.junit.runner.RunWith;
-import org.mockito.InjectMocks;
-import org.mockito.Mock;
import org.mockito.Mockito;
-import org.mockito.MockitoAnnotations;
import org.powermock.api.mockito.PowerMockito;
import org.powermock.core.classloader.annotations.PowerMockIgnore;
import org.powermock.core.classloader.annotations.PrepareForTest;
import org.junit.Test;
-import org.onap.dmaap.mr.client.MRClientFactory;
import org.onap.dmaap.mr.client.impl.MRConstants;
import org.onap.dmaap.mr.client.impl.MRConsumerImpl;
package org.onap.dmaap.mr.client.impl;
import java.io.IOException;
-import java.net.MalformedURLException;
import java.util.Collection;
import java.util.LinkedList;
import java.util.Set;
-
import org.junit.Before;
-import org.junit.Rule;
import org.junit.Test;
-
-import static com.github.tomakehurst.wiremock.client.WireMock.*;
import static org.junit.Assert.assertTrue;
-
import com.att.nsa.apiClient.http.HttpException;
import com.att.nsa.apiClient.http.HttpObjectNotFoundException;
-import org.onap.dmaap.mr.client.MRClient.MRApiException;
import org.onap.dmaap.mr.client.MRTopicManager.TopicInfo;
-import com.github.tomakehurst.wiremock.junit.WireMockRule;
public class MRMetaClientTest {
import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
-import java.util.List;
import java.util.Properties;
-import java.util.concurrent.TimeUnit;
-
-import org.json.JSONObject;
-import org.junit.After;
-import org.junit.Assert;
import org.junit.Before;
import org.junit.Test;
import org.onap.dmaap.mr.client.MRClientFactory;
import org.onap.dmaap.mr.client.MRConsumer;
-import org.onap.dmaap.mr.client.MRPublisher.message;
-import org.onap.dmaap.mr.client.response.MRPublisherResponse;
public class MRSimplerBatchConsumerTest {
import java.util.concurrent.TimeUnit;
import org.json.JSONObject;
-import org.junit.After;
import org.junit.Assert;
import org.junit.Before;
import org.junit.Test;
package org.onap.dmaap.mr.client.response;
import static org.junit.Assert.assertTrue;
-
-import java.util.concurrent.TimeUnit;
-
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
-import org.onap.dmaap.mr.client.HostSelector;
-
public class MRConsumerResponseTest {
private MRConsumerResponse test = null;
package org.onap.dmaap.mr.client.response;
import static org.junit.Assert.assertTrue;
-
-import java.util.concurrent.TimeUnit;
-
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
-import org.onap.dmaap.mr.client.HostSelector;
-
public class MRPublisherResponseTest {
private MRPublisherResponse response = null;
import static org.junit.Assert.assertTrue;
-import java.lang.reflect.Constructor;
-import java.lang.reflect.InvocationTargetException;
-import java.lang.reflect.Method;
-import java.util.ArrayList;
-import java.util.concurrent.TimeUnit;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
-import org.onap.dmaap.mr.client.HostSelector;
-import org.onap.dmaap.mr.client.MRPublisher.message;
-import org.onap.dmaap.mr.test.support.MRBatchingPublisherMock.Listener;
-
public class HeaderReplyHandlerTest {
private HeaderReplyHandler handler = null;
package org.onap.dmaap.mr.dme.client;
-import static org.junit.Assert.assertTrue;
-
-import java.lang.reflect.Constructor;
-import java.lang.reflect.InvocationTargetException;
-import java.lang.reflect.Method;
-import java.util.ArrayList;
-import java.util.concurrent.TimeUnit;
-
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
-import org.onap.dmaap.mr.client.HostSelector;
-import org.onap.dmaap.mr.client.MRPublisher.message;
-import org.onap.dmaap.mr.test.support.MRBatchingPublisherMock.Listener;
-
public class PreferredRouteReplyHandlerTest {
private PreferredRouteReplyHandler handler = null;
package org.onap.dmaap.mr.dme.client;
-import static org.junit.Assert.assertTrue;
-
-import java.lang.reflect.Constructor;
-import java.lang.reflect.InvocationTargetException;
-import java.lang.reflect.Method;
-import java.util.ArrayList;
-import java.util.concurrent.TimeUnit;
-
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
-import org.onap.dmaap.mr.client.HostSelector;
-import org.onap.dmaap.mr.client.MRPublisher.message;
-import org.onap.dmaap.mr.test.support.MRBatchingPublisherMock.Listener;
-
public class PreferredRouteRequestHandlerTest {
private PreferredRouteRequestHandler handler = null;
import static org.junit.Assert.assertTrue;
-import java.lang.reflect.Constructor;
-import java.lang.reflect.InvocationTargetException;
-import java.lang.reflect.Method;
-import java.util.ArrayList;
-import java.util.concurrent.TimeUnit;
-
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
-import org.onap.dmaap.mr.client.HostSelector;
-import org.onap.dmaap.mr.client.MRPublisher.message;
-import org.onap.dmaap.mr.test.support.MRBatchingPublisherMock.Listener;
-
public class SimpleExamplePublisherTest {
private SimpleExamplePublisher pub = null;
import static org.junit.Assert.assertTrue;
-import java.util.concurrent.TimeUnit;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
-import org.onap.dmaap.mr.client.HostSelector;
-
public class MRAppenderTest {
private MRAppender appender = null;
import static org.junit.Assert.assertTrue;
-import java.io.IOException;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
import static org.junit.Assert.assertTrue;
-import java.io.IOException;
-import java.lang.reflect.InvocationTargetException;
-import java.lang.reflect.Method;
-
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
import static org.junit.Assert.assertTrue;
-import java.io.IOException;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
import static org.junit.Assert.assertTrue;
-import java.io.IOException;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
import static org.junit.Assert.assertTrue;
-import java.io.IOException;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
import static org.junit.Assert.assertTrue;
-import java.io.IOException;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
import static org.junit.Assert.assertTrue;
-import java.io.IOException;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
import static org.junit.Assert.assertTrue;
-import java.lang.reflect.Constructor;
-import java.lang.reflect.InvocationTargetException;
-import java.lang.reflect.Method;
import java.util.ArrayList;
-import java.util.concurrent.TimeUnit;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
-import org.onap.dmaap.mr.client.HostSelector;
import org.onap.dmaap.mr.client.MRPublisher.message;
-import org.onap.dmaap.mr.test.support.MRBatchingPublisherMock.Listener;
public class MRBatchingPublisherMockTest {
private MRBatchingPublisherMock pub = null;
import java.io.IOException;
import java.util.ArrayList;
-import java.util.concurrent.TimeUnit;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
-import org.onap.dmaap.mr.client.HostSelector;
-import org.onap.dmaap.mr.client.MRPublisher.message;
-import org.onap.dmaap.mr.test.support.MRBatchingPublisherMock.Entry;
-
public class MRConsumerMockTest {
private MRConsumerMock cons = null;
private MRConsumerMock.Entry entry = null;
import static org.junit.Assert.assertTrue;
-import java.io.FileNotFoundException;
-import java.io.IOException;
-import java.io.PrintStream;
-import java.util.ArrayList;
-import java.util.concurrent.TimeUnit;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
-import com.att.nsa.apiClient.http.HttpTracer;
-import com.att.nsa.cmdtool.CommandNotReadyException;
-import org.onap.dmaap.mr.client.HostSelector;
-import org.onap.dmaap.mr.client.MRClient;
-import org.onap.dmaap.mr.client.MRPublisher.message;
-import org.onap.dmaap.mr.test.support.MRBatchingPublisherMock.Entry;
public class MRCommandContextTest {
private MRCommandContext command = null;