...
| Code Block | ||||||
|---|---|---|---|---|---|---|
| ||||||
{
"eventId": "bfb86f3e-641b-4750-b3a0-d8d31f01a708",
"eventCorrelationId": "2539f8ac-b2c3-422d-bb75-b3f10d3d6216",
"eventTime": "2022-05-05T13:48:53.375+0000",
"eventSource": "org.onap.ncmp",
"eventSchema": "urn:cps:org.onap.cps:async-request-response-event-schema:v1",
"eventTarget": "my-topic-999",
"eventOrigin": {
"eventId": "c5c7c885-2e31-4951-aba5-3062889b8a7c",
"eventCorrelationId": "2539f8ac-b2c3-422d-bb75-b3f10d3d6216",
"eventTime": "2022-05-05T13:48:51.157+0000",
"eventSource": "org.onap.ncmp",
"eventSchema": "urn:cps:org.onap.cps:async-request-response-event-schema:v1",
"eventTarget": "my-topic-999"
},
"event": {
"response-data-schema": "urn:cps:org.onap.cps:async-request-response-event-schema:v1",
"response-status": "200",
"response-code": "SUCCESS",
"response-data": {
"ietf-netconf-monitoring:netconf-state": {
"schemas": {
"schema": [
{
"identifier": "ietf-tls-server",
"version": "2016-11-02",
"format": "ietf-netconf-monitoring:yang",
"namespace": "urn:ietf:params:xml:ns:yang:ietf-tls-server",
"location": [
"NETCONF"
]
},
...,
{
"identifier": "ietf-system",
"version": "2014-08-06",
"format": "ietf-netconf-monitoring:yin",
"namespace": "urn:ietf:params:xml:ns:yang:ietf-system",
"location": [
"NETCONF"
]
}
]
}
}
}
}
} |
Manual Testing
...
| Code Block | ||||||||
|---|---|---|---|---|---|---|---|---|
| ||||||||
{
"headers": {},
"body": {
"requestId": "0f574dfa-9c05-4899-9ae1-e6741f53c6d9"
},
"statusCode": "OK",
"statusCodeValue": 200
} |
| Code Block | ||||||||
|---|---|---|---|---|---|---|---|---|
| ||||||||
{"logTimeStamp":"2022-05-10T11:16:27.123Z","logLevel":"INFO","principalId":"cpsuser","serviceName":"cps-application","message":"Async task completed successfully.","processId":"1","threadName":"ForkJoinPool.commonPool-worker-5","class":"o.o.c.n.r.executor.CpsNcmpTaskExecutor"} |
| Code Block | ||||||||
|---|---|---|---|---|---|---|---|---|
| ||||||||
{
"eventId": "b2f629ae-ee90-44d9-97f9-500c8a595b6a",
"eventCorrelationId": "2243bbcd-b0b3-4aa5-9d53-41dc88a525a5",
"eventTime": "2022-05-10T08:39:37.597+0000",
"eventSource": "org.onap.ncmp",
"eventSchema": "urn:cps:org.onap.cps:async-request-response-event-schema:v1",
"eventTarget": "my-topic-999",
"eventContent": {
"response-data-schema": "urn:cps:org.onap.cps:async-request-response-event-schema:v1",
"response-status": "SUCCESS",
"response-code": "200",
"response-data": {
"ietf-netconf-monitoring:netconf-state": {
"schemas": {
"schema": [
{
"identifier": "ietf-tls-server",
"version": "2016-11-02",
"format": "ietf-netconf-monitoring:yang",
"namespace": "urn:ietf:params:xml:ns:yang:ietf-tls-server",
"location": [
"NETCONF"
]
},
{
"identifier": "nc-notifications",
"version": "2008-07-14",
"format": "ietf-netconf-monitoring:yang",
"namespace": "urn:ietf:params:xml:ns:netmod:notification",
"location": [
"NETCONF"
]
}
}
}
}
}
} |
NCMP → Client Topic
| Code Block | ||||||||
|---|---|---|---|---|---|---|---|---|
| ||||||||
{
"eventId": "699da452-4131-4e55-b49a-50e0c5f0d641",
"eventCorrelationId": "efc17123-902a-4f50-8294-178a782b9102",
"eventTarget": "test-env-1",
"eventTime": "2022-05-10T11:16:27.427+0000",
"forwardedEvent": {
"eventId": "0f574dfa-9c05-4899-9ae1-e6741f53c6d9",
"eventCorrelationId": "efc17123-902a-4f50-8294-178a782b9102",
"eventTime": "2022-05-10T11:16:27.374+0000",
"eventSource": "org.onap.ncmp",
"eventSchema": "urn:cps:org.onap.cps:async-request-response-event-schema:v1",
"eventTarget": "test-env-1",
"response-data-schema": "urn:cps:org.onap.cps:async-request-response-event-schema:v1",
"response-status": "SUCCESS",
"response-code": "200",
"response-data": {
"ietf-netconf-monitoring:netconf-state": {
"schemas": {
"schema": [
{
"identifier": "ietf-tls-server",
"version": "2016-11-02",
"format": "ietf-netconf-monitoring:yang",
"namespace": "urn:ietf:params:xml:ns:yang:ietf-tls-server",
"location": [
"NETCONF"
]
},
{
"identifier": "nc-notifications",
"version": "2008-07-14",
"format": "ietf-netconf-monitoring:yang",
"namespace": "urn:ietf:params:xml:ns:netmod:notification",
"location": [
"NETCONF"
]
}
]
}
}
}
}
} |
Kafka config & Implementation
...