recreate queues with topic filtering

queue-reset-filter.bash

#!/bin/bash

set -x

#Stop Katello/Satellite services
katello-service stop

CERT=/etc/pki/katello/certs/katello-apache.crt
KEY=/etc/pki/katello/private/katello-apache.key

# start qpidd
service qpidd start

sleep 130

#delete exchange
qpid-config --ssl-certificate $CERT --ssl-key $KEY -b "amqps://localhost:5671" del exchange event --durable

#create exchange:
qpid-config --ssl-certificate $CERT --ssl-key $KEY -b "amqps://localhost:5671" add exchange topic event --durable

#view exchange:
qpid-config --ssl-certificate $CERT --ssl-key $KEY -b "amqps://localhost:5671" exchanges

#delete queue
qpid-config --ssl-certificate $CERT --ssl-key $KEY -b 'amqps://localhost:5671' del queue katello_event_queue --force

#create queue:
qpid-config --ssl-certificate $CERT --ssl-key $KEY -b 'amqps://localhost:5671' add queue katello_event_queue --durable

#view queue:
qpid-config --ssl-certificate $CERT --ssl-key $KEY -b "amqps://localhost:5671" queues katello_event_queue

#bind queue to exchange with filtering:
qpid-config --ssl-certificate $CERT --ssl-key $KEY -b "amqps://localhost:5671" unbind event katello_event_queue '*.*'
qpid-config --ssl-certificate $CERT --ssl-key $KEY -b "amqps://localhost:5671" bind event katello_event_queue entitlement.deleted
qpid-config --ssl-certificate $CERT --ssl-key $KEY -b "amqps://localhost:5671" bind event katello_event_queue entitlement.created
qpid-config --ssl-certificate $CERT --ssl-key $KEY -b "amqps://localhost:5671" bind event katello_event_queue pool.created
qpid-config --ssl-certificate $CERT --ssl-key $KEY -b "amqps://localhost:5671" bind event katello_event_queue pool.deleted
qpid-config --ssl-certificate $CERT --ssl-key $KEY -b "amqps://localhost:5671" bind event katello_event_queue compliance.created

# Start up services
katello-service start

# Run the following command to monitor the katello event queue:
# qpid-stat -q --ssl-certificate=/etc/pki/katello/qpid_client_striped.crt -b amqps://localhost:5671