Big Bang

Author: mgonzalezbaile

.gitignore

@@ -0,0 +1,2 @@
+.idea
+vendor

composer.json

@@ -0,0 +1,13 @@
+{
+  "name": "soa-php/traceability",
+  "description": "Trace the conversations between your services",
+  "license": "MIT",
+  "require": {
+    "php": "^7.2"
+  },
+  "autoload": {
+    "psr-4": {
+      "Soa\\Traceability\\": "src/"
+    }
+  }
+}

docker/run.sh

@@ -0,0 +1,15 @@
+#!/usr/bin/env bash
+
+COMMAND=${1:-}
+shift
+
+run_in_docker="docker run -it --rm -v $PWD:/srv/app -w /srv/app --user ${UID} mgonzalezbaile/php_base:1.0"
+
+case "$COMMAND" in
+    composer)
+    ${run_in_docker} composer $@
+    ;;
+    exec)
+    ${run_in_docker} $@
+    ;;
+esac

src/Trace.php

@@ -0,0 +1,78 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Soa\Traceability;
+
+class Trace
+{
+    /**
+     * @var string
+     */
+    private $occurredOn;
+
+    /**
+     * @var string
+     */
+    private $correlationId;
+
+    /**
+     * @var string
+     */
+    private $causationId;
+
+    /**
+     * @var string
+     */
+    private $replyTo;
+
+    /**
+     * @var string
+     */
+    private $processId;
+
+    /**
+     * @var string
+     */
+    private $messageId;
+
+    public function __construct(string $messageId, string $occurredOn, string $correlationId, string $causationId, string $replyTo, string $processId)
+    {
+        $this->occurredOn    = $occurredOn;
+        $this->correlationId = $correlationId;
+        $this->causationId   = $causationId;
+        $this->replyTo       = $replyTo;
+        $this->processId     = $processId;
+        $this->messageId     = $messageId;
+    }
+
+    public function occurredOn(): string
+    {
+        return $this->occurredOn;
+    }
+
+    public function correlationId(): string
+    {
+        return $this->correlationId;
+    }
+
+    public function causationId(): string
+    {
+        return $this->causationId;
+    }
+
+    public function replyTo(): string
+    {
+        return $this->replyTo;
+    }
+
+    public function processId(): string
+    {
+        return $this->processId;
+    }
+
+    public function messageId(): string
+    {
+        return $this->messageId;
+    }
+}