...
Link: (https://github.com/sngular/scs-multiapi-plugin)
Below the plugin for policy-clamp-models:
| Code Block | ||||
|---|---|---|---|---|
| ||||
<plugin>
<groupId>com.sngular</groupId>
<artifactId>scs-multiapi-maven-plugin</artifactId>
<version>5.3.5</version>
<executions>
<execution>
<id>asyncapi</id>
<phase>generate-sources</phase>
<goals>
<goal>asyncapi-generation</goal>
</goals>
<configuration>
<specFiles>
<specFile>
<filePath>${project.basedir}/src/main/resources/asyncapi/asyncapi.yaml</filePath>
<supplier>
<ids>sendMessage</ids>
<modelPackage>org.onap.policy.clamp.models.acm.messages.kafka.participant</modelPackage>
</supplier>
<consumer>
<ids>receiveMessage</ids>
<modelPackage>org.onap.policy.clamp.models.acm.messages.kafka.participant</modelPackage>
</consumer>
</specFile>
</specFiles>
<generatedSourcesFolder>sources-generated</generatedSourcesFolder>
</configuration>
</execution>
</executions>
</plugin> |
Below the models/src/main/resources/asyncapi/asyncapi.yaml for ParticipantRegister and ParticipantRegisterAck messages.
| Code Block | ||||
|---|---|---|---|---|
| ||||
asyncapi: 2.0.0
info:
title: Account Service
version: '1.0.0'
description: Manages user accounts in the system.
servers:
production:
url: kafka:9092
protocol: kafka
description: kafka broker
channels:
policy-acm-participant:
publish:
operationId: sendMessage
message:
$ref: '#/components/messages/ParticipantRegisterAck'
policy-acm-acruntime:
subscribe:
operationId: receiveMessage
message:
$ref: '#/components/messages/ParticipantRegister'
components:
messages:
ParticipantRegister:
name: ParticipantRegister
title: ParticipantRegister
summary: Register a participant
contentType: application/json
payload:
$ref: '#/components/schemas/ParticipantRegister'
ParticipantRegisterAck:
name: ParticipantRegisterAck
title: ParticipantRegisterAck
summary: Send message back from a registered participant
contentType: application/json
payload:
$ref: '#/components/schemas/ParticipantRegisterAck'
schemas:
ParticipantRegister:
type: object
properties:
messageType:
description: "Message Type"
$ref: '#/components/schemas/ParticipantMessageType'
default: 'PARTICIPANT_REGISTER'
messageId:
type: string
format: uuid
timestamp:
type: string
format: dateTime
participantId:
type: string
format: uuid
participantSupportedElementType:
type: array
items:
$ref: '#/components/schemas/ParticipantSupportedElementType'
ParticipantSupportedElementType:
type: object
properties:
id:
type: string
format: uuid
typeName:
type: string
typeVersion:
type: string
ParticipantRegisterAck:
type: object
properties:
messageType:
description: "Message Type"
$ref: '#/components/schemas/ParticipantMessageType'
default: 'PARTICIPANT_REGISTER_ACK'
responseTo:
type: string
format: uuid
timestamp:
type: string
format: dateTime
participantId:
type: string
format: uuid
Message:
type: string
ParticipantMessageType:
type: string
enum:
- PARTICIPANT_STATUS
- PARTICIPANT_STATE_CHANGE
- AUTOMATION_COMPOSITION_DEPLOY
- AUTOMATION_COMPOSITION_STATE_CHANGE
- PARTICIPANT_REGISTER
- PARTICIPANT_REGISTER_ACK
- PARTICIPANT_DEREGISTER
- PARTICIPANT_DEREGISTER_ACK
- PARTICIPANT_PRIME
- PARTICIPANT_PRIME_ACK
- AUTOMATION_COMPOSITION_DEPLOY_ACK
- AUTOMATION_COMPOSITION_STATECHANGE_ACK
- PARTICIPANT_STATUS_REQ
- PROPERTIES_UPDATE
- PARTICIPANT_RESTART
- AUTOMATION_COMPOSITION_MIGRATION |
...