aboutsummaryrefslogtreecommitdiffstats
path: root/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/DmaapConsumerTaskImpl.java
AgeCommit message (Collapse)AuthorFilesLines
2019-12-06Refactor AaiClient API - package restructureMichal Kabaj1-1/+1
- Reorganized aaiclient related classes between api/impl/main packages Issue-ID: DCAEGEN2-1955 Signed-off-by: Michal Kabaj <michal.kabaj@nokia.com> Change-Id: Ie68f74cd94a6de0806c192046c1746af25979170
2019-06-12Align to new SDK versionJoanna Jeremicz1-2/+1
Change-Id: I06974c7f890bfa1cb875d776efa8b3a9f5b0a711 Issue-ID: DCAEGEN2-1613 Signed-off-by: Joanna Jeremicz <joanna.jeremicz@nokia.com>
2019-05-29SSL key loading for Dmaap clientgrabinsk1-16/+7
Change-Id: I65b3d0bcd6735af655c9243f20f3596ce8f03aca Issue-ID: DCAEGEN2-1501 Signed-off-by: grabinsk <maciej.grabinski@nokia.com>
2019-05-22Align PRH to El Alto SDKpwielebs1-21/+10
Change-Id: I65c445d76092e11084fb60c68740e1321b35708c Issue-ID: DCAEGEN2-1501 Signed-off-by: pwielebs <piotr.wielebski@nokia.com>
2019-04-10use CBS SDK in PRH (II)pwielebs1-5/+0
-remove unused classes -fix junit tests -use cbs -patch project version updated Change-Id: I5fb63408b33b07632eab579d028070eb3a025865 Issue-ID: DCAEGEN2-1360 Signed-off-by: pwielebs <piotr.wielebski@nokia.com>
2019-03-27Use SDK DMaaP Client genericMarcin Migdal1-2/+2
Change-Id: I031de4f59b7045f3bc45562edf3f58b86eace6bd Issue-ID: DCAEGEN2-1361 Signed-off-by: Marcin Migdal <marcin.migdal@nokia.com>
2019-03-20Fix JunitsMarcin Migdal1-6/+3
Change-Id: I4ed75b52a8d6266a4e09da3382fc06f3ed4c0ae0 Issue-ID: DCAEGEN2-1078 Signed-off-by: Marcin Migdal <marcin.migdal@nokia.com>
2019-03-20Integrate PRH with SDK in version 1.1.4pwielebs1-1/+8
- AAI client aligned - CBS client aligned - DmaaP client aligned Change-Id: I7afd0a44572e1097be5c3a4acc7221c7923cea8b Issue-ID: DCAEGEN2-1319 Signed-off-by: pwielebs <piotr.wielebski@nokia.com>
2018-12-18Integration with SDKpwielebs1-1/+2
* minor version upgraded in poms * align ConsumerDmaapModel to abstraction exposed in SDK * UTs modified Change-Id: Iaef2f9e8fab746106574771b2317c5689e047a5b Issue-ID: DCAEGEN2-1042 Signed-off-by: pwielebs <piotr.wielebski@nokia.com>
2018-12-03SDK integration: use aai in PRHmicdzied1-4/+4
Change-Id: I68c9a5323e05a27de463bef9dd368f8a092559ae Issue-ID: DCAEGEN2-1013 Signed-off-by: micdzied <michal.1.dziedzic@nokia.com>
2018-11-06SSL setup for dmaap consumerpkaras1-4/+6
Change-Id: I5856554fa05cfd9ad637c0491eb801f9937c967a Issue-ID: DCAEGEN2-951 Signed-off-by: piotr.karas <piotr.karas@nokia.com>
2018-11-05DmaaP Publisher and consumer interfaces ssl setuppkaras1-15/+11
Change-Id: I971d0fb222c6e8e15de4fc4a4d9eeb4ef3a99f44 Issue-ID: DCAEGEN2-944 Signed-off-by: piotr.karas <piotr.karas@nokia.com>
2018-10-26Simplify DmaaP Publisher and consumer interfacespkaras1-18/+15
Change-Id: Iaa7d870e8bd33687047832960c86adb7e97d969c Issue-ID: DCAEGEN2-922 Signed-off-by: piotr.karas <piotr.karas@nokia.com>
2018-10-08PRH DMaaP objects batchingwasala1-2/+3
*Getting collection of object in one request *Refator the workflow in the old implementation Change-Id: I4fdbf4bd8ae70cd78dbf5c3c441ba01c28e6ce4f Issue-ID: DCAEGEN2-834 Signed-off-by: wasala <przemyslaw.wasala@nokia.com>
2018-09-05delete unused importsmicdzied1-2/+0
Change-Id: I530e3d76ec9dd191c70abf520aa82a3af976847e Issue-ID: DCAEGEN2-750 Signed-off-by: micdzied <michal.1.dziedzic@nokia.com>
2018-09-04MDC fixmicdzied1-3/+1
Change-Id: I4b12f9b9914d93ee2969b4b3cf48a47837330a6d Issue-ID: DCAEGEN2-745 Signed-off-by: micdzied <michal.1.dziedzic@nokia.com>
2018-09-04Refatoring due to prh workflowpwielebs1-8/+5
1. Added specified HttpClient for DmaaPPublisher: *DmaaP Handle transfer-encoding: chunk header and reject the request if it will be set by the client. In conclusion no other reactive http client can be used for pushing something to dmaap. 2. Added sll support to A&AI rective webclient. *Behaviour of reactive A&AI HttpClient is different as in native spring have without it. 3. Added 10s fixed time in PRH for requesting DmaaP. 4. Added debug log in reactive/native http clients. 5. Fixed reactive workflow of prh. 6. Updated the version of: * spring-boot-dependencies:2.0.1.RELEASE->2.0.4.RELEASE * spring-boot-starter-reactor-netty:2.0.2.RELEASE->2.0.4.RELEASE * spring-webflux:5.0.5.RELEASE->5.0.8.RELEASE * reactor-bom:Bismuth-RELEASE->Bismuth-SR10 Change-Id: I815ffb5bdcf48d94f3b7c64040a73e98e404a5e8 Issue-ID: DCAEGEN2-743 Signed-off-by: pwielebs <piotr.wielebski@nokia.com>
2018-08-30add MDC'smicdzied1-2/+8
Change-Id: Ie4fe86791f46b790ae42088a5d2b93f491e4549d Issue-ID: DCAEGEN2-730 Signed-off-by: micdzied <michal.1.dziedzic@nokia.com>
2018-08-29Revert web server to prh, fix configurationJakub Zieba1-5/+2
Revert web server to prh, becaue it is used by health check Fix cloud configuration fetching Additional code refactoring Change-Id: Ic3d6f4c266064436e2701ec3ef3a7534b2d5b8b4 Issue-ID: DCAEGEN2-696 Signed-off-by: Jakub Zieba <jakub.zieba@nokia.com>
2018-08-22Fix for logging:pwielebs1-1/+0
- removal of authentication in Dmaap client - improvement of logging in the DmaaP's & AAI's clients - Dmaap Topic upgraded according to VES 7.0 spec - correction in tasks scheduling Change-Id: Ie0b153b5544c69be54718460247dcd1d83f6ebe2 Issue-ID: DCAEGEN2-721 Signed-off-by: pwielebs <piotr.wielebski@nokia.com>
2018-08-21Downloading prhConf fromConsulwasala1-6/+7
*Added backGround task for downloading dynamic Configuration from Consul *This configuration can pass for Kubernetes and heat (bare metal) deployment *Parsing/validation configuration from system environment Change-Id: I937cbda1bc8b715dc3e754bea8a39dd141180e49 Issue-ID: DCAEGEN2-696 Signed-off-by: wasala <przemyslaw.wasala@nokia.com>
2018-08-07Checkstyle violationswasala1-5/+6
*Correction of violations without javadoc Change-Id: Ida177bf32a58605e74feae5fab22198228e970ce Issue-ID: DCAEGEN2-563 Signed-off-by: wasala <przemyslaw.wasala@nokia.com>
2018-08-07Bug fixeswasala1-4/+3
Improve UnitTest Add changes after review in DmaaPReactiveTasks workflow Change-Id: I920092235528964758014c2d9d229ccd22e69cae Issue-ID: DCAEGEN2-563 Signed-off-by: wasala <przemyslaw.wasala@nokia.com>
2018-08-07Added JUnit for DMaaPWebClientwasala1-10/+3
Refactored DMaaP tasks for creation WebClient in higher abstraction level Change-Id: I4ae4f99d1f739a1718c5520929fc4eb8b4a6178e Issue-ID: DCAEGEN2-563 Signed-off-by: wasala <przemyslaw.wasala@nokia.com>
2018-08-07Added reactive DMaaPClientwasala1-11/+17
Extracted WebCLientBuilder for Producer and Consumer. Added unit test for ReactiveProducerClient. Change-Id: I632e6928813ed9feb48982900c173f741e4483e3 Issue-ID: DCAEGEN2-563 Signed-off-by: wasala <przemyslaw.wasala@nokia.com>
2018-08-07Refactor Optional in MonoResponsewasala1-5/+3
Added JUnit tests for DmaapConsumer Reactive Client. Added property for spring to run PRH as none-web application Change-Id: I8b762389927151387da5b79e8b75b670600ee5e8 Issue-ID: DCAEGEN2-563 Signed-off-by: wasala <przemyslaw.wasala@nokia.com>
2018-08-07DmaapConsumerReactive fixed testswasala1-5/+4
Change-Id: I888ef94a084f32a18c77c12a18fb6636a4f33649 Issue-ID: DCAEGEN2-557 Signed-off-by: wasala <przemyslaw.wasala@nokia.com>
2018-08-07Added dmaapReactiveConsumerwasala1-14/+16
*Tests have not been ready yet Change-Id: I2e1d9c4218f91ae2f066b28acdbaa1870d7d27e7 Issue-ID: DCAEGEN2-557 Signed-off-by: wasala <przemyslaw.wasala@nokia.com>
2018-08-06Cleaned in code in reactive taskswasala1-4/+3
*Formated code *Added handling exceptions *Deleted unused code Change-Id: I3e95bcb8ba7cdf85f6a1daaec7cadc86080e0b10 Issue-ID: DCAEGEN2-557 Signed-off-by: wasala <przemyslaw.wasala@nokia.com>
2018-08-06Added reactive tasks flow controlwasala1-18/+1
Change-Id: I9cb2bede66e9e446912f2e6a815c7b56b80813b9 Issue-ID: DCAEGEN2-557 Signed-off-by: wasala <przemyslaw.wasala@nokia.com>
2018-06-15Added simply logs from tasks.wasala1-8/+23
*Logging responsed object from DmaaP *Logging parsed oject from DmaaP *Logging sended object to AAI *Logging sended object and topic To DmaaP Change-Id: I33de0cd751762ac004f9d8a09beee921f4026af6 Issue-ID: DCAEGEN2-545 Signed-off-by: wasala <przemyslaw.wasala@nokia.com>
2018-06-12Catch empty response from DmaaPwasala1-1/+3
Change-Id: Ibd8739c3f9718eec15ff20e0b88d0bfcd4f6d84d Issue-ID: DCAEGEN2-540 Signed-off-by: wasala <przemyslaw.wasala@nokia.com>
2018-06-05Correction for DmaapJsonParserwasala1-1/+8
*Added cases fo uTests *Changed schedule tasks to 5s *Changed batching message to 1 Change-Id: I8daa4f143699488c8a593634ad67452b4a194437 Issue-ID: DCAEGEN2-540 Signed-off-by: wasala <przemyslaw.wasala@nokia.com>
2018-05-21Code refactorwasala1-14/+8
*DmaapTasks *AAITasks Change-Id: I62d2ae758b58435ca8930354cb86172236646c20 Issue-ID: DCAEGEN2-396 Signed-off-by: wasala <przemyslaw.wasala@nokia.com>
2018-05-17Added tests for DmaapPublisherTaskwasala1-4/+4
Change-Id: I2c265879bffd20e17dd8da981a4111cf2e10c375 Issue-ID: DCAEGEN2-396 Signed-off-by: wasala <przemyslaw.wasala@nokia.com>
2018-05-17Added tests for DmaapConsumerTaskwasala1-7/+19
Change-Id: I1068eb44eba5871f5c1e44e34f149584e056a7a2 Issue-ID: DCAEGEN2-396 Signed-off-by: wasala <przemyslaw.wasala@nokia.com>
2018-05-17Change package in prh-dmaap-client modulewasala1-2/+2
Move package org.onap.dcaegen2.services to org.onap.dcaegen2.services.prh Change-Id: Idef63833dcbc9cd28dda6b893245fcd16df4d97d Issue-ID: DCAEGEN2-396 Signed-off-by: wasala <przemyslaw.wasala@nokia.com>
2018-05-17Change package in prh-commons modulewasala1-1/+1
Move package org.onap.dcaegen2.services to org.onap.dcaegen2.services.prh Change-Id: Idb13c5f1173897fceb1a8544dd893f6f9fee2c52 Issue-ID: DCAEGEN2-396 Signed-off-by: wasala <przemyslaw.wasala@nokia.com>
2018-05-16Added test for AAIProducerTaskwasala1-2/+2
Included jacoco for Code Coverage Change-Id: I48ae221e7d83fcf11f1ca00bf5b6f9d00d78d9c1 Issue-ID: DCAEGEN2-396 Signed-off-by: wasala <przemyslaw.wasala@nokia.com>
2018-05-11AAI client configuration & tasks changedpwielebs1-4/+2
Change-Id: I86a2f2ed62565263f2be2c9078a092f993234a19 Issue-ID: DCAEGEN2-451 Signed-off-by: pwielebs <piotr.wielebski@nokia.com>
2018-05-09Added dmaap consumer task execution to workflowwasala1-18/+16
Change-Id: I67904a8ffb7d401fa2188fb046e28474eded4377 Issue-ID: DCAEGEN2-474 Signed-off-by: wasala <przemyslaw.wasala@nokia.com>
2018-04-27AAI tasks addedpwielebs1-2/+3
- aaiClients spllitted for consuming and producing - http removed from names of all clients and interfaces - HttpRequestDetails added as a second parameter for tasks - parameters required from dmaap consumer - pnf-name for URI (get request -> aaiConsumer) - pnf-name and ipv4-oam (and or ipv6-oam) (patch request -> aaiProducer) Change-Id: I87a1b46ab419cd00e9573e08c4d89cb384dd75b5 Issue-ID: DCAEGEN2-451 Signed-off-by: pwielebs <piotr.wielebski@nokia.com>
2018-04-25Parsing arguments from cloudify.wasala1-1/+2
*Added functionality for replacing default value from command line tosca template. Change-Id: I5923d9b5192f2f9df026320e1c6c56d4eaf9756a Issue-ID: DCAEGEN2-458 Signed-off-by: wasala <przemyslaw.wasala@nokia.com>
2018-04-25Load configuration by executing taskswasala1-0/+5
Change-Id: Ie8f18a836e42dabd96a8bdb41e6ba8189c59e023 Issue-ID: DCAEGEN2-469 Signed-off-by: wasala <przemyslaw.wasala@nokia.com>
2018-04-16Already added flow control for tasks.wasala1-9/+21
*The next step will be get common model for all request/response message based on HTTPClient implementation Change-Id: I76af15ab06cae783b6cec5099510d7f97e9d65c2 Issue-ID: DCAEGEN2-445 Signed-off-by: wasala <przemyslaw.wasala@nokia.com>
2018-04-13Extracted high abstraction for taskswasala1-0/+61
*First of all, all tasks were defined as implementation. *All tasks class have been injected into spring container. Change-Id: I00337b49ed1de3f1b8cadf64f774f19377ae349e Issue-ID: DCAEGEN2-443 Signed-off-by: wasala <przemyslaw.wasala@nokia.com>