test_blocked_publish

#!/bin/bash
rabbitmqctl set_vm_memory_high_watermark 0.4
python sample-generator.py -r 100 -m 1000 -u nova -p bOgj3Obj -n 10.109.2.4:5673,10.109.2.5:5673,10.109.2.6:5673 -S &
sleep 3
rabbitmqctl set_vm_memory_high_watermark 0 2>&1
rabbitmqctl -q list_queues name messages state 2>&1 | grep meter
python sample-generator.py -m 1000 -u nova -p bOgj3Obj -n 10.109.2.4:5673,10.109.2.5:5673,10.109.2.6:5673 -s -d 10 &
while true; do
  rabbitmqctl -q eval 'rabbit_alarm:get_alarms().' 2>&1
  rabbitmqctl -q list_connections name state 2>&1 | grep blocked | tee blocked_connections
  rabbitmqctl -q list_queues name messages state 2>&1 | grep 'meter.*block' | tee blocked_queues
  rabbitmqctl -q list_queues name messages state 2>&1 | grep meter | tee metering_queues
  rabbitmqctl set_vm_memory_high_watermark 0 2>&1
  sleep 1
done