src/test/java/com/att/nsa/cambria/backends/kafka/KafkaConsumerCacheTest.java

   1 /*-\r
   2  * ============LICENSE_START=======================================================\r
   3  * ONAP Policy Engine\r
   4  * ================================================================================\r
   5  * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.\r
   6  * ================================================================================\r
   7  * Licensed under the Apache License, Version 2.0 (the "License");\r
   8  * you may not use this file except in compliance with the License.\r
   9  * You may obtain a copy of the License at\r
  10  * \r
  11  *      http://www.apache.org/licenses/LICENSE-2.0\r
  12  * \r
  13  * Unless required by applicable law or agreed to in writing, software\r
  14  * distributed under the License is distributed on an "AS IS" BASIS,\r
  15  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
  16  * See the License for the specific language governing permissions and\r
  17  * limitations under the License.\r
  18  * ============LICENSE_END=========================================================\r
  19  */\r
  20 \r
  21 package com.att.nsa.cambria.backends.kafka;\r
  22 \r
  23 import static org.junit.Assert.*;\r
  24 \r
  25 import org.apache.curator.framework.CuratorFramework;\r
  26 import org.junit.After;\r
  27 import org.junit.Before;\r
  28 import org.junit.Test;\r
  29 \r
  30 import com.att.nsa.cambria.backends.MetricsSet;\r
  31 import com.att.nsa.cambria.backends.kafka.KafkaConsumerCache.KafkaConsumerCacheException;\r
  32 \r
  33 public class KafkaConsumerCacheTest {\r
  34 \r
  35         @Before\r
  36         public void setUp() throws Exception {\r
  37         }\r
  38 \r
  39         @After\r
  40         public void tearDown() throws Exception {\r
  41         }\r
  42 \r
  43         // DOES NOT WORK\r
  44         @Test\r
  45         public void testStartCache() {\r
  46 \r
  47                 /*\r
  48                  * KafkaConsumerCache kafka = null;\r
  49                  * \r
  50                  * try { kafka = new KafkaConsumerCache("123", null);\r
  51                  * \r
  52                  * } catch (NoClassDefFoundError e) { try { kafka.startCache("DMAAP",\r
  53                  * null); } catch (NullPointerException e1) { // TODO Auto-generated\r
  54                  * catch block assertTrue(true); } catch (KafkaConsumerCacheException\r
  55                  * e1) { // TODO Auto-generated catch block e1.printStackTrace(); } }\r
  56                  */\r
  57 \r
  58                 KafkaConsumerCache kafka = null;\r
  59                 new CuratorFrameworkImpl();\r
  60                 new MetricsSetImpl();\r
  61                 try {\r
  62                         kafka = new KafkaConsumerCache("123", null);\r
  63                         kafka.startCache("DMAAP", null);\r
  64                 } catch (NoClassDefFoundError e) {\r
  65 \r
  66                 } catch (KafkaConsumerCacheException e) {\r
  67                         // TODO Auto-generated catch block\r
  68                         e.printStackTrace();\r
  69                 }\r
  70 \r
  71         }\r
  72 \r
  73         @Test\r
  74         public void testGetCuratorFramework() {\r
  75 \r
  76                 CuratorFramework curator = new CuratorFrameworkImpl();\r
  77                 new MetricsSetImpl();\r
  78                 try {\r
  79 \r
  80                 } catch (NoClassDefFoundError e) {\r
  81 \r
  82                         KafkaConsumerCache.getCuratorFramework(curator);\r
  83                 }\r
  84 \r
  85         }\r
  86 \r
  87         /*@Test\r
  88         public void testStopCache() {\r
  89 \r
  90                 KafkaConsumerCache kafka = null;\r
  91                 new CuratorFrameworkImpl();\r
  92                 new MetricsSetImpl();\r
  93                 try {\r
  94                         kafka = new KafkaConsumerCache("123", null);\r
  95                         kafka.stopCache();\r
  96                 } catch (NoClassDefFoundError e) {\r
  97 \r
  98                 }\r
  99 \r
 100         }*/\r
 101 \r
 102         @Test\r
 103         public void testGetConsumerFor() {\r
 104 \r
 105                 KafkaConsumerCache kafka = null;\r
 106 \r
 107                 try {\r
 108                         kafka = new KafkaConsumerCache("123", null);\r
 109                         kafka.getConsumerFor("testTopic", "CG1", "23");\r
 110                 } catch (NoClassDefFoundError e) {\r
 111 \r
 112                 } catch (KafkaConsumerCacheException e) {\r
 113                         // TODO Auto-generated catch block\r
 114                         e.printStackTrace();\r
 115                 }\r
 116 \r
 117         }\r
 118 \r
 119         @Test\r
 120         public void testPutConsumerFor() {\r
 121 \r
 122                 KafkaConsumer consumer = null;\r
 123                 KafkaConsumerCache kafka = null;\r
 124 \r
 125                 try {\r
 126                         kafka = new KafkaConsumerCache("123", null);\r
 127 \r
 128                 } catch (NoClassDefFoundError e) {\r
 129                         try {\r
 130                                 kafka.putConsumerFor("testTopic", "CG1", "23", consumer);\r
 131                         } catch (NullPointerException e1) {\r
 132                                 // TODO Auto-generated catch block\r
 133                                 assertTrue(true);\r
 134                         } catch (KafkaConsumerCacheException e1) {\r
 135                                 // TODO Auto-generated catch block\r
 136                                 e1.printStackTrace();\r
 137                         }\r
 138                 }\r
 139 \r
 140         }\r
 141 \r
 142         @Test\r
 143         public void testGetConsumers() {\r
 144 \r
 145                 KafkaConsumerCache kafka = null;\r
 146 \r
 147                 try {\r
 148                         kafka = new KafkaConsumerCache("123", null);\r
 149 \r
 150                 } catch (NoClassDefFoundError e) {\r
 151                         try {\r
 152                                 kafka.getConsumers();\r
 153                         } catch (NullPointerException e1) {\r
 154                                 // TODO Auto-generated catch block\r
 155                                 assertTrue(true);\r
 156                         }\r
 157                 }\r
 158 \r
 159         }\r
 160 \r
 161         @Test\r
 162         public void testDropAllConsumers() {\r
 163 \r
 164                 KafkaConsumerCache kafka = null;\r
 165                 try {\r
 166                         kafka = new KafkaConsumerCache("123", null);\r
 167 \r
 168                 } catch (NoClassDefFoundError e) {\r
 169                         try {\r
 170                                 kafka.dropAllConsumers();\r
 171                         } catch (NullPointerException e1) {\r
 172                                 // TODO Auto-generated catch block\r
 173                                 assertTrue(true);\r
 174                         }\r
 175                 }\r
 176 \r
 177         }\r
 178 \r
 179         @Test\r
 180         public void testSignalOwnership() {\r
 181 \r
 182                 KafkaConsumerCache kafka = null;\r
 183 \r
 184                 try {\r
 185                         kafka = new KafkaConsumerCache("123", null);\r
 186                         // kafka.signalOwnership("testTopic", "CG1", "23");\r
 187                 } catch (NoClassDefFoundError e) {\r
 188                         try {\r
 189                                 kafka.signalOwnership("testTopic", "CG1", "23");\r
 190                         } catch (KafkaConsumerCacheException e1) {\r
 191                                 // TODO Auto-generated catch block\r
 192                                 e.printStackTrace();\r
 193                         } catch (NullPointerException e1) {\r
 194                                 // TODO Auto-generated catch block\r
 195                                 //assertTrue(true);\r
 196                                 e1.printStackTrace();\r
 197                         }\r
 198 \r
 199                 }\r
 200                 \r
 201                 //assertTrue(true);\r
 202         }\r
 203 \r
 204         @Test\r
 205         public void testDropConsumer() {\r
 206 \r
 207                 KafkaConsumerCache kafka = null;\r
 208 \r
 209                 try {\r
 210                         kafka = new KafkaConsumerCache("123", null);\r
 211                         // kafka.dropConsumer("testTopic", "CG1", "23");\r
 212                 } catch (NoClassDefFoundError e) {\r
 213                         try {\r
 214                                 kafka.dropConsumer("testTopic", "CG1", "23");\r
 215                         } catch (NullPointerException e1) {\r
 216                                 // TODO Auto-generated catch block\r
 217                                 assertTrue(true);\r
 218                         }\r
 219                 }\r
 220 \r
 221         }\r
 222 \r
 223 }\r