1.2.Â Cheat Sheet for configuring Queue Options

> +1.2.Â Cheat Sheet for configuring Queue Options

Apache Qpid

Documentation

Community

Developers

About AMQP

What is AMQP?

About Apa che

> >

1.2.Â +

1.2.Â Cheat Sheet for configuring Queue Options -

1.2.1.Â +

1.2.1.Â Configuring Queue Options

The C++ Broker M4 or later supports the following additional Queue constraints. -

SectionÂ 1.2.1, â Configuring Queue Options â -

The 0.10 C++ Broker supports the following additional Queue configuration options: -

- SectionÂ 1.9, â +
- + SectionÂ 1.8, â Producer Flow Control â -
1.2.1.1.Â +

1.2.1.1.Â Applying Queue Sizing Constraints

This allows to specify how to size a queue and what to do when @@ -62,11 +62,11 @@

Once the Queue meets/ exceeds these constraints the follow policies can be applied -

REJECT - Reject the published message -
FLOW_TO_DISK - Flow the messages to disk, to preserve memory -
RING - start overwriting messages in a ring based on sizing. +
- REJECT - Reject the published message +
- FLOW_TO_DISK - Flow the messages to disk, to preserve memory +
- RING - start overwriting messages in a ring based on sizing. If head meets tail, advance head -
- RING_STRICT - start overwriting messages in a ring based on +
- RING_STRICT - start overwriting messages in a ring based on sizing. If head meets tail, AND the consumer has the tail message acquired it will reject
@@ -90,7 +90,7 @@ qo.setSizePolicy(RING,0,1000); session.queueDeclare(arg::queue=queue, arg::arguments=qo); -

1.2.1.2.Â +

1.2.1.2.Â Changing the Queue ordering Behaviors (FIFO/LVQ)

The default ordering in a queue in Qpid is FIFO. However @@ -121,23 +121,23 @@

Notes: -

Messages that are dequeued and the re-queued will have the +
- Messages that are dequeued and the re-queued will have the following exceptions. a.) if a new message has been queued with the same key, the re-queue from the consumer, will combine these two messages. b.) If an update happens for a message of the same key, after the re-queue, it will not update the re-queued message. This is done to protect a client from being able to adversely manipulate the queue. -
- Acquire: When a message is acquired from the queue, no matter +
- Acquire: When a message is acquired from the queue, no matter it's position, it will behave the same as a dequeue -
- LVQ does not support durable messages. If the queue or +
- LVQ does not support durable messages. If the queue or messages are declared durable on an LVQ, the durability will be ignored.
A fully worked SectionÂ 1.6.3, âLVQ Exampleâ can be found here -

1.2.1.3.Â +

1.2.1.3.Â Setting additional behaviors -

+

Persist Last Node

@@ -148,10 +148,10 @@ messages.

Note -

if a cluster is started with only one active node, this mode +
- if a cluster is started with only one active node, this mode will not be triggered. It is only triggered the first time the cluster fails down to 1 node. -
- The queue MUST be configured durable +
- The queue MUST be configured durable
Example:
```
@@ -161,7 +161,7 @@
     qo.clearPersistLastNode();
 
     session.queueDeclare(arg::queue=queue, arg::durable=true, arg::arguments=qo);
-
```

+

Queue event generation

@@ -185,7 +185,7 @@ 'qpid.queue_event_generation' and the value is and integer value of 1 (to replicate only enqueue events) or 2 (to replicate both enqueue and dequeue events). -

1.2.1.4.Â +

1.2.1.4.Â Other Clients

Modified: qpid/site/docs/books/trunk/AMQP-Messaging-Broker-CPP-Book/html/ch01s03.html URL: http://svn.apache.org/viewvc/qpid/site/docs/books/trunk/AMQP-Messaging-Broker-CPP-Book/html/ch01s03.html?rev=1441019&r1=1441018&r2=1441019&view=diff ============================================================================== --- qpid/site/docs/books/trunk/AMQP-Messaging-Broker-CPP-Book/html/ch01s03.html (original) +++ qpid/site/docs/books/trunk/AMQP-Messaging-Broker-CPP-Book/html/ch01s03.html Thu Jan 31 15:32:50 2013 @@ -1,24 +1,24 @@ -1.3.Â Cheat Sheet for configuring Exchange Options

Apache Qpidâ¢

Open Source AMQP Messaging

Apache Qpid

Documentation

Community

Developers

About AMQP

About Ap ache

Apache Qpidâ¢

Open Source AMQP Messaging

Apache Qpid

Documentation

Community

Developers

About AMQP

About Apa che

1.2.Â +

1.2.Â Cheat Sheet for configuring Queue Options -

1.2.1.Â +

1.2.1.Â Configuring Queue Options

1.2.1.1.Â +

1.2.1.1.Â Applying Queue Sizing Constraints

1.2.1.2.Â +

1.2.1.2.Â Changing the Queue ordering Behaviors (FIFO/LVQ)

1.2.1.3.Â +

1.2.1.3.Â Setting additional behaviors -

+

Persist Last Node

+

Queue event generation

1.2.1.4.Â +

1.2.1.4.Â Other Clients

Apache Qpidâ¢

Open Source AMQP Messaging

Apache Qpid

Documentation

Community

Developers

About AMQP

About Apache

Apache Qpidâ¢

Open Source AMQP Messaging

Apache Qpid

Documentation

Community

Developers

About AMQP

About Apache

1.3.Â +

1.3.Â Cheat Sheet for configuring Exchange Options -

1.3.1.Â +

1.3.1.Â Configuring Exchange Options

1.3.1.1.Â Exchange Level Message sequencing

1.3.1.2.Â +

1.3.1.2.Â Initial Value Exchange

1.3.1.3.Â +

1.3.1.3.Â Exclusive binding for key

Apache Qpidâ¢

Open Source AMQP Messaging

Apache Qpid

Documentation

Community

Developers

About AMQP

About Apache

Apache Qpidâ¢

Open Source AMQP Messaging

Apache Qpid

Documentation

Community

Developers

About AMQP

About Apache

1.6.Â LVQ - Last Value Queue

1.6.1.Â Understanding LVQ

1.6.Â LVQ - Last Value Queue

1.6.1.Â Understanding LVQ

1.6.1.1.Â Common Use-Cases

1.6.1.1.Â Common Use-Cases

1.6.2.Â Creating a Last Value Queue

Apache Qpidâ¢

Apache Qpidâ¢

Apache Qpidâ¢

Apache Qpidâ¢

Apache Qpidâ¢

Apache Qpidâ¢

Apache Qpidâ¢

Apache Qpidâ¢