Processor
The processor service is will process the message requests, and create chat rooms and chat messages in the Parro database
The service
The processor is responsible for creating the Nexus chat messages. It receive the small messages created by the ingester and transform them into chat messages. It will first check if there already is a chat room between the Nexus parntner bot and the receiver. If not it will create a new bot room. It will then create a chat message for that room.
The processor has its own tables in the Parro database in which it will log its progress of which messages are processed successfully or with an error
NATS
Request/Reply
The ingester has no request/reply subjects
Consuming
| subject | description |
|---|---|
| message.v1.prepared | It will consume the messages which need to be transformed into a chat message |
| message.v1.receipt | It will store the receipts in the database |
Publishing
| subject | description |
|---|---|
| push.v1.chatmessage | A request to create a push message for a new chat message |
| connect.v1.error | When an error is thrown a message will be published on the error subject |