PHPackages                             spryker-community/queue-cli - 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. spryker-community/queue-cli

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

spryker-community/queue-cli
===========================

SprykerCommunity Queue cli tool

00PHP

Since Jul 14Pushed 11mo agoCompare

[ Source](https://github.com/spryker-community/queue-cli)[ Packagist](https://packagist.org/packages/spryker-community/queue-cli)[ RSS](/packages/spryker-community-queue-cli/feed)WikiDiscussions main Synced today

READMEChangelogDependenciesVersions (1)Used By (0)

Queue CLI Command
=================

[](#queue-cli-command)

This document provides instructions for using the `queue:messages` console command. This command allows you to move messages between different queues within your Spryker application.

Overview
--------

[](#overview)

The primary purpose of this command is to transfer messages from a specified source queue to a target queue. This is particularly useful for reprocessing failed messages, testing, or manually managing queue backlogs. You can move all messages or selectively filter them based on content, limit the number of messages moved, and choose whether to keep the original messages in the source queue.

Install
-------

[](#install)

Install the module with composer.

`composer require spryker-community/queue-cli`

Add new console commands to your `ConsoleDependencyProvider``

```
protected function getConsoleCommands(Container $container): array // phpcs:ignore SlevomatCodingStandard.Functions.UnusedParameter
{
    return [
        // other console commands
        new QueueMessagesListConsole(),
        new QueueMessagesMoveConsole(),
    ];
}

```

---

Move Command
------------

[](#move-command)

`console queue:messages:move`

### Arguments

[](#arguments)

The command requires two arguments to function:

ArgumentDescription`source-queue`**(Required)** The name of the queue you want to move messages *from*.`target-queue`**(Required)** The name of the queue you want to move messages *to*.### Options

[](#options)

You can refine the moving process with the following optional flags:

OptionShortcutDescriptionDefault`--chunk-size``-c`The number of messages to process in a single batch.`100``--filter``-f`A string pattern to match against the message body. Only messages containing this string will be moved.`null``--limit``-l`The maximum total number of messages to move.`null``--keep``-k`If this flag is present, messages will be copied to the target queue instead of moved (they will not be deleted from the source queue).`false`List Command
------------

[](#list-command)

`console queue:messages:list`

### Arguments

[](#arguments-1)

The command requires two arguments to function:

ArgumentDescription`source-queue`**(Required)** The name of the queue you want to move messages *from*.### Options

[](#options-1)

You can refine the moving process with the following optional flags:

OptionShortcutDescriptionDefault`--filter``-f`A string pattern to match against the message body. Only messages containing this string will be moved.`null``--limit``-l`The maximum total number of messages to move.`null`---

Usage Examples
--------------

[](#usage-examples)

Here are some common scenarios demonstrating how to use the command.

### 1. Basic Move

[](#1-basic-move)

Move all messages from `source_queue` to `target_queue`.

```
console queue:messages:move source_queue target_queue
```

### 2. Move a Limited Number of Messages

[](#2-move-a-limited-number-of-messages)

Move a maximum of 50 messages from `error_queue` to `retry_queue`.

```
console queue:messages:move error_queue retry_queue --limit=50
```

or using the shortcut:

```
console queue:messages:move error_queue retry_queue -l 50
```

### 3. Move Messages with a Specific Content (Filter)

[](#3-move-messages-with-a-specific-content-filter)

Move all messages from `source_queue` to `target_queue` where the message body contains the string "customer\_reference\_123".

```
console queue:messages:move source_queue target_queue --filter="customer_reference_123"
```

or using the shortcut:

```
console queue:messages:move source_queue target_queue -f "customer_reference_123"
```

### 4. Copy Messages (Keep in Source Queue)

[](#4-copy-messages-keep-in-source-queue)

Copy all messages from `source_queue` to a `debug_queue` for inspection, without removing them from the original queue.

```
console queue:messages:move source_queue debug_queue --keep
```

or using the shortcut:

```
console queue:messages:move source_queue debug_queue -k
```

### 5. Combining Options

[](#5-combining-options)

Copy a maximum of 200 messages containing "SKU-XYZ-01" from `product_events` to `product_events_reprocess`, processing 50 messages at a time.

```
console queue:messages:move product_events product_events_reprocess --filter="SKU-XYZ-01" --limit=200 --chunk-size=50 --keep
```

### 5. List messages from Queue

[](#5-list-messages-from-queue)

List 10 messages containing "Foo" from `events`.

```
console queue:messages:list events --filter="foo" --limit=10
```

###  Health Score

15

—

LowBetter than 3% of packages

Maintenance37

Infrequent updates — may be unmaintained

Popularity0

Limited adoption so far

Community9

Small or concentrated contributor base

Maturity14

Early-stage or recently created project

 Bus Factor1

Top contributor holds 71.4% 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.

### Community

Maintainers

![](https://avatars.githubusercontent.com/u/138799308?v=4)[Spryker Community & Innovation Lab](/maintainers/spryker-community)[@spryker-community](https://github.com/spryker-community)

---

Top Contributors

[![abitskil](https://avatars.githubusercontent.com/u/10989183?v=4)](https://github.com/abitskil "abitskil (10 commits)")[![sebastianlarisch](https://avatars.githubusercontent.com/u/52778227?v=4)](https://github.com/sebastianlarisch "sebastianlarisch (3 commits)")[![fsmeier](https://avatars.githubusercontent.com/u/1506919?v=4)](https://github.com/fsmeier "fsmeier (1 commits)")

---

Tags

hackathonhackathon-june-2025

### Embed Badge

![Health badge](/badges/spryker-community-queue-cli/health.svg)

```
[![Health](https://phpackages.com/badges/spryker-community-queue-cli/health.svg)](https://phpackages.com/packages/spryker-community-queue-cli)
```

###  Alternatives

[league/geotools

Geo-related tools PHP 7.3+ library

1.4k5.6M31](/packages/league-geotools)[illuminate/bus

The Illuminate Bus package.

6046.3M542](/packages/illuminate-bus)[uecode/qpush-bundle

Asynchronous processing for Symfony using Push Queues

1672.5M2](/packages/uecode-qpush-bundle)[belvg/module-sqs

N/A

1544.6k](/packages/belvg-module-sqs)[bsidev/bitrix-queue

Queues for Bitrix CMS

232.8k](/packages/bsidev-bitrix-queue)[mayconbordin/l5-stomp-queue

Stomp Queue Driver for Laravel 5

121.1k](/packages/mayconbordin-l5-stomp-queue)

PHPackages © 2026

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