Skip to content

Commit e6d4562

Browse files
committed
feat(pubsub): Add queue-based message retrieval and comprehensive integration tests
- Add PubSubQueue property to BaseClient for queue-based message access - Enhance PubSubMessageHandler.GetQueue() to prevent mixing callback/queue modes - Add 11 comprehensive integration tests for queue-based PubSub functionality - Rename PubSubFFICallbackIntegrationTests to PubSubCallbackIntegrationTests - Update unit tests to validate callback/queue mode separation - Add testresults/ and reports/ to .gitignore - Remove obsolete design documentation files Tests cover: - Standalone and cluster client queue retrieval - Pattern subscriptions with queue mode - Message ordering preservation - Async operations with cancellation - High volume message handling - Multiple channel subscriptions - Unicode and special character handling - Error handling for mixed callback/queue modes All 1,797 tests passing with 67.7% line coverage. Signed-off-by: Joe Brinkman <[email protected]>
1 parent 41de891 commit e6d4562

File tree

10 files changed

+988
-1625
lines changed

10 files changed

+988
-1625
lines changed

.gitignore

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -151,3 +151,7 @@ $RECYCLE.BIN/
151151
_NCrunch*
152152

153153
glide-logs/
154+
155+
# Test results and coverage reports
156+
testresults/
157+
reports/

PUBSUB_REFACTORING.md

Lines changed: 0 additions & 198 deletions
This file was deleted.

monitor-valkey.sh

Lines changed: 19 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,19 @@
1+
#!/bin/zsh
2+
# Streams all commands from Valkey and logs them to a file with timestamps in ./log directory.
3+
4+
LOGDIR="./log"
5+
LOGFILE="$LOGDIR/valkey-monitor.log"
6+
7+
# Ensure directory exists
8+
if [ ! -d "$LOGDIR" ]; then
9+
mkdir -p "$LOGDIR"
10+
fi
11+
# Ensure log file exists
12+
if [ ! -f "$LOGFILE" ]; then
13+
touch "$LOGFILE"
14+
fi
15+
16+
# Run MONITOR and prepend timestamps using date
17+
valkey-cli MONITOR | while read -r line; do
18+
echo "$(date '+[%Y-%m-%d %H:%M:%S]') $line"
19+
done >> "$LOGFILE"

0 commit comments

Comments
 (0)