diff options
Diffstat (limited to 'src/test/resources')
| -rw-r--r-- | src/test/resources/DMaaPErrorMesaages.properties | 59 | ||||
| -rw-r--r-- | src/test/resources/MsgRtrApi.properties | 169 | ||||
| -rw-r--r-- | src/test/resources/spring-context.xml | 120 |
3 files changed, 348 insertions, 0 deletions
diff --git a/src/test/resources/DMaaPErrorMesaages.properties b/src/test/resources/DMaaPErrorMesaages.properties new file mode 100644 index 0000000..a3d6ce7 --- /dev/null +++ b/src/test/resources/DMaaPErrorMesaages.properties @@ -0,0 +1,59 @@ +############################################################################### +# ============LICENSE_START======================================================= +# org.onap.dmaap +# ================================================================================ +# Copyright © 2017 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========================================================= +# +# ECOMP is a trademark and service mark of AT&T Intellectual Property. +# +############################################################################### +############################################################################### +## +## DMaaP Error Messages +############################################################################### + +## +# Generic WebApplication Exceptions +## +resource.not.found=The requested resource was not found.Please verify the URL and try again. +server.unavailable=Server is temporarily unavailable or busy.Try again later, or try another server in the cluster. +http.method.not.allowed=The specified HTTP method is not allowed for the requested resource.Enter a valid HTTP method and try again. +incorrect.request.json=Incorrect JSON object. Please correct the JSON format and try again. +network.time.out=Connection to the DMaaP MR was timed out.Please try again. + +## +# AAF Errors +## +authentication.failure=Access Denied: Invalid Credentials. Enter a valid MechId and Password and try again. +not.permitted.access.1=Access Denied.User does not have permission to perform +not.permitted.access.2=operation on Topic: +unable.to.authorize=Unable to authorize the user. Please try again later. + + +## +#Topic +## +get.topic.failure=Failed to retrieve list of all topics. +get.topic.details.failure=Failed to retrieve details of topic: +create.topic.failure=Failed to create topic: +delete.topic.failure=Failed to delete topic: + +consume.msg.error=Error while reading data from topic. +publish.msg.error=Error while publishing data to topic. +msg_size_exceeds=Message size exceeds the default size. +publish.msg.count=Successfully published number of messages : + +incorrect.json=Incorrect JSON object.Could not parse JSON. Please correct the JSON format and try again. +topic.not.exist=No such topic exists.
\ No newline at end of file diff --git a/src/test/resources/MsgRtrApi.properties b/src/test/resources/MsgRtrApi.properties new file mode 100644 index 0000000..3aef922 --- /dev/null +++ b/src/test/resources/MsgRtrApi.properties @@ -0,0 +1,169 @@ +############################################################################### +# ============LICENSE_START======================================================= +# org.onap.dmaap +# ================================================================================ +# Copyright © 2017 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========================================================= +# +# ECOMP is a trademark and service mark of AT&T Intellectual Property. +# +############################################################################### +############################################################################### +## +## Cambria API Server config +## +## - Default values are shown as commented settings. +## + +############################################################################### +## +## HTTP service +## +## - 3904 is standard as of 7/29/14. +# +## Zookeeper Connection +## +## Both Cambria and Kafka make use of Zookeeper. +## +#config.zk.servers=172.18.1.1 +config.zk.servers=<zookeeper_host> +#config.zk.root=/fe3c/cambria/config + + +############################################################################### +## +## Kafka Connection +## +## Items below are passed through to Kafka's producer and consumer +## configurations (after removing "kafka.") +## if you want to change request.required.acks it can take this one value +#kafka.metadata.broker.list=localhost:9092,localhost:9093 +kafka.metadata.broker.list=<kafka_host>:<kafka_port> +##kafka.request.required.acks=-1 +#kafka.client.zookeeper=${config.zk.servers} +consumer.timeout.ms=100 +zookeeper.connection.timeout.ms=6000 +zookeeper.session.timeout.ms=20000 +zookeeper.sync.time.ms=2000 +auto.commit.interval.ms=1000 +fetch.message.max.bytes =1000000 +auto.commit.enable=false + +#(backoff*retries > zksessiontimeout) +kafka.rebalance.backoff.ms=10000 +kafka.rebalance.max.retries=6 + + +############################################################################### +## +## Secured Config +## +## Some data stored in the config system is sensitive -- API keys and secrets, +## for example. to protect it, we use an encryption layer for this section +## of the config. +## +## The key is a base64 encode AES key. This must be created/configured for +## each installation. +#cambria.secureConfig.key= +## +## The initialization vector is a 16 byte value specific to the secured store. +## This must be created/configured for each installation. +#cambria.secureConfig.iv= + +## Southfield Sandbox +cambria.secureConfig.key=b/7ouTn9FfEw2PQwL0ov/Q== +cambria.secureConfig.iv=wR9xP5k5vbz/xD0LmtqQLw== +authentication.adminSecret=fe3cCompound +#cambria.secureConfig.key[pc569h]=YT3XPyxEmKCTLI2NK+Sjbw== +#cambria.secureConfig.iv[pc569h]=rMm2jhR3yVnU+u2V9Ugu3Q== + + +############################################################################### +## +## Consumer Caching +## +## Kafka expects live connections from the consumer to the broker, which +## obviously doesn't work over connectionless HTTP requests. The Cambria +## server proxies HTTP requests into Kafka consumer sessions that are kept +## around for later re-use. Not doing so is costly for setup per request, +## which would substantially impact a high volume consumer's performance. +## +## This complicates Cambria server failover, because we often need server +## A to close its connection before server B brings up the replacement. +## + +## The consumer cache is normally enabled. +#cambria.consumer.cache.enabled=true + +## Cached consumers are cleaned up after a period of disuse. The server inspects +## consumers every sweepFreqSeconds and will clean up any connections that are +## dormant for touchFreqMs. +#cambria.consumer.cache.sweepFreqSeconds=15 +cambria.consumer.cache.touchFreqMs=120000 +##stickforallconsumerrequests=false +## The cache is managed through ZK. The default value for the ZK connection +## string is the same as config.zk.servers. +#cambria.consumer.cache.zkConnect=${config.zk.servers} + +## +## Shared cache information is associated with this node's name. The default +## name is the hostname plus the HTTP service port this host runs on. (The +## hostname is determined via InetAddress.getLocalHost ().getCanonicalHostName(), +## which is not always adequate.) You can set this value explicitly here. +## +#cambria.api.node.identifier=<use-something-unique-to-this-instance> + +#cambria.rateLimit.maxEmptyPollsPerMinute=30 +#cambria.rateLimitActual.delay.ms=10 + +############################################################################### +## +## Metrics Reporting +## +## This server can report its metrics periodically on a topic. +## +#metrics.send.cambria.enabled=true +#metrics.send.cambria.topic=cambria.apinode.metrics #msgrtr.apinode.metrics.dmaap +#metrics.send.cambria.sendEverySeconds=60 + +cambria.consumer.cache.zkBasePath=/fe3c/cambria/consumerCache +consumer.timeout=17 + +############################################################################## +#100mb +maxcontentlength=10000 + + +############################################################################## +#AAF Properties +msgRtr.namespace.aaf=org.onap.dmaap.mr.topic +msgRtr.topicfactory.aaf=org.onap.dmaap.mr.topicFactory|:org.onap.dmaap.mr.topic: +enforced.topic.name.AAF=org.onap.dmaap.mr +forceAAF=false +transidUEBtopicreqd=false +defaultNSforUEB=org.onap.dmaap.mr +############################################################################## +#Mirror Maker Agent +msgRtr.mirrormakeradmin.aaf=org.onap.dmaap.mr.mirrormaker|*|admin +msgRtr.mirrormakeruser.aaf=org.onap.dmaap.mr.mirrormaker|*|user +msgRtr.mirrormakeruser.aaf.create=org.onap.dmaap.mr.topicFactory|:org.onap.dmaap.mr.topic: +msgRtr.mirrormaker.timeout=15000 +msgRtr.mirrormaker.topic=org.onap.dmaap.mr.mmagent +msgRtr.mirrormaker.consumergroup=mmagentserver +msgRtr.mirrormaker.consumerid=1 + +kafka.max.poll.interval.ms=300000 +kafka.heartbeat.interval.ms=60000 +kafka.session.timeout.ms=240000 +kafka.max.poll.records=1000
\ No newline at end of file diff --git a/src/test/resources/spring-context.xml b/src/test/resources/spring-context.xml new file mode 100644 index 0000000..717dddf --- /dev/null +++ b/src/test/resources/spring-context.xml @@ -0,0 +1,120 @@ +<?xml version="1.0" encoding="UTF-8"?> +<!-- + ============LICENSE_START======================================================= + org.onap.dmaap + ================================================================================ + Copyright © 2017 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========================================================= + + ECOMP is a trademark and service mark of AT&T Intellectual Property. + + --> + +<beans xmlns="http://www.springframework.org/schema/beans" + xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:mvc="http://www.springframework.org/schema/mvc" + xmlns:context="http://www.springframework.org/schema/context" + xsi:schemaLocation=" + http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc-3.0.xsd + http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd + http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd"> + + <!-- Dependency Injection with annotations --> + <context:component-scan + base-package="com.att.nsa.cambria.utils,com.att.nsa.cambria.service.impl,com.att.nsa.cambria.exception" /> + + <context:property-placeholder + location="classpath:msgRtrApi.properties,classpath:DMaaPErrorMesaages.properties" /> + + + <bean id="propertyReader" class="com.att.nsa.cambria.utils.PropertyReader" /> + <bean + class="org.springframework.beans.factory.config.MethodInvokingFactoryBean"> + <!-- Next value is the full qualified name of the static setter including + method name --> + <property name="staticMethod" + value="com.att.nsa.cambria.beans.DMaaPKafkaConsumerFactory.populateKafkaInternalDefaultsMap" /> + <property name="arguments"> + <list> + <ref bean="propertyReader" /> + </list> + </property> + </bean> + + <bean id="drumlinRequestRouter" + class="com.att.nsa.drumlin.service.framework.routing.DrumlinRequestRouter" /> + + <bean id="dMaaPMetricsSet" class="com.att.nsa.cambria.beans.DMaaPMetricsSet"> + <constructor-arg ref="propertyReader" /> + </bean> + + <bean id="dMaaPZkClient" class=" com.att.nsa.cambria.beans.DMaaPZkClient"> + <constructor-arg ref="propertyReader" /> + </bean> + + <bean id="dMaaPZkConfigDb" class=" com.att.nsa.cambria.beans.DMaaPZkConfigDb"> + <constructor-arg ref="dMaaPZkClient" /> + <constructor-arg ref="propertyReader" /> + </bean> + + <bean id="kafkaPublisher" class=" com.att.nsa.cambria.backends.kafka.KafkaPublisher"> + <constructor-arg ref="propertyReader" /> + </bean> + + <bean id="dMaaPKafkaConsumerFactory" class=" com.att.nsa.cambria.beans.DMaaPKafkaConsumerFactory"> + <constructor-arg ref="propertyReader" /> + <constructor-arg ref="dMaaPMetricsSet" /> + <constructor-arg ref="curator" /> + </bean> + + <bean id="curator" class="com.att.nsa.cambria.utils.DMaaPCuratorFactory" + factory-method="getCurator"> + <constructor-arg ref="propertyReader" /> + </bean> + + <bean id="dMaaPKafkaMetaBroker" class=" com.att.nsa.cambria.beans.DMaaPKafkaMetaBroker"> + <constructor-arg ref="propertyReader" /> + <constructor-arg ref="dMaaPZkClient" /> + <constructor-arg ref="dMaaPZkConfigDb" /> + </bean> + + <!-- <bean id="q" class=" com.att.nsa.cambria.backends.memory.MemoryQueue" /> + + <bean id="mmb" class=" com.att.nsa.cambria.backends.memory.MemoryMetaBroker"> + <constructor-arg ref="q" /> + <constructor-arg ref="dMaaPZkConfigDb" /> + <constructor-arg ref="propertyReader" /> + </bean> + + <bean id="dMaaPNsaApiDb" class="com.att.nsa.cambria.beans.DMaaPNsaApiDb" + factory-method="buildApiKeyDb"> + <constructor-arg ref="propertyReader" /> + <constructor-arg ref="dMaaPZkConfigDb" /> + </bean> + + <bean id="dMaaPTranDb" class="com.att.nsa.cambria.transaction.DMaaPTransactionDB" + factory-method="buildTransactionDb"> <constructor-arg ref="propertyReader" + /> <constructor-arg ref="dMaaPZkConfigDb" /> </bean> + + <bean id="dMaaPAuthenticatorImpl" class="com.att.nsa.cambria.security.DMaaPAuthenticatorImpl"> + <constructor-arg ref="dMaaPNsaApiDb" /> + </bean> + <bean id="defLength" class="com.att.nsa.filter.DefaultLength"> + <property name="defaultLength" value="${maxcontentlength}"></property> + </bean> --> + + <!-- <bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"> + <property name="location"> <value>msgRtrApi.properties</value> </property> + </bean> --> + +</beans>
\ No newline at end of file |