tg-dump-queues

Multi-queue Pulsar message dumper for debugging TrustGraph message flows.

Synopsis 

tg-dump-queues [pubsub-options] [-o LOG_FILE] QUEUE [QUEUE ...]

Description

The tg-dump-queues command monitors multiple Pulsar queues simultaneously and logs all messages to a file with timestamps and pretty-printed formatting. It uses TrustGraph’s Subscriber abstraction for pub/sub compatibility, making it a low-level debugging tool that connects directly to the pub/sub backend. This is useful for diagnosing message flow issues, inspecting queue contents, and verifying that processors are producing expected output.

Options

Positional Arguments

Argument Description
QUEUE [QUEUE ...] One or more queue names to monitor

Optional Arguments

Option Default Description
-o, --output LOG_FILE None Path to a log file for captured messages

Pub/Sub Arguments

Standard pub/sub connection arguments are also accepted (added via add_pubsub_args), including the Pulsar broker URL and related connection settings.

Examples

Monitor a Single Queue 

tg-dump-queues my-queue

Monitor Multiple Queues 

tg-dump-queues prompt-request prompt-response graph-rag

Log Output to File 

tg-dump-queues -o debug-log.txt prompt-request prompt-response

Environment Variables

  • TRUSTGRAPH_URL: Default pub/sub connection URL