diff options
Diffstat (limited to 'src/test/java/com/att/nsa/cambria/backends/memory')
7 files changed, 15 insertions, 103 deletions
diff --git a/src/test/java/com/att/nsa/cambria/backends/memory/JUnitTestSuite.java b/src/test/java/com/att/nsa/cambria/backends/memory/JUnitTestSuite.java index ba5a7c6..fc11552 100644 --- a/src/test/java/com/att/nsa/cambria/backends/memory/JUnitTestSuite.java +++ b/src/test/java/com/att/nsa/cambria/backends/memory/JUnitTestSuite.java @@ -29,7 +29,7 @@ import org.apache.log4j.Logger; @RunWith(Suite.class)
@SuiteClasses({ MemoryConsumerFactoryTest.class, MemoryMetaBrokerTest.class, MemoryQueueTest.class,
- MemoryQueuePublisherTest.class, MessageDropperTest.class, MessageLoggerTest.class, })
+ MemoryQueuePublisherTest.class, MessageLoggerTest.class, })
public class JUnitTestSuite {
private static final Logger LOGGER = Logger.getLogger(JUnitTestSuite.class);
diff --git a/src/test/java/com/att/nsa/cambria/backends/memory/MemoryConsumerFactoryTest.java b/src/test/java/com/att/nsa/cambria/backends/memory/MemoryConsumerFactoryTest.java index 7b470bc..d6fe6e6 100644 --- a/src/test/java/com/att/nsa/cambria/backends/memory/MemoryConsumerFactoryTest.java +++ b/src/test/java/com/att/nsa/cambria/backends/memory/MemoryConsumerFactoryTest.java @@ -28,6 +28,8 @@ import org.junit.After; import org.junit.Before;
import org.junit.Test;
+import com.att.dmf.mr.backends.memory.MemoryConsumerFactory;
+
public class MemoryConsumerFactoryTest {
@Before
@@ -46,8 +48,9 @@ public class MemoryConsumerFactoryTest { String topic = "testTopic";
String consumerGroupId = "CG1";
String clientId = "C1";
+ String remoteHost="remoteHost";
int timeoutMs = 1000;
- factory.getConsumerFor(topic, consumerGroupId, clientId, timeoutMs);
+ factory.getConsumerFor(topic, consumerGroupId, clientId, timeoutMs,remoteHost);
String trueValue = "True";
assertTrue(trueValue.equalsIgnoreCase("True"));
diff --git a/src/test/java/com/att/nsa/cambria/backends/memory/MemoryMetaBrokerTest.java b/src/test/java/com/att/nsa/cambria/backends/memory/MemoryMetaBrokerTest.java index b15cb2f..2c41068 100644 --- a/src/test/java/com/att/nsa/cambria/backends/memory/MemoryMetaBrokerTest.java +++ b/src/test/java/com/att/nsa/cambria/backends/memory/MemoryMetaBrokerTest.java @@ -28,7 +28,8 @@ import org.junit.After; import org.junit.Before;
import org.junit.Test;
-import com.att.nsa.cambria.metabroker.Broker.TopicExistsException;
+import com.att.dmf.mr.backends.memory.MemoryMetaBroker;
+import com.att.dmf.mr.metabroker.Broker.TopicExistsException;
public class MemoryMetaBrokerTest {
diff --git a/src/test/java/com/att/nsa/cambria/backends/memory/MemoryQueuePublisherTest.java b/src/test/java/com/att/nsa/cambria/backends/memory/MemoryQueuePublisherTest.java index 8ee4bd1..4522734 100644 --- a/src/test/java/com/att/nsa/cambria/backends/memory/MemoryQueuePublisherTest.java +++ b/src/test/java/com/att/nsa/cambria/backends/memory/MemoryQueuePublisherTest.java @@ -28,6 +28,8 @@ import org.junit.After; import org.junit.Before;
import org.junit.Test;
+import com.att.dmf.mr.backends.memory.MemoryQueuePublisher;
+
public class MemoryQueuePublisherTest {
@@ -44,7 +46,7 @@ public class MemoryQueuePublisherTest { MemoryQueuePublisher publisher = new MemoryQueuePublisher(null, null);
try {
- publisher.sendBatchMessage("testTopic", null);
+ publisher.sendBatchMessageNew("testTopic", null);
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
diff --git a/src/test/java/com/att/nsa/cambria/backends/memory/MemoryQueueTest.java b/src/test/java/com/att/nsa/cambria/backends/memory/MemoryQueueTest.java index fdb84d0..637add2 100644 --- a/src/test/java/com/att/nsa/cambria/backends/memory/MemoryQueueTest.java +++ b/src/test/java/com/att/nsa/cambria/backends/memory/MemoryQueueTest.java @@ -27,6 +27,8 @@ import org.junit.After; import org.junit.Before;
import org.junit.Test;
+import com.att.dmf.mr.backends.memory.MemoryQueue;
+
public class MemoryQueueTest {
diff --git a/src/test/java/com/att/nsa/cambria/backends/memory/MessageDropperTest.java b/src/test/java/com/att/nsa/cambria/backends/memory/MessageDropperTest.java deleted file mode 100644 index c27621e..0000000 --- a/src/test/java/com/att/nsa/cambria/backends/memory/MessageDropperTest.java +++ /dev/null @@ -1,98 +0,0 @@ -/*-
- * ============LICENSE_START=======================================================
- * ONAP Policy Engine
- * ================================================================================
- * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
- * ================================================================================
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * ============LICENSE_END=========================================================
- */
-
-package com.att.nsa.cambria.backends.memory;
-
-import static org.junit.Assert.*;
-
-import java.io.IOException;
-import java.util.ArrayList;
-import java.util.List;
-
-import org.junit.After;
-import org.junit.Before;
-import org.junit.Test;
-
-import com.att.nsa.cambria.backends.Publisher.message;
-import com.att.nsa.cambria.metabroker.Broker.TopicExistsException;
-
-import kafka.producer.KeyedMessage;
-
-public class MessageDropperTest {
-
- @Before
- public void setUp() throws Exception {
- }
-
- @After
- public void tearDown() throws Exception {
- }
-
- @Test
- public void testSendMessage() {
- MessageDropper dropper = new MessageDropper();
-
- try {
- dropper.sendMessage("testTopic", null);
- } catch (IOException e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
- }
-
- String trueValue = "True";
- assertTrue(trueValue.equalsIgnoreCase("True"));
-
- }
-
- @Test
- public void testSendMessages() {
- MessageDropper dropper = new MessageDropper();
-
- try {
- dropper.sendMessages("testTopic", null);
- } catch (IOException e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
- }
-
- String trueValue = "True";
- assertTrue(trueValue.equalsIgnoreCase("True"));
-
- }
-
-
- @Test
- public void testSendBatchMessage() {
- MessageDropper dropper = new MessageDropper();
-
- try {
- dropper.sendBatchMessage("testTopic", null);
- } catch (IOException e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
- }
-
- String trueValue = "True";
- assertTrue(trueValue.equalsIgnoreCase("True"));
-
- }
-
-
-}
diff --git a/src/test/java/com/att/nsa/cambria/backends/memory/MessageLoggerTest.java b/src/test/java/com/att/nsa/cambria/backends/memory/MessageLoggerTest.java index d2ae163..81e620c 100644 --- a/src/test/java/com/att/nsa/cambria/backends/memory/MessageLoggerTest.java +++ b/src/test/java/com/att/nsa/cambria/backends/memory/MessageLoggerTest.java @@ -28,6 +28,8 @@ import org.junit.After; import org.junit.Before;
import org.junit.Test;
+import com.att.dmf.mr.backends.memory.MessageLogger;
+
public class MessageLoggerTest {
@@ -82,7 +84,7 @@ public class MessageLoggerTest { MessageLogger dropper = new MessageLogger();
try {
- dropper.sendBatchMessage("testTopic", null);
+ dropper.sendBatchMessageNew("testTopic", null);
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
|