You can configure the frequency with which the SCD process will check for slow consumers, along with the unit of time used to specify that frequency.

The virtualhosts.virtualhost.hostname.slow-consumer-detection elements delay and timeunit are used to specify the frequency and timeunit respectively in the virtualhosts.xml file e.g.

<virtualhosts>
	<default>test</default>
	<virtualhost>
		<name>test</name>
		<test>
		   <slow-consumer-detection>
			<delay>60<delay/>
			<timeunit>seconds<timeunit/>
		<slow-consumer-detection/>
		</test>
	</virtualhost>
</virtualhosts>

When the SCD component finds a queue with a configured threshold to check, the operational logging component (if enabled) will output the following line:

    SCD-1003 : Checking Status of Queue
    

One key feature of SCD is the disconnection of a consuming client when a specified threshold is exceeded. For a pub-sub model using topics, this means that messages will no longer be delivered to the private queue which was associated with that consuming client, thus reducing any associated backlog in the broker.

For durable subscriptions, simply disconnecting the consuming client will not suffice since the associated queue is by definition durable and messages would continue to flow to it after disconnection, potentially worsening any backing up of data on the broker.

The solution is to configure durable subscriptions to delete the underlying queue on disconnection. This means that messages will no longer be delivered to the private queue associated with the subscription, thus preventing any backlog.

Full details of how to configure the thresholds are provided below.

You can configure SCD to be triggered on a topic or subscription when the oldest message in the associated private queue for the consumer ages beyond the specified value, in milliseconds.

You can opt to use the depth of the queue in bytes as a threshold. SCD will be triggered by a queue depth greater than the threshold specified i.e. when a broker receives a message that takes the queue depth over the threshold.

You can use the message count for the consumer's queue as the trigger, where a count higher than that specified will trigger disconnection.

You can configure the policy you wish to apply in your broker configuration. There are currently 2 policies available:

Delete Temporary Queues Only

If you do not specify a <topicDelete/> element in your configuration, then only temporary queues associated with a topic subscription will be deleted on client disconnect. This is the default behaviour.

Delete Durable Subscription Queues

If you add the <topicDelete/> element with the sub-element <delete-persistent/> to your config, then the persistent queue which is associated with durable subscriptions to a topic will also be deleted. This is an important consideration since without deleting the underlying queue the client's unconsumed data will grow indefinitely while they will be unable to reconnect to that queue due to the SCD threshold configured, potentially having an adverse effect on the application or broker in use.

Example Topic Configuration

The following steps are required to configure SCD:

The example below shows a simple definition, with all three thresholds specified and a simple disconnection, with deletion of any temporary queue, defined.

For a durable subscription to this topic, no queue deletion would be applied on disconnect - which is likely to be undesirable (see section above).

<topics>
	 <topic>
	 <name>stocks.us.*</name>
		 <slow-consumer-detection>
			 <!-- The maximum depth before which -->
			 <!-- the policy will be applied-->
			 <depth>4235264</depth>
			 <!-- The maximum message age before which -->
			 <!-- the policy will be applied-->
			 <messageAge>600000</messageAge>
			 <!-- The maximum number of message before -->
			 <!-- which the policy will be applied-->
			 <messageCount>50</messageCount>
			 <!-- Policy Selection -->
			 <policy name="TopicDelete"/>
		 </slow-consumer-detection>
	 </topic>
</topics>