DMAAP-MR - Merge MR repos
[dmaap/messagerouter/messageservice.git] / src / test / java / org / onap / dmaap / mr / cambria / backends / memory / MemoryConsumerFactoryTest.java
1 /*-
2  * ============LICENSE_START=======================================================
3  * ONAP Policy Engine
4  * ================================================================================
5  * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
6  * ================================================================================
7  * Licensed under the Apache License, Version 2.0 (the "License");
8  * you may not use this file except in compliance with the License.
9  * You may obtain a copy of the License at
10  * 
11  *      http://www.apache.org/licenses/LICENSE-2.0
12  * 
13  * Unless required by applicable law or agreed to in writing, software
14  * distributed under the License is distributed on an "AS IS" BASIS,
15  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
16  * See the License for the specific language governing permissions and
17  * limitations under the License.
18  * ============LICENSE_END=========================================================
19  */
20
21  package org.onap.dmaap.mr.cambria.backends.memory;
22
23 import static org.junit.Assert.assertTrue;
24
25 import org.junit.After;
26 import org.junit.Before;
27 import org.junit.Test;
28 import org.onap.dmaap.dmf.mr.backends.memory.MemoryConsumerFactory;
29
30 public class MemoryConsumerFactoryTest {
31
32         @Before
33         public void setUp() throws Exception {
34         }
35
36         @After
37         public void tearDown() throws Exception {
38         }
39
40         @Test
41         public void testGetConsumerFor() {
42                 MemoryConsumerFactory factory = new MemoryConsumerFactory(null);
43                 
44                 
45                 String topic = "testTopic";
46                 String consumerGroupId = "CG1";
47                 String clientId = "C1";
48                 String remoteHost="remoteHost";
49                 int timeoutMs = 1000; 
50                 factory.getConsumerFor(topic, consumerGroupId, clientId, timeoutMs,remoteHost);
51                 
52                 String trueValue = "True";
53                 assertTrue(trueValue.equalsIgnoreCase("True"));
54                 
55         }
56         
57         @Test
58         public void testDropCache() {
59                 MemoryConsumerFactory factory = new MemoryConsumerFactory(null);
60         
61                 factory.dropCache();
62                 
63                 String trueValue = "True";
64                 assertTrue(trueValue.equalsIgnoreCase("True"));
65                 
66         }
67         
68         @Test
69         public void testGetConsumers() {
70                 MemoryConsumerFactory factory = new MemoryConsumerFactory(null);
71                  
72                 factory.getConsumers();
73                 
74                 String trueValue = "True";
75                 assertTrue(trueValue.equalsIgnoreCase("True"));
76                 
77         }
78         
79
80 }