RabbitMQ

Management UI

RabbitMQ bietet eine Management UI an, welche eine Verwaltung und Überwachung der Message Queue ermöglicht. Die UI ist über den Port:15672 erreichbar. User und Passwort befinden sich in der .env-Datei.

Releases

Die Archivierung wird in der Regel mit dem RabbitMQ Docker Image der Version 3.8.9-management-alpine ausgeführt.

Der Service wird auch in der Versionen als Docker Container aus dem Repo docker-nob-erp.next-level-apps.com/archive-rabbitmq bereitgestellt. Dieses Image wrappt jedoch nur die offizielle RabbitMQ Docker Image, sodass wir empfehlen gleich die offizielle Version zu verwenden.

2021-06-28

| Ticket | Beschreibung | |———–|———————-| | BTOB-7780 | Initiale Entwicklung |

Monitoring der RabbitMQ (nur für Admins und die Entwicklung)

Alle Optionen, zu den Nachrichten in einer Queue, sind über den Queues Tab der UI erreichbar.

  • Ready zeigt die Anzahl der in der Queue befindlichen Nachrichten.
  • Unacked sind alle Nachrichten, die von einem Consumer abgeholt, aber noch nicht acknowledged wurden.

Klickt man auf den Namen der Queue, wird man auf eine erweiterte Ansicht für die Queue weitergeleitet. Alle folgende Optionen sollten nur im Notfall und mit Vorsicht ausgeführt werden.

  • Publish messageerlaubt es eine Nachricht der Queue hinzuzufügen. Dies erfolgt im JSON-Format.
  • Get messageserlaubt es die Nachrichten der Queue abzurufen. Eine Reihenfolge oder Abfrage bestimmer Nachrichten ist nicht möglich.
  • Purgeerlaubt es die Nachrichten aus der Queue unwiderruflich zu löschen.

API Doku der Queues (nur für die Entwicklung)

Workpackage Queue

// WorkpackageQueueTimeslice
{
  "periodStart": "2021-05-27T10:00:29.372Z", // required, Date wird als Unix Time Stamp angegeben
  "periodEnd": "2021-05-27T10:00:29.372Z" // required
}

Persistence Queue

// PersistenceQueueArchiveMessage
{
"messageid" : "34259560-bed2-11eb-8e9a-0000ac12000c", // required
"referenceid" : "UBCG3EXVPIEKU1",
"direction" : 0,
"started" : "2021-05-27T08:57:13.000Z",
"finished" : "2021-05-27T10:00:29.372Z",
"formatin" : "edi",
"formatout" : "13018",
"vdewtype" : "MSCONS",
"vdewversion" : "2.3b",
"state" : "ARC",
"acknowledgement" : "CTE",
"partner" : "4042805000706",
"sender" : "9911845000009",
"correlationid" : "UBCG3EXVPIEKU1",
"alternativeid" : null,
"channelid" : "IN_ERR_MP",
"clearingcode" : null,
"archiveAttributes" : [
    {
      "attributeid": "B3P_MIME_MSG_MAIN" // required
    }
 ]
}

Index Queue

// IndexQueueArchiveMessage
{
"messageid" : "34259560-bed2-11eb-8e9a-0000ac12000c", // required
"referenceid" : "UBCG3EXVPIEKU1",
"direction" : 0,
"started" : "2021-05-27T08:57:13.000Z",
"finished" : "2021-05-27T10:00:29.372Z",
"formatin" : "edi",
"formatout" : "13018",
"vdewtype" : "MSCONS",
"vdewversion" : "2.3b",
"state" : "ARC",
"acknowledgement" : "CTE",
"partner" : "4042805000706",
"sender" : "9911845000009",
"correlationid" : "UBCG3EXVPIEKU1",
"alternativeid" : null,
"channelid" : "IN_ERR_MP",
"clearingcode" : null,
"archiveAttributes" : [
    {
      "attributeid": "B3P_MIME_MSG_MAIN", // required
      "archiveId": "8e9a-0000ac12000c-34259560-bed2-11eb" // required
    }
 ]
}

Success Queue

// FinishQueueMessage
{
  "messageId": "34259560-bed2-11eb-8e9a-0000ac12000c", // required
  "archivingSuccess": INDEX // optional, default: ALL
}

Error Queue

// ErrorQueueMessage
{
  "messageId": "34259560-bed2-11eb-8e9a-0000ac12000c", // required
  "errorMessage": "Cannot find messageId",
  "errorStacktrace": "Stacktrace..."
}
View Me   Edit Me