aboutsummaryrefslogtreecommitdiffstats
path: root/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/DmaapConsumerTask.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-05-30Fix Sonar issuespwielebs1-0/+1
Change-Id: If7134bf3b5aabdba6d057562ae863b40412e2d6b Issue-ID: DCAEGEN2-1501 Signed-off-by: pwielebs <piotr.wielebski@nokia.com>
2019-05-29SSL key loading for Dmaap clientgrabinsk1-3/+1
Change-Id: I65b3d0bcd6735af655c9243f20f3596ce8f03aca Issue-ID: DCAEGEN2-1501 Signed-off-by: grabinsk <maciej.grabinski@nokia.com>
2019-05-22Align PRH to El Alto SDKpwielebs1-7/+2
Change-Id: I65c445d76092e11084fb60c68740e1321b35708c Issue-ID: DCAEGEN2-1501 Signed-off-by: pwielebs <piotr.wielebski@nokia.com>
2019-04-10use CBS SDK in PRH (II)pwielebs1-2/+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>
2018-12-18Integration with SDKpwielebs1-1/+3
* 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-2/+2
Change-Id: I68c9a5323e05a27de463bef9dd368f8a092559ae Issue-ID: DCAEGEN2-1013 Signed-off-by: micdzied <michal.1.dziedzic@nokia.com>
2018-11-06SSL setup for dmaap consumerpkaras1-2/+4
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-3/+0
Change-Id: I971d0fb222c6e8e15de4fc4a4d9eeb4ef3a99f44 Issue-ID: DCAEGEN2-944 Signed-off-by: piotr.karas <piotr.karas@nokia.com>
2018-10-26Simplify DmaaP Publisher and consumer interfacespkaras1-14/+5
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-04Fixing code issuespwielebs1-1/+1
1. SonarIssues 2. CheckStyle corrections 3. Empty code deletions 4. Adding AAIHeaders config to cloud configurations Change-Id: Id624c52bc7f57338fad5276fffd9f29b21af2f69 Issue-ID: DCAEGEN2-606 Signed-off-by: pwielebs <piotr.wielebski@nokia.com>
2018-09-04Refatoring due to prh workflowpwielebs1-3/+2
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-07Checkstyle violationswasala1-0/+1
*Correction of violations without javadoc Change-Id: Ida177bf32a58605e74feae5fab22198228e970ce Issue-ID: DCAEGEN2-563 Signed-off-by: wasala <przemyslaw.wasala@nokia.com>
2018-08-07Bug fixeswasala1-5/+1
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-1/+13
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-2/+2
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-2/+2
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-2/+3
Change-Id: I888ef94a084f32a18c77c12a18fb6636a4f33649 Issue-ID: DCAEGEN2-557 Signed-off-by: wasala <przemyslaw.wasala@nokia.com>
2018-08-07Added dmaapReactiveConsumerwasala1-4/+5
*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-2/+2
*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-1/+3
Change-Id: I9cb2bede66e9e446912f2e6a815c7b56b80813b9 Issue-ID: DCAEGEN2-557 Signed-off-by: wasala <przemyslaw.wasala@nokia.com>
2018-06-15Added simply logs from tasks.wasala1-2/+2
*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-05-23Fix sonar issueswasala1-1/+1
Change-Id: I61155448422f0084ac08f294452ac90f5b3454aa Issue-ID: DCAEGEN2-396 Signed-off-by: wasala <przemyslaw.wasala@nokia.com>
2018-05-21Code refactorwasala1-3/+5
*DmaapTasks *AAITasks Change-Id: I62d2ae758b58435ca8930354cb86172236646c20 Issue-ID: DCAEGEN2-396 Signed-off-by: wasala <przemyslaw.wasala@nokia.com>
2018-05-17Added tests for DmaapConsumerTaskwasala1-2/+4
Change-Id: I1068eb44eba5871f5c1e44e34f149584e056a7a2 Issue-ID: DCAEGEN2-396 Signed-off-by: wasala <przemyslaw.wasala@nokia.com>
2018-05-09Added dmaap consumer task execution to workflowwasala1-2/+2
Change-Id: I67904a8ffb7d401fa2188fb046e28474eded4377 Issue-ID: DCAEGEN2-474 Signed-off-by: wasala <przemyslaw.wasala@nokia.com>
2018-04-16Already added flow control for tasks.wasala1-1/+3
*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-29/+7
*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>
2018-04-12Already added loading config for AAI and DMAAPwasala1-0/+6
First of all we have defined a file in which we have pointer to configuration file for DMAAP and AAI After that added UT Change-Id: I7f9554a019b348a3460f5fa9d8dd3e4002a6686f Issue-ID: DCAEGEN2-407 Signed-off-by: wasala <przemyslaw.wasala@nokia.com>
2018-04-05Add endpoint for load configuration(DMaaP, A&AI)wasala1-1/+2
Refactor from tests ppoint of view Change-Id: If747a499c70517a74bda6fbc895306271dc61d13 Issue-ID: DCAEGEN2-407 Signed-off-by: wasala <przemyslaw.wasala@nokia.com>
2018-04-03Fixed Sonar Issueswasala1-1/+0
Deleted useless code Change-Id: I8d813d82c5b8b6ae3093d5d6fdec1688dd8eae6d Issue-ID: DCAEGEN2-407 Signed-off-by: wasala <przemyslaw.wasala@nokia.com>
2018-03-28Already fixed Sonar issueswasala1-1/+1
We have fixed Sonar issue with critical and minor tag Change-Id: Iccc343654686ba87f71d57382b68ddf9c54caeea Issue-ID: DCAEGEN2-407 Signed-off-by: wasala <przemyslaw.wasala@nokia.com>
2018-03-28Added logswasala1-16/+3
Improve Dockerfile and build fat jar Change-Id: I8b4dd1a56350af310c70236d6843ae1c357ad95e Issue-ID: DCAEGEN2-407 Signed-off-by: wasala <przemyslaw.wasala@nokia.com>
2018-03-28Added U&IT tests in prh modulewasala1-1/+14
We have already added tests in our Module. In addition some dependencies were added too. Clean up in pom.xml files Change-Id: I4217d585293f48f2f00870d147807bb1d5b2b33f Issue-ID: DCAEGEN2-407 Signed-off-by: wasala <przemyslaw.wasala@nokia.com>
2018-03-26Divide into module dependecywasala1-0/+46
Add dependency build of dmaapClients and aaiClients. This modules are mandatory to prh application. Issue-ID: DCAEGEN2-407 Change-Id: I2150a15d76e81dd01503f44339ddb3c50f5b0348 Signed-off-by: wasala <przemyslaw.wasala@nokia.com>