PHPackages                             pmg/queue-cloudwatch - PHPackages - PHPackages  [Skip to content](#main-content)[PHPackages](/)[Directory](/)[Categories](/categories)[Trending](/trending)[Leaderboard](/leaderboard)[Changelog](/changelog)[Analyze](/analyze)[Collections](/collections)[Log in](/login)[Sign up](/register)

1. [Directory](/)
2. /
3. [Queues & Workers](/categories/queues)
4. /
5. pmg/queue-cloudwatch

ActiveLibrary[Queues & Workers](/categories/queues)

pmg/queue-cloudwatch
====================

Track your queue with CloudWatch metrics

v8.0.0(5mo ago)08.3kApache-2.0PHPPHP ^8.3CI failing

Since Aug 31Pushed 3mo ago15 watchersCompare

[ Source](https://github.com/AgencyPMG/queue-cloudwatch)[ Packagist](https://packagist.org/packages/pmg/queue-cloudwatch)[ RSS](/packages/pmg-queue-cloudwatch/feed)WikiDiscussions master Synced 2d ago

READMEChangelog (1)Dependencies (5)Versions (11)Used By (0)

Queue CloudWatch
================

[](#queue-cloudwatch)

A `pmg/queue` driver decorator that dispatches cloudwatch metrics when messages are sent through.

Example
-------

[](#example)

```
use AWS\CloudWatch\CloudWatchClient;
use PMG\Queue\Driver;
use PMG\Queue\CloudWatch\MetricsDriver;

/** @var Driver $driver */
$driver = createAnActualDriverSomehow();

// this is the default metric namespace, change if desired.
$metricNamespace = 'PMG/Queue';
$finalDriver = new MetricsDriver($driver, CloudWatchClient::factory([
    'region' => 'us-east-1',
    'version' => 'latest',
]), $metricNamespace);

// now use $finalDriver in your consumers/producers
```

Metrics
-------

[](#metrics)

All metrics have the dimensions...

- `QueueName` - The name of the queue to which the metrics belong
- `MessageName` - The value returned from `Message::getName`. When a message is not present for logging the metric, this dimension will be set to `__none__`.

### Driver Metrics

[](#driver-metrics)

- `DriverError` - A `Count` metric unit fired when the wrapped driver throws a `DriverError` exception. This will have an `ErrorClass` dimension that contains the exception class name that was thrown.

### Message Counts

[](#message-counts)

There's a metric for each method on the driver, essentially. They all use `Count` as the metric unit.

- `MessageEnqueue` - Fired on `Driver::enqueue`
- `MessageDequeue` - Fired on `Driver::dequeue`. This is only fired when a message is returned from the wrapped `Driver::dequeue`.
- `MessageSuccess ` - Fired on `Driver::ack`
- `MessageFailure` - Fired on `Driver::fail`
- `MessageRetry` - Fired on `Driver::retry`
- `MessageRelease` - Fired on `Driver::release`

You might use these message counts to alert on a high volume of message failures or retries.

### Message Timers

[](#message-timers)

The metrics driver will time dequeued jobs until they are acked, failed, or retried. These all use `Milliseconds` as their metric unit.

- `MessageTime` - The amount of time a message took, tracked for every message regardless of how it finished.

The `MessageTime` metric will have an additional dimension named `MessageStatus`which is how the given message finished when the timer completed. This will be:

- `Success` when the message was passed to `Driver::ack`
- `Failure` when the message was passed to `Driver::fail`
- `Retry` When the message was passed to `Driver::retry`
- `Release` When the message was passed to `Driver::release`

Error Handling
--------------

[](#error-handling)

First up, the wrapped driver is *always* called first. If an error occurs from the wrapped driver it's tracked and rethrown before any further metrics can be logged. The idea here is that driver errors invalidate any processes acting on a message anyway.

Errors from the cloudwatch client are caught and logged, however. You can pass a fourth `$logger` argument to `MetricsDriver` if you wish to see these errors, but a `NullLogger` is used by default.

```
use AWS\CloudWatch\CloudWatchClient;
use PMG\Queue\Driver;
use PMG\Queue\CloudWatch\MetricsDriver;

/** @var Driver $driver */
$driver = createAnActualDriverSomehow();

// this is the default metric namespace, change if desired.
$metricNamespace = 'PMG/Queue';
$finalDriver = new MetricsDriver($driver, CloudWatchClient::factory([
    'region' => 'us-east-1',
    'version' => 'latest',
]), $metricNamespace, $yourLoggerFromSomeplace);

// now use $finalDriver in your consumers/producers
```

Testing
-------

[](#testing)

```
./vendor/bin/phpunit

```

The tests include a set of integration tests that actually talk to CloudWatch. Be sure to have [set up credentials](http://docs.aws.amazon.com/aws-sdk-php/v3/guide/guide/credentials.html). in order to run those tests. Otherwise you may exclude them with...

```
./vendor/bin/phpunit --exclude-group integration

```

###  Health Score

52

—

FairBetter than 96% of packages

Maintenance76

Regular maintenance activity

Popularity18

Limited adoption so far

Community14

Small or concentrated contributor base

Maturity84

Battle-tested with a long release history

 Bus Factor1

Top contributor holds 59.5% of commits — single point of failure

How is this calculated?**Maintenance (25%)** — Last commit recency, latest release date, and issue-to-star ratio. Uses a 2-year decay window.

**Popularity (30%)** — Total and monthly downloads, GitHub stars, and forks. Logarithmic scaling prevents top-heavy scores.

**Community (15%)** — Contributors, dependents, forks, watchers, and maintainers. Measures real ecosystem engagement.

**Maturity (30%)** — Project age, version count, PHP version support, and release stability.

###  Release Activity

Cadence

Every ~510 days

Recently: every ~529 days

Total

7

Last Release

167d ago

Major Versions

1.0.0 → v5.0.02020-03-31

v5.1.0 → v6.0.02023-01-12

v6.0.0 → v7.0.02025-06-12

v7.0.0 → v8.0.02026-01-15

PHP version history (5 changes)1.0.0PHP ~7.0

v5.0.0PHP ^7.3

v5.1.0PHP ^7.4 || ^8.0

v6.0.0PHP ^8.0

v7.0.0PHP ^8.3

### Community

Maintainers

![](https://www.gravatar.com/avatar/d396af79150164dd4d28f3e816b377e2f3c04df431d8338477517efa0013664c?d=identicon)[chrisguitarguy](/maintainers/chrisguitarguy)

---

Top Contributors

[![chrisguitarguy](https://avatars.githubusercontent.com/u/1010392?v=4)](https://github.com/chrisguitarguy "chrisguitarguy (25 commits)")[![jrughani9](https://avatars.githubusercontent.com/u/108751272?v=4)](https://github.com/jrughani9 "jrughani9 (14 commits)")[![WebCu](https://avatars.githubusercontent.com/u/3429093?v=4)](https://github.com/WebCu "WebCu (3 commits)")

---

Tags

awscloudwatch-metricsmetricsphppmg-queuepmg-queue-driverqueuequeuecloudwatch

###  Code Quality

TestsPHPUnit

### Embed Badge

![Health badge](/badges/pmg-queue-cloudwatch/health.svg)

```
[![Health](https://phpackages.com/badges/pmg-queue-cloudwatch/health.svg)](https://phpackages.com/packages/pmg-queue-cloudwatch)
```

###  Alternatives

[symfony/messenger

Helps applications send and receive messages to/from other applications or via message queues

1.1k132.9M1.5k](/packages/symfony-messenger)[matomo/matomo

Matomo is the leading Free/Libre open analytics platform

21.7k38.9k](/packages/matomo-matomo)[keboola/storage-api-client

Keboola Storage API PHP Client

10405.9k38](/packages/keboola-storage-api-client)[orisai/scheduler

Cron job scheduler - with locks, parallelism and more

4044.1k5](/packages/orisai-scheduler)[jasara/php-amzn-selling-partner-api

A fluent interface for Amazon's Selling Partner API in PHP

1348.7k1](/packages/jasara-php-amzn-selling-partner-api)

PHPackages © 2026

[Directory](/)[Categories](/categories)[Trending](/trending)[Changelog](/changelog)[Analyze](/analyze)