diff options
Diffstat (limited to 'utils/DmaapPublisher/src')
15 files changed, 0 insertions, 668 deletions
diff --git a/utils/DmaapPublisher/src/main/java/org/openecomp/sdc/dmaap/CliArgs.java b/utils/DmaapPublisher/src/main/java/org/openecomp/sdc/dmaap/CliArgs.java deleted file mode 100644 index 87fdcdd87a..0000000000 --- a/utils/DmaapPublisher/src/main/java/org/openecomp/sdc/dmaap/CliArgs.java +++ /dev/null @@ -1,79 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * SDC - * ================================================================================ - * Copyright (C) 2019 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 org.openecomp.sdc.dmaap; - -import com.google.common.base.MoreObjects; -import org.kohsuke.args4j.Option; - -public class CliArgs { - - @Option(name="yml",aliases = {"-YML","YML","-yml","-YAML","YAML","-yaml"}, usage="mandatory arg. YAML filename", required=true) - private String yamlFilename; - - @Option(name="path",aliases = {"-path","PATH","-PATH"}, usage="mandatory arg. path to the yaml file which contains topic config (publisher data + messages)", required=true) - private String yamlPath; - - @Option(name="cr",aliases = {"CR","-cr","-CR"}, usage="optional arg. concurrent requests", required=false) - private String concurrentRequests; - - @Option(name="notification",aliases = {"NOTIFICATION","-NOTIFICATION","-notification"}, usage="optional load dynamic messages", required=false) - private String notificationData; - - public String getYamlPath() { - return yamlPath; - } - - public String getYamlFilename() { - return yamlFilename; - } - - public void setYamlPath(String yamlPath) { - this.yamlPath = yamlPath; - } - - - public String getConcurrentRequests() { - return concurrentRequests; - } - - public void setConcurrentRequests(String concurrentRequests) { - this.concurrentRequests = concurrentRequests; - } - - public String getNotificationData() { - return notificationData; - } - - - public void setYamlFilename(String yamlFilename) { - this.yamlFilename = yamlFilename; - } - - @Override - public String toString() { - return MoreObjects.toStringHelper(this) - .add("yamlPath", yamlPath) - .add("concurrentRequests", concurrentRequests) - .toString(); - } - - -} diff --git a/utils/DmaapPublisher/src/main/java/org/openecomp/sdc/dmaap/DmaapPublishTool.java b/utils/DmaapPublisher/src/main/java/org/openecomp/sdc/dmaap/DmaapPublishTool.java deleted file mode 100644 index 08411c6b69..0000000000 --- a/utils/DmaapPublisher/src/main/java/org/openecomp/sdc/dmaap/DmaapPublishTool.java +++ /dev/null @@ -1,109 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * SDC - * ================================================================================ - * Copyright (C) 2019 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 org.openecomp.sdc.dmaap; - -import com.att.nsa.mr.client.MRBatchingPublisher; -import com.att.nsa.mr.client.MRClientFactory; -import com.att.nsa.mr.client.MRPublisher.message; -import org.apache.commons.lang3.StringUtils; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; -import org.yaml.snakeyaml.Yaml; - -import java.util.concurrent.TimeUnit; - -public class DmaapPublishTool { - - private static final Logger logger = LoggerFactory.getLogger(DmaapPublishTool.class); - final private TopicConfig topicConfig; - - public DmaapPublishTool(String yamlPath) throws FileNotFoundException { - topicConfig = loadTopicConfig(yamlPath); - System.out.println("yaml file loaded."); - } - public DmaapPublishTool(String yamlPath , String notifications) throws FileNotFoundException { - topicConfig = loadTopicConfig(yamlPath); - if (StringUtils.isNotBlank(notifications) ) - topicConfig.add( notifications ); - System.out.println("yaml file loaded."); - } - - public void addNotifications(Collection<String> notification){ - topicConfig.addAll( notification ); - } - - //safe stream doesn't throw null pointer exception - public <T> Collection<T> safe(Collection<T> obj){ - return Optional.ofNullable(obj).orElse(Collections.emptySet()); - } - public <T> List<T> safe(List<T> obj){ - return Optional.ofNullable(obj).orElse(Collections.emptyList()); - } - - public void publish(String path) throws IOException, InterruptedException { - MRBatchingPublisher pub = createPublisher( topicConfig, path ); - System.out.println( "pending message count -> "+pub.getPendingMessageCount() ); - List<String> list = this.topicConfig.getIncomingTopicMessages(); - for(String msg : safe(list) ){ - publishOne( pub , msg ); - } - closePublisher(pub); - } - - private MRBatchingPublisher createPublisher(TopicConfig topicConfig,String path) throws IOException { - MRBatchingPublisher publisher = MRClientFactory.createBatchingPublisher(Objects.requireNonNull(Util.toPath(path,topicConfig.getPublisherPropertiesFilePath()))); - System.out.println("publisher created."); - return publisher; - } - - private TopicConfig loadTopicConfig(String yamlPath) throws FileNotFoundException { - File yamlFile = new File(Objects.requireNonNull(yamlPath)); - InputStream input = new FileInputStream(yamlFile); - Yaml yamlHelper = new Yaml(); - return yamlHelper.loadAs(input, TopicConfig.class); - } - - private void publishOne(MRBatchingPublisher pub, String msg) throws IOException, InterruptedException { - System.out.println("sending: " + msg); - pub.send(msg); - System.out.println("message sent."); - } - - private void closePublisher(MRBatchingPublisher pub) throws IOException, InterruptedException { - System.out.println("closing publisher..."); - // close the publisher to make sure everything's sent before exiting. The batching - // publisher interface allows the app to get the set of unsent messages. It could - // write them to disk, for example, to try to send them later. - final List<message> stuck = pub.close(20, TimeUnit.SECONDS); - if(!stuck.isEmpty()) - { - final String errMsg = stuck.size() + " messages unsent"; - logger.error(errMsg); - System.err.println(errMsg); - } - else - { - final String successMsg = "Clean exit; all messages sent."; - logger.info(successMsg); - System.out.println(successMsg); - } - } -} diff --git a/utils/DmaapPublisher/src/main/java/org/openecomp/sdc/dmaap/DmaapPublisher.java b/utils/DmaapPublisher/src/main/java/org/openecomp/sdc/dmaap/DmaapPublisher.java deleted file mode 100644 index 8bf39e56a1..0000000000 --- a/utils/DmaapPublisher/src/main/java/org/openecomp/sdc/dmaap/DmaapPublisher.java +++ /dev/null @@ -1,169 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * SDC - * ================================================================================ - * Copyright (C) 2019 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 org.openecomp.sdc.dmaap; - -import org.apache.commons.lang3.StringUtils; -import org.apache.commons.lang3.math.NumberUtils; -import org.kohsuke.args4j.CmdLineException; -import org.kohsuke.args4j.CmdLineParser; -import org.kohsuke.args4j.OptionHandlerFilter; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -import java.io.IOException; -import java.util.ArrayList; -import java.util.Collection; -import java.util.List; -import java.util.concurrent.ConcurrentLinkedDeque; -import java.util.concurrent.CopyOnWriteArrayList; -import java.util.function.Consumer; -import java.util.stream.IntStream; - -import static org.openecomp.sdc.dmaap.Util.*; - -public class DmaapPublisher { - private static final Logger logger = LoggerFactory.getLogger(DmaapPublisher.class); - private static RequestManager requestManager ; - private static final ConcurrentLinkedDeque notificationBuffer = new ConcurrentLinkedDeque(); - - - private static final List<Long> registeredTasks = new CopyOnWriteArrayList<>(); - private DmaapPublisher() {} - - public static void add(String notification){ - notificationBuffer.add( notification ); - } - public static void addAll(List<String> notifications){ - notificationBuffer.addAll( notifications ); - } - public static void main(String[] args) { - doPublish(args); - } - - private static void doPublish( String[] args ) { - CliArgs cliArgs = new CliArgs(); - CmdLineParser parser = new CmdLineParser(cliArgs); - - try { - // parse the arguments. - parser.parseArgument( args ); - doPublish( cliArgs ); - } - catch(CmdLineException e) { - logger.error("#doPublish - failed to parse arguments.", e); - printUsage(parser, e); - return; - } - } - - public static void doPublish( CliArgs cliArgs ){ - try { - // parse the arguments. - DmaapPublishTool tool = new DmaapPublishTool( toPath(cliArgs.getYamlPath() , cliArgs.getYamlFilename()) , cliArgs.getNotificationData() ); - Collection<String> notifications = new ArrayList<String>( notificationBuffer ); - tool.addNotifications( notifications ); - notificationBuffer.removeAll(notifications); - Integer concurrentRequestCount = 1; - if ( StringUtils.isNotBlank( cliArgs.getConcurrentRequests() ) ) - concurrentRequestCount = Integer.parseInt( cliArgs.getConcurrentRequests() ); - requestManager = new RequestManager( concurrentRequestCount ); - - IntStream.range(0,concurrentRequestCount).forEach( it -> { - //region - report upon finish mechanishem - long ticket = System.nanoTime(); - registeredTasks.add( ticket ); - Consumer callback = ( uniqueTicket ) -> { - synchronized ( registeredTasks ){ - registeredTasks.remove( (long)uniqueTicket ); - registeredTasks.notifyAll(); - }}; - - RunnableReporter task = new RunnableReporter( ticket , tool , cliArgs , callback ); - requestManager.getExecutor().execute( task ) ; - }); - } - catch(NumberFormatException e) { - logger.error("#doPublish - failed to parse argument CR.", e); - return; - } - catch(Exception e) { - logger.error("#doPublish - failed to publish.", e); - } - } - - public static class RunnableReporter implements Runnable{ - - final private long ticket ; - final private DmaapPublishTool tool; - final private CliArgs cliArgs; - final Consumer reporter; - - public RunnableReporter(final long ticket , final DmaapPublishTool tool , final CliArgs args , Consumer reporter){ - this.ticket = ticket ; - this.tool = tool ; - this.cliArgs = args ; - this.reporter = reporter; - } - @Override - public void run() { - try { - tool.publish( cliArgs.getYamlPath() ); - reporter.accept(ticket); - }catch(IOException e){ - logger.error("#doPublish - failed to publish.", e); - }catch(InterruptedException e){ - logger.error("#doPublish - cannot complete publish, thread interuppted.", e); - Thread.currentThread().interrupt(); - } - } - } - - - public static List<Long> getRegisteredTasks() { - return registeredTasks; - } - - public static void preparePublish( String path, String filename , String concurrentRequests ){ - - CliArgs cliArgs = new CliArgs(); - if ( StringUtils.isNotBlank( filename ) ) - cliArgs.setYamlFilename( filename ); - if ( StringUtils.isNotBlank( path ) ) - cliArgs.setYamlPath( path ); - if ( NumberUtils.isCreatable( concurrentRequests ) ) - cliArgs.setConcurrentRequests( concurrentRequests ); - - doPublish( cliArgs ); - - } - - - private static void printUsage(CmdLineParser parser, CmdLineException e) { - System.err.println( e.getMessage() ); - System.err.println("java DmaapPublisher [options...] arguments..."); - // print the list of available options - parser.printUsage(System.err); - System.err.println(); - // print option sample. This is useful some time - System.err.println(" Example: java DmaapPublisher " + parser.printExample(OptionHandlerFilter.ALL)); - - } -} diff --git a/utils/DmaapPublisher/src/main/java/org/openecomp/sdc/dmaap/RequestManager.java b/utils/DmaapPublisher/src/main/java/org/openecomp/sdc/dmaap/RequestManager.java deleted file mode 100644 index c30a397372..0000000000 --- a/utils/DmaapPublisher/src/main/java/org/openecomp/sdc/dmaap/RequestManager.java +++ /dev/null @@ -1,39 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * SDC - * ================================================================================ - * Copyright (C) 2019 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 org.openecomp.sdc.dmaap; - -import java.util.concurrent.Executor; -import java.util.concurrent.Executors; - -public class RequestManager { - - private Executor executor; - - public RequestManager(int poolSize ){ - int sz = Math.max( poolSize , 1); - int recommendedMaxSz = Runtime.getRuntime().availableProcessors() * 2; - executor = Executors.newFixedThreadPool( Math.min( sz , recommendedMaxSz ) ); - } - - public Executor getExecutor() { - return executor; - } -} diff --git a/utils/DmaapPublisher/src/main/java/org/openecomp/sdc/dmaap/TopicConfig.java b/utils/DmaapPublisher/src/main/java/org/openecomp/sdc/dmaap/TopicConfig.java deleted file mode 100644 index c76a0f57b0..0000000000 --- a/utils/DmaapPublisher/src/main/java/org/openecomp/sdc/dmaap/TopicConfig.java +++ /dev/null @@ -1,72 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * SDC - * ================================================================================ - * Copyright (C) 2019 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 org.openecomp.sdc.dmaap; - -import com.google.common.base.MoreObjects; - -import java.util.ArrayList; -import java.util.Collection; -import java.util.Collections; -import java.util.List; - -public class TopicConfig { - - private String publisherPropertiesFilePath; - private String[] topicMessages; //messages from file - private final List<String> incomingTopicMessages = Collections.synchronizedList( new ArrayList<String>() ); //incoming messages from network stream|Main - - public String getPublisherPropertiesFilePath() { - return publisherPropertiesFilePath; - } - public void setPublisherPropertiesFilePath(String publisherPropertiesFilePath) { - this.publisherPropertiesFilePath = publisherPropertiesFilePath; - } - - public List<String> getIncomingTopicMessages() { - return incomingTopicMessages; - } - public String[] getTopicMessages() { - return topicMessages; - } - //add incoming message - public TopicConfig add( String notifications ){ - incomingTopicMessages.add( notifications); - return this; - } - - public TopicConfig addAll( Collection<String> notifications ){ - incomingTopicMessages.addAll( notifications ); - return this; - } - - public void setTopicMessages(String[] topicMessages) { - this.topicMessages = topicMessages; - } - - @Override - public String toString() { - return MoreObjects.toStringHelper(this) - .add("publisherPropertiesFilePath", publisherPropertiesFilePath) - .add("topicMessages", topicMessages) - .toString(); - } - -} diff --git a/utils/DmaapPublisher/src/main/java/org/openecomp/sdc/dmaap/Util.java b/utils/DmaapPublisher/src/main/java/org/openecomp/sdc/dmaap/Util.java deleted file mode 100644 index cbc6198172..0000000000 --- a/utils/DmaapPublisher/src/main/java/org/openecomp/sdc/dmaap/Util.java +++ /dev/null @@ -1,39 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * SDC - * ================================================================================ - * Copyright (C) 2019 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 org.openecomp.sdc.dmaap; - -import org.apache.commons.lang3.StringUtils; - -import java.nio.file.InvalidPathException; - -public class Util { - - public static String toPath(String path , String filename) throws InvalidPathException{ - if (StringUtils.isNotBlank(path) ){ - if (path.trim().endsWith("/") || path.trim().endsWith("/")){ - return path+(filename!=null ? filename : ""); - } - return path+"/"+(filename!=null ? filename : ""); - - } - throw new InvalidPathException("wrong path configuration cannot find path -> ",path); - } -} diff --git a/utils/DmaapPublisher/src/main/resources/catalogMgmt.properties b/utils/DmaapPublisher/src/main/resources/catalogMgmt.properties deleted file mode 100644 index 748e90a778..0000000000 --- a/utils/DmaapPublisher/src/main/resources/catalogMgmt.properties +++ /dev/null @@ -1,35 +0,0 @@ -TransportType=DME2 -Latitude =32.109333 -Longitude =34.855499 -Version =1.0 -ServiceName =dmaap-v1.onap.org/events -Environment =TEST -Partner=BOT_R -routeOffer=MR1 -SubContextPath =/ -Protocol =https -MethodType =POST -username =onapdemo -password =Aa123456 -contenttype = application/json -Authorization = Basic b25hcGRlbW86QWExMjM0NTY= -authKey= -authDate= -#Dmaap Server Url port 3904-HTTP 3905-https -host=demo.onap.org:3904 -###topic=com.att.ccd.CCD-CatalogManagement-go539p or com.att.sdc.SDCforTestDev | com.att.sdc.23911-SDCforTestDev-v001 -#com.att.sdc.23911-scdc001dev001test-v1 -topic=com.att.sdc.23911-SDCforTestDev-v001 -partition=1 -maxBatchSize=100 -maxAgeMs=250 -AFT_DME2_EXCHANGE_REQUEST_HANDLERS=com.att.nsa.test.PreferredRouteRequestHandler -AFT_DME2_EXCHANGE_REPLY_HANDLERS=com.att.nsa.test.PreferredRouteReplyHandler -AFT_DME2_REQ_TRACE_ON=true -AFT_ENVIRONMENT=AFTUAT -AFT_DME2_EP_CONN_TIMEOUT=15000 -AFT_DME2_ROUNDTRIP_TIMEOUT_MS=240000 -AFT_DME2_EP_READ_TIMEOUT_MS=50000 -sessionstickinessrequired=NO -DME2preferredRouterFilePath=src/main/resources/preferredRouter.txt -MessageSentThreadOccurance=50
\ No newline at end of file diff --git a/utils/DmaapPublisher/src/main/resources/catalogMgmt.yaml b/utils/DmaapPublisher/src/main/resources/catalogMgmt.yaml deleted file mode 100644 index 04ac9fb992..0000000000 --- a/utils/DmaapPublisher/src/main/resources/catalogMgmt.yaml +++ /dev/null @@ -1,7 +0,0 @@ -publisherPropertiesFilePath: "catalogMgmt.properties" -topicMessages: - - "{\"operationalEnvironmentId\": \"1234\",\"operationalEnvironmentName\":\"Op Env Name\",\"operationalEnvironmentType\":\"ECOMP\",\"tenantContext\":\"Test\",\"workloadContext\":\"VNF_E2E-IST\",\"action\":\"CREATE\"}" - #- "{\"transactionId\": \"221e8cbe-493d-4848-b46c-a552b8928075\",\"notificationReason\":[\"product\"],\"republish\":\"No\"}" - #- "{\"transactionId\": \"221e8cbe-493d-4848-b46c-a552b8928075\",\"notificationReason\":[\"logo\"],\"republish\":\"No\"}" - #- "{\"transactionId\": \"221e8cbe-493d-4848-b46c-a552b8928075\",\"notificationReason\":[\"availabilitymatrix\"],\"republish\":\"No\"}" - #- "{\"transactionId\": \"221e8cbe-493d-4848-b46c-a552b8928075\",\"notificationReason\":[\"product\",\"availabilitymatrix\"],\"republish\":\"No\"}"
\ No newline at end of file diff --git a/utils/DmaapPublisher/src/main/resources/catalogWfMgmt.properties b/utils/DmaapPublisher/src/main/resources/catalogWfMgmt.properties deleted file mode 100644 index 7d0fd4cc0f..0000000000 --- a/utils/DmaapPublisher/src/main/resources/catalogWfMgmt.properties +++ /dev/null @@ -1,32 +0,0 @@ -TransportType=DME2 -Latitude =32.109333 -Longitude =34.855499 -Version =1.0 -ServiceName =dmaap-v1.onap.org/events -Environment =TEST -Partner=BOT_R -routeOffer=MR1 -SubContextPath =/ -Protocol =https -MethodType =POST -username =onapdemo -password =Aa123456 -contenttype = application/json -authKey= -authDate= -host=demo.onap.org:3904 -###topic=com.att.ccd.CCD-CatalogWorkflowManagement-go539p-v1 -topic=com.att.ccd.CCD-CatalogWorkflowManagement-v1 -partition=1 -maxBatchSize=100 -maxAgeMs=250 -AFT_DME2_EXCHANGE_REQUEST_HANDLERS=com.att.nsa.test.PreferredRouteRequestHandler -AFT_DME2_EXCHANGE_REPLY_HANDLERS=com.att.nsa.test.PreferredRouteReplyHandler -AFT_DME2_REQ_TRACE_ON=true -AFT_ENVIRONMENT=AFTUAT -AFT_DME2_EP_CONN_TIMEOUT=15000 -AFT_DME2_ROUNDTRIP_TIMEOUT_MS=240000 -AFT_DME2_EP_READ_TIMEOUT_MS=50000 -sessionstickinessrequired=NO -DME2preferredRouterFilePath=resources/preferredRouter.txt -MessageSentThreadOccurance=50
\ No newline at end of file diff --git a/utils/DmaapPublisher/src/main/resources/catalogWfMgmt.yaml b/utils/DmaapPublisher/src/main/resources/catalogWfMgmt.yaml deleted file mode 100644 index da2ebd635a..0000000000 --- a/utils/DmaapPublisher/src/main/resources/catalogWfMgmt.yaml +++ /dev/null @@ -1,6 +0,0 @@ -publisherPropertiesFilePath: "resources/catalogWfMgmt.properties" -topicMessages: - - "{\"transactionId\": \"221e8cbe-493d-4848-b46c-a552b8928075\",\"action\":\"Activate\"}" - #- "{\"transactionId\": \"221e8cbe-493d-4848-b46c-a552b8928075\",\"action\":\"Rollback\"}" - #- "{\"transactionId\": \"221e8cbe-493d-4848-b46c-a552b8928075\",\"action\":\"Activate\"}" - #- "{\"transactionId\": \"221e8cbe-493d-4848-b46c-a552b8928075\",\"action\":\"Activate\"}"
\ No newline at end of file diff --git a/utils/DmaapPublisher/src/main/resources/preferredRouter.txt b/utils/DmaapPublisher/src/main/resources/preferredRouter.txt deleted file mode 100644 index e69de29bb2..0000000000 --- a/utils/DmaapPublisher/src/main/resources/preferredRouter.txt +++ /dev/null diff --git a/utils/DmaapPublisher/src/test/java/org/openecomp/sdc/dmaap/DmaapPublisherTest.java b/utils/DmaapPublisher/src/test/java/org/openecomp/sdc/dmaap/DmaapPublisherTest.java deleted file mode 100644 index b0a3a5f2a9..0000000000 --- a/utils/DmaapPublisher/src/test/java/org/openecomp/sdc/dmaap/DmaapPublisherTest.java +++ /dev/null @@ -1,40 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * SDC - * ================================================================================ - * Copyright (C) 2019 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 org.openecomp.sdc.dmaap; - -import org.junit.Test; - -import java.io.File; - -import static org.junit.Assert.*; - -public class DmaapPublisherTest { - @Test - public void main() throws Exception { - File resource = new File("src/test/resources"); - String absPath = resource.getAbsolutePath(); - - String msg = "{\"operationalEnvironmentId\":\"12345\",\"operationalEnvironmentName\":\"Op_Env_Name\",\"operationalEnvironmentType\":\"ECOMP\",\"tenantContext\":\"Test\",\"workloadContext\":\"VNF_E2E-IST\",\"action\":\"CREATE\"}"; - String cmd = "-cr 5 "+ "-notification=" + msg+ " -path "+absPath+" -yaml catalogMgmtTest.yaml" ; - DmaapPublisher.main( cmd.split(" ") ); - Thread.sleep(10000); - } -} diff --git a/utils/DmaapPublisher/src/test/resources/catalogMgmtTest.properties b/utils/DmaapPublisher/src/test/resources/catalogMgmtTest.properties deleted file mode 100644 index 7fbd2d5b34..0000000000 --- a/utils/DmaapPublisher/src/test/resources/catalogMgmtTest.properties +++ /dev/null @@ -1,34 +0,0 @@ -TransportType=DME2 -Latitude =32.109333 -Longitude =34.855499 -Version =1.0 -ServiceName =dmaap-v1.onap.org/events -Environment =TEST -Partner=BOT_R -routeOffer=MR1 -SubContextPath =/ -Protocol =https -MethodType =POST -username =onapdemo -password =Aa123456 -contenttype = application/json -Authorization = Basic b25hcGRlbW86QWExMjM0NTY= -authKey= -authDate= -#Dmaap Server Url port 3904-HTTP 3905-https -host=demo.onap.org:3904 -###topic=com.att.ccd.CCD-CatalogManagement-go539p or com.att.sdc.SDCforTestDev | com.att.sdc.23911-SDCforTestDev-v001 -topic=com.att.sdc.23911-SDCforTestDev-v001 -partition=1 -maxBatchSize=100 -maxAgeMs=250 -AFT_DME2_EXCHANGE_REQUEST_HANDLERS=com.att.nsa.test.PreferredRouteRequestHandler -AFT_DME2_EXCHANGE_REPLY_HANDLERS=com.att.nsa.test.PreferredRouteReplyHandler -AFT_DME2_REQ_TRACE_ON=true -AFT_ENVIRONMENT=AFTUAT -AFT_DME2_EP_CONN_TIMEOUT=15000 -AFT_DME2_ROUNDTRIP_TIMEOUT_MS=240000 -AFT_DME2_EP_READ_TIMEOUT_MS=50000 -sessionstickinessrequired=NO -DME2preferredRouterFilePath=src/test/resources/preferredRouter.txt -MessageSentThreadOccurance=50
\ No newline at end of file diff --git a/utils/DmaapPublisher/src/test/resources/catalogMgmtTest.yaml b/utils/DmaapPublisher/src/test/resources/catalogMgmtTest.yaml deleted file mode 100644 index f55641d859..0000000000 --- a/utils/DmaapPublisher/src/test/resources/catalogMgmtTest.yaml +++ /dev/null @@ -1,7 +0,0 @@ -publisherPropertiesFilePath: "catalogMgmtTest.properties" -topicMessages: - - - "{\"transactionId\": \"221e8cbe-493d-4848-b46c-a552b8928075\",\"notificationReason\":[\"product\"],\"republish\":\"No\"}" - #- "{\"transactionId\": \"221e8cbe-493d-4848-b46c-a552b8928075\",\"notificationReason\":[\"logo\"],\"republish\":\"No\"}" - #- "{\"transactionId\": \"221e8cbe-493d-4848-b46c-a552b8928075\",\"notificationReason\":[\"availabilitymatrix\"],\"republish\":\"No\"}" - #- "{\"transactionId\": \"221e8cbe-493d-4848-b46c-a552b8928075\",\"notificationReason\":[\"product\",\"availabilitymatrix\"],\"republish\":\"No\"}"
\ No newline at end of file diff --git a/utils/DmaapPublisher/src/test/resources/preferredRouter.txt b/utils/DmaapPublisher/src/test/resources/preferredRouter.txt deleted file mode 100644 index e69de29bb2..0000000000 --- a/utils/DmaapPublisher/src/test/resources/preferredRouter.txt +++ /dev/null |