diff --git a/src/Job.php b/src/Job.php index 1d4e7d4..1446c37 100644 --- a/src/Job.php +++ b/src/Job.php @@ -41,6 +41,11 @@ public function __construct(Container $container, PsrContext $psrContext, PsrCon $this->psrMessage = $psrMessage; $this->connectionName = $connectionName; } + + public function getJobId() + { + return $this->psrMessage->getMessageId(); + } /** * {@inheritdoc}