-/*
-* ============LICENSE_START=======================================================
-* ONAP : DCAE
-* ================================================================================
-* Copyright 2018 TechMahindra
-*=================================================================================
-* 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 org.onap.universalvesadapter.service;
-
-import static org.junit.Assert.*;
-import static org.mockito.Mockito.doNothing;
-import static org.mockito.Mockito.doReturn;
-
-import java.io.IOException;
-import java.util.Arrays;
-import java.util.Collections;
-
-import org.junit.Before;
-import org.junit.Ignore;
-import org.junit.Test;
-import org.junit.runner.RunWith;
-import org.mockito.ArgumentCaptor;
-import org.mockito.InjectMocks;
-import org.mockito.Mock;
-import org.mockito.Mockito;
-import org.mockito.MockitoAnnotations;
-import org.onap.universalvesadapter.Application;
-import org.onap.universalvesadapter.exception.DMaapException;
-import org.onap.universalvesadapter.service.DMaapService;
-import org.onap.universalvesadapter.service.VesService;
-import org.onap.universalvesadapter.utils.ParallelTasks;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.boot.test.context.SpringBootTest;
-import org.springframework.test.context.junit4.SpringRunner;
-
-import com.att.nsa.mr.client.MRConsumer;
-@Ignore
-@RunWith(SpringRunner.class)
-@SpringBootTest(classes = Application.class)
-public class VesServiceTest {
-
- @InjectMocks
- @Autowired
- private VesService vesService;
-
- @Mock
- private DMaapService dmaapService;
-
- private final Logger eLOGGER = LoggerFactory.getLogger(this.getClass());
-
- @Before
- public void init() {
- MockitoAnnotations.initMocks(this);
- }
-
-
- @Test
- public void testStart() throws IOException {
-
- String[] incomingMessages = {"{ "
- + " \"protocol version \": \"v2c \", "
- + " \"notify OID \": \".1.3.6.1.4.1.74.2.46.12.1.1AAA \", "
- + " \"cambria.partition \": \"dcae-snmp.client.research.att.com \", "
- + " \"trap category \": \"UCSNMP-HEARTBEAT \", "
- + " \"epoch_serno \": 15161177410000, "
- + " \"community \": \"public \", "
- + " \"time received \": 1516117741, "
- + " \"agent name \": \"localhost \", "
- + " \"agent address \": \"127.0.0.1 \", "
- + " \"community len \": 6, "
- + " \"notify OID len \": 12, "
- + " \"varbinds \": [{ "
- + " \"varbind_type \": \"octet \", "
- + " \"varbind_oid \": \".1.3.6.1.4.1.74.2.46.12.1.1.1 \", "
- + " \"varbind_value \": \"ucsnmp heartbeat - ignore \" "
- + " }, { "
- + " \"varbind_type \": \"octet \", "
- + " \"varbind_oid \": \".1.3.6.1.4.1.74.2.46.12.1.1.2 \", "
- + " \"varbind_value \": \"Tue Jan 16 10:49:01 EST 2018 \" "
- + " }] "
- + "}"};
- try {
- // Mockito.when(dmaapService.fetchAndPublishInDMaaP(null,null)).thenReturn(Arrays.asList(incomingMessages)).thenReturn(() -> Collections.emptyIterator());
- } catch (Exception e) {
- eLOGGER.error("Error occurred : " + e.getMessage());
- }
-
- ArgumentCaptor<?> valueCapture = ArgumentCaptor.forClass(String.class);
- try {
- //doNothing().when(dmaapService).fetchAndPublishInDMaaP((String) valueCapture.capture());
- } catch (DMaapException e) {
- eLOGGER.error("Error occurred : " + e.getMessage());
- }
-
-
- new Thread(new Runnable() {
-
- @Override
- public void run() {
- // TODO Auto-generated method stub
- vesService.start();
-
- }
- }).start();
- try {
- Thread.sleep(5000);
- } catch (InterruptedException e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
- }
- new Thread(new Runnable() {
-
- @Override
- public void run() {
- // TODO Auto-generated method stub
- vesService.stop();
-
- }
- }).start();
- String result = "{\"event\":{\"commonEventHeader\":{},\"faultFields\":{},\"measurementsForVfScalingFields\":{\"additionalMeasurements\":[]}}}";
- assertEquals(result, valueCapture.getValue());
- }
-
- @Test
- public void testStop() {
- fail("Not yet implemented");
- }
-
-}
-*/
\ No newline at end of file
+/*-\r
+ * ============LICENSE_START=======================================================\r
+ * ONAP : DCAE\r
+ * ================================================================================\r
+ * Copyright 2018-2019 TechMahindra\r
+ * ================================================================================\r
+ * Licensed under the Apache License, Version 2.0 (the "License");\r
+ * you may not use this file except in compliance with the License.\r
+ * You may obtain a copy of the License at\r
+ *\r
+ * http://www.apache.org/licenses/LICENSE-2.0\r
+ *\r
+ * Unless required by applicable law or agreed to in writing, software\r
+ * distributed under the License is distributed on an "AS IS" BASIS,\r
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
+ * See the License for the specific language governing permissions and\r
+ * limitations under the License.\r
+ * ============LICENSE_END=========================================================\r
+ *\r
+ * \r
+ * package org.onap.universalvesadapter.service;\r
+ * \r
+ * import static org.junit.Assert.*; import static org.mockito.Mockito.doNothing; import static\r
+ * org.mockito.Mockito.doReturn;\r
+ * \r
+ * import java.io.IOException; import java.util.Arrays; import java.util.Collections;\r
+ * \r
+ * import org.junit.Before; import org.junit.Ignore; import org.junit.Test; import\r
+ * org.junit.runner.RunWith; import org.mockito.ArgumentCaptor; import org.mockito.InjectMocks;\r
+ * import org.mockito.Mock; import org.mockito.Mockito; import org.mockito.MockitoAnnotations;\r
+ * import org.onap.universalvesadapter.Application; import\r
+ * org.onap.universalvesadapter.exception.DMaapException; import\r
+ * org.onap.universalvesadapter.service.DMaapService; import\r
+ * org.onap.universalvesadapter.service.VesService; import\r
+ * org.onap.universalvesadapter.utils.ParallelTasks; import org.slf4j.Logger; import\r
+ * org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import\r
+ * org.springframework.boot.test.context.SpringBootTest; import\r
+ * org.springframework.test.context.junit4.SpringRunner;\r
+ * \r
+ * import com.att.nsa.mr.client.MRConsumer;\r
+ * \r
+ * @Ignore\r
+ * \r
+ * @RunWith(SpringRunner.class)\r
+ * \r
+ * @SpringBootTest(classes = Application.class) public class VesServiceTest {\r
+ * \r
+ * @InjectMocks\r
+ * \r
+ * @Autowired private VesService vesService;\r
+ * \r
+ * @Mock private DMaapService dmaapService;\r
+ * \r
+ * private final Logger eLOGGER = LoggerFactory.getLogger(this.getClass());\r
+ * \r
+ * @Before public void init() { MockitoAnnotations.initMocks(this); }\r
+ * \r
+ * \r
+ * @Test public void testStart() throws IOException {\r
+ * \r
+ * String[] incomingMessages = {"{ " + " \"protocol version \": \"v2c \", " +\r
+ * " \"notify OID \": \".1.3.6.1.4.1.74.2.46.12.1.1AAA \", " +\r
+ * " \"cambria.partition \": \"dcae-snmp.client.research.att.com \", " +\r
+ * " \"trap category \": \"UCSNMP-HEARTBEAT \", " + " \"epoch_serno \": 15161177410000, " +\r
+ * " \"community \": \"public \", " + " \"time received \": 1516117741, " +\r
+ * " \"agent name \": \"localhost \", " + " \"agent address \": \"127.0.0.1 \", " +\r
+ * " \"community len \": 6, " + " \"notify OID len \": 12, " + " \"varbinds \": [{ " +\r
+ * " \"varbind_type \": \"octet \", " +\r
+ * " \"varbind_oid \": \".1.3.6.1.4.1.74.2.46.12.1.1.1 \", " +\r
+ * " \"varbind_value \": \"ucsnmp heartbeat - ignore \" " + " }, { " +\r
+ * " \"varbind_type \": \"octet \", " +\r
+ * " \"varbind_oid \": \".1.3.6.1.4.1.74.2.46.12.1.1.2 \", " +\r
+ * " \"varbind_value \": \"Tue Jan 16 10:49:01 EST 2018 \" " + " }] " + "}"}; try { //\r
+ * Mockito.when(dmaapService.fetchAndPublishInDMaaP(null,null)).\r
+ * thenReturn(Arrays.asList(incomingMessages)).thenReturn(() -> Collections.emptyIterator());\r
+ * \r
+ * } catch (Exception e) { eLOGGER.error("Error occurred : " + e.getMessage()); }\r
+ * \r
+ * ArgumentCaptor<?> valueCapture = ArgumentCaptor.forClass(String.class); try {\r
+ * //doNothing().when(dmaapService).fetchAndPublishInDMaaP((String) valueCapture.capture()); } catch\r
+ * (DMaapException e) { eLOGGER.error("Error occurred : " + e.getMessage()); }\r
+ * \r
+ * \r
+ * new Thread(new Runnable() {\r
+ * \r
+ * @Override public void run() { // TODO Auto-generated method stub vesService.start();\r
+ * \r
+ * } }).start(); try { Thread.sleep(5000); } catch (InterruptedException e) { // TODO Auto-generated\r
+ * catch block e.printStackTrace(); } new Thread(new Runnable() {\r
+ * \r
+ * @Override public void run() { // TODO Auto-generated method stub vesService.stop();\r
+ * \r
+ * } }).start(); String result = "{\"event\":{\"commonEventHeader\":{},\"faultFields\":{},\r
+ * \"measurementsForVfScalingFields\":{\"additionalMeasurements\":[]}}}"; assertEquals(result,\r
+ * valueCapture.getValue()); }\r
+ * \r
+ * @Test public void testStop() { fail("Not yet implemented"); }\r
+ * \r
+ * }\r
+ */\r
Code Review / dcaegen2 / services / mapper.git / blobdiff