apiroute/apiroute-service/src/test/java/org/onap/msb/apiroute/SyncDataManagerTest.java

   1 package org.onap.msb.apiroute;
   2
   3 import org.junit.Before;
   4 import org.junit.Test;
   5 import org.junit.runner.RunWith;
   6 import org.mockito.Mockito;
   7 import org.onap.msb.apiroute.SyncDataManager;
   8 import org.onap.msb.apiroute.wrapper.consulextend.async.ConsulResponseCallback;
   9 import org.onap.msb.apiroute.wrapper.consulextend.util.Http;
  10 import org.powermock.api.mockito.PowerMockito;
  11 import org.powermock.core.classloader.annotations.PowerMockIgnore;
  12 import org.powermock.core.classloader.annotations.PrepareForTest;
  13 import org.powermock.modules.junit4.PowerMockRunner;
  14
  15 import com.fasterxml.jackson.core.type.TypeReference;
  16
  17 @RunWith(PowerMockRunner.class)
  18 @PrepareForTest({ Http.class })
  19 @PowerMockIgnore({ "javax.net.ssl.*" })
  20 public class SyncDataManagerTest {
  21
  22         @SuppressWarnings("unchecked")
  23         @Before
  24         public void setUpBeforeTest() {
  25                 Http http = PowerMockito.mock(Http.class);
  26
  27                 PowerMockito
  28                                 .doNothing()
  29                                 .when(http)
  30                                 .asyncGet(Mockito.anyString(),
  31                                                 Mockito.any(TypeReference.class),
  32                                                 Mockito.any(ConsulResponseCallback.class));
  33
  34                 PowerMockito
  35                                 .doNothing()
  36                                 .when(http)
  37                                 .asyncGetDelayHandle(Mockito.anyString(),
  38                                                 Mockito.any(TypeReference.class),
  39                                                 Mockito.any(ConsulResponseCallback.class));
  40
  41                 //
  42                 PowerMockito.spy(Http.class);
  43                 PowerMockito.when(Http.getInstance()).thenReturn(http);
  44
  45         }
  46
  47         @Test
  48         public void testSyncDataManager()
  49         {
  50                 SyncDataManager.initSyncTask("127.0.0.1",8500);
  51                 SyncDataManager.startWatchService("huangleibo");
  52                 SyncDataManager.resetIndex("huangleibo");
  53                 SyncDataManager.stopWatchService("huangleibo");
  54                 SyncDataManager.stopWatchServiceList();
  55         }
  56 }