qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From conflue...@apache.org
Subject [CONF] Apache Qpid > Qpid extensions to AMQP
Date Wed, 02 Mar 2011 13:21:01 GMT
<html>
<head>
    <base href="https://cwiki.apache.org/confluence">
            <link rel="stylesheet" href="/confluence/s/2036/9/21/_/styles/combined.css?spaceKey=qpid&amp;forWysiwyg=true"
type="text/css">
    </head>
<body style="background: white;" bgcolor="white" class="email-body">
<div id="pageContent">
<div id="notificationFormat">
<div class="wiki-content">
<div class="email">
    <h2><a href="https://cwiki.apache.org/confluence/display/qpid/Qpid+extensions+to+AMQP">Qpid
extensions to AMQP</a></h2>
    <h4>Page <b>edited</b> by             <a href="https://cwiki.apache.org/confluence/display/~gsim@redhat.com">Gordon
Sim</a>
    </h4>
        <br/>
                         <h4>Changes (1)</h4>
                                 
    
<div id="page-diffs">
                    <table class="diff" cellpadding="0" cellspacing="0">
    
            <tr><td class="diff-snipped" >...<br></td></tr>
            <tr><td class="diff-unchanged" >| qpid.alert_count |Y| N | Specified
that if the queue gets above this size (in message count) an alert should be sent (alias for
x-qpid-maximum-message-count) | <br>| qpid.alert_repeat_gap |Y| N | Specified the minimum
time gap between consecutive alerts (alias for x-qpid-minimum-alert-repeat-gap) | <br></td></tr>
            <tr><td class="diff-added-lines" style="background-color: #dfd;">|
qpid.priorities | Y | N | Defines the number of distinct priority levels supported by the
queue (alias for x-qpid-priorities) | <br></td></tr>
            <tr><td class="diff-unchanged" > <br>h3. Subscription <br></td></tr>
            <tr><td class="diff-snipped" >...<br></td></tr>
    
            </table>
    </div>                            <h4>Full Content</h4>
                    <div class="notificationGreySide">
        <h2><a name="QpidextensionstoAMQP-Overview"></a>Overview</h2>

<p>This page is an attempt to collect in a single place all the extensions that have
been made (thorough the use of arguments/options/tec.) to AMQP across the Qpid Java and C++
Brokers.</p>

<p>Ultimately the aim is to try to get both brokers implementing as much common functionality
as possible through common extensions - and to advertise which extensions are available in
a common way, so that clients can take advantage of functions that are present (or work around
functions that are not).</p>

<h3><a name="QpidextensionstoAMQP-Connection"></a>Connection</h3>

<h4><a name="QpidextensionstoAMQP-Connection.Start"></a>Connection.Start</h4>

<p>Options are carried in the server-properties field</p>

<div class='table-wrap'>
<table class='confluenceTable'><tbody>
<tr>
<th class='confluenceTh'> Name </th>
<th class='confluenceTh'> C++ </th>
<th class='confluenceTh'> Java </th>
<th class='confluenceTh'> Description </th>
</tr>
<tr>
<td class='confluenceTd'> qpid.federation_tag </td>
<td class='confluenceTd'> Y </td>
<td class='confluenceTd'> Y </td>
<td class='confluenceTd'>&nbsp;</td>
</tr>
</tbody></table>
</div>


<h4><a name="QpidextensionstoAMQP-Connection.StartOk"></a>Connection.Start-Ok</h4>

<p>Options are carried in the client-properties field</p>

<div class='table-wrap'>
<table class='confluenceTable'><tbody>
<tr>
<th class='confluenceTh'> Name </th>
<th class='confluenceTh'> C++ </th>
<th class='confluenceTh'> Java </th>
<th class='confluenceTh'> Description </th>
</tr>
<tr>
<td class='confluenceTd'> qpid.client_pid </td>
<td class='confluenceTd'> Y </td>
<td class='confluenceTd'> N </td>
<td class='confluenceTd'>Allows the process id of a client to be reported by mgmt tools</td>
</tr>
<tr>
<td class='confluenceTd'> qpid.client_ppid </td>
<td class='confluenceTd'> Y </td>
<td class='confluenceTd'> N </td>
<td class='confluenceTd'>Allows the parent process id of a client to be reported by
mgmt tools</td>
</tr>
<tr>
<td class='confluenceTd'> qpid.client_process </td>
<td class='confluenceTd'> Y </td>
<td class='confluenceTd'> N </td>
<td class='confluenceTd'>Allows the process name of a client to be reported by mgmt
tools</td>
</tr>
</tbody></table>
</div>


<h3><a name="QpidextensionstoAMQP-Session"></a>Session</h3>

<p>???</p>

<h3><a name="QpidextensionstoAMQP-Exchange"></a>Exchange</h3>

<h4><a name="QpidextensionstoAMQP-Exchange.Declare"></a>Exchange.Declare</h4>

<div class='table-wrap'>
<table class='confluenceTable'><tbody>
<tr>
<th class='confluenceTh'> Name </th>
<th class='confluenceTh'> C++ </th>
<th class='confluenceTh'> Java </th>
<th class='confluenceTh'> Description </th>
</tr>
<tr>
<td class='confluenceTd'> qpid.ive </td>
<td class='confluenceTd'> Y </td>
<td class='confluenceTd'> N </td>
<td class='confluenceTd'>Specifies 'initial value exchange' behaviour is desired</td>
</tr>
<tr>
<td class='confluenceTd'> qpid.msg_sequence </td>
<td class='confluenceTd'> Y </td>
<td class='confluenceTd'> N </td>
<td class='confluenceTd'>Requests that the exchange sequences all messages routed through
it and adds the sequence number to the message headers</td>
</tr>
</tbody></table>
</div>



<h3><a name="QpidextensionstoAMQP-Binding"></a>Binding</h3>

<h4><a name="QpidextensionstoAMQP-Exchange.Bind"></a>Exchange.Bind</h4>

<p>Options are carried in the arguments field</p>

<div class='table-wrap'>
<table class='confluenceTable'><tbody>
<tr>
<th class='confluenceTh'> Name </th>
<th class='confluenceTh'> C++ </th>
<th class='confluenceTh'> Java </th>
<th class='confluenceTh'> Description </th>
</tr>
<tr>
<td class='confluenceTd'> qpid.fed.origin </td>
<td class='confluenceTd'> Y </td>
<td class='confluenceTd'> Y </td>
<td class='confluenceTd'>&nbsp;</td>
</tr>
<tr>
<td class='confluenceTd'> x-filter-jms-selector </td>
<td class='confluenceTd'>N</td>
<td class='confluenceTd'> Y* </td>
<td class='confluenceTd'> (Java Broker topic exchange only currently) add a JMS Selector
to the binding to filter messages against an SQL style query </td>
</tr>
</tbody></table>
</div>


<h3><a name="QpidextensionstoAMQP-Queue"></a>Queue</h3>

<h4><a name="QpidextensionstoAMQP-Queue.Declare"></a>Queue.Declare</h4>

<p>Options are carried in the arguments field</p>

<div class='table-wrap'>
<table class='confluenceTable'><tbody>
<tr>
<th class='confluenceTh'> Name </th>
<th class='confluenceTh'> C++ </th>
<th class='confluenceTh'> Java </th>
<th class='confluenceTh'> Description </th>
</tr>
<tr>
<td class='confluenceTd'> no-local </td>
<td class='confluenceTd'> Y </td>
<td class='confluenceTd'>N</td>
<td class='confluenceTd'> Specifies that the queue should discard any messages enqueued
by sessions on the same connection as that which declares the queue </td>
</tr>
<tr>
<td class='confluenceTd'> qpid.policy_type </td>
<td class='confluenceTd'> Y </td>
<td class='confluenceTd'> N </td>
<td class='confluenceTd'> Valid values "reject", "flow_to_disk", "ring", "ring_strict"
</td>
</tr>
<tr>
<td class='confluenceTd'> qpid.max_size </td>
<td class='confluenceTd'> Y </td>
<td class='confluenceTd'> N </td>
<td class='confluenceTd'> Defines the maximum number of messages that a queue can contain
before the action dictated by the policy_type is taken. </td>
</tr>
<tr>
<td class='confluenceTd'> qpid.max_count </td>
<td class='confluenceTd'> Y </td>
<td class='confluenceTd'> N </td>
<td class='confluenceTd'> Defines the maximum size of message data (in bytes) that a
queue can contain before the action dictated by the policy_type is taken.</td>
</tr>
<tr>
<td class='confluenceTd'> qpid.file_count </td>
<td class='confluenceTd'> Y </td>
<td class='confluenceTd'> N </td>
<td class='confluenceTd'> This is really a property of a particular store implementation
(sets the number of files to use for the queue's 'journal') </td>
</tr>
<tr>
<td class='confluenceTd'> qpid.file_size </td>
<td class='confluenceTd'> Y </td>
<td class='confluenceTd'> N </td>
<td class='confluenceTd'> This is really a property of a particular store implementation
(sets the size of the files to use for the queue's 'journal') </td>
</tr>
<tr>
<td class='confluenceTd'> qpid.last_value_queue </td>
<td class='confluenceTd'> Y </td>
<td class='confluenceTd'> N </td>
<td class='confluenceTd'> Enables last value queue behaviour </td>
</tr>
<tr>
<td class='confluenceTd'> qpid.last_value_queue_no_browse </td>
<td class='confluenceTd'> Y </td>
<td class='confluenceTd'> N </td>
<td class='confluenceTd'> Enables special mode for last value queue behaviour (see QPID-2104)</td>
</tr>
<tr>
<td class='confluenceTd'> qpid.msg_sequence </td>
<td class='confluenceTd'> Y </td>
<td class='confluenceTd'> N </td>
<td class='confluenceTd'> Causes a sequence number to be added to headers of enqueued
messages</td>
</tr>
<tr>
<td class='confluenceTd'> qpid.queue_event_generation </td>
<td class='confluenceTd'> Y </td>
<td class='confluenceTd'> N </td>
<td class='confluenceTd'> Causes an event to be generated for enqueues and dequeues,
currently used for asynchronous state replication </td>
</tr>
<tr>
<td class='confluenceTd'> qpid.trace.id </td>
<td class='confluenceTd'> Y </td>
<td class='confluenceTd'> Y </td>
<td class='confluenceTd'> Adds the given trace id as to the application header "x-qpid.trace"
in messages sent from the queue </td>
</tr>
<tr>
<td class='confluenceTd'> qpid.trace.excludes </td>
<td class='confluenceTd'> Y </td>
<td class='confluenceTd'> Y </td>
<td class='confluenceTd'> Does not send on messages which include one of the given (comma
separated) trace ids </td>
</tr>
<tr>
<td class='confluenceTd'> x-qpid-priorities </td>
<td class='confluenceTd'> Y </td>
<td class='confluenceTd'> Y </td>
<td class='confluenceTd'> Defines the number of distinct priority levels supported by
the queue </td>
</tr>
<tr>
<td class='confluenceTd'> x-qpid-maximum-message-age </td>
<td class='confluenceTd'>N</td>
<td class='confluenceTd'> Y </td>
<td class='confluenceTd'> Specifies that if the oldest message on the queue gets above
this age then alerts should be sent </td>
</tr>
<tr>
<td class='confluenceTd'> x-qpid-maximum-message-size </td>
<td class='confluenceTd'>Y</td>
<td class='confluenceTd'> Y </td>
<td class='confluenceTd'> Specifies that if the queue gets above this size (in bytes)
an alert should be sent </td>
</tr>
<tr>
<td class='confluenceTd'> x-qpid-maximum-message-count </td>
<td class='confluenceTd'>Y</td>
<td class='confluenceTd'> Y </td>
<td class='confluenceTd'> Specified that if the queue gets above this size (in message
count) an alert should be sent</td>
</tr>
<tr>
<td class='confluenceTd'> x-qpid-minimum-alert-repeat-gap </td>
<td class='confluenceTd'>Y</td>
<td class='confluenceTd'> Y </td>
<td class='confluenceTd'> Specified the minimum time gap between consecutive alerts
</td>
</tr>
<tr>
<td class='confluenceTd'> x-qpid-capacity </td>
<td class='confluenceTd'>N </td>
<td class='confluenceTd'> Y </td>
<td class='confluenceTd'> Defines the size of the queue in bytes at which flow control
on producers will be brought into affect </td>
</tr>
<tr>
<td class='confluenceTd'> x-qpid-flow-resume-capacity </td>
<td class='confluenceTd'>N</td>
<td class='confluenceTd'> Y </td>
<td class='confluenceTd'> Defines the size on bytes of the queue when flow control will
be rescinded </td>
</tr>
<tr>
<td class='confluenceTd'> qpid.flow_stop_count </td>
<td class='confluenceTd'>Y</td>
<td class='confluenceTd'> N </td>
<td class='confluenceTd'> Defines the queue depth in messages at which flow control
of producer will come into affect </td>
</tr>
<tr>
<td class='confluenceTd'> qpid.flow_resume_count </td>
<td class='confluenceTd'>Y</td>
<td class='confluenceTd'> N </td>
<td class='confluenceTd'> Defines the queue depth in messages at which inflow from producers
will no longer be restricted  </td>
</tr>
<tr>
<td class='confluenceTd'> qpid.flow_stop_size </td>
<td class='confluenceTd'>Y</td>
<td class='confluenceTd'> N </td>
<td class='confluenceTd'> Defines the queue depth in bytes at which flow control of
producer will come into affect </td>
</tr>
<tr>
<td class='confluenceTd'> qpid.flow_resume_size </td>
<td class='confluenceTd'>Y</td>
<td class='confluenceTd'> N </td>
<td class='confluenceTd'> Defines the queue depth in bytes at which inflow from producers
will no longer be restricted  </td>
</tr>
<tr>
<td class='confluenceTd'> qpid.alert_size </td>
<td class='confluenceTd'>Y</td>
<td class='confluenceTd'> N </td>
<td class='confluenceTd'> Specifies that if the queue gets above this size (in bytes)
an alert should be sent (alias for x-qpid-maximum-message-size) </td>
</tr>
<tr>
<td class='confluenceTd'> qpid.alert_count </td>
<td class='confluenceTd'>Y</td>
<td class='confluenceTd'> N </td>
<td class='confluenceTd'> Specified that if the queue gets above this size (in message
count) an alert should be sent (alias for x-qpid-maximum-message-count) </td>
</tr>
<tr>
<td class='confluenceTd'> qpid.alert_repeat_gap </td>
<td class='confluenceTd'>Y</td>
<td class='confluenceTd'> N </td>
<td class='confluenceTd'> Specified the minimum time gap between consecutive alerts
(alias for x-qpid-minimum-alert-repeat-gap) </td>
</tr>
<tr>
<td class='confluenceTd'> qpid.priorities </td>
<td class='confluenceTd'> Y </td>
<td class='confluenceTd'> N </td>
<td class='confluenceTd'> Defines the number of distinct priority levels supported by
the queue (alias for x-qpid-priorities) </td>
</tr>
</tbody></table>
</div>


<h3><a name="QpidextensionstoAMQP-Subscription"></a>Subscription</h3>

<h4><a name="QpidextensionstoAMQP-Message.Subscribe%28Basic.Consumein08%2F09%29"></a>Message.Subscribe
(Basic.Consume in 0-8/0-9)</h4>

<div class='table-wrap'>
<table class='confluenceTable'><tbody>
<tr>
<th class='confluenceTh'> Name </th>
<th class='confluenceTh'> C++ </th>
<th class='confluenceTh'> Java </th>
<th class='confluenceTh'> Description </th>
</tr>
<tr>
<td class='confluenceTd'> x-filter-jms-selector </td>
<td class='confluenceTd'>N</td>
<td class='confluenceTd'> Y </td>
<td class='confluenceTd'> add a JMS Selector to the subscription to filter messages
against an SQL style query </td>
</tr>
<tr>
<td class='confluenceTd'> x-filter-no-consume </td>
<td class='confluenceTd'>N</td>
<td class='confluenceTd'> Y </td>
<td class='confluenceTd'> (0-8/0-9 only) Implements browsing for 0-8/0-9 - messages
sent on the subscription are not acquired </td>
</tr>
<tr>
<td class='confluenceTd'> x-filter-auto-close </td>
<td class='confluenceTd'>N</td>
<td class='confluenceTd'> Y </td>
<td class='confluenceTd'> (0-8/0-9 only) The server closes the subscription when the
queue becomes empty </td>
</tr>
</tbody></table>
</div>


    </div>
        <div id="commentsSection" class="wiki-content pageSection">
        <div style="float: right;">
            <a href="https://cwiki.apache.org/confluence/users/viewnotifications.action"
class="grey">Change Notification Preferences</a>
        </div>
        <a href="https://cwiki.apache.org/confluence/display/qpid/Qpid+extensions+to+AMQP">View
Online</a>
        |
        <a href="https://cwiki.apache.org/confluence/pages/diffpagesbyversion.action?pageId=10387741&revisedVersion=7&originalVersion=6">View
Changes</a>
                |
        <a href="https://cwiki.apache.org/confluence/display/qpid/Qpid+extensions+to+AMQP?showComments=true&amp;showCommentArea=true#addcomment">Add
Comment</a>
            </div>
</div>
</div>
</div>
</div>
</body>
</html>

---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project:      http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org


Mime
View raw message