hy-app-monitor/testbox/scripts/create-rocketmq-topics.sh

20 lines
553 B
Bash
Executable File

#!/usr/bin/env bash
set -euo pipefail
NAMESRV="${ROCKETMQ_NAMESRV_ADDR:-rocketmq-namesrv:9876}"
CLUSTER="${ROCKETMQ_CLUSTER:-DefaultCluster}"
BROKER_CONTAINER="${ROCKETMQ_BROKER_CONTAINER:-chatapp-test-rocketmq-broker}"
MQADMIN="/home/rocketmq/rocketmq-5.3.1/bin/mqadmin"
topics=(
RC_DEFAULT_APP_ORDINARY
RC_DEFAULT_APP_DELAYED
RC_DEFAULT_APP_ORDER
)
for topic in "${topics[@]}"; do
docker exec "$BROKER_CONTAINER" sh -lc \
"$MQADMIN updateTopic -n '$NAMESRV' -c '$CLUSTER' -t '$topic' >/dev/null"
echo "rocketmq topic ok: $topic"
done