🎄 Happy Holidays! 🥳

Most of Solace is closed December 24–January 1 so our employees can spend time with their families. We will re-open Thursday, January 2, 2024. Please expect slower response times during this period and open a support ticket for anything needing immediate assistance.

Happy Holidays!

Please note: most of Solace is closed December 25–January 2, and will re-open Tuesday, January 3, 2023.

House keeping for durable exclusive queues/DTEs having no consumer for a defined time

subhoatg
subhoatg Member Posts: 17 ✭
in PubSub+ Event Broker #1

Hi,

We want to implement a housekeeping mechanism for our Solace system so that durable exclusive queues/DTEs having no consumer for a defined time are deleted.


We are thinking of the following approach.


We implement a poller which looks at all the Queues/DTEs and finds out all the exclusive Queues/DTEs

For each of them, the poller then checks if there are active consumers in them with the SEMP API `GET SEMP/v2/monitor/msgVpns/<VPN-NAME>/topicEndpoints/<DTE-NAME>/txFlows`. If there are none, then it starts the deletion counter and also notes the bindSuccessCount from the `GET SEMP/v2/monitor/msgVpns/<VPN-NAME>/topicEndpoints/<DTE-NAME>`.

For every subsequent poll, it checks if there are any active consumer added or the bindSuccessCount has changed. If yes, then it resets the counter. Or else, it increases the counter.

Once the counter exceeds the timelimit of the pre-defined time, it deletes the queue/dte.

We want to know if this approach looks fine or there are better ways to achieve the same. Kindly suggest.

Tagged:

Best Answer

  • marc
    marc Member, Administrator, Moderator, Employee Posts: 963 admin
    edited April 2022 #2 Answer ✓

    Hi @subhoatg,

    With your approach I could see the possibility that you miss a consumer which binds and unbinds to an endpoint in between your checks. I would consider using the "bindRequestCount" metric on the endpoint instead. This number would have incremented if a bind request was made between your polls.

    You can find it via this SEMP request under data .

    http://localhost:8080/SEMP/v2/monitor/msgVpns/<YOUR_MSG_VPN>/queues/<YOUR_QUEUE>

    Another option would be to do this in an asynchronous manner by parsing the syslog events that the broker puts out. There is a CLIENT_CLIENT_BIND_SUCCESS (and FAILURE) event that you could watch for.


    Hope that helps!

Answers

  • marc
    marc Member, Administrator, Moderator, Employee Posts: 963 admin
    edited April 2022 #3 Answer ✓

    Hi @subhoatg,

    With your approach I could see the possibility that you miss a consumer which binds and unbinds to an endpoint in between your checks. I would consider using the "bindRequestCount" metric on the endpoint instead. This number would have incremented if a bind request was made between your polls.

    You can find it via this SEMP request under data .

    http://localhost:8080/SEMP/v2/monitor/msgVpns/<YOUR_MSG_VPN>/queues/<YOUR_QUEUE>

    Another option would be to do this in an asynchronous manner by parsing the syslog events that the broker puts out. There is a CLIENT_CLIENT_BIND_SUCCESS (and FAILURE) event that you could watch for.


    Hope that helps!

  • subhoatg
    subhoatg Member Posts: 17 ✭
    #4

    Hi @marc ,

    Thanks for your reply. My understanding was that both bindRequestcount and bindSuccessCount will increase in case of any consumer connects and disconnects between the polls.

  • marc
    marc Member, Administrator, Moderator, Employee Posts: 963 admin
    #5

    Hi @subhoatg,

    Correct, wouldn't that give you what you want? If the count goes up then an app is using/trying to use that endpoint and you wouldn't want to delete it.

Categories

This Month's Leaders

This Week's Leaders