Controlling subscription queues for topic receivers

queue limits and slow subscriber

  my-topic; {link:{x-declare:{arguments:{'qpid.max_count':500}}}}

no-local

You can request that your subscriber does not receive any messages published on that same connection using the no-local option:

  my-topic; {link:{x-declare:{arguments:{no-local:True}}}}

reliability and durability

subscription bindings, e.g. subscriptions on XML and headers exchanges, multiple binding patterns etc

Creating shared queues on-demand

queue limits

  queue-a; {create: always, node:{x-declare:{arguments:{'qpid.max_count':1000}}}}

  queue-b; {create: always, node:{x-declare:{arguments:{'qpid.max_count':1000, 'qpid.max_size':1000000}}}}

LVQs

  my-lvq; {create: always, node:{x-declare:{arguments:{'qpid.last_value_queue_key':'qpid.subject'}}}}

priority queues

  my-priority-queue; {create: always, node:{x-declare:{arguments:{'x-qpid-priorities':10}}}}

Note that qpid.priorities can be used as an alias for x-qpid-priorities with the c++ broker (i.e. qpidd) for the sake of consistency; the latter is supported by the Java broker as well however.

automatic deletion of queues

Bindings