qpid-jms git commit: QPIDJMS-423 Log only the host and port data from the URI on connect
Repository: qpid-jms
Updated Branches:
refs/heads/master d96734e0f -> abc75a35e
QPIDJMS-423 Log only the host and port data from the URI on connect
Update the connection event handler to log only the on-query portion of
the URI when processing the event.
This closes #23
Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/abc75a35
Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/abc75a35
Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/abc75a35
Branch: refs/heads/master
Commit: abc75a35e22fdfde95511b78d2b020c303bb31a8
Parents: d96734e
Author: Timothy Bish
Authored: Mon Oct 29 14:45:36 2018 -0400
Committer: Timothy Bish
Committed: Mon Oct 29 14:45:36 2018 -0400
--
.../src/main/java/org/apache/qpid/jms/JmsConnection.java| 9 -
1 file changed, 8 insertions(+), 1 deletion(-)
--
http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/abc75a35/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsConnection.java
--
diff --git
a/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsConnection.java
b/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsConnection.java
index a3537e3..b4e2682 100644
--- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsConnection.java
+++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsConnection.java
@@ -18,6 +18,7 @@ package org.apache.qpid.jms;
import java.io.IOException;
import java.net.URI;
+import java.net.URISyntaxException;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.ConcurrentHashMap;
@@ -86,6 +87,7 @@ import org.apache.qpid.jms.util.MessageQueue;
import org.apache.qpid.jms.util.PriorityMessageQueue;
import org.apache.qpid.jms.util.QpidJMSThreadFactory;
import org.apache.qpid.jms.util.ThreadPoolUtils;
+import org.apache.qpid.jms.util.URISupport;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -1322,7 +1324,12 @@ public class JmsConnection implements AutoCloseable,
Connection, TopicConnection
@Override
public void onConnectionEstablished(final URI remoteURI) {
-LOG.info("Connection {} connected to remote Broker: {}",
connectionInfo.getId(), remoteURI);
+try {
+LOG.info("Connection {} connected to remote Broker: {}",
connectionInfo.getId(), URISupport.removeQuery(remoteURI));
+} catch (URISyntaxException e) {
+LOG.info("Connection {} connected to remote Broker: {}",
connectionInfo.getId());
+}
+
setMessageFactory(provider.getMessageFactory());
connectionInfo.setConnectedURI(provider.getRemoteURI());
-
To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org
For additional commands, e-mail: commits-h...@qpid.apache.org
qpid-broker-j git commit: QPID-8242 : JDBC store should remove message content/metadata asynchronously
Repository: qpid-broker-j
Updated Branches:
refs/heads/master 7a99cdc98 -> bb57b5159
QPID-8242 : JDBC store should remove message content/metadata asynchronously
Project: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/commit/bb57b515
Tree: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/tree/bb57b515
Diff: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/diff/bb57b515
Branch: refs/heads/master
Commit: bb57b51593128b31c796f80cba249f9a3e126177
Parents: 7a99cdc
Author: rgodfrey
Authored: Mon Oct 29 21:58:29 2018 +0100
Committer: rgodfrey
Committed: Mon Oct 29 21:58:29 2018 +0100
--
.../store/jdbc/AbstractJDBCMessageStore.java| 124 +--
1 file changed, 87 insertions(+), 37 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/bb57b515/broker-plugins/jdbc-store/src/main/java/org/apache/qpid/server/store/jdbc/AbstractJDBCMessageStore.java
--
diff --git
a/broker-plugins/jdbc-store/src/main/java/org/apache/qpid/server/store/jdbc/AbstractJDBCMessageStore.java
b/broker-plugins/jdbc-store/src/main/java/org/apache/qpid/server/store/jdbc/AbstractJDBCMessageStore.java
index 4ad0fe6..e92aa73 100644
---
a/broker-plugins/jdbc-store/src/main/java/org/apache/qpid/server/store/jdbc/AbstractJDBCMessageStore.java
+++
b/broker-plugins/jdbc-store/src/main/java/org/apache/qpid/server/store/jdbc/AbstractJDBCMessageStore.java
@@ -38,8 +38,11 @@ import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledThreadPoolExecutor;
import java.util.concurrent.ThreadFactory;
+import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.atomic.AtomicLong;
+import java.util.concurrent.atomic.AtomicReference;
+import java.util.stream.Collectors;
import com.google.common.util.concurrent.Futures;
import com.google.common.util.concurrent.ListenableFuture;
@@ -83,6 +86,10 @@ public abstract class AbstractJDBCMessageStore implements
MessageStore
private final AtomicLong _messageId = new AtomicLong(0);
+private static final List EMPTY_LIST = Collections.emptyList();
+private final AtomicReference> _messagesToDelete = new
AtomicReference<>(EMPTY_LIST);
+private final AtomicBoolean _messageRemovalScheduled = new AtomicBoolean();
+
protected final EventManager _eventManager = new EventManager();
private ConfiguredObject _parent;
@@ -409,57 +416,100 @@ public abstract class AbstractJDBCMessageStore
implements MessageStore
return _messageId.incrementAndGet();
}
-private void removeMessage(long messageId)
+private void removeMessageAsync(long messageId)
+{
+List orig;
+List updated;
+do
+{
+orig = _messagesToDelete.get();
+updated = new ArrayList<>(orig.size()+1);
+updated.addAll(orig);
+updated.add(messageId);
+updated = Collections.unmodifiableList(updated);
+} while (! _messagesToDelete.compareAndSet(orig, updated));
+scheduleMessageRemoval();
+}
+
+private void scheduleMessageRemoval()
{
-try(Connection conn = newConnection())
+if(_messageRemovalScheduled.compareAndSet(false, true))
{
-try
-{
-try(PreparedStatement stmt = conn.prepareStatement("DELETE
FROM " + getMetaDataTableName()
- + " WHERE
message_id = ?"))
+_executor.submit(() -> {
+List messageIds;
+do
{
-stmt.setLong(1, messageId);
-int results = stmt.executeUpdate();
-stmt.close();
+messageIds = _messagesToDelete.getAndSet(EMPTY_LIST);
+removeMessages(messageIds);
+} while(!messageIds.isEmpty());
+
+_messageRemovalScheduled.set(false);
+if(!_messagesToDelete.get().isEmpty())
+{
+scheduleMessageRemoval();
+}
-if (results == 0)
+});
+}
+}
+
+boolean isMessageRemovalScheduled()
+{
+return _messageRemovalScheduled.get();
+}
+
+private void removeMessages(List messageIds)
+{
+if(messageIds != null && !messageIds.isEmpty())
+{
+String inpart =
messageIds.stream().map(Object::toString).collect(Collectors.joining(", ", "(",
")"));
+try(Connection conn = newConnection())
+{
+try
+{
+try
[07/51] [partial] qpid-site git commit: QPID-8250: Update for Qpid C++ 1.39.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/input/releases/qpid-cpp-1.39.0/cpp-broker/book/chap-Messaging_User_Guide-Broker_Federation.html.in -- diff --git a/input/releases/qpid-cpp-1.39.0/cpp-broker/book/chap-Messaging_User_Guide-Broker_Federation.html.in b/input/releases/qpid-cpp-1.39.0/cpp-broker/book/chap-Messaging_User_Guide-Broker_Federation.html.in new file mode 100644 index 000..cf65990 --- /dev/null +++ b/input/releases/qpid-cpp-1.39.0/cpp-broker/book/chap-Messaging_User_Guide-Broker_Federation.html.in @@ -0,0 +1,348 @@ +1.4. Broker FederationPrev Chapter 1. + Running the AMQP Messaging Broker + Next1.4. Broker Federation +Broker Federation allows messaging networks to be defined by creating message routes, in which messages in one broker (the source broker) are automatically routed to another broker (the destination broker). These routes may be defined between exchanges in the two brokers (the source exchange and the destination exchange), or from a queue in the source broker (the source queue) to an exchange in the destination broker. Message routes are unidirectional; when bidirectional flow is needed, one route is created in each direction. Routes can be durable or transient. A durable route survives broker restarts, restoring a route as soon as both the source broker and the destination are available. If the connection to a destination is lost, messages associated with a durable route continue to accumulate on the source, so they can be retrieved when the connection is reestablished. + +Broker Federation can be used to build large messaging networks, with many brokers, one route at a time. If network connectivity permits, an entire distributed messaging network can be configured from a single location. The rules used for routing can be changed dynamically as servers change, responsibilities change, at different times of day, or to reflect other changing conditions. + +Broker Federation is useful in a wide variety of scenarios. Some of these have to do with functional organization; for instance, brokers may be organized by geography, service type, or priority. Here are some use cases for federation: + + Geography: Customer requests may be routed to a processing location close to the customer. + + Service Type: High value customers may be routed to more responsive servers. + + Load balancing: Routing among brokers may be changed dynamically to account for changes in actual or anticipated load. + + High Availability: Routing may be changed to a new broker if an existing broker becomes unavailable. + + WAN Connectivity: Federated routes may connect disparate locations across a wide area network, while clients connect to brokers on their own local area network. Each broker can provide persistent queues that can hold messages even if there are gaps in WAN connectivity. + + Functional Organization: The flow of messages among software subsystems can be configured to mirror the logical structure of a distributed application. + + Replicated Exchanges: High-function exchanges like the XML exchange can be replicated to scale performance. + + Interdepartmental Workflow: The flow of messages among brokers can be configured to mirror interdepartmental workflow at an organization. + + + 1.4.1. Message Routes + Broker Federation is done by creating message routes. The destination for a route is always an exchange on the destination broker. By default, a message route is created by configuring the destination broker, which then contacts the source broker to subscribe to the source queue. This is called a pull route. It is also possible to create a route by configuring the source broker, which then contacts the destination broker in order to send messages. This is called a push route, and is particularly useful when the destination broker may not be available at the time the messaging route is configured, or when a large number of routes are created with the same destination exchange. + + The source for a route can be either an exchange or a queue on the source broker. If a route is between two exchanges, the routing criteria can be given explicitly, or the bindings of the destination exchange can be used to determine the routing criteria. To support this functionality, there are three kinds of message routes: queue routes, exchange routes, and dynamic exchange routes. +1.4.1.1. Queue Routes + Queue Routes route all messages from a source queue to a destination exchange. If message acknowledgement is enabled, messages are removed from the queue when they have been received by the destination exchange; if message acknowledgement is off, messages are removed from the queue when sent. + 1.4
[44/51] [partial] qpid-site git commit: QPID-8250: Update for Qpid C++ 1.39.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/cpp-broker/book/chapter-ha.html
--
diff --git a/content/releases/qpid-cpp-1.39.0/cpp-broker/book/chapter-ha.html
b/content/releases/qpid-cpp-1.39.0/cpp-broker/book/chapter-ha.html
new file mode 100644
index 000..702f7f9
--- /dev/null
+++ b/content/releases/qpid-cpp-1.39.0/cpp-broker/book/chapter-ha.html
@@ -0,0 +1,930 @@
+
+
+http://www.w3.org/1999/xhtml"; xml:lang="en">
+
+1.12. Active-Passive Messaging Clusters - Apache
Qpid™
+
+
+
+
+var _deferredFunctions = [];
+
+
+
+
+https://git-wip-us.apache.org/repos/asf/qpid-proton.git"/>
+https://github.com/apache/qpid-proton/blob/go1/README.md
+https://github.com/apache/qpid-proton/tree/go1{/dir}
+https://github.com/apache/qpid-proton/blob/go1{/dir}/{file}#L{line}"/>
+
+
+
+
+
+
+
+
+
+ Apache
Qpid™
+ Documentation
+ Download
+ Discussion
+
+
+
+
+
+
+Project
+
+
+ Overview
+ Components
+ Releases
+
+
+
+
+Messaging APIs
+
+
+ Qpid Proton
+ Qpid JMS
+ Qpid
Messaging API
+
+
+
+
+Servers and tools
+
+
+ Broker-J
+ C++
broker
+ Dispatch
router
+
+
+
+
+Resources
+
+
+ Dashboard
+ https://cwiki.apache.org/confluence/display/qpid/Index";>Wiki
+ More resources
+
+
+
+
+
+
+http://www.google.com/search"; method="get">
+
+
+ Search
+ More ways to search
+
+
+
+
+HomeReleasesQpid C++ 1.39.0AMQP Messaging
Broker (Implemented in C++)1.12. Active-Passive Messaging
Clusters
+
+
+ 1.12. Active-Passive Messaging ClustersPrev Chapter 1.
+ Running the AMQP Messaging Broker
+ Next1.12. Active-Passive Messaging
Clusters1.12.1. Overview
+
+ The High Availability (HA) module provides
+ active-passive, hot-standby
+ messaging clusters to provide fault tolerant message delivery.
+
+ In an active-passive cluster only one broker, known as the
+ primary, is active and serving clients at a
time. The other
+ brokers are standing by as backups. Changes
on the primary
+ are replicated to all the backups so they are always up-to-date or
"hot". Backup
+ brokers reject client connection attempts, to enforce the requirement
that clients
+ only connect to the primary.
+
+ If the primary fails, one of the backups is promoted to take over as the
new
+ primary. Clients fail-over to the new primary automatically. If there
are multiple
+ backups, the other backups also fail-over to become backups of the new
primary.
+
+ This approach relies on an external cluster
resource manager
+ to detect failures, choose the new primary and handle network
partitions. https://fedorahosted.org/cluster/wiki/RGManager";
target="_top">rgmanager is supported
+ initially, but others may be supported in the future.
+1.12.1.1. Avoiding message
loss
+ In order to avoid message loss, the primary broker delays
+ acknowledgement of messages received from clients until the
+ message has been replicated and acknowledged by all of the back-up
+ brokers, or has been consumed from the primary queue.
+
+ This ensures that all acknowledged messages are safe: they have either
+ been consumed or backed up to all backup brokers. Messages that are
+ consumed before they are
replicated do not need to
+ be replicated. This reduces the work load when replicating a queue with
+ active consumers.
+
+ Clients keep unacknowledged
messages in a buffer
+ [1]
+ until they are acknowledged by the primary. If the primary fails,
clients will
+ fail-over to the new primary and re-send all their
+ unacknowledged messages.
+ [2]
+
+ If the primary crashes, all the acknowledged
+ messages will be available on the backup that takes over as the new
+ primary. The unacknowledged
messages will be
+ re-sent by the clients. Thus no messages are lost.
+
+ Note that this means it is possible for messages to be
+ duplicated. In the event of a
failure it is possible for a
+ message to received by the backup that becomes the new primary
+ and re-sent by the client. The
application must take steps
+ to identify and eliminate duplicates.
+
+ When a new primary is promot
[50/51] [partial] qpid-site git commit: QPID-8250: Update for Qpid C++ 1.39.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-broker-j-7.0.5/book/Java-Broker-Introduction.html
--
diff --git
a/content/releases/qpid-broker-j-7.0.5/book/Java-Broker-Introduction.html
b/content/releases/qpid-broker-j-7.0.5/book/Java-Broker-Introduction.html
index cb250e3..3cd796b 100644
--- a/content/releases/qpid-broker-j-7.0.5/book/Java-Broker-Introduction.html
+++ b/content/releases/qpid-broker-j-7.0.5/book/Java-Broker-Introduction.html
@@ -117,7 +117,7 @@
https://github.com/apache/qpid-proton/blob/go1{/dir}/{file}#L{line}"/>
Chapter 1. IntroductionPrev NextChapter 1. IntroductionThe
Apache Qpid Broker-J is a powerful open-source message broker that implements
all versions of the
http://www.amqp.org"; target="_top"> Advanced
Message Queuing Protocol (AMQP). The Apache Qpid Broker-J
is actually one of two message brokers provided by the http://qpid.apache.org"; target="_top">Apache Qpid project: Qpid
Broker-J and the C++
-Broker.This document relates to the Apache Qpid Broker-J. The C++ Broker is
+Broker.This document relates to the Apache Qpid Broker-J. The C++ Broker is
described separately.Headline
features100% Java implementation - runs on any platform supporting Java 1.8
or higherMessaging clients support in Java (JMS 1.1 and 2.0 compliance), C++,
Python and more.Persistent and non-persistent (transient) message
supportSupports for all common messaging patterns (point-to-point,
publish/subscribe, fan-out
etc).Transaction support including XA[1]Supports for all versions
of the AMQP protocol (0-8, 0-9, 0-9-1, 0-10 and 1.0).Supports for AMQP over
websockets.Automatic message translation, allowing clients using different AMQP
versions to communicate with each other.Pluggable authentication architecture with
out-of-the-box support for Kerberos, LDAP,
External, OAuth2, and file-based authentication
mechanisms.Support for message compressionPluggable storage architecture with
implementations including http://db.apache.org/derby/";
target="_top">Apache
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-broker-j-7.0.6/book/Java-Broker-Introduction.html
--
diff --git
a/content/releases/qpid-broker-j-7.0.6/book/Java-Broker-Introduction.html
b/content/releases/qpid-broker-j-7.0.6/book/Java-Broker-Introduction.html
index e0ab4c4..b18fe7b 100644
--- a/content/releases/qpid-broker-j-7.0.6/book/Java-Broker-Introduction.html
+++ b/content/releases/qpid-broker-j-7.0.6/book/Java-Broker-Introduction.html
@@ -117,7 +117,7 @@
https://github.com/apache/qpid-proton/blob/go1{/dir}/{file}#L{line}"/>
Chapter 1. IntroductionPrev NextChapter 1. IntroductionThe
Apache Qpid Broker-J is a powerful open-source message broker that implements
all versions of the
http://www.amqp.org"; target="_top"> Advanced
Message Queuing Protocol (AMQP). The Apache Qpid Broker-J
is actually one of two message brokers provided by the http://qpid.apache.org"; target="_top">Apache Qpid project: Qpid
Broker-J and the C++
-Broker.This document relates to the Apache Qpid Broker-J. The C++ Broker is
+Broker.This document relates to the Apache Qpid Broker-J. The C++ Broker is
described separately.Headline
features100% Java implementation - runs on any platform supporting Java 1.8
or higherMessaging clients support in Java (JMS 1.1 and 2.0 compliance), C++,
Python and more.Persistent and non-persistent (transient) message
supportSupports for all common messaging patterns (point-to-point,
publish/subscribe, fan-out
etc).Transaction support including XA[1]Supports for all versions
of the AMQP protocol (0-8, 0-9, 0-9-1, 0-10 and 1.0).Supports for AMQP over
websockets.Automatic message translation, allowing clients using different AMQP
versions to communicate with each other.Pluggable authentication architecture with
out-of-the-box support for Kerberos, LDAP,
External, OAuth2, and file-based authentication
mechanisms.Support for message compressionPluggable storage architecture with
implementations including http://db.apache.org/derby/";
target="_top">Apache
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-broker-j-master/java-broker/book/Java-Broker-Introduction.html
--
diff --git
a/content/releases/qpid-broker-j-master/java-broker/book/Java-Broker-Introduction.html
b/content/releases/qpid-broker-j-master/java-broker/book/Java-Broker-Introduction.html
index 1761d1d..125e125 100644
---
a/content/releases/qpid-broker-j-master/java-broker/book/Java-Broker-Introduction.html
+++
b/content/releases/qpid-broker-j-master/java-broker/book/Java-Broker-Introduction.html
@@ -117,7 +117,7 @@
https://github.com/
[46/51] [partial] qpid-site git commit: QPID-8250: Update for Qpid C++ 1.39.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/cpp-broker/book/chap-Messaging_User_Guide-Security.html
--
diff --git
a/content/releases/qpid-cpp-1.39.0/cpp-broker/book/chap-Messaging_User_Guide-Security.html
b/content/releases/qpid-cpp-1.39.0/cpp-broker/book/chap-Messaging_User_Guide-Security.html
new file mode 100644
index 000..8caf46f
--- /dev/null
+++
b/content/releases/qpid-cpp-1.39.0/cpp-broker/book/chap-Messaging_User_Guide-Security.html
@@ -0,0 +1,1374 @@
+
+
+http://www.w3.org/1999/xhtml"; xml:lang="en">
+
+1.5. Security - Apache Qpid™
+
+
+
+
+var _deferredFunctions = [];
+
+
+
+
+https://git-wip-us.apache.org/repos/asf/qpid-proton.git"/>
+https://github.com/apache/qpid-proton/blob/go1/README.md
+https://github.com/apache/qpid-proton/tree/go1{/dir}
+https://github.com/apache/qpid-proton/blob/go1{/dir}/{file}#L{line}"/>
+
+
+
+
+
+
+
+
+
+ Apache
Qpid™
+ Documentation
+ Download
+ Discussion
+
+
+
+
+
+
+Project
+
+
+ Overview
+ Components
+ Releases
+
+
+
+
+Messaging APIs
+
+
+ Qpid Proton
+ Qpid JMS
+ Qpid
Messaging API
+
+
+
+
+Servers and tools
+
+
+ Broker-J
+ C++
broker
+ Dispatch
router
+
+
+
+
+Resources
+
+
+ Dashboard
+ https://cwiki.apache.org/confluence/display/qpid/Index";>Wiki
+ More resources
+
+
+
+
+
+
+http://www.google.com/search"; method="get">
+
+
+ Search
+ More ways to search
+
+
+
+
+HomeReleasesQpid C++ 1.39.0AMQP Messaging
Broker (Implemented in C++)1.5. Security
+
+
+ 1.5. SecurityPrev Chapter 1.
+ Running the AMQP Messaging Broker
+ Next1.5. Security
+ This chapter describes how authentication, rule-based
authorization, encryption, and digital signing can be accomplished using Qpid.
Authentication is the process of verifying the identity of a user; in Qpid,
this is done using the SASL framework. Rule-based authorization is a mechanism
for specifying the actions that each user is allowed to perform; in Qpid, this
is done using an Access Control List (ACL) that is part of the Qpid broker.
Encryption is used to ensure that data is not transferred in a plain-text
format that could be intercepted and read. Digital signatures provide proof
that a given message was sent by a known sender. Encryption and signing are
done using SSL (they can also be done using SASL, but SSL provides stronger
encryption).
+ 1.5.1. User
Authentication
+ AMQP uses Simple Authentication and Security Layer
(SASL) to authenticate client connections to the broker. SASL is a framework
that supports a variety of authentication methods. For secure applications, we
suggest CRAM-MD5, DIGEST-MD5, or GSSAPI. The ANONYMOUS method is not secure. The
PLAIN method is secure only when
used together with SSL.
+
+ Both the Qpid broker and Qpid clients use the http://cyrusimap.web.cmu.edu/"; target="_top">Cyrus SASL
library, a full-featured authentication framework, which offers many
configuration options. This section shows how to configure users for
authentication with SASL, which is sufficient when using SASL PLAIN. If you are not using SSL,
you should configure SASL to use CRAM-MD5, DIGEST-MD5, or GSSAPI (which provides Kerberos
authentication). For information on configuring these and other options in
SASL, see the Cyrus SASL documentation.
+ Important
+ The SASL
PLAIN method sends passwords in cleartext, and is vulnerable to
man-in-the-middle attacks unless SSL (Secure Socket Layer) is also used (see Section 1.5.4, “Encryption
using SSL”).
+
+ If you are not using SSL, we recommend that you
disable PLAIN authentication in
the broker.
+
+ The Qpid broker uses the auth yes|no option to determine whether
to use SASL authentication. Turn on authentication by setting auth to yes in /etc/qpidd.conf:
+
+# /etc/qpidd.conf
+#
+# Set auth to 'yes' or 'no'
+
+auth=yes
+1.5.1.1. Configuring
SASL
+ On Linux systems, the SASL configuration file
is generally found in /etc/sasl2/qpidd.conf or
/usr/lib/sasl2/qpidd.conf.
+
+
[04/51] [partial] qpid-site git commit: QPID-8250: Update for Qpid C++ 1.39.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/input/releases/qpid-cpp-1.39.0/cpp-broker/book/css/style.css
--
diff --git a/input/releases/qpid-cpp-1.39.0/cpp-broker/book/css/style.css
b/input/releases/qpid-cpp-1.39.0/cpp-broker/book/css/style.css
new file mode 100644
index 000..c681596
--- /dev/null
+++ b/input/releases/qpid-cpp-1.39.0/cpp-broker/book/css/style.css
@@ -0,0 +1,279 @@
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ *
+ */
+ul {
+list-style-type:square;
+}
+
+th {
+font-weight: bold;
+}
+
+.navfooter td {
+font-size:10pt;
+}
+
+.navheader td {
+font-size:10pt;
+}
+
+body {
+margin:0;
+background:#FF;
+font-family:"Verdana", sans-serif;
+font-size:10pt;
+}
+
+.container {
+width:950px;
+margin:0 auto;
+}
+
+body a {
+color:#00;
+}
+
+
+div.book {
+margin-left:10pt;
+margin-right:10pt;
+}
+
+div.preface {
+margin-left:10pt;
+margin-right:10pt;
+}
+
+div.chapter {
+margin-left:10pt;
+margin-right:10pt;
+}
+
+div.section {
+margin-left:10pt;
+margin-right:10pt;
+}
+
+div.titlepage {
+margin-left:-10pt;
+margin-right:-10pt;
+}
+
+.calloutlist td {
+font-size:10pt;
+}
+
+.table-contents table {
+border-spacing: 0px;
+}
+
+.table-contents td {
+font-size:10pt;
+padding-left:6px;
+padding-right:6px;
+}
+
+div.breadcrumbs {
+font-size:9pt;
+margin-right:10pt;
+padding-bottom:16px;
+}
+
+.chapter h2.title {
+font-size:20pt;
+color:#0c3b82;
+}
+
+.chapter .section h2.title {
+font-size:18pt;
+color:#0c3b82;
+}
+
+.section h2.title {
+font-size:16pt;
+color:#0c3b82;
+}
+
+.section h3.title {
+font-size:14pt;
+color:#0c3b82;
+}
+
+.section h4.title {
+font-size:12pt;
+color:#0c3b82;
+}
+
+.section h5.title {
+font-size:12pt;
+color:#0c3b82;
+}
+
+.section h6.title {
+font-size:12pt;
+color:#0c3b82;
+}
+
+.toc a {
+font-size:9pt;
+}
+
+.header {
+height:100px;
+width:950px;
+background:url(http://qpid.apache.org/images/header.png)
+}
+
+.logo {
+text-align:center;
+font-weight:600;
+padding:0 0 0 0;
+font-size:14px;
+font-family:"Verdana", cursive;
+}
+
+.logo a {
+color:#00;
+text-decoration:none;
+}
+
+.main_text_area {
+margin-left:200px;
+}
+
+.main_text_area_top {
+height:14px;
+font-size:1px;
+}
+
+.main_text_area_bottom {
+display:none;
+/* height:14px;
+margin-bottom:4px;*/
+}
+
+.main_text_area_body {
+padding:5px 24px;
+}
+
+.main_text_area_body p {
+text-align:justify;
+}
+
+.main_text_area br {
+line-height:10px;
+}
+
+.main_text_area h1 {
+font-size:28px;
+font-weight:600;
+margin:0 0 24px 0;
+color:#0c3b82;
+font-family:"Verdana", Times, serif;
+}
+
+.main_text_area h2 {
+font-size:24px;
+font-weight:600;
+margin:24px 0 8px 0;
+color:#0c3b82;
+font-family:"Verdana",Times, serif;
+}
+
+.main_text_area ol, .main_text_area ul {
+padding:0;
+margin:10px 0;
+margin-left:20px;
+}
+
+.main_text_area li {
+/*margin-left:40px; */
+}
+
+.main_text_area, .menu_box {
+font-size:13px;
+line-height:17px;
+color:#00;
+}
+
+.main_text_area {
+font-size:14px;
+}
+
+.main_text_area a {
+color:#00;
+}
+
+.main_text_area a:hover {
+color:#00;
+}
+
+.menu_box {
+width:196px;
+float:left;
+margin-left:4px;
+}
+
+.menu_box_top {
+background:url(http://qpid.apache.org/images/menu_top.png) no-repeat;
+height:14px;
+font-size:1px;
+}
+
+.menu_box_body {
+background:url(http://qpid.apache.org/images/menu_body.png) repeat-y;
+padding:5px 24px 5px 24px;
+}
+
+.menu_box_bottom {
+background:url(http://qpid.apache.org/images/menu_bottom.png) no-repeat;
+height:14px;
+font-size:1px;
+margin-bottom:1px;
+}
+
+.menu_box h3 {
+font-size:20px;
+font-weight:500;
+margin:0 0 8px 0;
+color:#0c3b82;
+font-family:"Verdana",Times, serif;
+}
+
+.menu_box ul {
+margin:12px;
+padding:0px;
+}
+
+.menu_box li {
+list-style:square;
+}
+
+.menu_box a {
+
[47/51] [partial] qpid-site git commit: QPID-8250: Update for Qpid C++ 1.39.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/cpp-broker/book/ch02s03.html
--
diff --git a/content/releases/qpid-cpp-1.39.0/cpp-broker/book/ch02s03.html
b/content/releases/qpid-cpp-1.39.0/cpp-broker/book/ch02s03.html
new file mode 100644
index 000..3f23e00
--- /dev/null
+++ b/content/releases/qpid-cpp-1.39.0/cpp-broker/book/ch02s03.html
@@ -0,0 +1,847 @@
+
+
+http://www.w3.org/1999/xhtml"; xml:lang="en">
+
+ch02s03.html - Apache Qpid™
+
+
+
+
+var _deferredFunctions = [];
+
+
+
+
+https://git-wip-us.apache.org/repos/asf/qpid-proton.git"/>
+https://github.com/apache/qpid-proton/blob/go1/README.md
+https://github.com/apache/qpid-proton/tree/go1{/dir}
+https://github.com/apache/qpid-proton/blob/go1{/dir}/{file}#L{line}"/>
+
+
+
+
+
+
+
+
+
+ Apache
Qpid™
+ Documentation
+ Download
+ Discussion
+
+
+
+
+
+
+Project
+
+
+ Overview
+ Components
+ Releases
+
+
+
+
+Messaging APIs
+
+
+ Qpid Proton
+ Qpid JMS
+ Qpid
Messaging API
+
+
+
+
+Servers and tools
+
+
+ Broker-J
+ C++
broker
+ Dispatch
router
+
+
+
+
+Resources
+
+
+ Dashboard
+ https://cwiki.apache.org/confluence/display/qpid/Index";>Wiki
+ More resources
+
+
+
+
+
+
+http://www.google.com/search"; method="get">
+
+
+ Search
+ More ways to search
+
+
+
+
+HomeReleasesQpid C++ 1.39.0AMQP Messaging
Broker (Implemented in C++)ch02s03.html
+
+
+ 2.3.
+ QMF Python Console Tutorial
+Prev Chapter 2.
+ Managing the AMQP Messaging Broker
+ 2.3.
+ QMF Python Console Tutorial
+
+Section 2.3.1,
“
+Prerequisite
+- Install Qpid Messaging
+ ”
+
+Section 2.3.2, “
+Synchronous
+Console Operations
+ ”
+
+
+Section 2.3.2.1, “
+Creating a QMF Console Session and Attaching to a Broker
+ ”
+
+Section 2.3.2.2, “
+Accessing
+Managed Objects
+ ”
+
+
+the section called
“
+Viewing Properties and Statistics of an Object
+ ”
+
+the section called “
+Invoking
+Methods on an Object
+ ”
+
+
+
+Section 2.3.3, “
+Asynchronous
+Console Operations
+ ”
+
+
+Section 2.3.3.1, “
+Creating a Console Class to Receive Asynchronous Data
+ ”
+
+Section 2.3.3.2, “
+Receiving
+Events
+ ”
+
+Section 2.3.3.3, “
+Receiving
+Objects
+ ”
+
+Section 2.3.3.4, “
+Asynchronous Method Calls and Method Timeouts
+ ”
+
+
+Section 2.3.4, “
+Discovering what Kinds of Objects are Available
+ ”
+ 2.3.1.
+Prerequisite
+- Install Qpid Messaging
+
+QMF uses AMQP Messaging (QPid) as its means of communication. To
+use QMF, Qpid messaging must be installed somewhere in the
+network. Qpid can be downloaded as source from Apache, is
+packaged with a number of Linux distributions, and can be
+purchased from commercial vendors that use Qpid. Please see
+http://qpid.apache.org";
target="_top">http://qpid.apache.orgfor
+information as to where to get Qpid Messaging.
+
+Qpid Messaging includes a message broker (qpidd) which typically
+runs as a daemon on a system. It also includes client bindings in
+various programming languages. The Python-language client library
+includes the QMF console libraries needed for this tutorial.
+
+Please note that Qpid Messaging has two broker implementations.
+One is implemented in C++ and the other in Java. At press time,
+QMF is suppo
[10/51] [partial] qpid-site git commit: QPID-8250: Update for Qpid C++ 1.39.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-java-6.0.8/java-broker/book/Java-Broker-Introduction.html
--
diff --git
a/content/releases/qpid-java-6.0.8/java-broker/book/Java-Broker-Introduction.html
b/content/releases/qpid-java-6.0.8/java-broker/book/Java-Broker-Introduction.html
index c0697f1..6fcfdad 100644
---
a/content/releases/qpid-java-6.0.8/java-broker/book/Java-Broker-Introduction.html
+++
b/content/releases/qpid-java-6.0.8/java-broker/book/Java-Broker-Introduction.html
@@ -117,7 +117,7 @@
https://github.com/apache/qpid-proton/blob/go1{/dir}/{file}#L{line}"/>
Chapter 1. IntroductionPrev NextChapter 1. IntroductionThe
Apache Qpid Broker for Java is a powerful open-source message broker that
implements all versions of the
http://www.amqp.org"; target="_top"> Advanced
Message Queuing Protocol (AMQP). The Apache Qpid Broker for Java
is actually one of two message brokers provided by the http://qpid.apache.org"; target="_top">Apache Qpid project: Broker for
Java and the C++
-Broker.This document relates to the Apache Qpid Broker for Java.
The C++ Broker is
+Broker.This document relates to the Apache Qpid Broker for Java.
The C++ Broker is
described separately.Headline
features100% Java implementation - runs on any platform supporting Java 1.7
or higherMessaging clients support in Java, C++, Python.JMS 1.1 compliance (Java
client).Persistent and non-persistent (transient) message
supportSupports for all common messaging patterns (point-to-point,
publish/subscribe, fan-out
etc).Transaction support including XA[1]Supports for all versions
of the AMQP protocolAutomatic message translation, allowing clients using different AMQP
versions to communicate with each other.Pluggable authentication architecture with
out-of-the-box support for Kerberos, LDAP,
External, and file-based authentication mechanisms.Support for message
compressionClient support for end to end message encryptionPluggable storage
architecture with implementations including http://db.apache.org/derby/"; target="_top">Apache Derby, Oracle BDB
JE[2], and External DatabaseWeb based management
interface and programmatic management interfaces via REST.SSL supportHigh availability (HA)
support.[3][1]
XA provided when using AMQP 0-10[2]
Oracle BDB JE must be downloaded separately.[3] HA currently only available to users of the optional
BDB JE HA based message store.Prev NextApache Qpid Broker for Java Home Chapter 2. Installation
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-java-6.1.0/java-broker/book/Java-Broker-Introduction.html
--
diff --git
a/content/releases/qpid-java-6.1.0/java-broker/book/Java-Broker-Introduction.html
b/content/releases/qpid-java-6.1.0/java-broker/book/Java-Broker-Introduction.html
index 971ca48..8bf18bc 100644
---
a/content/releases/qpid-java-6.1.0/java-broker/book/Java-Broker-Introduction.html
+++
b/content/releases/qpid-java-6.1.0/java-broker/book/Java-Broker-Introduction.html
@@ -117,7 +117,7 @@
https://github.com/apache/qpid-proton/blob/go1{/dir}/{file}#L{line}"/>
Chapter 1. IntroductionPrev NextChapter 1. IntroductionThe
Apache Qpid Broker for Java is a powerful open-source message broker that
implements all versions of the
http://www.amqp.org"; target="_top"> Advanced
Message Queuing Protocol (AMQP). The Apache Qpid Broker for Java
is actually one of two message brokers provided by the http://qpid.apache.org"; target="_top">Apache Qpid project: Broker for
Java and the C++
-Broker.This document relates to the Apache Qpid Broker for Java.
The C++ Broker is
+Broker.This document relates to the Apache Qpid Broker for Java.
The C++ Broker is
described separately.Headline
features100% Java implementation - runs on any platform supporting Java 1.7
or higherMessaging clients support in Java, C++, Python.JMS 1.1 compliance (Java
client).Persistent and non-persistent (transient) message
supportSupports for all common messaging patterns (point-to-point,
publish/subscribe, fan-out
etc).Transaction support including XA[1]Supports for all versions
of the AMQP protocolAutomatic message translation, allowing clients using different AMQP
versions to communicate with each other.Pluggable authentication architecture with
out-of-the-box support for Kerberos, LDAP,
External, OAuth2, and file-based authentication
mechanisms.Support for message compressionClient support for end to end message
encryptionPluggable storage architecture with implementations including http://db.apache.org/derby/"; target="_top">Apache Derby,
Oracle BDB
JE[2], and External DatabaseWeb based management
interface and programmatic management interfaces via REST.SSL supportHigh availability
[19/51] [partial] qpid-site git commit: QPID-8250: Update for Qpid C++ 1.39.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1MalformedAddress.html
--
diff --git
a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1MalformedAddress.html
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1MalformedAddress.html
new file mode 100755
index 000..9433928
--- /dev/null
+++
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1MalformedAddress.html
@@ -0,0 +1,156 @@
+http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd";>
+http://www.w3.org/1999/xhtml";>
+
+
+
+
+
+Qpid C++ Messaging API: qpid::messaging::MalformedAddress Struct
Reference
+
+
+
+
+
+
+
+
+ $(document).ready(initResizable);
+
+
+
+
+
+ $(document).ready(function() { init_search(); });
+
+
+
+
+
+
+
+
+
+
+ Qpid C++ Messaging API
+ 1.39.0
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+var searchBox = new SearchBox("searchBox", "search",false,'Search');
+
+
+
+
+
+
+
+
+
+
+
+
+$(document).ready(function(){initNavTree('structqpid_1_1messaging_1_1MalformedAddress.html','');});
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+Public Member Functions |
+List of all
members
+
+qpid::messaging::MalformedAddress Struct Reference
+
+
+
+#include
+
+Inheritance diagram for qpid::messaging::MalformedAddress:
+
+
+
+
+
+
+
+
+
+
+
+
+Public Member Functions
+
+QPID_MESSAGING_EXTERN MalformedAddress (const std::string &msg)
+
+ Public Member Functions inherited from qpid::messaging::AddressError
+
+QPID_MESSAGING_EXTERN AddressError (const std::string &)
+
+ Public Member Functions inherited from qpid::messaging::LinkError
+
+QPID_MESSAGING_EXTERN LinkError (const std::string &)
+
+ Public Member Functions inherited from qpid::messaging::MessagingException
+
+QPID_MESSAGING_EXTERN MessagingException (const std::string &msg)
+
+ Public Member Functions inherited from qpid::types::Exception
+
+QPID_TYPES_EXTERN Exception (const std::string &message=std::string())
throw ()
+
+
+virtual QPID_TYPES_EXTERN const char * what () const throw ()
+
+
+Detailed
Description
+Thrown when an address string with invalid syntax is
used.
+The documentation for this struct was generated from the following
file:
+qpid/messaging/exceptions.h
+
+
+
+
+
+
+qpidmessagingMalformedAddress
+Generated by
+http://www.doxygen.org/index.html";>
+ 1.8.13
+
+
+
+
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1MalformedAddress.js
--
diff --git
a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1MalformedAddress.js
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1MalformedAddress.js
new file mode 100755
index 000..7446ad1
--- /dev/null
+++
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1MalformedAddress.js
@@ -0,0 +1,4 @@
+var structqpid_1_1messaging_1_1MalformedAddress =
+[
+[ "MalformedAddress",
"structqpid_1_1messaging_1_1MalformedAddress.html#af85ad34c00b6c7c8bab965d60067b434",
null ]
+];
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1MalformedAddress.png
--
diff --git
a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1MalformedAddress.png
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1MalformedAddress.png
new file mode 100755
index 000..c68533e
Binary files /dev/null and
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1MalformedAddress.png
differ
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1MessageRejected-members.html
--
diff --git
a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1MessageRejected-members.html
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1MessageRejected-members.html
new file mode 100755
index 000..e4eac79
--- /dev/null
+++
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1MessageRejected-members.html
@@ -0,0 +1,119 @@
+http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd";>
+http://www.w3.org/1999/xhtml";>
+
+
+
+
+
+Qpid C++ Messaging API: Member List
+
+
+
+
+
+
+
+
+
[23/51] [partial] qpid-site git commit: QPID-8250: Update for Qpid C++ 1.39.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/search/all_4.js -- diff --git a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/search/all_4.js b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/search/all_4.js new file mode 100755 index 000..29f5edc --- /dev/null +++ b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/search/all_4.js @@ -0,0 +1,6 @@ +var searchData= +[ + ['failoverupdates',['FailoverUpdates',['../classqpid_1_1messaging_1_1FailoverUpdates.html',1,'qpid::messaging']]], + ['fetch',['fetch',['../classqpid_1_1messaging_1_1Receiver.html#aa3b46a16b002054cd73f9c625ff496bb',1,'qpid::messaging::Receiver::fetch(Message &message, Duration timeout=Duration::FOREVER)'],['../classqpid_1_1messaging_1_1Receiver.html#aaa7226095a43c3dda3f1e709b21e7ab2',1,'qpid::messaging::Receiver::fetch(Duration timeout=Duration::FOREVER)']]], + ['fetcherror',['FetchError',['../structqpid_1_1messaging_1_1FetchError.html',1,'qpid::messaging']]] +]; http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/search/all_5.html -- diff --git a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/search/all_5.html b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/search/all_5.html new file mode 100755 index 000..89a879e --- /dev/null +++ b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/search/all_5.html @@ -0,0 +1,26 @@ +http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd";> + + + + + + + + + +Loading... + + +Searching... +No Matches + + + + http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/search/all_5.js -- diff --git a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/search/all_5.js b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/search/all_5.js new file mode 100755 index 000..19f9410 --- /dev/null +++ b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/search/all_5.js @@ -0,0 +1,29 @@ +var searchData= +[ + ['generate',['generate',['../classqpid_1_1types_1_1Uuid.html#a3805c19501e878ad5f8972e30c2f2855',1,'qpid::types::Uuid']]], + ['get',['get',['../classqpid_1_1messaging_1_1Receiver.html#af60ff3ff2a71728b191bbfc656ccba93',1,'qpid::messaging::Receiver::get(Message &message, Duration timeout=Duration::FOREVER)'],['../classqpid_1_1messaging_1_1Receiver.html#a31f17a5b1c0d250f319c5e82a5cdb8e9',1,'qpid::messaging::Receiver::get(Duration timeout=Duration::FOREVER)']]], + ['getaddress',['getAddress',['../classqpid_1_1messaging_1_1Receiver.html#a1e96a2068161527e0a7c61563e73f359',1,'qpid::messaging::Receiver::getAddress()'],['../classqpid_1_1messaging_1_1Sender.html#a53e25e4f4275ac9e3ca23d5ba442e6e8',1,'qpid::messaging::Sender::getAddress()']]], + ['getavailable',['getAvailable',['../classqpid_1_1messaging_1_1Receiver.html#a7722e100c8a1908d873a60d250d30b27',1,'qpid::messaging::Receiver::getAvailable()'],['../classqpid_1_1messaging_1_1Sender.html#a2aaec7fcb5362df5f5c3c63acaf61c21',1,'qpid::messaging::Sender::getAvailable()']]], + ['getcapacity',['getCapacity',['../classqpid_1_1messaging_1_1Receiver.html#a66ec1eaf8e6bd407eab5f079e3eb0d59',1,'qpid::messaging::Receiver::getCapacity()'],['../classqpid_1_1messaging_1_1Sender.html#ae23edfc07ba612172c314b044f1e7dcc',1,'qpid::messaging::Sender::getCapacity()']]], + ['getconnection',['getConnection',['../classqpid_1_1messaging_1_1Session.html#a346e24ceed2f3becb7af53b82d648858',1,'qpid::messaging::Session']]], + ['getcontent',['getContent',['../classqpid_1_1messaging_1_1Message.html#aa62a42f90125a7b6456b68e4e5a1e465',1,'qpid::messaging::Message']]], + ['getcontentbytes',['getContentBytes',['../classqpid_1_1messaging_1_1Message.html#a914acea34e1e41f89a6d5e9068b0e484',1,'qpid::messaging::Message']]], + ['getcontentobject',['getContentObject',['../classqpid_1_1messaging_1_1Message.html#a3893ff4d0aeb3aedc647c7e8a3ed043f',1,'qpid::messaging::Message::getContentObject()'],['../classqpid_1_1messaging_1_1Message.html#a555e9cd47866b200ca1b504516d05364',1,'qpid::messaging::Message::getContentObject() const']]], + ['getcontentptr',['getContentPtr',['../classqpid_1_1messaging_1_1Message.html#a3674ef2462a70e21dd885a0ae5de856f',1,'qpid::messaging::Message']]], + ['getcontentsize',['getContentSize',['../classqpid_1_1messaging_1_1Message.html#a6f27f4f88366299ef663e24632f645da',1,'qpid::messaging::Message']]], + ['getcontenttype',['getContentType',['../classqpid_1_1messaging_
[17/51] [partial] qpid-site git commit: QPID-8250: Update for Qpid C++ 1.39.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1ResolutionError.html
--
diff --git
a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1ResolutionError.html
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1ResolutionError.html
new file mode 100755
index 000..a929e82
--- /dev/null
+++
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1ResolutionError.html
@@ -0,0 +1,158 @@
+http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd";>
+http://www.w3.org/1999/xhtml";>
+
+
+
+
+
+Qpid C++ Messaging API: qpid::messaging::ResolutionError Struct
Reference
+
+
+
+
+
+
+
+
+ $(document).ready(initResizable);
+
+
+
+
+
+ $(document).ready(function() { init_search(); });
+
+
+
+
+
+
+
+
+
+
+ Qpid C++ Messaging API
+ 1.39.0
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+var searchBox = new SearchBox("searchBox", "search",false,'Search');
+
+
+
+
+
+
+
+
+
+
+
+
+$(document).ready(function(){initNavTree('structqpid_1_1messaging_1_1ResolutionError.html','');});
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+Public Member Functions |
+List of all
members
+
+qpid::messaging::ResolutionError Struct Reference
+
+
+
+#include
+
+Inheritance diagram for qpid::messaging::ResolutionError:
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+Public Member Functions
+
+QPID_MESSAGING_EXTERN ResolutionError (const std::string &msg)
+
+ Public Member Functions inherited from qpid::messaging::AddressError
+
+QPID_MESSAGING_EXTERN AddressError (const std::string &)
+
+ Public Member Functions inherited from qpid::messaging::LinkError
+
+QPID_MESSAGING_EXTERN LinkError (const std::string &)
+
+ Public Member Functions inherited from qpid::messaging::MessagingException
+
+QPID_MESSAGING_EXTERN MessagingException (const std::string &msg)
+
+ Public Member Functions inherited from qpid::types::Exception
+
+QPID_TYPES_EXTERN Exception (const std::string &message=std::string())
throw ()
+
+
+virtual QPID_TYPES_EXTERN const char * what () const throw ()
+
+
+Detailed
Description
+Thrown when a syntactically correct address cannot
be resolved or used.
+The documentation for this struct was generated from the following
file:
+qpid/messaging/exceptions.h
+
+
+
+
+
+
+qpidmessagingResolutionError
+Generated by
+http://www.doxygen.org/index.html";>
+ 1.8.13
+
+
+
+
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1ResolutionError.js
--
diff --git
a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1ResolutionError.js
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1ResolutionError.js
new file mode 100755
index 000..1dfda81
--- /dev/null
+++
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1ResolutionError.js
@@ -0,0 +1,4 @@
+var structqpid_1_1messaging_1_1ResolutionError =
+[
+[ "ResolutionError",
"structqpid_1_1messaging_1_1ResolutionError.html#aa51eb483dfbf77f84d73393db53828e5",
null ]
+];
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1ResolutionError.png
--
diff --git
a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1ResolutionError.png
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1ResolutionError.png
new file mode 100755
index 000..56f4c3d
Binary files /dev/null and
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1ResolutionError.png
differ
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1SendError-members.html
--
diff --git
a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1SendError-members.html
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1SendError-members.html
new file mode 100755
index 000..37b2dea
--- /dev/null
+++
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1SendError-members.html
@@ -0,0 +1,118 @@
+http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd";>
+http://www.w3.org/1999/xhtml";>
+
+
+
+
+
+Qpid C++ Messaging API: Member List
+
+
+
+
+
+
+
+
+ $(document).ready(initResiza
[03/51] [partial] qpid-site git commit: QPID-8250: Update for Qpid C++ 1.39.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/input/releases/qpid-cpp-1.39.0/messaging-api/book/ch01s03.html.in
--
diff --git a/input/releases/qpid-cpp-1.39.0/messaging-api/book/ch01s03.html.in
b/input/releases/qpid-cpp-1.39.0/messaging-api/book/ch01s03.html.in
new file mode 100644
index 000..a4f9cf2
--- /dev/null
+++ b/input/releases/qpid-cpp-1.39.0/messaging-api/book/ch01s03.html.in
@@ -0,0 +1,48 @@
+1.3. A Simple Messaging
Program in .NET C#Prev Chapter 1. Using the Qpid Messaging API Next1.3. A Simple Messaging Program in .NET
C#The following .NET C#
+ [1]
+ program shows how to create a connection,
+ create a session, send messages using a sender, and receive
+ messages using a receiver.
+ Example 1.3. "Hello world!" in .NET
C#
+ using System;
+ using Org.Apache.Qpid.Messaging; (1)
+
+ namespace Org.Apache.Qpid.Messaging {
+ class Program {
+ static void Main(string[] args) {
+ String broker = args.Length > 0 ? args[0] : "localhost:5672";
+ String address = args.Length > 1 ? args[1] : "amq.topic";
+
+ Connection connection = null;
+ try {
+ connection = new Connection(broker);
+ connection.Open(); (2)
+ Session session = connection.CreateSession(); (3)
+
+ Receiver receiver = session.CreateReceiver(address); (4)
+ Sender sender = session.CreateSender(address); (5)
+
+ sender.Send(new Message("Hello world!"));
+
+ Message message = new Message();
+ message = receiver.Fetch(DurationConstants.SECOND * 1); (6)
+ Console.WriteLine("{0}", message.GetContent());
+ session.Acknowledge(); (7)
+
+ connection.Close(); (8)
+ } catch (Exception e) {
+ Console.WriteLine("Exception {0}.", e);
+ if (null != connection)
+ connection.Close();
+ }
+ }
+ }
+ }
+
+ (1)
Permits use of
Org.Apache.Qpid.Messaging types and methods without explicit namespace
qualification. Any .NET project must have a project reference to the assembly
file Org.Apache.Qpid.Messaging.dll in order to
obtain the definitions of the .NET Binding for Qpid Messaging
namespace.(2) Establishes the connection with the messaging
broker.(3)
Creates a session object on which
messages wi
ll be sent and received.(4) Creates a receiver that receives messages from the given
address.(5)
Creates a sender that sends to the
given address.(6)
Receives the next message. The
duration is optional, if omitted, will wait indefinitely for the next
message.(7)
Acknowledges receipt of all fe
tched messages on the
+ session. This informs the broker that the messages were
+ transfered and processed by the client
successfully.(8)
Closes the connection, all sessions
managed by the connection, and all senders and receivers managed by each
session.[1]
+ The .NET binding for the Qpid C++ Messaging API
+ applies to all .NET Framework managed code languages. C# was chosen
+ for illustration purposes only.
+ Prev Up Next1.2. A Simple Messaging Program in
Python Home 1.4. Addresses
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/input/releases/qpid-cpp-1.39.0/messaging-api/book/ch01s08.html.in
--
diff --git a/input/releases/qpid-cpp-1.39.0/messaging-api/book/ch01s08.html.in
b/input/releases/qpid-cpp-1.39.0/messaging-api/book/ch01s08.html.in
new file mode 100644
index 000..f538d03
--- /dev/null
+++ b/input/releases/qpid-cpp-1.39.0/messaging-api/book/ch01s08.html.in
@@ -0,0 +1,37 @@
+1.8. Receiving Messages
from Multiple SourcesPrev Chapter 1. Using the Qpid Messaging
API Next1.8. Receiving Messages from Multiple
SourcesA receiver can only read from one source, but
many
+ programs need to be able to read messages from many sources. In
+ the Qpid Messaging API, a program can ask a session for
+ the “next
receiver”; that is, the receiver that is
+ responsible for the next available message. The following
+ examples show how this is done in C++, Python, and .NET C#.
+ Note that to use this pattern you must enable prefetching
+ for each receiver of interest so that the broker will send
+ messages before a fetch call is made. See
+ Section 1.6, “Receiver Capacity (Prefetch)”
for more on this.Example 1.12. Receiving Messages from Multiple
SourcesC++:
+ Receiver receiver1 = session.createReceiver(address1);
+ receiver1.setCapacity(10);
+ Receiver receiver2 = session.createReceiver(address2);
+ receiver2.setCapacity(10);
+
+ Message message = session.nextReceiver().fetch();
+ std::cout << message.getContent() << std::endl;
+ session.acknowledge(); // acknow
[45/51] [partial] qpid-site git commit: QPID-8250: Update for Qpid C++ 1.39.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/cpp-broker/book/chapter-Managing-CPP-Broker.html
--
diff --git
a/content/releases/qpid-cpp-1.39.0/cpp-broker/book/chapter-Managing-CPP-Broker.html
b/content/releases/qpid-cpp-1.39.0/cpp-broker/book/chapter-Managing-CPP-Broker.html
new file mode 100644
index 000..ba79c69
--- /dev/null
+++
b/content/releases/qpid-cpp-1.39.0/cpp-broker/book/chapter-Managing-CPP-Broker.html
@@ -0,0 +1,602 @@
+
+
+http://www.w3.org/1999/xhtml"; xml:lang="en">
+
+2.1. Managing the C++ Broker - Apache Qpid™
+
+
+
+
+var _deferredFunctions = [];
+
+
+
+
+https://git-wip-us.apache.org/repos/asf/qpid-proton.git"/>
+https://github.com/apache/qpid-proton/blob/go1/README.md
+https://github.com/apache/qpid-proton/tree/go1{/dir}
+https://github.com/apache/qpid-proton/blob/go1{/dir}/{file}#L{line}"/>
+
+
+
+
+
+
+
+
+
+ Apache
Qpid™
+ Documentation
+ Download
+ Discussion
+
+
+
+
+
+
+Project
+
+
+ Overview
+ Components
+ Releases
+
+
+
+
+Messaging APIs
+
+
+ Qpid Proton
+ Qpid JMS
+ Qpid
Messaging API
+
+
+
+
+Servers and tools
+
+
+ Broker-J
+ C++
broker
+ Dispatch
router
+
+
+
+
+Resources
+
+
+ Dashboard
+ https://cwiki.apache.org/confluence/display/qpid/Index";>Wiki
+ More resources
+
+
+
+
+
+
+http://www.google.com/search"; method="get">
+
+
+ Search
+ More ways to search
+
+
+
+
+HomeReleasesQpid C++ 1.39.0AMQP Messaging
Broker (Implemented in C++)2.1. Managing the C++
Broker
+
+
+ Chapter 2.
+ Managing the AMQP Messaging Broker
+Prev NextChapter 2.
+ Managing the AMQP Messaging Broker
+Table of
Contents2.1.
Managing the C++ Broker 2.1.1.
+Using qpid-config
+ 2.1.2.
+Using qpid-route
+ 2.1.3.
+Using qpid-tool
+ 2.1.4.
+Using
+qpid-printevents
+ 2.1.5. Using
qpid-ha2.2.
+ Qpid Management Framework
+2.2.1.
+What Is QMF
+ 2.2.2.
+Getting
+Started with QMF
+ 2.2.3.
+QMF Concepts
+ 2.2.4.
+The QMF
+Protocol
+ 2.2.5.
+How
+to Write a QMF Console
+ 2.2.6.
+How to
+Write a QMF Agent
+ 2.3.
+ QMF Python Console Tutorial
+2.3.1.
+Prerequisite
+- Install Qpid Messaging
+ 2.3.2.
+Synchronous
+Console Operations
+ 2.3.3.
+Asynchronous
+Console Operations
+ 2.3.4.
+Discovering what Kinds of Objects are Available
+ 2.1. Managing the C++ Broker
+There are quite a few ways to interact with the C++ broker. The
+command line tools
+include:
+ qpid-route - used to configure federation
(a set of federated
+brokers)
+qpid-config - used to configure
queues, exchanges, bindings
+and list them etc
+qpid-tool - used to view
management information/statistics
+and call any management actions on the broker
+qpid-printevents - used to
receive and print QMF events
+qpid-ha - used to interact with
the High Availability module
+2.1.1.
+Using qpid-config
+
+This utility can be used to create queues exchanges and bindings,
+both durable and transient. Always check for latest options by
+running --help command.
+
+$ qpid-config --help
+Usage: qpid-config [OPTIONS]
+qpid-config [OPTIONS] exchanges [filter-string]
+qpid-config [OPTIONS] queues[filter-string]
+qpid-config [OPTIONS] add exchange
[AddExchangeOptions]
+qpid-config [OPTIONS] del exchange
+qpid-config [OPTIONS] add queue [AddQueueOptions]
+qpid-config [OPTIONS] del queue
+qpid-config [OPTIONS] bind
[binding-key]
+qpid-config [OPTIONS] unbind
[binding-key]
+
+Options:
+-b [ --bindings ] Show bindings in queue or
exchange list
+-a [ --broker-addr ] A
[24/51] [partial] qpid-site git commit: QPID-8250: Update for Qpid C++ 1.39.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/messaging_2ImportExport_8h_source.html
--
diff --git
a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/messaging_2ImportExport_8h_source.html
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/messaging_2ImportExport_8h_source.html
new file mode 100755
index 000..e0d3b8e
--- /dev/null
+++
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/messaging_2ImportExport_8h_source.html
@@ -0,0 +1,108 @@
+http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd";>
+http://www.w3.org/1999/xhtml";>
+
+
+
+
+
+Qpid C++ Messaging API: qpid/messaging/ImportExport.h Source
File
+
+
+
+
+
+
+
+
+ $(document).ready(initResizable);
+
+
+
+
+
+ $(document).ready(function() { init_search(); });
+
+
+
+
+
+
+
+
+
+
+ Qpid C++ Messaging API
+ 1.39.0
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+var searchBox = new SearchBox("searchBox", "search",false,'Search');
+
+
+
+
+
+
+
+
+
+
+
+
+$(document).ready(function(){initNavTree('messaging_2ImportExport_8h_source.html','');});
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ImportExport.h
+
+
+1 #ifndef
QPID_MESSAGING_IMPORTEXPORT_H2 #define QPID_MESSAGING_IMPORTEXPORT_H
3 4 /*5 * Licensed to the Apache Software Foundation (ASF) under
one
6 * or more contributor license agreements.
See the NOTICE file7 * distributed w
ith this work for additional information8
* regarding copyright ownership. The ASF licenses this file9 * to you under the Apache License, Version 2.0
(the
10 * "License"); you may not use
this file except in compliance 11
* with the License. You may obtain a copy of the License at 12 * 13 *
http://www.apache.org/licen
ses/LICENSE-2.0 14 * 15 * Unless required by applicable law or agreed to in
writing, 16 * software distributed
under the License is distributed on an 17
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF
ANY
18 * KIND, either express or implied. See
the License for the 19 * specific language
governing permissions and limit
ations 20 * under the
License. 21 */
22 23 #include
"qpid/ImportExport.h" 24 25 #if defined(CLIENT_EXPORT) || defined
(qpidmessaging_EXPORTS) 26 # define QPID_MESSAGING_EXTERN
QPID_EXPORT
27 # define
QPID_MESSAGING_CLASS_EXTERN QPID_CLASS_EXPORT 28 # define QPID_MESSAGING_INLINE_EXTERN
QPID_INLINE_EXPORT 29 #else 30 # define QPID_MESSAGING_EXTERN
QPID_IMPORT 31 # define
QPID_MESSAGING_CLASS_EXTERN QPID_CLASS_IMPORT 32 # define QPID_MESSAGING_INLINE_EXTERN
QPID_INLINE_IMPORT 33 <
span class="preprocessor">#endif 34 35 #endif
+
+
+
+
+qpidmessagingImportExport.h
+Generated by
+http://www.doxygen.org/index.html";>
+ 1.8.13
+
+
+
+
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/nav_f.png
--
diff --git a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/nav_f.png
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/nav_f.png
new file mode 100755
index 000..72a58a5
Binary files /dev/null and
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/nav_f.png differ
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/nav_g.png
--
diff --git a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/nav_g.png
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/nav_g.png
new file mode 100755
index 000..2093a23
Binary files /dev/null and
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/nav_g.png differ
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/nav_h.png
--
diff --git a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/nav_h.png
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/nav_h.png
new file mode 100755
index 000..33389b1
Binary files /dev/null and
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/nav_h.png differ
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/navtree.css
--
diff --git a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/navtree.css
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/navtree.css
new file mode 100755
index 000..0cc7e77
--- /dev/null
+++ b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/navtree.css
@@ -0,0 +1
[37/51] [partial] qpid-site git commit: QPID-8250: Update for Qpid C++ 1.39.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/Exception_8h_source.html
--
diff --git
a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/Exception_8h_source.html
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/Exception_8h_source.html
new file mode 100755
index 000..da6c6a0
--- /dev/null
+++
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/Exception_8h_source.html
@@ -0,0 +1,110 @@
+http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd";>
+http://www.w3.org/1999/xhtml";>
+
+
+
+
+
+Qpid C++ Messaging API: qpid/types/Exception.h Source File
+
+
+
+
+
+
+
+
+ $(document).ready(initResizable);
+
+
+
+
+
+ $(document).ready(function() { init_search(); });
+
+
+
+
+
+
+
+
+
+
+ Qpid C++ Messaging API
+ 1.39.0
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+var searchBox = new SearchBox("searchBox", "search",false,'Search');
+
+
+
+
+
+
+
+
+
+
+
+
+$(document).ready(function(){initNavTree('Exception_8h_source.html','');});
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+Exception.h
+
+
+1 #ifndef
QPID_TYPES_EXCEPTION_H2 #define
QPID_TYPES_EXCEPTION_H3 4 /*5 *6 * Licensed to the Apache Software Foundation (ASF) under
one
7 * or more contributor license agreements.
See the NOTICE file8 * distributed with this work for additional
information9 * regarding copyright
ownership. The ASF licenses this file 10
* to you under the Apache License, Version 2.0 (the 11 * "License"); you may not use this file except in
compliance 12 * with the License.
You may obtain a copy of the License at 13
*14 *
http://www.apache.org/licenses/LICENSE-2.0 15
*
16 * Unless required by applicable law or
agreed to in writing, 17 * software distributed
under the License is distributed on an 18
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF
ANY
19 * KIND, either express or implied. See
the License for the 20 * specific language
governing permissions and limitations 21
* under the License. 22 * 23 */ 24 25 #include 26 #include
"qpid/types/ImportExport.h" 27 28 namespace
qpid { 29 namespace types { 30 31 class QPID_TYPES_CLASS_EXTERN Exception : public std::exception 32 { 33
public: 34 QPID_TYPES_EXTERN
explicit Exception(const std::string& message=std::string()) throw(); 35 QPID_TYPES_EXTERN
virtual ~Exception() throw(); 36 QPID_TYPES_EXTERN
virtual const char* what() const
throw(); 37 38
private:
39
const std::string message;
40 }; 41 42 }} // namespace qpid::types 43 44 #endif qpid::types::ExceptionDefinition: Exception.h:31
+qpidDefinition:
Address.h:32
+
+
+
+
+
+qpidtypesException.h
+Generated by
+http://www.doxygen.org/index.html";>
+ 1.8.13
+
+
+
+
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/FailoverUpdates_8h_source.html
--
diff --git
a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/FailoverUpdates_8h_source.html
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/FailoverUpdates_8h_source.html
new file mode 100755
index 000..077e0a5
--- /dev/null
+++
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/FailoverUpdates_8h_source.html
@@ -0,0 +1,111 @@
+http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd";>
+http://www.w3.org/1999/xhtml";>
+
+
+
+
+
+Qpid C++ Messaging API: qpid/messaging/FailoverUpdates.h Source
File
+
+
+
+
+
+
+
+
+ $(document).ready(initResizable);
+
+
+
+
+
+ $(document).ready(function() { init_search(); });
+
+
+
+
+
+
+
+
+
+
+ Qpid C++ Messaging API
+ 1.39.0
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+var searchBox = new SearchBox("searchBox", "search",false,'Search');
+
+
+
+
+
+
+
+
+
+
+
+
+$(document).ready(function(){initNavTree('FailoverUpdates_8h_source.html','');});
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+FailoverUpdates.h
+
+
+1 #ifndef
QPID_CLIENT_AMQP0_10_FAILOVERUPDATES_H2 #define
QPID_CLIENT_AMQP0_10_FAILOVERUPDATES_H3 4 /*5 *6 * Licensed to the Apache Software Foundation (ASF) under
one
7 * or more contributor license agreements.
See the NOTICE
file
8 * distributed with this work for
additional information9 * regarding copyright
ownership. The ASF licenses this file 10
* to you under the Apache License, Version 2.0 (the 11 * "License"); you may not use this file except in
compliance 12 * with the License.
You may obtain a copy of the License at 13
*
>14 *
>http://w
[01/51] [partial] qpid-site git commit: QPID-8250: Update for Qpid C++ 1.39.0
Repository: qpid-site Updated Branches: refs/heads/asf-site 2b7a4a813 -> c3ab60f6d http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/input/releases/qpid-cpp-1.39.0/messaging-api/book/section-amqp0-10-mapping.html.in -- diff --git a/input/releases/qpid-cpp-1.39.0/messaging-api/book/section-amqp0-10-mapping.html.in b/input/releases/qpid-cpp-1.39.0/messaging-api/book/section-amqp0-10-mapping.html.in new file mode 100644 index 000..e6514fe --- /dev/null +++ b/input/releases/qpid-cpp-1.39.0/messaging-api/book/section-amqp0-10-mapping.html.in @@ -0,0 +1,164 @@ +1.16. The AMQP 0-10 mappingPrev Chapter 1. Using the Qpid Messaging API Next1.16. The AMQP 0-10 mapping + This section describes the AMQP 0-10 mapping for the Qpid + Messaging API. + +The interaction with the broker triggered by creating a sender +or receiver depends on what the specified address resolves +to. Where the node type is not specified in the address, the +client queries the broker to determine whether it refers to a +queue or an exchange. + +When sending to a queue, the queue's name is set as the +routing key and the message is transfered to the default (or +nameless) exchange. When sending to an exchange, the message +is transfered to that exchange and the routing key is set to +the message subject if one is specified. A default subject may +be specified in the target address. The subject may also be +set on each message individually to override the default if +required. In each case any specified subject is also added as +a qpid.subject entry in the application-headers field of the +message-properties. + +When receiving from a queue, any subject in the source address +is currently ignored. The client sends a message-subscribe +request for the queue in question. The accept-mode is +determined by the reliability option in the link properties; +for unreliable links the accept-mode is none, for reliable +links it is explicit. The default for a queue is reliable. The +acquire-mode is determined by the value of the mode option. If +the mode is set to browse the acquire mode is not-acquired, +otherwise it is set to pre-acquired. The exclusive and +arguments fields in the message-subscribe command can be +controlled using the x-subscribe map. + +When receiving from an exchange, the client creates a +subscription queue and binds that to the exchange. The +subscription queue's arguments can be specified using the +x-declare map within the link properties. The reliability +option determines most of the other parameters. If the +reliability is set to unreliable then an auto-deleted, +exclusive queue is used meaning that if the client or +connection fails messages may be lost. For exactly-once the +queue is not set to be auto-deleted. The durability of the +subscription queue is determined by the durable option in the +link properties. The binding process depends on the type of +the exchange the source address resolves to. + +For a topic exchange, if no subject is specified and no +x-bindings are defined for the link, the subscription +queue is bound using a wildcard matching any routing key +(thus satisfying the expectation that any message sent to +that address will be received from it). If a subject is +specified in the source address however, it is used for +the binding key (this means that the subject in the source +address may be a binding pattern including wildcards). + +For a fanout exchange the binding key is irrelevant to +matching. A receiver created from a source address that +resolves to a fanout exchange receives all messages +sent to that exchange regardless of any subject the source +address may contain. An x-bindings element in the link +properties should be used if there is any need to set the +arguments to the bind. + +For a direct exchange, the subject is used as the binding +key. If no subject is specified an empty string is used as +the binding key. + +For a headers exchange, if no subject is specified the +binding arguments simply contain an x-match entry and no +other entries, causing all messages to match. If a subject +is specified then the binding arguments contain an x-match +entry set to all and an entry for qpid.subject whose value +is the subject in the source address (this means
[16/51] [partial] qpid-site git commit: QPID-8250: Update for Qpid C++ 1.39.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1SessionError.js
--
diff --git
a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1SessionError.js
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1SessionError.js
new file mode 100755
index 000..90df378
--- /dev/null
+++
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1SessionError.js
@@ -0,0 +1,4 @@
+var structqpid_1_1messaging_1_1SessionError =
+[
+[ "SessionError",
"structqpid_1_1messaging_1_1SessionError.html#a086265b744847419aa9f4d3897912f9d",
null ]
+];
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1SessionError.png
--
diff --git
a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1SessionError.png
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1SessionError.png
new file mode 100755
index 000..0192543
Binary files /dev/null and
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1SessionError.png
differ
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1TargetCapacityExceeded-members.html
--
diff --git
a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1TargetCapacityExceeded-members.html
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1TargetCapacityExceeded-members.html
new file mode 100755
index 000..39c567d
--- /dev/null
+++
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1TargetCapacityExceeded-members.html
@@ -0,0 +1,119 @@
+http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd";>
+http://www.w3.org/1999/xhtml";>
+
+
+
+
+
+Qpid C++ Messaging API: Member List
+
+
+
+
+
+
+
+
+ $(document).ready(initResizable);
+
+
+
+
+
+ $(document).ready(function() { init_search(); });
+
+
+
+
+
+
+
+
+
+
+ Qpid C++ Messaging API
+ 1.39.0
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+var searchBox = new SearchBox("searchBox", "search",false,'Search');
+
+
+
+
+
+
+
+
+
+
+
+
+$(document).ready(function(){initNavTree('structqpid_1_1messaging_1_1TargetCapacityExceeded.html','');});
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+qpid::messaging::TargetCapacityExceeded Member List
+
+
+
+This is the complete list of members for qpid::messaging::TargetCapacityExceeded,
including all inherited members.
+
+ Exception(const
std::string &message=std::string()) (defined in qpid::types::Exception)qpid::types::Exceptionexplicit
+ LinkError(const std::string
&) (defined in qpid::messaging::LinkError)qpid::messaging::LinkError
+ MessagingException(const std::string &msg) (defined in
qpid::messaging::MessagingException)qpid::messaging::MessagingException
+ SenderError(const std::string
&) (defined in qpid::messaging::SenderError)qpid::messaging::SenderError
+ SendError(const
std::string &) (defined in qpid::messaging::SendError)qpid::messaging::SendError
+ TargetCapacityExceeded(const
std::string &) (defined in qpid::messaging::TargetCapacityExceeded)qpid::messaging::TargetCapacityExceeded
+ what() const
(defined in qpid::types::Exception)qpid::types::Exceptionvirtual
+ ~Exception() (defined in qpid::types::Exception)qpid::types::Exceptionvirtual
+ ~MessagingException() (defined in qpid::messaging::MessagingException)qpid::messaging::MessagingExceptionvirtual
+
+
+
+
+
+Generated by
+http://www.doxygen.org/index.html";>
+ 1.8.13
+
+
+
+
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1TargetCapacityExceeded.html
--
diff --git
a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1TargetCapacityExceeded.html
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1TargetCapacityExceeded.html
new file mode 100755
index 000..7a1a697
--- /dev/null
+++
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1TargetCapacityExceeded.html
@@ -0,0 +1,161 @@
+http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd";>
+http://www.w3.org/1999/xhtml";>
+
+
+
+
+
+Qpid C++ Messaging API: qpid::messaging::TargetCapacityExceeded Struct
Reference
+
+
+
+
+
+
+
+
+ $(docu
[22/51] [partial] qpid-site git commit: QPID-8250: Update for Qpid C++ 1.39.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/search/functions_1.js -- diff --git a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/search/functions_1.js b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/search/functions_1.js new file mode 100755 index 000..9e0ca9c --- /dev/null +++ b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/search/functions_1.js @@ -0,0 +1,11 @@ +var searchData= +[ + ['checkerror',['checkError',['../classqpid_1_1messaging_1_1Session.html#aa2e0eb9e53cec590d23b2dd8b442e708',1,'qpid::messaging::Session']]], + ['clear',['clear',['../classqpid_1_1types_1_1Uuid.html#a21237148629551f32db63ac0ee920dcb',1,'qpid::types::Uuid']]], + ['close',['close',['../classqpid_1_1messaging_1_1Connection.html#a57c6b7c5b7f99fe3b6e287f906a59b7b',1,'qpid::messaging::Connection::close()'],['../classqpid_1_1messaging_1_1Receiver.html#a5f9e4b67b32ed49aa795011f53938b8e',1,'qpid::messaging::Receiver::close()'],['../classqpid_1_1messaging_1_1Session.html#ae182a6447018dd69ace0ec2897e66ba0',1,'qpid::messaging::Session::close()']]], + ['commit',['commit',['../classqpid_1_1messaging_1_1Session.html#a06a812821bdb2841cabf1f6b83fe57c0',1,'qpid::messaging::Session']]], + ['configure',['configure',['../classqpid_1_1messaging_1_1Logger.html#abbe85863cc46da050ad0305d31ea32c6',1,'qpid::messaging::Logger']]], + ['connection',['Connection',['../classqpid_1_1messaging_1_1Connection.html#a4d3f1bacc02722f3d2ae43efaa880db6',1,'qpid::messaging::Connection::Connection(const std::string &url, const qpid::types::Variant::Map &options=qpid::types::Variant::Map())'],['../classqpid_1_1messaging_1_1Connection.html#a7ed5f335b7614cd7b2b580ad92cbf3d2',1,'qpid::messaging::Connection::Connection(const std::string &url, const std::string &options)']]], + ['createreceiver',['createReceiver',['../classqpid_1_1messaging_1_1Session.html#a412e46c562c7211e833df2d243c743cc',1,'qpid::messaging::Session::createReceiver(const Address &address)'],['../classqpid_1_1messaging_1_1Session.html#a23b36bccba731544fc686af56872f005',1,'qpid::messaging::Session::createReceiver(const std::string &address)']]], + ['createsender',['createSender',['../classqpid_1_1messaging_1_1Session.html#afed2184cb6a54b6452bcacac3d7491b8',1,'qpid::messaging::Session::createSender(const Address &address)'],['../classqpid_1_1messaging_1_1Session.html#a310e2fefeaf0ab0b0b110c8b9bed72af',1,'qpid::messaging::Session::createSender(const std::string &address)']]] +]; http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/search/functions_2.html -- diff --git a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/search/functions_2.html b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/search/functions_2.html new file mode 100755 index 000..ecce2f3 --- /dev/null +++ b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/search/functions_2.html @@ -0,0 +1,26 @@ +http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd";> + + + + + + + + + +Loading... + + +Searching... +No Matches + + + + http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/search/functions_2.js -- diff --git a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/search/functions_2.js b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/search/functions_2.js new file mode 100755 index 000..9d87fc9 --- /dev/null +++ b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/search/functions_2.js @@ -0,0 +1,4 @@ +var searchData= +[ + ['described',['described',['../classqpid_1_1types_1_1Variant.html#a3b486c73ad069de85dc995fb76794641',1,'qpid::types::Variant::described(const Variant &descriptor, const Variant &value)'],['../classqpid_1_1types_1_1Variant.html#a328765159474f69304617f25ffeb414f',1,'qpid::types::Variant::described(const Variant &descriptor, const List &value)']]] +]; http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/search/functions_3.html -- diff --git a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/search/functions_3.html b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/search/functions_3.html new file mode 100755 index 000..15f06ab --- /dev/null +++ b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/search/functions_3.html @@ -0,0 +1,26
[09/51] [partial] qpid-site git commit: QPID-8250: Update for Qpid C++ 1.39.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/input/releases/qpid-cpp-1.39.0/cpp-broker/book/Using-message-groups.html.in -- diff --git a/input/releases/qpid-cpp-1.39.0/cpp-broker/book/Using-message-groups.html.in b/input/releases/qpid-cpp-1.39.0/cpp-broker/book/Using-message-groups.html.in new file mode 100644 index 000..ced3682 --- /dev/null +++ b/input/releases/qpid-cpp-1.39.0/cpp-broker/book/Using-message-groups.html.in @@ -0,0 +1,156 @@ +1.11. +Using Message Groups + Prev Chapter 1. + Running the AMQP Messaging Broker + Next1.11. +Using Message Groups + 1.11.1. + Overview + +The broker allows messaging applications to classify a set of related messages as +belonging to a group. This allows a message producer to indicate to the consumer +that a group of messages should be considered a single logical operation with +respect to the application. + +The broker can use this group identification to enforce policies controlling how +messages from a given group can be distributed to consumers. For instance, the +broker can be configured to guarantee all the messages from a particular group are +processed in order across multiple consumers. + +For example, assume we have a shopping application that manages items in a virtual +shopping cart. A user may add an item to their shopping cart, then change their +mind and remove it. If the application sends an add message to the broker, +immediately followed by a remove message, they will be queued in the proper +order - add, followed by remove. + +However, if there are multiple consumers, it is possible that once a consumer +acquires the add message, a different consumer may acquire the +remove message. This allows both messages to be processed in parallel, +which could result in a "race" where the remove operation is incorrectly +performed before the add operation. + 1.11.2. +Grouping Messages + +In order to group messages, the application would designate a particular +message header as containing a message's group identifier. The group +identifier stored in that header field would be a string value set by the message +producer. Messages from the same group would have the same group identifier +value. The key that identifies the header must also be known to the message +consumers. This allows the consumers to determine a message's assigned group. + +The header that is used to hold the group identifier, as well as the values used +as group identifiers, are totally under control of the application. + 1.11.3. +The Role of the Broker + +The broker will apply the following processing on each grouped message: +Enqueue a received message on the destination queue.Determine the message's group by examining the message's group identifier header.Enforce consumption ordering among messages belonging to the same group. +Consumption ordering means that the broker will not allow outstanding +unacknowledged messages to more than one consumer for a given group. + +This means that only one consumer can be processing messages from a particular +group at a given time. When the consumer acknowledges all of its acquired +messages, then the broker may pass the next pending message +from that group to a different consumer. + +Specifically, for any given group the broker allows only the first N messages in +the group to be delivered to a consumer. The value of N would be determined by +the selected consumer's configured prefetch capacity. The broker blocks access by +any other consumer to any remaining undelivered messages in that group. Once the +receiving consumer has: +acknowledged,released, orrejected +all the delivered messages, the broker allows the next messages in the group to be +delivered. The next messages may be delivered to a different +consumer. + +Note well that distinct message groups would not block each other from delivery. +For example, assume a queue contains messages from two different message groups - +say group "A" and group "B" - and they are enqueued such that "A"'s messages are +in front of "B". If the first message of group "A" is in the process of being +consumed by a client, then the remaining "A" messages are blocked, but the +messages of the "B" group are available for consumption by other consumers - even +though it is "behind" group "A" in the queue. + 1.11.4. +Well Behaved Consumers + +T
[11/51] [partial] qpid-site git commit: QPID-8250: Update for Qpid C++ 1.39.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/examples/spout.cpp.html
--
diff --git
a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/examples/spout.cpp.html
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/examples/spout.cpp.html
new file mode 100644
index 000..fb57407
--- /dev/null
+++ b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/examples/spout.cpp.html
@@ -0,0 +1,316 @@
+
+
+http://www.w3.org/1999/xhtml"; xml:lang="en">
+
+spout.cpp - Apache Qpid™
+
+
+
+
+var _deferredFunctions = [];
+
+
+
+
+https://git-wip-us.apache.org/repos/asf/qpid-proton.git"/>
+https://github.com/apache/qpid-proton/blob/go1/README.md
+https://github.com/apache/qpid-proton/tree/go1{/dir}
+https://github.com/apache/qpid-proton/blob/go1{/dir}/{file}#L{line}"/>
+
+
+
+
+
+
+
+
+
+ Apache
Qpid™
+ Documentation
+ Download
+ Discussion
+
+
+
+
+
+
+Project
+
+
+ Overview
+ Components
+ Releases
+
+
+
+
+Messaging APIs
+
+
+ Qpid Proton
+ Qpid JMS
+ Qpid
Messaging API
+
+
+
+
+Servers and tools
+
+
+ Broker-J
+ C++
broker
+ Dispatch
router
+
+
+
+
+Resources
+
+
+ Dashboard
+ https://cwiki.apache.org/confluence/display/qpid/Index";>Wiki
+ More resources
+
+
+
+
+
+
+http://www.google.com/search"; method="get">
+
+
+ Search
+ More ways to search
+
+
+
+
+HomeReleasesQpid C++ 1.39.0C++
Messaging API Examplesspout.cpp
+
+
+
+spout.cpp
+#include
+#include
+#include
+#include
+#include
+#include
+#include
+
+#include
+#include
+#include
+#include
+
+#include "OptionParser.h"
+
+using namespace qpid::messaging;
+using namespace qpid::types;
+
+typedef std::vector string_vector;
+
+struct Options : OptionParser
+{
+std::string url;
+std::string address;
+int timeout;
+bool durable;
+int count;
+std::string id;
+std::string replyto;
+string_vector properties;
+string_vector entries;
+std::string content;
+std::string connectionOptions;
+bool print;
+
+Options()
+: OptionParser("Usage: spout [OPTIONS]
ADDRESS", "Send
messages to the specified address"),
+ url("127.0.0.1"),
+ timeout(0),
+ count(1),
+ durable(false),
+ print(false)
+{
+add("broker,b", url, "url of
broker to connect to");
+add("timeout,t", timeout, "exit
after the specified time");
+add("durable,d", durable, "make the
message durable (def. transient)");
+add("count,c", count, "stop after
count messages have been sent, zero disables");
+add("id,i", id, "use the
supplied id instead of generating one");
+add("reply-to", replyto, "specify
reply-to address");
+add("property,P", properties, "specify message property");
+add("map,M", entries, "specify
entry for map content");
+add("content", content, "specify
textual content");
+add("connection-options", connectionOptions, "connection options string in the form {name1:value1,
name2:value2}");
+add("print", print, "print each
message sent");
+}
+
+static bool nameval(const
std::string& in, std::string&
name, std::string& value)
+{
+std::string::size_type i =
in.find("=");
+if (i == std::string::npos) {
+name = in;
+return false;
+} else {
+name = in.substr(0, i);
+if (i+1 < in.size()) {
+value = in.substr(i+1);
+return true;
+} else {
+return false;
+}
+}
+}
+
+static void setProperty(Message& message, const
std::string& property)
+{
+std::string name;
+std::string value;
+if (nameval(property, name, value)) {
+message.getProperties()[name] = value;
+message.getProperties()[name].setEncoding("utf8");
+} else {
+message.getProperties()[name] = Variant();
+}
+}
+
+void setProperties(Message&
message) const
+{
+for (string_vector::const_iter
[02/51] [partial] qpid-site git commit: QPID-8250: Update for Qpid C++ 1.39.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/input/releases/qpid-cpp-1.39.0/messaging-api/book/connections.html.in -- diff --git a/input/releases/qpid-cpp-1.39.0/messaging-api/book/connections.html.in b/input/releases/qpid-cpp-1.39.0/messaging-api/book/connections.html.in new file mode 100644 index 000..cae0392 --- /dev/null +++ b/input/releases/qpid-cpp-1.39.0/messaging-api/book/connections.html.in @@ -0,0 +1,158 @@ +1.10. ConnectionsPrev Chapter 1. Using the Qpid Messaging API Next1.10. Connections + Messaging connections are created by specifying a broker or a list of brokers, and + an optional set of connection options. The constructor prototypes for Connections + are: + + Connection connection(); + Connection connection(const string url); + Connection connection(const string url, const string& options); + Connection connection(const string url, const Variant::Map& options); + + Messaging connection URLs specify only the network host address(es). Connection + options are specified separately as an options string or map. This is different + from JMS Connection URLs that combine the network address and connection properties + in a single string. + 1.10.1. Connection URLs + Connection URLs describe the broker or set of brokers to which the connection + is to attach. The format of the Connection URL is defined by AMQP 0.10 + Domain:connection.amqp-host-url. + + amqp_url = "amqp:" prot_addr_list + prot_addr_list = [prot_addr ","]* prot_addr + prot_addr = tcp_prot_addr | tls_prot_addr + + tcp_prot_addr = tcp_id tcp_addr + tcp_id = "tcp:" | "" + tcp_addr = [host [":" port] ] + host =; + port = number + Examples of Messaging Connection URLs + + localhost + localhost:5672 + localhost: + 192.168.1.2:5672 + mybroker.example.com:5672 + amqp:tcp:localhost:5672 + tcp:locahost:5672,localhost:5800 + 1.10.2. Connection Options + Aspects of the connections behaviour can be controlled through + specifying connection options. For example, connections can be + configured to automatically reconnect if the connection to a + broker is lost. + Example 1.14. Specifying Connection Options in C++, Python, and .NETIn C++, these options can be set using Connection::setOption() or by passing in a set of options to the constructor. The options can be passed in as a map or in string form:or + Connection connection("localhost:5672"); + connection.setOption("reconnect", true); + try { + connection.open(); + !!! SNIP !!! + In Python, these options can be set as attributes of the connection or using named arguments in + the Connection constructor: + connection = Connection("localhost:5672", reconnect=True) + try: + connection.open() + !!! SNIP !!! + or + connection = Connection("localhost:5672") + connection.reconnect = True + try: + connection.open() + !!! SNIP !!! + + In .NET, these options can be set using Connection.SetOption() or by passing in a set of options to the constructor. The options can be passed in as a map or in string form: + + Connection connection= new Connection("localhost:5672", "{reconnect: true}"); + try { + connection.Open(); + !!! SNIP !!! + + or + + Connection connection = new Connection("localhost:5672"); + connection.SetOption("reconnect", true); + try { + connection.Open(); + !!! SNIP !!! + See the reference documentation for details in each language.The following table lists the supported connection options.Table 1.4. Connection Optionsoption namevalue typesemantics + username + + string + + The username to use when authenticating to the broker. + + password + + string + + The password to use when authenticating to the broker. + + sasl_mechanisms + + string + + The specific SASL mechanisms to use with the python + client when authenticating to the broker. The value + is a space separated list. + + reconnect + + boolean + + Transparently reconnect if the connection is lost. + + recon
[36/51] [partial] qpid-site git commit: QPID-8250: Update for Qpid C++ 1.39.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/Message__io_8h_source.html
--
diff --git
a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/Message__io_8h_source.html
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/Message__io_8h_source.html
new file mode 100755
index 000..3138513
--- /dev/null
+++
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/Message__io_8h_source.html
@@ -0,0 +1,109 @@
+http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd";>
+http://www.w3.org/1999/xhtml";>
+
+
+
+
+
+Qpid C++ Messaging API: qpid/messaging/Message_io.h Source File
+
+
+
+
+
+
+
+
+ $(document).ready(initResizable);
+
+
+
+
+
+ $(document).ready(function() { init_search(); });
+
+
+
+
+
+
+
+
+
+
+ Qpid C++ Messaging API
+ 1.39.0
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+var searchBox = new SearchBox("searchBox", "search",false,'Search');
+
+
+
+
+
+
+
+
+
+
+
+
+$(document).ready(function(){initNavTree('Message__io_8h_source.html','');});
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+Message_io.h
+
+
+1 #ifndef
QPID_MESSAGING_MESSAGE_IO_H2 #define QPID_MESSAGING_MESSAGE_IO_H
3 4 /*5 *6 * Licensed to the
Apache Software Foundation (ASF) under one7
* or more contributor license agreements. See the NOTICE file8 * distributed with this work for additional
information9 * regarding copyright
ownership. The ASF licenses this file 10
* to you under the Apache License, Version 2.0 (the 11 * "License"); you may not use this file except in
compliance 12 * with the License.
You may obtain a copy of the License at 13
* 14 *
http://www.apache.org/licenses/LICENSE-2.0 15
*
16 * Unless required by applicable law or
agreed to in writing, 17 * software distributed
under the License is distributed on an 18
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF
ANY
19 * KIND, either express or implied. See
the License for the 20 * specific
language governing permissions and limitations 21
* under the License. 22 * 23 */ 24 #include
"Message.h" 25 #include
26 27 namespace qpid { 28 namespace messaging { 29
30 QPID_MESSAGING_EXTERN std::ostream&
operator<<(std::ostream&, const
Message&); 31 32 }} // namespace qpid::messaging 33 34 #endif qpidDefinition:
Address.h:32
+
+
+
+
+
+qpidmessagingMessage_io.h
+Generated by
+http://www.doxygen.org/index.html";>
+ 1.8.13
+
+
+
+
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/Receiver_8h_source.html
--
diff --git
a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/Receiver_8h_source.html
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/Receiver_8h_source.html
new file mode 100755
index 000..4d41227
--- /dev/null
+++
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/Receiver_8h_source.html
@@ -0,0 +1,116 @@
+http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd";>
+http://www.w3.org/1999/xhtml";>
+
+
+
+
+
+Qpid C++ Messaging API: qpid/messaging/Receiver.h Source File
+
+
+
+
+
+
+
+
+ $(document).ready(initResizable);
+
+
+
+
+
+ $(document).ready(function() { init_search(); });
+
+
+
+
+
+
+
+
+
+
+ Qpid C++ Messaging API
+ 1.39.0
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+var searchBox = new SearchBox("searchBox", "search",false,'Search');
+
+
+
+
+
+
+
+
+
+
+
+
+$(document).ready(function(){initNavTree('Receiver_8h_source.html','');});
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+Receiver.h
+
+
+1 #ifndef
QPID_MESSAGING_RECEIVER_H2 #define QPID_MESSAGING_RECEIVER_H
3 4 /*5 *6 * Licensed to the
Apache Software Foundation (ASF) under one7
* or more contributor license agreements. See the NOTICE file8 * distributed with this work for additional
information9 * regarding copyright
ownership. The ASF licenses this file 10
* to you under the Apache License, Version 2.0 (the 11 * "License"); you may not use this file except in
compliance 12 * with the License.
You may obtain a copy of the License at 13
*14 *
http://www.apache.org/licenses/LICENSE-2.0 15
*
16 * Unless required by applicable law or
agreed to in writing, 17 * software distributed
under the License is distributed on an 18
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF
ANY
19 * KIND, either express or implied. See
the License for the 20 * specific language
governing permissions and limitations 21
* under the License. 22 * 23
[05/51] [partial] qpid-site git commit: QPID-8250: Update for Qpid C++ 1.39.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/input/releases/qpid-cpp-1.39.0/cpp-broker/book/chapter-Managing-CPP-Broker.html.in -- diff --git a/input/releases/qpid-cpp-1.39.0/cpp-broker/book/chapter-Managing-CPP-Broker.html.in b/input/releases/qpid-cpp-1.39.0/cpp-broker/book/chapter-Managing-CPP-Broker.html.in new file mode 100644 index 000..705abfd --- /dev/null +++ b/input/releases/qpid-cpp-1.39.0/cpp-broker/book/chapter-Managing-CPP-Broker.html.in @@ -0,0 +1,459 @@ +Chapter 2. + Managing the AMQP Messaging Broker +Prev NextChapter 2. + Managing the AMQP Messaging Broker +Table of Contents2.1. Managing the C++ Broker 2.1.1. +Using qpid-config + 2.1.2. +Using qpid-route + 2.1.3. +Using qpid-tool + 2.1.4. +Using +qpid-printevents + 2.1.5. Using qpid-ha2.2. + Qpid Management Framework +2.2.1. +What Is QMF + 2.2.2. +Getting +Started with QMF + 2.2.3. +QMF Concepts + 2.2.4. +The QMF +Protocol + 2.2.5. +How +to Write a QMF Console + 2.2.6. +How to +Write a QMF Agent + 2.3. + QMF Python Console Tutorial +2.3.1. +Prerequisite +- Install Qpid Messaging + 2.3.2. +Synchronous +Console Operations + 2.3.3. +Asynchronous +Console Operations + 2.3.4. +Discovering what Kinds of Objects are Available + 2.1. Managing the C++ Broker +There are quite a few ways to interact with the C++ broker. The +command line tools +include: + qpid-route - used to configure federation (a set of federated +brokers) +qpid-config - used to configure queues, exchanges, bindings +and list them etc +qpid-tool - used to view management information/statistics +and call any management actions on the broker +qpid-printevents - used to receive and print QMF events +qpid-ha - used to interact with the High Availability module +2.1.1. +Using qpid-config + +This utility can be used to create queues exchanges and bindings, +both durable and transient. Always check for latest options by +running --help command. + +$ qpid-config --help +Usage: qpid-config [OPTIONS] +qpid-config [OPTIONS] exchanges [filter-string] +qpid-config [OPTIONS] queues[filter-string] +qpid-config [OPTIONS] add exchange[AddExchangeOptions] +qpid-config [OPTIONS] del exchange +qpid-config [OPTIONS] add queue [AddQueueOptions] +qpid-config [OPTIONS] del queue +qpid-config [OPTIONS] bind [binding-key] +qpid-config [OPTIONS] unbind [binding-key] + +Options: +-b [ --bindings ] Show bindings in queue or exchange list +-a [ --broker-addr ] Address (localhost) Address of qpidd broker + broker-addr is in the form: [username/password@] hostname | ip-address [: ] + ex: localhost, 10.1.1.7:1, broker-host:1, guest/guest@localhost + +Add Queue Options: +--durableQueue is durable +--file-count N (8) Number of files in queue's persistence journal +--file-size N (24) File size in pages (64Kib/page) +--max-queue-size N Maximum in-memory queue size as bytes +--max-queue-count N Maximum in-memory queue size as a number of messages +--limit-policy [none | reject | flow-to-disk | ring | ring-strict] + Action taken when queue limit is reached: + none (default) - Use broker's default policy + reject - Reject enqueued messages + flow-to-disk - Page messages to disk + ring - Replace oldest unacquired message with new + ring-strict- Replace oldest message, reject if oldest is acquired +--order [fifo | lvq | lvq-no-browse] + Set queue ordering policy: + fifo (default) - First in, first out + lvq- Last Value Queue ordering, allows queue browsing + lvq-no-browse - Last Value Queue ordering, browsing clients may lose data + +Add Exchange Options: +--durableExchange is durable +--sequence Exchange will insert a 'qpid.msg_sequence' field in the message header +
[15/51] [partial] qpid-site git commit: QPID-8250: Update for Qpid C++ 1.39.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1TransportFailure-members.html
--
diff --git
a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1TransportFailure-members.html
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1TransportFailure-members.html
new file mode 100755
index 000..1612df4
--- /dev/null
+++
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1TransportFailure-members.html
@@ -0,0 +1,116 @@
+http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd";>
+http://www.w3.org/1999/xhtml";>
+
+
+
+
+
+Qpid C++ Messaging API: Member List
+
+
+
+
+
+
+
+
+ $(document).ready(initResizable);
+
+
+
+
+
+ $(document).ready(function() { init_search(); });
+
+
+
+
+
+
+
+
+
+
+ Qpid C++ Messaging API
+ 1.39.0
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+var searchBox = new SearchBox("searchBox", "search",false,'Search');
+
+
+
+
+
+
+
+
+
+
+
+
+$(document).ready(function(){initNavTree('structqpid_1_1messaging_1_1TransportFailure.html','');});
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+qpid::messaging::TransportFailure Member List
+
+
+
+This is the complete list of members for qpid::messaging::TransportFailure,
including all inherited members.
+
+ Exception(const
std::string &message=std::string()) (defined in qpid::types::Exception)qpid::types::Exceptionexplicit
+ MessagingException(const
std::string &msg) (defined in qpid::messaging::MessagingException)qpid::messaging::MessagingException
+ TransportFailure(const std::string &) (defined in qpid::messaging::TransportFailure)qpid::messaging::TransportFailure
+ what() const (defined in qpid::types::Exception)qpid::types::Exceptionvirtual
+ ~Exception()
(defined in qpid::types::Exception)qpid::types::Exceptionvirtual
+ ~MessagingException()
(defined in qpid::messaging::MessagingException)qpid::messaging::MessagingExceptionvirtual
+
+
+
+
+
+Generated by
+http://www.doxygen.org/index.html";>
+ 1.8.13
+
+
+
+
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1TransportFailure.html
--
diff --git
a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1TransportFailure.html
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1TransportFailure.html
new file mode 100755
index 000..9119704
--- /dev/null
+++
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1TransportFailure.html
@@ -0,0 +1,146 @@
+http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd";>
+http://www.w3.org/1999/xhtml";>
+
+
+
+
+
+Qpid C++ Messaging API: qpid::messaging::TransportFailure Struct
Reference
+
+
+
+
+
+
+
+
+ $(document).ready(initResizable);
+
+
+
+
+
+ $(document).ready(function() { init_search(); });
+
+
+
+
+
+
+
+
+
+
+ Qpid C++ Messaging API
+ 1.39.0
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+var searchBox = new SearchBox("searchBox", "search",false,'Search');
+
+
+
+
+
+
+
+
+
+
+
+
+$(document).ready(function(){initNavTree('structqpid_1_1messaging_1_1TransportFailure.html','');});
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+Public Member Functions |
+List of all
members
+
+qpid::messaging::TransportFailure Struct Reference
+
+
+
+#include
+
+Inheritance diagram for qpid::messaging::TransportFailure:
+
+
+
+
+
+
+
+
+
+
+Public Member Functions
+
+QPID_MESSAGING_EXTERN TransportFailure (const std::string &)
+
+ Public Member Functions inherited from qpid::messaging::MessagingException
+
+QPID_MESSAGING_EXTERN MessagingException (const std::string &msg)
+
+ Public Member Functions inherited from qpid::types::Exception
+
+QPID_TYPES_EXTERN Exception (const std::string &message=std::string())
throw ()
+
+
+virtual QPID_TYPES_EXTERN const char * what () const throw ()
+
+
+Detailed
Description
+Thrown to indicate loss of underlying connection.
When auto-reconnect is used this will be caught by the library and used to
trigger reconnection attempts. If reconnection fails (according to whatever
settings have been configured), then an instnace of this class will be thrown
to signal that.
+The documentation for this struct was generated from the following
file:
+qpid/messaging/exceptions.h
+
+
+
+
+
+
+qpidmessagingTransportFailure
+Generated by
+http://www.doxygen.org/index.html";>
+ 1.8.13
+
+
+
+
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/rele
[06/51] [partial] qpid-site git commit: QPID-8250: Update for Qpid C++ 1.39.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/input/releases/qpid-cpp-1.39.0/cpp-broker/book/chap-Messaging_User_Guide-Security.html.in -- diff --git a/input/releases/qpid-cpp-1.39.0/cpp-broker/book/chap-Messaging_User_Guide-Security.html.in b/input/releases/qpid-cpp-1.39.0/cpp-broker/book/chap-Messaging_User_Guide-Security.html.in new file mode 100644 index 000..54e59de --- /dev/null +++ b/input/releases/qpid-cpp-1.39.0/cpp-broker/book/chap-Messaging_User_Guide-Security.html.in @@ -0,0 +1,1231 @@ +1.5. SecurityPrev Chapter 1. + Running the AMQP Messaging Broker + Next1.5. Security + This chapter describes how authentication, rule-based authorization, encryption, and digital signing can be accomplished using Qpid. Authentication is the process of verifying the identity of a user; in Qpid, this is done using the SASL framework. Rule-based authorization is a mechanism for specifying the actions that each user is allowed to perform; in Qpid, this is done using an Access Control List (ACL) that is part of the Qpid broker. Encryption is used to ensure that data is not transferred in a plain-text format that could be intercepted and read. Digital signatures provide proof that a given message was sent by a known sender. Encryption and signing are done using SSL (they can also be done using SASL, but SSL provides stronger encryption). + 1.5.1. User Authentication + AMQP uses Simple Authentication and Security Layer (SASL) to authenticate client connections to the broker. SASL is a framework that supports a variety of authentication methods. For secure applications, we suggest CRAM-MD5, DIGEST-MD5, or GSSAPI. The ANONYMOUS method is not secure. The PLAIN method is secure only when used together with SSL. + + Both the Qpid broker and Qpid clients use the http://cyrusimap.web.cmu.edu/"; target="_top">Cyrus SASL library, a full-featured authentication framework, which offers many configuration options. This section shows how to configure users for authentication with SASL, which is sufficient when using SASL PLAIN. If you are not using SSL, you should configure SASL to use CRAM-MD5, DIGEST-MD5, or GSSAPI (which provides Kerberos authentication). For information on configuring these and other options in SASL, see the Cyrus SASL documentation. + Important + The SASL PLAIN method sends passwords in cleartext, and is vulnerable to man-in-the-middle attacks unless SSL (Secure Socket Layer) is also used (see Section 1.5.4, “Encryption using SSL”). + + If you are not using SSL, we recommend that you disable PLAIN authentication in the broker. + + The Qpid broker uses the auth yes|no option to determine whether to use SASL authentication. Turn on authentication by setting auth to yes in /etc/qpidd.conf: + +# /etc/qpidd.conf +# +# Set auth to 'yes' or 'no' + +auth=yes +1.5.1.1. Configuring SASL + On Linux systems, the SASL configuration file is generally found in /etc/sasl2/qpidd.conf or /usr/lib/sasl2/qpidd.conf. + + The SASL database contains user names and passwords for SASL. In SASL, a user may be associated with a realm. The Qpid broker authenticates users in the QPID realm by default, but it can be set to a different realm using the realm option: + +# /etc/qpidd.conf +# +# Set the SASL realm using 'realm=' + +auth=yes +realm=QPID + + The SASL database is installed at /var/lib/qpidd/qpidd.sasldb; initially, it has one user named guest in the QPID realm, and the password for this user is guest. + Note + The user database is readable only by the qpidd user. When run as a daemon, Qpid always runs as the qpidd user. If you start the broker from a user other than the qpidd user, you will need to either reconfigure SASL or turn authentication off. + Important + The SASL database stores user names and passwords in plain text. If it is compromised so are all of the passwords that it stores. This is the reason that the qpidd user is the only user that can read the database. If you modify permissions, be careful not to expose the SASL database. + + Add new users to the database by using the saslpasswd2 command, which specifies a realm and a user ID. A user ID takes the form user-id@domain.. + # saslpasswd2 -f /var/lib/qpidd/qpidd.sasldb -u realm new_user_name + To list the users in t
[33/51] [partial] qpid-site git commit: QPID-8250: Update for Qpid C++ 1.39.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/classqpid_1_1messaging_1_1FailoverUpdates.html
--
diff --git
a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/classqpid_1_1messaging_1_1FailoverUpdates.html
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/classqpid_1_1messaging_1_1FailoverUpdates.html
new file mode 100755
index 000..ea48e08
--- /dev/null
+++
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/classqpid_1_1messaging_1_1FailoverUpdates.html
@@ -0,0 +1,125 @@
+http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd";>
+http://www.w3.org/1999/xhtml";>
+
+
+
+
+
+Qpid C++ Messaging API: qpid::messaging::FailoverUpdates Class
Reference
+
+
+
+
+
+
+
+
+ $(document).ready(initResizable);
+
+
+
+
+
+ $(document).ready(function() { init_search(); });
+
+
+
+
+
+
+
+
+
+
+ Qpid C++ Messaging API
+ 1.39.0
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+var searchBox = new SearchBox("searchBox", "search",false,'Search');
+
+
+
+
+
+
+
+
+
+
+
+
+$(document).ready(function(){initNavTree('classqpid_1_1messaging_1_1FailoverUpdates.html','');});
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+Public Member Functions |
+List of all
members
+
+qpid::messaging::FailoverUpdates Class Reference
+
+
+
+#include
+
+
+Public Member Functions
+
+QPID_MESSAGING_EXTERN FailoverUpdates (Connection
&connection)
+
+
+Detailed
Description
+A utility to listen for updates on cluster
membership and update the list of known urls for a connection accordingly.
+The documentation for this class was generated from the following
file:
+qpid/messaging/FailoverUpdates.h
+
+
+
+
+
+
+qpidmessagingFailoverUpdates
+Generated by
+http://www.doxygen.org/index.html";>
+ 1.8.13
+
+
+
+
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/classqpid_1_1messaging_1_1FailoverUpdates.js
--
diff --git
a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/classqpid_1_1messaging_1_1FailoverUpdates.js
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/classqpid_1_1messaging_1_1FailoverUpdates.js
new file mode 100755
index 000..f4ada19
--- /dev/null
+++
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/classqpid_1_1messaging_1_1FailoverUpdates.js
@@ -0,0 +1,5 @@
+var classqpid_1_1messaging_1_1FailoverUpdates =
+[
+[ "FailoverUpdates",
"classqpid_1_1messaging_1_1FailoverUpdates.html#a4042cc9b3ab0592a67e704ffcd97d56a",
null ],
+[ "~FailoverUpdates",
"classqpid_1_1messaging_1_1FailoverUpdates.html#a24ce01b159ba534fe8d13883d425c399",
null ]
+];
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/classqpid_1_1messaging_1_1Handle-members.html
--
diff --git
a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/classqpid_1_1messaging_1_1Handle-members.html
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/classqpid_1_1messaging_1_1Handle-members.html
new file mode 100755
index 000..39554e9
--- /dev/null
+++
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/classqpid_1_1messaging_1_1Handle-members.html
@@ -0,0 +1,119 @@
+http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd";>
+http://www.w3.org/1999/xhtml";>
+
+
+
+
+
+Qpid C++ Messaging API: Member List
+
+
+
+
+
+
+
+
+ $(document).ready(initResizable);
+
+
+
+
+
+ $(document).ready(function() { init_search(); });
+
+
+
+
+
+
+
+
+
+
+ Qpid C++ Messaging API
+ 1.39.0
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+var searchBox = new SearchBox("searchBox", "search",false,'Search');
+
+
+
+
+
+
+
+
+
+
+
+
+$(document).ready(function(){initNavTree('classqpid_1_1messaging_1_1Handle.html','');});
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+qpid::messaging::Handle< T > Member List
+
+
+
+This is the complete list of members for qpid::messaging::Handle< T
>, including all inherited members.
+
+ Handle()
(defined in qpid::messaging::Handle< T
>)qpid::messaging::Handle< T
>inlineprotected
+ Impl typedef (defined in qpid::messaging::Handle< T
>)qpid::messaging::Handle< T
>protected
+ impl (defined in
qpid::messaging::Handle< T
>)qpid::messaging::Handle< T
>protected
+ isNull()
constqpid::messaging::Handle< T
>inline
+ isValid()
constqpid::messaging::Handle< T
>inline
+ operator
bool() constqpid::messaging::Handle< T
>inline
+ operator!()
constqpid::messaging::Handle< T
>inline
+ PrivateImplRef< T >
(defined in qpid::messaging::Han
[48/51] [partial] qpid-site git commit: QPID-8250: Update for Qpid C++ 1.39.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/cpp-broker/book/ch01s06.html
--
diff --git a/content/releases/qpid-cpp-1.39.0/cpp-broker/book/ch01s06.html
b/content/releases/qpid-cpp-1.39.0/cpp-broker/book/ch01s06.html
new file mode 100644
index 000..f2dd255
--- /dev/null
+++ b/content/releases/qpid-cpp-1.39.0/cpp-broker/book/ch01s06.html
@@ -0,0 +1,250 @@
+
+
+http://www.w3.org/1999/xhtml"; xml:lang="en">
+
+1.6. LVQ - Last Value Queue - Apache Qpid™
+
+
+
+
+var _deferredFunctions = [];
+
+
+
+
+https://git-wip-us.apache.org/repos/asf/qpid-proton.git"/>
+https://github.com/apache/qpid-proton/blob/go1/README.md
+https://github.com/apache/qpid-proton/tree/go1{/dir}
+https://github.com/apache/qpid-proton/blob/go1{/dir}/{file}#L{line}"/>
+
+
+
+
+
+
+
+
+
+ Apache
Qpid™
+ Documentation
+ Download
+ Discussion
+
+
+
+
+
+
+Project
+
+
+ Overview
+ Components
+ Releases
+
+
+
+
+Messaging APIs
+
+
+ Qpid Proton
+ Qpid JMS
+ Qpid
Messaging API
+
+
+
+
+Servers and tools
+
+
+ Broker-J
+ C++
broker
+ Dispatch
router
+
+
+
+
+Resources
+
+
+ Dashboard
+ https://cwiki.apache.org/confluence/display/qpid/Index";>Wiki
+ More resources
+
+
+
+
+
+
+http://www.google.com/search"; method="get">
+
+
+ Search
+ More ways to search
+
+
+
+
+HomeReleasesQpid C++ 1.39.0AMQP Messaging
Broker (Implemented in C++)1.6. LVQ - Last Value
Queue
+
+
+ 1.6. LVQ - Last Value QueuePrev Chapter 1.
+ Running the AMQP Messaging Broker
+ Next1.6. LVQ - Last Value
Queue1.6.1. Understanding
LVQ
+ A Last Value Queue is configured with the name of a message header that
+ is used as a key. The queue behaves as a normal FIFO queue with the
+ exception that when a message is enqueued, any other message in the
+ queue with the same value in the key header is removed and discarded.
+ Thus, for any given key value, the queue holds only the most recent
+ message.
+
+ The following example illustrates the operation of a Last Value Queue.
+ The example shows an empty queue with no consumers and a sequence of
+ produced messages. The numbers represent the key for each message.
+
+
+ 1 =>
+ 1
+ 2 =>
+ 1 2
+ 3 =>
+ 1 2 3
+ 4 =>
+ 1 2 3 4
+ 2 =>
+ 1 3 4 2
+ 1 =>
+ 3 4 2 1
+
+ Note that the first four messages are enqueued normally in FIFO order.
+ The fifth message has key '2' and is also enqueued on the tail of the
+ queue. However the message already in the queue with the same key is
+ discarded.
+ Note
+ If the set of keys used in the messages in a LVQ is constrained, the
+ number of messages in the queue shall not exceed the number of
+ distinct keys in use.
+
+1.6.1.1. Common
Use-Cases
+LVQ with zero or one consuming subscriptions - In this case, if
+the consumer drops momentarily or is slower than the producer(s),
+it will only receive current information relative to the message
+keys.
+
+LVQ with zero or more browsing subscriptions - A browsing consumer
+can subscribe to the LVQ and get an immediate dump of all of the
+"current" messages and track updates thereafter. Any number of
+independent browsers can subscribe to the same LVQ with the same
+effect. Since messages are never consumed, they only disappear
+when replaced with a newer message with the same key or when their
+TTL expires.
+ 1.6.2. Creating a Last Value
Queue1.6.2.1. Using Addressing
Syntax
+A LVQ may be created using directives in the API's address syntax.
+The important argument is "qpid.last_value_queue_key". The following
+Python example shows how a producer of stock price updates can create
+a LVQ to hold the latest stock prices for each ticker symbol. The
+message header used to hold the ticker symbol is called "ticker".
+
+conn = Connection(url)
+conn.open()
+sess = conn.session()
+tx = sess.sender("prices;{create:always, node:{type:queue,
x-declare:{arguments:{'q
[08/51] [partial] qpid-site git commit: QPID-8250: Update for Qpid C++ 1.39.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/input/releases/qpid-cpp-1.39.0/cpp-broker/book/ch02s02.html.in -- diff --git a/input/releases/qpid-cpp-1.39.0/cpp-broker/book/ch02s02.html.in b/input/releases/qpid-cpp-1.39.0/cpp-broker/book/ch02s02.html.in new file mode 100644 index 000..ac2c39e --- /dev/null +++ b/input/releases/qpid-cpp-1.39.0/cpp-broker/book/ch02s02.html.in @@ -0,0 +1,586 @@ +2.2. + Qpid Management Framework +Prev Chapter 2. + Managing the AMQP Messaging Broker + Next2.2. + Qpid Management Framework + +Section 2.2.1, “ +What Is QMF + ” + +Section 2.2.2, “ +Getting +Started with QMF + ” + +Section 2.2.3, “ +QMF Concepts + ” + + +Section 2.2.3.1, “ +Console, +Agent, and Broker + ” + +Section 2.2.3.2, “ +Schema + ” + +Section 2.2.3.3, “ +Class +Keys and Class Versioning + ” + + +Section 2.2.4, “ +The QMF +Protocol + ” + +Section 2.2.5, “ +How +to Write a QMF Console + ” + +Section 2.2.6, “ +How to +Write a QMF Agent + ” + + Please visit the ??? for information + about the future of QMF. +2.2.1. +What Is QMF + +QMF (Qpid Management Framework) is a general-purpose management +bus built on Qpid Messaging. It takes advantage of the +scalability, security, and rich capabilities of Qpid to provide +flexible and easy-to-use manageability to a large set of +applications. + 2.2.2. +Getting +Started with QMF + +QMF is used through two primary APIs. The console API is +used for console applications that wish to access and manipulate +manageable components through QMF. The agent API is used +for application that wish to be managed through QMF. + +The fastest way to get started with QMF is to work through the +"How To" tutorials for consoles and agents. For a deeper +understanding of what is happening in the tutorials, it is +recommended that you look at the Qmf Concepts section. + 2.2.3. +QMF Concepts + +This section introduces important concepts underlying QMF. + 2.2.3.1. +Console, +Agent, and Broker + +The major architectural components of QMF are the Console, the +Agent, and the Broker. Console components are the "managing" +components of QMF and agent components are the "managed" parts. +The broker is a central (possibly distributed, clustered and +fault-tolerant) component that manages name spaces and caches +schema information. + +A console application may be a command-line utility, a +three-tiered web-based GUI, a collection and storage device, a +specialized application that monitors and reacts to events and +conditions, or anything else somebody wishes to develop that uses +QMF management data. + +An agent application is any application that has been enhanced to +allow itself to be managed via QMF. + + +-++-++---+ +---+ + | CLI utility || Web app || Audit storage || Event correlation | + +-++-++---+ +---+ + ^^ ^^ | + || || | + vv vv v + +-+ +|Qpid Messaging Bus (with QMF Broker capability) | + +-+ +^ ^ ^ +| | | +v v v + ++++++ + | Manageable app || Manageabl
[49/51] [partial] qpid-site git commit: QPID-8250: Update for Qpid C++ 1.39.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/cpp-broker/book/ch01.html
--
diff --git a/content/releases/qpid-cpp-1.39.0/cpp-broker/book/ch01.html
b/content/releases/qpid-cpp-1.39.0/cpp-broker/book/ch01.html
new file mode 100644
index 000..85df8c2
--- /dev/null
+++ b/content/releases/qpid-cpp-1.39.0/cpp-broker/book/ch01.html
@@ -0,0 +1,690 @@
+
+
+http://www.w3.org/1999/xhtml"; xml:lang="en">
+
+ch01.html - Apache Qpid™
+
+
+
+
+var _deferredFunctions = [];
+
+
+
+
+https://git-wip-us.apache.org/repos/asf/qpid-proton.git"/>
+https://github.com/apache/qpid-proton/blob/go1/README.md
+https://github.com/apache/qpid-proton/tree/go1{/dir}
+https://github.com/apache/qpid-proton/blob/go1{/dir}/{file}#L{line}"/>
+
+
+
+
+
+
+
+
+
+ Apache
Qpid™
+ Documentation
+ Download
+ Discussion
+
+
+
+
+
+
+Project
+
+
+ Overview
+ Components
+ Releases
+
+
+
+
+Messaging APIs
+
+
+ Qpid Proton
+ Qpid JMS
+ Qpid
Messaging API
+
+
+
+
+Servers and tools
+
+
+ Broker-J
+ C++
broker
+ Dispatch
router
+
+
+
+
+Resources
+
+
+ Dashboard
+ https://cwiki.apache.org/confluence/display/qpid/Index";>Wiki
+ More resources
+
+
+
+
+
+
+http://www.google.com/search"; method="get">
+
+
+ Search
+ More ways to search
+
+
+
+
+HomeReleasesQpid C++ 1.39.0AMQP Messaging
Broker (Implemented in C++)ch01.html
+
+
+ Chapter 1.
+ Running the AMQP Messaging Broker
+Prev NextChapter 1.
+ Running the AMQP Messaging Broker
+Table of
Contents1.1.
+Running a Qpid C++ Broker
+ 1.1.1.
+Building the
+C++ Broker and Client Libraries
+ 1.1.2.
+Running the C++ Broker
+ 1.1.3.
+Most
+common questions getting qpidd running
+ 1.1.4.
+Authentication
+ 1.1.5.
+Slightly more
+complex configuration
+ 1.1.6.
+Loading extra modules
+ 1.1.7. Timestamping Received
Messages1.1.8. Logging
Options1.2.
+ Cheat Sheet for configuring Queue Options
+1.2.1.
+Configuring
+Queue Options
+ 1.3.
+Cheat Sheet for configuring Exchange Options
+ 1.3.1.
+ Configuring Exchange Options
+1.4. Broker
Federation1.4.1.
Message Routes1.4.2.
Federation Topologies1.4.3.
Federation among High Availability Message Clusters1.4.4.
The qpid-route Utility1.4.5.
Broker options affecting federation1.5.
Security1.5.1.
User Authentication1.5.2.
Authorization1.5.3.
User Connection and Queue Quotas1.5.4.
Encryption using SSL<
dt>1.6. LVQ - Last Value
Queue1.6.1. Understanding
LVQ1.6.2. Creating a Last Value
Queue1.6.3. LVQ Example1.6.4. Deprecated LVQ
Modes1.7.
+Queue State Replication
+ 1.7.1.
+ Asynchronous
+ Replication of Queue State
+1.8.
+Producer Flow Control
+ 1.8.1.
+ Overview
+1.8.2.
+User Interface
+ 1.9.
+ AMQP compatibility
+1.9.1.
+AMQP
+Compatibility of Qpid releases:
+ 1.9.2.
+Interop
+table by AMQP specification version
+ 1.10.
Qpid Interoperability Documentation1.10.1.
+SASL
+ 1.11.
+Using Message Groups
+ 1.11.1.
+ Overview
+1.11.2.
+Grouping Messages
+ 1.11.3.
+The Role of the Broker
+ 1.11.4.
+Well Behaved Consumers
+ 1.11.5.
+Broker Configuration
+ 1.12. Active-Passive Messaging
Clusters1.12.1. Overview1.12.2. Virtual IP
Addresses1.12.3. Configuring the
Brokers1.12.4. The Cluster Resource
Manager1.12.5. Configuring with rgmanager as resource
manager1.12.6. Broker Administration
Tools1.12.7. Controlling replication of
queues and
exchanges1.12.8. Client Connection and
Fail-over1.12.9. Security and Access
Control.1.12.10. Integrating with other Cluster
Resource Managers1.12.11. Using a message store in a
cluster1.12.12. Troubleshooting a
cluster1.13. Replicating Queues with the HA
module1.13.1. Replicating
queues1.13.2. Replicating
queues between clusters1.1.
+Running a Qpid C++ Broker
+ 1.1.1.
+Building the
+C++ Broker and Client Libraries
+
+The root directory for the
[20/51] [partial] qpid-site git commit: QPID-8250: Update for Qpid C++ 1.39.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1FetchError-members.html
--
diff --git
a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1FetchError-members.html
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1FetchError-members.html
new file mode 100755
index 000..85e8c76
--- /dev/null
+++
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1FetchError-members.html
@@ -0,0 +1,118 @@
+http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd";>
+http://www.w3.org/1999/xhtml";>
+
+
+
+
+
+Qpid C++ Messaging API: Member List
+
+
+
+
+
+
+
+
+ $(document).ready(initResizable);
+
+
+
+
+
+ $(document).ready(function() { init_search(); });
+
+
+
+
+
+
+
+
+
+
+ Qpid C++ Messaging API
+ 1.39.0
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+var searchBox = new SearchBox("searchBox", "search",false,'Search');
+
+
+
+
+
+
+
+
+
+
+
+
+$(document).ready(function(){initNavTree('structqpid_1_1messaging_1_1FetchError.html','');});
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+qpid::messaging::FetchError Member List
+
+
+
+This is the complete list of members for qpid::messaging::FetchError,
including all inherited members.
+
+ Exception(const
std::string &message=std::string()) (defined in qpid::types::Exception)qpid::types::Exceptionexplicit
+ FetchError(const std::string
&) (defined in qpid::messaging::FetchError)qpid::messaging::FetchError
+ LinkError(const
std::string &) (defined in qpid::messaging::LinkError)qpid::messaging::LinkError
+ MessagingException(const
std::string &msg) (defined in qpid::messaging::MessagingException)qpid::messaging::MessagingException
+ ReceiverError(const std::string &) (defined in qpid::messaging::ReceiverError)qpid::messaging::ReceiverError
+ what() const (defined in qpid::types::Exception)qpid::types::Exceptionvirtual
+ ~Exception()
(defined in qpid::types::Exception)qpid::types::Exceptionvirtual
+ ~MessagingException()
(defined in qpid::messaging::MessagingException)qpid::messaging::MessagingExceptionvirtual
+
+
+
+
+
+Generated by
+http://www.doxygen.org/index.html";>
+ 1.8.13
+
+
+
+
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1FetchError.html
--
diff --git
a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1FetchError.html
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1FetchError.html
new file mode 100755
index 000..7b068a5
--- /dev/null
+++
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1FetchError.html
@@ -0,0 +1,153 @@
+http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd";>
+http://www.w3.org/1999/xhtml";>
+
+
+
+
+
+Qpid C++ Messaging API: qpid::messaging::FetchError Struct
Reference
+
+
+
+
+
+
+
+
+ $(document).ready(initResizable);
+
+
+
+
+
+ $(document).ready(function() { init_search(); });
+
+
+
+
+
+
+
+
+
+
+ Qpid C++ Messaging API
+ 1.39.0
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+var searchBox = new SearchBox("searchBox", "search",false,'Search');
+
+
+
+
+
+
+
+
+
+
+
+
+$(document).ready(function(){initNavTree('structqpid_1_1messaging_1_1FetchError.html','');});
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+Public Member Functions |
+List of all
members
+
+qpid::messaging::FetchError Struct Reference
+
+
+
+Inheritance diagram for qpid::messaging::FetchError:
+
+
+
+
+
+
+
+
+
+
+
+
+
+Public Member Functions
+
+QPID_MESSAGING_EXTERN FetchError (const std::string &)
+
+ Public Member Functions inherited from qpid::messaging::ReceiverError
+
+QPID_MESSAGING_EXTERN ReceiverError (const std::string &)
+
+ Public Member Functions inherited from qpid::messaging::LinkError
+
+QPID_MESSAGING_EXTERN LinkError (const std::string &)
+
+ Public Member Functions inherited from qpid::messaging::MessagingException
+
+QPID_MESSAGING_EXTERN MessagingException (const std::string &msg)
+
+ Public Member Functions inherited from qpid::types::Exception
+
+QPID_TYPES_EXTERN Exception (const std::string &message=std::string())
throw ()
+
+
+virtual QPID_TYPES_EXTERN const char * what () const throw ()
+
+
+The documentation for this struct was generated from the following
file:
+qpid/messaging/exceptions.h
+
+
+
+
+
+
+qpidmessagingFetchError
+Generated by
+http://www.doxygen.org/index.html";>
+ 1.8.13
+
+
+
+
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/
[51/51] [partial] qpid-site git commit: QPID-8250: Update for Qpid C++ 1.39.0
QPID-8250: Update for Qpid C++ 1.39.0 Project: http://git-wip-us.apache.org/repos/asf/qpid-site/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-site/commit/c3ab60f6 Tree: http://git-wip-us.apache.org/repos/asf/qpid-site/tree/c3ab60f6 Diff: http://git-wip-us.apache.org/repos/asf/qpid-site/diff/c3ab60f6 Branch: refs/heads/asf-site Commit: c3ab60f6dbb9bcd34c6b187699050b118faadfc9 Parents: 2b7a4a8 Author: Justin Ross Authored: Fri Oct 26 16:45:31 2018 -0700 Committer: Justin Ross Committed: Fri Oct 26 16:45:31 2018 -0700 -- content/components/cpp-broker/index.html| 18 +- content/components/messaging-api/index.html | 18 +- content/dashboard.html |2 +- content/documentation.html |8 +- content/download.html | 12 +- content/releases/index.html |3 +- .../book/Java-Broker-Introduction.html |2 +- .../book/Java-Broker-Introduction.html |2 +- .../book/Java-Broker-Introduction.html |2 +- .../book/Java-Broker-Introduction.html |2 +- .../book/Java-Broker-Introduction.html |2 +- .../book/Java-Broker-Introduction.html |2 +- .../book/Java-Broker-Introduction.html |2 +- .../book/Java-Broker-Introduction.html |2 +- content/releases/qpid-cpp-1.35.0/index.html |2 +- content/releases/qpid-cpp-1.36.0/index.html |2 +- content/releases/qpid-cpp-1.37.0/index.html |2 +- content/releases/qpid-cpp-1.38.0/index.html |2 +- .../cpp-broker/book/AMQP-Compatibility.html | 536 ++ ...ation-QpidInteroperabilityDocumentation.html | 375 .../cpp-broker/book/Using-message-groups.html | 299 .../qpid-cpp-1.39.0/cpp-broker/book/ch01.html | 690 .../cpp-broker/book/ch01s02.html| 286 .../cpp-broker/book/ch01s03.html| 241 +++ .../cpp-broker/book/ch01s06.html| 250 +++ .../cpp-broker/book/ch02s02.html| 729 .../cpp-broker/book/ch02s03.html| 847 ++ ...-Messaging_User_Guide-Broker_Federation.html | 491 ++ .../chap-Messaging_User_Guide-Security.html | 1374 +++ .../book/chapter-Managing-CPP-Broker.html | 602 +++ .../cpp-broker/book/chapter-ha.html | 930 ++ .../cpp-broker/book/css/style.css | 279 +++ .../cpp-broker/book/ha-queue-replication.html | 221 +++ .../qpid-cpp-1.39.0/cpp-broker/book/index.html | 251 +++ .../qpid-cpp-1.39.0/cpp-broker/book/pr01.html | 149 ++ .../cpp-broker/book/producer-flow-control.html | 334 .../book/queue-state-replication.html | 372 .../cpp-broker/cpp-broker-book.pdf | Bin 0 -> 363775 bytes content/releases/qpid-cpp-1.39.0/index.html | 231 +++ .../book/Message-Groups-Guide.html | 242 +++ .../messaging-api/book/acknowledgements.html| 164 ++ .../messaging-api/book/ch01s02.html | 174 ++ .../messaging-api/book/ch01s03.html | 191 +++ .../messaging-api/book/ch01s08.html | 180 ++ .../messaging-api/book/ch01s09.html | 176 ++ .../messaging-api/book/ch01s12.html | 185 ++ .../messaging-api/book/ch01s13.html | 165 ++ .../messaging-api/book/ch01s14.html | 177 ++ .../messaging-api/book/ch01s15.html | 169 ++ .../messaging-api/book/ch02.html| 184 ++ .../messaging-api/book/ch02s02.html | 161 ++ .../messaging-api/book/ch02s03.html | 182 ++ .../messaging-api/book/connections.html | 301 .../messaging-api/book/css/style.css| 279 +++ .../messaging-api/book/index.html | 144 ++ .../messaging-api/book/prefetch.html| 152 ++ .../messaging-api/book/replay.html | 168 ++ .../messaging-api/book/section-Maps.html| 300 .../messaging-api/book/section-addresses.html | 720 .../book/section-amqp0-10-mapping.html | 307 .../book/using-the-qpid-messaging-api.html | 213 +++ .../cpp/api/Address_8h_source.html | 110 ++ .../cpp/api/Connection_8h_source.html | 114 ++ .../cpp/api/Duration_8h_source.html | 110 ++ .../cpp/api/Exception_8h_source.html| 110 ++ .../cpp/api/FailoverUpdates_8h_source.html | 111 ++ .../messaging-api/cpp/api/Handle_8h_source.html | 114 ++ .../messaging-api/cpp/api/Logger_8h_source.html | 111 ++ .../cpp/api/Message_8h_source.html | 115 ++ .../cpp/api/Message__io_8h_source.html | 109 ++ .../cpp/api/Receiver_8h_source.html | 116 ++ .../messaging-api/cpp/api/Sender_8h_source.html | 115 ++ .../cpp/api/Session_8h_source.html
[35/51] [partial] qpid-site git commit: QPID-8250: Update for Qpid C++ 1.39.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/Variant_8h_source.html
--
diff --git
a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/Variant_8h_source.html
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/Variant_8h_source.html
new file mode 100755
index 000..1d5691f
--- /dev/null
+++
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/Variant_8h_source.html
@@ -0,0 +1,113 @@
+http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd";>
+http://www.w3.org/1999/xhtml";>
+
+
+
+
+
+Qpid C++ Messaging API: qpid/types/Variant.h Source File
+
+
+
+
+
+
+
+
+ $(document).ready(initResizable);
+
+
+
+
+
+ $(document).ready(function() { init_search(); });
+
+
+
+
+
+
+
+
+
+
+ Qpid C++ Messaging API
+ 1.39.0
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+var searchBox = new SearchBox("searchBox", "search",false,'Search');
+
+
+
+
+
+
+
+
+
+
+
+
+$(document).ready(function(){initNavTree('Variant_8h_source.html','');});
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+Variant.h
+
+
+1 #ifndef
QPID_TYPES_VARIANT_H2 #define
QPID_TYPES_VARIANT_H3 4 /*5 *6 * Licensed to the Apache Software Foundation (ASF) under
one
7 * or more contributor license agreements.
See the NOTICE file<
a name="l8">8 * distributed with this work for additional
information9 * regarding copyright
ownership. The ASF licenses this file 10
* to you under the Apache License, Version 2.0 (the 11 * "License"); you may not use this file except in
compliance 12 * with the License.
You may obtain a copy of the License at 13
*14 *
>http://www.apache.org/licenses/LICENSE-2.0name="l00015"> 15 class="comment"> * class="lineno"> 16 * Unless required by
>applicable law or agreed to in writing,name="l00017"> 17 class="comment"> * software distributed under the License is distributed on
>an
>18 * "AS IS" BASIS, WITHOUT
>WARRANTIES OR CONDITIONS OF ANYname="l00019"> 19 class="comment"> * KIND, either express or implied. See the License for
>the 20 * specific language governing
permissions and limitations 21
* under the License. 22 * 23 */ 24 #include
25 #include
[14/51] [partial] qpid-site git commit: QPID-8250: Update for Qpid C++ 1.39.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/types_2ImportExport_8h_source.html
--
diff --git
a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/types_2ImportExport_8h_source.html
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/types_2ImportExport_8h_source.html
new file mode 100755
index 000..ad050dc
--- /dev/null
+++
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/types_2ImportExport_8h_source.html
@@ -0,0 +1,108 @@
+http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd";>
+http://www.w3.org/1999/xhtml";>
+
+
+
+
+
+Qpid C++ Messaging API: qpid/types/ImportExport.h Source File
+
+
+
+
+
+
+
+
+ $(document).ready(initResizable);
+
+
+
+
+
+ $(document).ready(function() { init_search(); });
+
+
+
+
+
+
+
+
+
+
+ Qpid C++ Messaging API
+ 1.39.0
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+var searchBox = new SearchBox("searchBox", "search",false,'Search');
+
+
+
+
+
+
+
+
+
+
+
+
+$(document).ready(function(){initNavTree('types_2ImportExport_8h_source.html','');});
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ImportExport.h
+
+
+1 #ifndef
QPID_TYPES_IMPORTEXPORT_H2 #define QPID_TYPES_IMPORTEXPORT_H
3 4 /*5 * Licensed to the Apache Software Foundation (ASF) under
one
6 * or more contributor license agreements.
See the NOTICE file7 * distributed with this
work for additional information8
* regarding copyright ownership. The ASF licenses this file9 * to you under the Apache License, Version 2.0
(the
10 * "License"); you may not use
this file except in compliance 11
* with the License. You may obtain a copy of the License at 12 * 13 *
http://www.apache.org/licenses/LICE
NSE-2.0 14 * 15 * Unless required by applicable law or agreed to in
writing, 16 * software distributed
under the License is distributed on an 17
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF
ANY
18 * KIND, either express or implied. See
the License for the 19 * specific language
governing permissions and limitations
20 * under the License. 21 */ 22 23 #include "qpid/ImportExport.h"
24 25 #if
defined(TYPES_EXPORT) || defined (qpidtypes_EXPORTS) 26 # define QPID_TYPES_EXTERN QPID_EXPORT 27 <
span class="preprocessor"># define QPID_TYPES_CLASS_EXTERN
QPID_CLASS_EXPORT 28 # define
QPID_TYPES_INLINE_EXTERN QPID_INLINE_EXPORT 29 #else 30 # define QPID_TYPES_EXTERN QPID_IMPORT 31 # define QPID_TYPES_CLASS_EXTERN
QPID_CLASS_IMPORT 32 # define
QPID_TYPES_INLINE_EXTERN QPID_INLINE_IMPORT 33 #endif
34 35 #endif
+
+
+
+
+qpidtypesImportExport.h
+Generated by
+http://www.doxygen.org/index.html";>
+ 1.8.13
+
+
+
+
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/examples/OptionParser.cpp
--
diff --git
a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/examples/OptionParser.cpp
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/examples/OptionParser.cpp
new file mode 100755
index 000..661d0a9
--- /dev/null
+++
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/examples/OptionParser.cpp
@@ -0,0 +1,257 @@
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ *
+ */
+#include "OptionParser.h"
+#include
+#include
+#include
+#include
+#include
+#include
+
+class Option
+{
+ public:
+Option(const std::string& name, const std::string& description);
+virtual ~Option() {}
+virtual void setValue(const std::string&) = 0;
+virtual bool isValueExpected() = 0;
+bool match(const std::string&);
+std::ostream& print(std::ostream& out);
+ private:
+std::string longName;
+std::string shortName;
+std::string description;
+std::ostream& printNames(std::ostream& out);
+ friend class OptionParser;
+};
+
+class StringOption : public Option
+{
+ public:
+StringOption(const std::strin
[18/51] [partial] qpid-site git commit: QPID-8250: Update for Qpid C++ 1.39.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1NotFound.html
--
diff --git
a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1NotFound.html
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1NotFound.html
new file mode 100755
index 000..c623545
--- /dev/null
+++
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1NotFound.html
@@ -0,0 +1,161 @@
+http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd";>
+http://www.w3.org/1999/xhtml";>
+
+
+
+
+
+Qpid C++ Messaging API: qpid::messaging::NotFound Struct
Reference
+
+
+
+
+
+
+
+
+ $(document).ready(initResizable);
+
+
+
+
+
+ $(document).ready(function() { init_search(); });
+
+
+
+
+
+
+
+
+
+
+ Qpid C++ Messaging API
+ 1.39.0
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+var searchBox = new SearchBox("searchBox", "search",false,'Search');
+
+
+
+
+
+
+
+
+
+
+
+
+$(document).ready(function(){initNavTree('structqpid_1_1messaging_1_1NotFound.html','');});
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+Public Member Functions |
+List of all
members
+
+qpid::messaging::NotFound Struct Reference
+
+
+
+#include
+
+Inheritance diagram for qpid::messaging::NotFound:
+
+
+
+
+
+
+
+
+
+
+
+
+
+Public Member Functions
+
+QPID_MESSAGING_EXTERN NotFound (const std::string &msg)
+
+ Public Member Functions inherited from qpid::messaging::ResolutionError
+
+QPID_MESSAGING_EXTERN ResolutionError (const std::string &msg)
+
+ Public Member Functions inherited from qpid::messaging::AddressError
+
+QPID_MESSAGING_EXTERN AddressError (const std::string &)
+
+ Public Member Functions inherited from qpid::messaging::LinkError
+
+QPID_MESSAGING_EXTERN LinkError (const std::string &)
+
+ Public Member Functions inherited from qpid::messaging::MessagingException
+
+QPID_MESSAGING_EXTERN MessagingException (const std::string &msg)
+
+ Public Member Functions inherited from qpid::types::Exception
+
+QPID_TYPES_EXTERN Exception (const std::string &message=std::string())
throw ()
+
+
+virtual QPID_TYPES_EXTERN const char * what () const throw ()
+
+
+Detailed
Description
+Thrown on attempts to create a sender or receiver to
a non-existent node.
+The documentation for this struct was generated from the following
file:
+qpid/messaging/exceptions.h
+
+
+
+
+
+
+qpidmessagingNotFound
+Generated by
+http://www.doxygen.org/index.html";>
+ 1.8.13
+
+
+
+
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1NotFound.js
--
diff --git
a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1NotFound.js
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1NotFound.js
new file mode 100755
index 000..8102c06
--- /dev/null
+++
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1NotFound.js
@@ -0,0 +1,4 @@
+var structqpid_1_1messaging_1_1NotFound =
+[
+[ "NotFound",
"structqpid_1_1messaging_1_1NotFound.html#a55cf97dbcff5a9003806952175473ace",
null ]
+];
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1NotFound.png
--
diff --git
a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1NotFound.png
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1NotFound.png
new file mode 100755
index 000..8c4ae75
Binary files /dev/null and
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1NotFound.png
differ
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1OutOfCapacity-members.html
--
diff --git
a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1OutOfCapacity-members.html
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1OutOfCapacity-members.html
new file mode 100755
index 000..b3e7471
--- /dev/null
+++
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1OutOfCapacity-members.html
@@ -0,0 +1,119 @@
+http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd";>
+http://www.w3.org/1999/xhtml";>
+
+
+
+
+
+Qpid C++ Messaging API: Member List
+
+
+
+
+
+
+
+
+ $(document).ready
[41/51] [partial] qpid-site git commit: QPID-8250: Update for Qpid C++ 1.39.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/book/ch01s13.html
--
diff --git a/content/releases/qpid-cpp-1.39.0/messaging-api/book/ch01s13.html
b/content/releases/qpid-cpp-1.39.0/messaging-api/book/ch01s13.html
new file mode 100644
index 000..3d4d0af
--- /dev/null
+++ b/content/releases/qpid-cpp-1.39.0/messaging-api/book/ch01s13.html
@@ -0,0 +1,165 @@
+
+
+http://www.w3.org/1999/xhtml"; xml:lang="en">
+
+1.13. Performance Tips - Apache Qpid™
+
+
+
+
+var _deferredFunctions = [];
+
+
+
+
+https://git-wip-us.apache.org/repos/asf/qpid-proton.git"/>
+https://github.com/apache/qpid-proton/blob/go1/README.md
+https://github.com/apache/qpid-proton/tree/go1{/dir}
+https://github.com/apache/qpid-proton/blob/go1{/dir}/{file}#L{line}"/>
+
+
+
+
+
+
+
+
+
+ Apache
Qpid™
+ Documentation
+ Download
+ Discussion
+
+
+
+
+
+
+Project
+
+
+ Overview
+ Components
+ Releases
+
+
+
+
+Messaging APIs
+
+
+ Qpid Proton
+ Qpid JMS
+ Qpid
Messaging API
+
+
+
+
+Servers and tools
+
+
+ Broker-J
+ C++
broker
+ Dispatch
router
+
+
+
+
+Resources
+
+
+ Dashboard
+ https://cwiki.apache.org/confluence/display/qpid/Index";>Wiki
+ More resources
+
+
+
+
+
+
+http://www.google.com/search"; method="get">
+
+
+ Search
+ More ways to search
+
+
+
+
+HomeReleasesQpid C++ 1.39.0Using the Qpid
Messaging API1.13. Performance Tips
+
+
+ 1.13. Performance TipsPrev Chapter 1. Using the Qpid Messaging
API Next1.13. Performance
TipsConsider prefetching messages for receivers
(see
+ Section 1.6, “Receiver Capacity
(Prefetch)”). This helps eliminate roundtrips
+ and increases throughput. Prefetch is disabled by default,
+ and enabling it is the most effective means of improving
+ throughput of received messages.Send messages asynchronously. Again, this helps
+ eliminate roundtrips and increases throughput. The C++ and
+ .NET clients send asynchronously by default, however the
+ python client defaults to synchronous sends. Acknowledge messages in batches (see
+ Section 1.7,
“Acknowledging Received Messages”). Rather than
+ acknowledging each message individually, consider issuing
+ acknowledgements after n messages and/or after a particular
+ duration has elapsed.Tune the
sender capacity (see
+ Section 1.5, “Sender Capacity and Replay”). If
the capacity is too low the
+ sender may block waiting for the broker to confirm receipt
+ of messages, before it can free up more capacity.If you are setting a reply-to address on messages
+ being sent by the c++ client, make sure the address type is
+ set to either queue or topic as appropriate. This avoids the
+ client having to determine which type of node is being
+ refered to, which is required when hanling reply-to in AMQP
+ 0-10. For latency sensitive
applications, setting tcp-nodelay
+ on qpidd and on client connections can help reduce the
+ latency.Prev Up Next1.12. The Request / Response Pattern Home 1.14. Cluster
Failover
+
+
+
+
+http://www.apache.org/";>Apache
+http://www.apache.org/licenses/";>License
+http://www.apache.org/foundation/sponsorship.html";>Sponsorship
+http://www.apache.org/foundation/thanks.html";>Thanks!
+Security
+http://www.apache.org/";>
+
+
+
+Apache Qpid, Messaging built on AMQP; Copyright © 2015
+The Apache Software Foundation; Licensed under
+the http://www.apache.org/licenses/LICENSE-2.0";>Apache
+License, Version 2.0; Apache Qpid, Qpid, Qpid Proton,
+Proton, Apache, the Apache feather logo, and the Apache Qpid
+project logo are trademarks of The Apache Software
+Foundation; All other marks mentioned may be trademarks or
+registered trademarks of their respective owners
+
+
+
+
+
+
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/book/ch01s14.html
--
diff --
[32/51] [partial] qpid-site git commit: QPID-8250: Update for Qpid C++ 1.39.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/classqpid_1_1messaging_1_1Message.html
--
diff --git
a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/classqpid_1_1messaging_1_1Message.html
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/classqpid_1_1messaging_1_1Message.html
new file mode 100755
index 000..b676942
--- /dev/null
+++
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/classqpid_1_1messaging_1_1Message.html
@@ -0,0 +1,643 @@
+http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd";>
+http://www.w3.org/1999/xhtml";>
+
+
+
+
+
+Qpid C++ Messaging API: qpid::messaging::Message Class Reference
+
+
+
+
+
+
+
+
+ $(document).ready(initResizable);
+
+
+
+
+
+ $(document).ready(function() { init_search(); });
+
+
+
+
+
+
+
+
+
+
+ Qpid C++ Messaging API
+ 1.39.0
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+var searchBox = new SearchBox("searchBox", "search",false,'Search');
+
+
+
+
+
+
+
+
+
+
+
+
+$(document).ready(function(){initNavTree('classqpid_1_1messaging_1_1Message.html','');});
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+Public Member Functions |
+Friends |
+List of all
members
+
+qpid::messaging::Message Class Reference
+
+
+
+#include
+
+
+Public Member Functions
+
+QPID_MESSAGING_EXTERN Message (qpid::types::Variant
&)
+
+
+QPID_MESSAGING_EXTERN Message (const std::string
&bytes=std::string())
+
+
+QPID_MESSAGING_EXTERN Message (const char *, size_t)
+
+
+QPID_MESSAGING_EXTERN Message (const Message &)
+
+
+QPID_MESSAGING_EXTERN Message & operator= (const Message &)
+
+
+QPID_MESSAGING_EXTERN void setReplyTo (const Address &)
+
+
+QPID_MESSAGING_EXTERN const Address & getReplyTo () const
+
+
+QPID_MESSAGING_EXTERN void setSubject (const std::string &)
+
+
+QPID_MESSAGING_EXTERN const std::string & getSubject () const
+
+QPID_MESSAGING_EXTERN void setContentType
(const std::string &)
+
+QPID_MESSAGING_EXTERN const std::string
& getContentType
() const
+
+QPID_MESSAGING_EXTERN void setMessageId
(const std::string &)
+
+
+QPID_MESSAGING_EXTERN const std::string & getMessageId () const
+
+QPID_MESSAGING_EXTERN void setUserId
(const std::string &)
+
+
+QPID_MESSAGING_EXTERN const std::string & getUserId () const
+
+QPID_MESSAGING_EXTERN void setCorrelationId
(const std::string &)
+
+
+QPID_MESSAGING_EXTERN const std::string & getCorrelationId () const
+
+QPID_MESSAGING_EXTERN void setPriority
(uint8_t)
+
+
+QPID_MESSAGING_EXTERN uint8_t getPriority () const
+
+QPID_MESSAGING_EXTERN void setTtl
(Duration
ttl)
+
+QPID_MESSAGING_EXTERN Duration getTtl
() const
+
+QPID_MESSAGING_EXTERN void setDurable
(bool durable)
+
+
+QPID_MESSAGING_EXTERN bool getDurable () const
+
+QPID_MESSAGING_EXTERN bool getRedelivered
() const
+
+QPID_MESSAGING_EXTERN void setRedelivered
(bool)
+
+QPID_MESSAGING_EXTERN const
qpid::types::Variant::Map & getProperties
() const
+
+
+QPID_MESSAGING_EXTERN qpid::types::Variant::Map & getProperties ()
+
+
+QPID_MESSAGING_EXTERN void setProperties (const qpid::types::Variant::Map
&)
+
+QPID_MESSAGING_EXTERN void setContent
(const std::string &)
+
+QPID_MESSAGING_EXTERN void setContent
(const char *chars, size_t count)
+
+QPID_MESSAGING_EXTERN std::string getContent
() const
+
+QPID_MESSAGING_EXTERN std::string getContentBytes
() const
+
+QPID_MESSAGING_EXTERN void setContentBytes
(const std::string &)
+
+QPID_MESSAGING_EXTERN qpid::types::Variant
& getContentObject
()
+
+QPID_MESSAGING_EXTERN const qpid::types::Variant
& getContentObject
() const
+
+QPID_MESSAGING_EXTERN void setContentObject
(const qpid::types::Variant
&)
+
+QPID_MESSAGING_EXTERN const char * getContentPtr
() const
+
+QPID_MESSAGING_EXTERN size_t getContentSize
() const
+
+
+QPID_MESSAGING_EXTERN void setProperty (const std::string &, const qpid::types::Variant
&)
+
+
+
+Friends
+
+struct MessageImplAccess
+
+
+Detailed
Description
+Representation of a message.
+Member Function Documentation
+
+◆ getContent()
+
+
+
+
+
+ QPID_MESSAGING_EXTERN std::string
qpid::messaging::Message::getContent
+ (
+ )
+ const
+
+
+
+Get the content as a std::string
+
+
+
+
+◆ getContentBytes()
+
+
+
+
+
+ QPID_MESSAGING_EXTERN std::string
qpid::messaging::Message::getContentBytes
+ (
+ )
+ const
+
+
+
+Get the content as raw bytes (an alias for getContent()
+
+
+
+
+◆ getContentObject()
[1/2]
+
+
+
+
+
+ QPID_MESSAGING_EXTERN qpid::types::Variant&
qpid::messaging::Message::getContentObject
+ (
+ )
+
+
+
+
+Get the content as a Variant, which can represent an object of differe
[13/51] [partial] qpid-site git commit: QPID-8250: Update for Qpid C++ 1.39.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/examples/client.cpp.html
--
diff --git
a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/examples/client.cpp.html
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/examples/client.cpp.html
new file mode 100644
index 000..9c50b93
--- /dev/null
+++
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/examples/client.cpp.html
@@ -0,0 +1,206 @@
+
+
+http://www.w3.org/1999/xhtml"; xml:lang="en">
+
+client.cpp - Apache Qpid™
+
+
+
+
+var _deferredFunctions = [];
+
+
+
+
+https://git-wip-us.apache.org/repos/asf/qpid-proton.git"/>
+https://github.com/apache/qpid-proton/blob/go1/README.md
+https://github.com/apache/qpid-proton/tree/go1{/dir}
+https://github.com/apache/qpid-proton/blob/go1{/dir}/{file}#L{line}"/>
+
+
+
+
+
+
+
+
+
+ Apache
Qpid™
+ Documentation
+ Download
+ Discussion
+
+
+
+
+
+
+Project
+
+
+ Overview
+ Components
+ Releases
+
+
+
+
+Messaging APIs
+
+
+ Qpid Proton
+ Qpid JMS
+ Qpid
Messaging API
+
+
+
+
+Servers and tools
+
+
+ Broker-J
+ C++
broker
+ Dispatch
router
+
+
+
+
+Resources
+
+
+ Dashboard
+ https://cwiki.apache.org/confluence/display/qpid/Index";>Wiki
+ More resources
+
+
+
+
+
+
+http://www.google.com/search"; method="get">
+
+
+ Search
+ More ways to search
+
+
+
+
+HomeReleasesQpid C++ 1.39.0C++
Messaging API Examplesclient.cpp
+
+
+
+client.cpp
+#include
+#include
+#include
+#include
+#include
+#include
+
+#include
+#include
+
+#include
+
+using namespace qpid::messaging;
+
+using std::stringstream;
+using std::string;
+
+int main(int argc, char** argv) {
+const char* url = argc>1 ? argv[1] : "amqp:tcp:127.0.0.1:5672";
+std::string connectionOptions = argc >
2 ? argv[2] : "";
+
+Connection connection(url, connectionOptions);
+ try {
+connection.open();
+Session session = connection.createSession();
+
+Sender sender = session.createSender("service_queue");
+
+//create temp queue & receiver...
+Receiver receiver = session.createReceiver("#");
+Address responseQueue
= receiver.getAddress();
+
+ // Now send some messages ...
+ string s[] = {
+"Twas brillig, and the slithy
toves",
+"Did gire and gymble in the
wabe.",
+"All mimsy were the
borogroves,",
+"And the mome raths outgrabe."
+};
+
+ Message request;
+request.setReplyTo(responseQueue);
+ for (int i=0; i<4; i++) {
+request.setContentObject(s[i]);
+sender.send(request);
+Message response
= receiver.fetch();
+std::cout << request.getContentObject() << " -> " << response.getContentObject() << std::endl;
+session.acknowledge(response);
+ }
+connection.close();
+return 0;
+} catch(const std::exception&
error) {
+std::cout << error.what() << std::endl;
+connection.close();
+}
+return 1;
+}
+
+
+Download this file
+
+
+
+
+
+http://www.apache.org/";>Apache
+http://www.apache.org/licenses/";>License
+http://www.apache.org/foundation/sponsorship.html";>Sponsorship
+http://www.apache.org/foundation/thanks.html";>Thanks!
+Security
+http://www.apache.org/";>
+
+
+
+Apache Qpid, Messaging built on AMQP; Copyright © 2015
+The Apache Software Foundation; Licensed under
+the http://www.apache.org/licenses/LICENSE-2.0";>Apache
+License, Version 2.0; Apache Qpid, Qpid, Qpid Proton,
+Proton, Apache, the Apache feather logo, and the Apache Qpid
+project logo are trademarks of The Apache Software
+Foundation; All other marks mentioned may be trademarks or
+registered trademarks of their respective owners
+
+
+
+
+
+
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/examp
[34/51] [partial] qpid-site git commit: QPID-8250: Update for Qpid C++ 1.39.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/classqpid_1_1messaging_1_1Address.html
--
diff --git
a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/classqpid_1_1messaging_1_1Address.html
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/classqpid_1_1messaging_1_1Address.html
new file mode 100755
index 000..e5bc85f
--- /dev/null
+++
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/classqpid_1_1messaging_1_1Address.html
@@ -0,0 +1,229 @@
+http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd";>
+http://www.w3.org/1999/xhtml";>
+
+
+
+
+
+Qpid C++ Messaging API: qpid::messaging::Address Class Reference
+
+
+
+
+
+
+
+
+ $(document).ready(initResizable);
+
+
+
+
+
+ $(document).ready(function() { init_search(); });
+
+
+
+
+
+
+
+
+
+
+ Qpid C++ Messaging API
+ 1.39.0
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+var searchBox = new SearchBox("searchBox", "search",false,'Search');
+
+
+
+
+
+
+
+
+
+
+
+
+$(document).ready(function(){initNavTree('classqpid_1_1messaging_1_1Address.html','');});
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+Public Member Functions |
+Friends |
+List of all
members
+
+qpid::messaging::Address Class Reference
+
+
+
+#include
+
+
+Public Member Functions
+
+QPID_MESSAGING_EXTERN Address (const std::string &address)
+
+
+QPID_MESSAGING_EXTERN Address (const std::string &name, const std::string
&subject, const qpid::types::Variant::Map &options, const std::string
&type="")
+
+
+QPID_MESSAGING_EXTERN Address (const Address
&address)
+
+
+QPID_MESSAGING_EXTERN Address & operator= (const Address &)
+
+
+QPID_MESSAGING_EXTERN const std::string & getName () const
+
+
+QPID_MESSAGING_EXTERN void setName (const std::string &)
+
+
+QPID_MESSAGING_EXTERN const std::string & getSubject () const
+
+
+QPID_MESSAGING_EXTERN void setSubject (const std::string &)
+
+
+QPID_MESSAGING_EXTERN const qpid::types::Variant::Map & getOptions () const
+
+
+QPID_MESSAGING_EXTERN qpid::types::Variant::Map & getOptions ()
+
+
+QPID_MESSAGING_EXTERN void setOptions (const qpid::types::Variant::Map
&)
+
+
+QPID_MESSAGING_EXTERN std::string getType () const
+
+QPID_MESSAGING_EXTERN void setType
(const std::string &)
+
+
+QPID_MESSAGING_EXTERN std::string str () const
+
+
+QPID_MESSAGING_EXTERN operator bool () const
+
+
+QPID_MESSAGING_EXTERN bool operator! () const
+
+
+
+Friends
+
+class AddressImpl
+
+
+Detailed
Description
+Represents an address to which messages can be sent
and from which messages can be received. Often a simple name is sufficient for
this, however this can be augmented with a subject pattern and options.
+All parts of an address can be specified in a string of the following
form:
+ [ / ] ; [ { : ,
... } ]
+Here the is a simple name for the addressed entity and
is a subject or subject pattern for messages sent to or
received from this address. The options are specified as a series of key value
pairs enclosed in curly brackets (denoting a map). Values can be nested maps,
or lists (which are denoted as a comma separated list of values inside square
brackets, e.g. [a, b, c]).
+The currently supported options are as follows:
+
+
+create Indicate whether the address should be
automatically created or not. Can be one of always, never,
sender or receiver. The properties of the node to be created
can be specified via the node options (see below).
+
+
+
+assert Indicate whether or not to assert any
specified node properties(see below) match the address. Can be one of
always, never, sender or receiver.
+
+
+
+delete Indicate whether or not to delete the
addressed node when a sender or receiver is cancelled. Can be one of
always, never, sender or receiver.
+
+
+
+node
+
+A nested map describing properties of the
addressed node. Current properties supported are type (topic or queue), durable
(boolean), x-declare and x-bindings. The x-declare option is a nested map in
whcih protocol amqp 0-10 specific options for queue or exchange declare can be
specified. The x-bindings option is a nested list, each element of which can
specify a queue, an exchange, a binding-key and arguments, which are used to
establish a binding on create. The node will be used if queue or exchange
values are not specified.
+
+
+
+link A nested map through which properties of
the 'link' from sender/receiver to node can be configured. Current propeties
are name, durable, realiability, x-declare, x-subscribe and x-bindings.
+For receivers there is one other option of interest:
+
+
+mode(only relevant for queues) indicates whether the subscribe
should consume (the default) or merely browse the messages. Valid values are
'consume' and 'browse'
[29/51] [partial] qpid-site git commit: QPID-8250: Update for Qpid C++ 1.39.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/classqpid_1_1types_1_1Uuid-members.html
--
diff --git
a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/classqpid_1_1types_1_1Uuid-members.html
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/classqpid_1_1types_1_1Uuid-members.html
new file mode 100755
index 000..b2ffd36
--- /dev/null
+++
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/classqpid_1_1types_1_1Uuid-members.html
@@ -0,0 +1,133 @@
+http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd";>
+http://www.w3.org/1999/xhtml";>
+
+
+
+
+
+Qpid C++ Messaging API: Member List
+
+
+
+
+
+
+
+
+ $(document).ready(initResizable);
+
+
+
+
+
+ $(document).ready(function() { init_search(); });
+
+
+
+
+
+
+
+
+
+
+ Qpid C++ Messaging API
+ 1.39.0
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+var searchBox = new SearchBox("searchBox", "search",false,'Search');
+
+
+
+
+
+
+
+
+
+
+
+
+$(document).ready(function(){initNavTree('classqpid_1_1types_1_1Uuid.html','');});
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+qpid::types::Uuid Member List
+
+
+
+This is the complete list of members for qpid::types::Uuid, including all
inherited members.
+
+ clear()qpid::types::Uuid
+ data() const (defined in qpid::types::Uuid)qpid::types::Uuid
+ generate()qpid::types::Uuid
+ hash()
constqpid::types::Uuid
+ isNull()
constqpid::types::Uuid
+ operator bool() const
(defined in qpid::types::Uuid)qpid::types::Uuid
+ operator!()
const (defined in qpid::types::Uuid)qpid::types::Uuid
+ operator!=(const
Uuid &, const Uuid &)qpid::types::Uuidfriend
+ operator<
(defined in qpid::types::Uuid)qpid::types::Uuidfriend
+ operator<<(std::ostream
&, Uuid)qpid::types::Uuidfriend
+ operator<=
(defined in qpid::types::Uuid)qpid::types::Uuidfriend
+ operator=(const Uuid &)
(defined in qpid::types::Uuid)qpid::types::Uuid
+ operator==(const
Uuid &, const Uuid &)qpid::types::Uuidfriend
+ operator> (defined in qpid::types::Uuid)qpid::types::Uuidfriend
+ operator>=
(defined in qpid::types::Uuid)qpid::types::Uuidfriend
+ operator>>(std::istream
&, Uuid &)qpid::types::Uuidfriend
+ size() const
(defined in qpid::types::Uuid)qpid::types::Uuid
+ SIZE (defined in qpid::types::Uuid)qpid::types::Uuidstatic
+ str()
constqpid::types::Uuid
+ Uuid(bool
unique=false)qpid::types::Uuid
+ Uuid(const Uuid
&) (defined in qpid::types::Uuid)qpid::types::Uuid
+ Uuid(const
unsigned char *data16)qpid::types::Uuid
+ Uuid(const char
*data16) (defined in qpid::types::Uuid)qpid::types::Uuid
+
+
+
+
+
+Generated by
+http://www.doxygen.org/index.html";>
+ 1.8.13
+
+
+
+
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/classqpid_1_1types_1_1Uuid.html
--
diff --git
a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/classqpid_1_1types_1_1Uuid.html
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/classqpid_1_1types_1_1Uuid.html
new file mode 100755
index 000..c232935
--- /dev/null
+++
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/classqpid_1_1types_1_1Uuid.html
@@ -0,0 +1,469 @@
+http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd";>
+http://www.w3.org/1999/xhtml";>
+
+
+
+
+
+Qpid C++ Messaging API: qpid::types::Uuid Class Reference
+
+
+
+
+
+
+
+
+ $(document).ready(initResizable);
+
+
+
+
+
+ $(document).ready(function() { init_search(); });
+
+
+
+
+
+
+
+
+
+
+ Qpid C++ Messaging API
+ 1.39.0
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+var searchBox = new SearchBox("searchBox", "search",false,'Search');
+
+
+
+
+
+
+
+
+
+
+
+
+$(document).ready(function(){initNavTree('classqpid_1_1types_1_1Uuid.html','');});
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+Classes |
+Public Member Functions |
+Static Public Attributes |
+Friends |
+List of all members
+
+qpid::types::Uuid Class Reference
+
+
+
+
+Classes
+struct
Hasher
+
+
+
+Public Member Functions
+QPID_TYPES_EXTERN Uuid
(bool unique=false)
+
+
+QPID_TYPES_EXTERN Uuid (const Uuid &)
+
+
+QPID_TYPES_EXTERN Uuid & operator= (const Uuid &)
+
+QPID_TYPES_EXTERN Uuid
(const unsigned char *data16)
+
+
+QPID_TYPES_EXTERN Uuid (const char *data16)
+
+QPID_TYPES_EXTERN void generate
()
+
+QPID_TYPES_EXTERN void clear
()
+
+QPID_TYPES_EXTERN bool isNull
() const
+
+
+QPID_TYPES_EXTERN operator bool () const
+
+
+QPID_TYPES_EXTERN bool operator! () const
+
+QPID_TYPES_EXTERN std::string str
() const
+
+
+QPID_TYPES_EXTERN size_t size () const
+
+
+QPID_TYPES_EXTERN const unsigned char * data () const
+
+QPID_TYPES_EXTERN size
[21/51] [partial] qpid-site git commit: QPID-8250: Update for Qpid C++ 1.39.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1AddressError.html
--
diff --git
a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1AddressError.html
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1AddressError.html
new file mode 100755
index 000..1f66b60
--- /dev/null
+++
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1AddressError.html
@@ -0,0 +1,151 @@
+http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd";>
+http://www.w3.org/1999/xhtml";>
+
+
+
+
+
+Qpid C++ Messaging API: qpid::messaging::AddressError Struct
Reference
+
+
+
+
+
+
+
+
+ $(document).ready(initResizable);
+
+
+
+
+
+ $(document).ready(function() { init_search(); });
+
+
+
+
+
+
+
+
+
+
+ Qpid C++ Messaging API
+ 1.39.0
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+var searchBox = new SearchBox("searchBox", "search",false,'Search');
+
+
+
+
+
+
+
+
+
+
+
+
+$(document).ready(function(){initNavTree('structqpid_1_1messaging_1_1AddressError.html','');});
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+Public Member Functions |
+List of all
members
+
+qpid::messaging::AddressError Struct Reference
+
+
+
+Inheritance diagram for qpid::messaging::AddressError:
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+Public Member Functions
+
+QPID_MESSAGING_EXTERN AddressError (const std::string &)
+
+ Public Member Functions inherited from qpid::messaging::LinkError
+
+QPID_MESSAGING_EXTERN LinkError (const std::string &)
+
+ Public Member Functions inherited from qpid::messaging::MessagingException
+
+QPID_MESSAGING_EXTERN MessagingException (const std::string &msg)
+
+ Public Member Functions inherited from qpid::types::Exception
+
+QPID_TYPES_EXTERN Exception (const std::string &message=std::string())
throw ()
+
+
+virtual QPID_TYPES_EXTERN const char * what () const throw ()
+
+
+The documentation for this struct was generated from the following
file:
+qpid/messaging/exceptions.h
+
+
+
+
+
+
+qpidmessagingAddressError
+Generated by
+http://www.doxygen.org/index.html";>
+ 1.8.13
+
+
+
+
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1AddressError.js
--
diff --git
a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1AddressError.js
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1AddressError.js
new file mode 100755
index 000..b460b80
--- /dev/null
+++
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1AddressError.js
@@ -0,0 +1,4 @@
+var structqpid_1_1messaging_1_1AddressError =
+[
+[ "AddressError",
"structqpid_1_1messaging_1_1AddressError.html#ae1636f6d53ca6c8303d8ee5caf578ee3",
null ]
+];
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1AddressError.png
--
diff --git
a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1AddressError.png
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1AddressError.png
new file mode 100755
index 000..7dd971c
Binary files /dev/null and
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1AddressError.png
differ
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1AssertionFailed-members.html
--
diff --git
a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1AssertionFailed-members.html
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1AssertionFailed-members.html
new file mode 100755
index 000..50652bd
--- /dev/null
+++
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/structqpid_1_1messaging_1_1AssertionFailed-members.html
@@ -0,0 +1,119 @@
+http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd";>
+http://www.w3.org/1999/xhtml";>
+
+
+
+
+
+Qpid C++ Messaging API: Member List
+
+
+
+
+
+
+
+
+ $(document).ready(initResizable);
+
+
+
+
+
+ $(document).ready(function() { init_search(); });
+
+
+
+
+
+
+
+
+
+
+ Qpid C++ Messaging API
+ 1.39.0
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+var searchBox = new SearchBox("searchBox", "s
[26/51] [partial] qpid-site git commit: QPID-8250: Update for Qpid C++ 1.39.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/functions.html
--
diff --git
a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/functions.html
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/functions.html
new file mode 100755
index 000..b1e4620
--- /dev/null
+++ b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/functions.html
@@ -0,0 +1,401 @@
+http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd";>
+http://www.w3.org/1999/xhtml";>
+
+
+
+
+
+Qpid C++ Messaging API: Class Members
+
+
+
+
+
+
+
+
+ $(document).ready(initResizable);
+
+
+
+
+
+ $(document).ready(function() { init_search(); });
+
+
+
+
+
+
+
+
+
+
+ Qpid C++ Messaging API
+ 1.39.0
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+var searchBox = new SearchBox("searchBox", "search",false,'Search');
+
+
+
+
+
+
+
+
+
+
+
+
+$(document).ready(function(){initNavTree('functions.html','');});
+
+
+
+
+
+
+
+
+
+
+
+
+
+Here is a list of all documented class members with
links to the class documentation for each member:
+
+- a -
+acknowledge()
+: qpid::messaging::Session
+
+acknowledgeUpTo()
+: qpid::messaging::Session
+
+
+
+
+- c -
+checkError()
+: qpid::messaging::Session
+
+clear()
+: qpid::types::Uuid
+
+close()
+: qpid::messaging::Connection
+, qpid::messaging::Receiver
+, qpid::messaging::Session
+
+commit()
+: qpid::messaging::Session
+
+configure()
+: qpid::messaging::Logger
+
+Connection()
+: qpid::messaging::Connection
+
+createReceiver()
+: qpid::messaging::Session
+
+createSender()
+: qpid::messaging::Session
+
+
+
+
+- d -
+described()
+: qpid::types::Variant
+
+
+
+
+- f -
+fetch()
+: qpid::messaging::Receiver
+
+
+
+
+- g -
+generate()
+: qpid::types::Uuid
+
+get()
+: qpid::messaging::Receiver
+
+getAddress()
+: qpid::messaging::Receiver
+, qpid::messaging::Sender
+
+getAvailable()
+: qpid::messaging::Receiver
+, qpid::messaging::Sender
+
+getCapacity()
+: qpid::messaging::Receiver
+, qpid::messaging::Sender
+
+getConnection()
+: qpid::messaging::Session
+
+getContent()
+: qpid::messaging::Message
+
+getContentBytes()
+: qpid::messaging::Message
+
+getContentObject()
+: qpid::messaging::Message
+
+getContentPtr()
+: qpid::messaging::Message
+
+getContentSize()
+: qpid::messaging::Message
+
+getContentType()
+: qpid::messaging::Message
+
+getDescriptor()
+: qpid::types::Variant
+
+getDescriptors()
+: qpid::types::Variant
+
+getName()
+: qpid::messaging::Receiver
+, qpid::messaging::Sender
+
+getProperties()
+: qpid::messaging::Message
+
+getReceivable()
+: qpid::messaging::Session
+
+getReceiver()
+: qpid::messaging::Session
+
+getRedelivered()
+: qpid::messaging::Message
+
+getSender()
+: qpid::messaging::Session
+
+getSession()
+: qpid::messaging::Receiver
+, qpid::messaging::Sender
+
+getString()
+: qpid::types::Variant
+
+getTtl()
+: qpid::messaging::Message
+
+getUnsettled()
+: qpid::messaging::Receiver
+, qpid::messaging::Sender
+
+getUnsettledAcks()
+: qpid::messaging::Session
+
+getUrl()
+: qpid::messaging::Connection
+
+
+
+
+- h -
+hasError()
+: qpid::messaging::Session
+
+hash()
+: qpid::types::Uuid
+
+
+
+
+- i -
+isClosed()
+: qpid::messaging::Receiver
+
+isDescribed()
+: qpid::types::Variant
+
+isNull()
+: qpid::messaging::Handle<
T >
+, qpid::types::Uuid
+
+isValid()
+: qpid::messaging::Handle<
T >
+
+
+
+
+- l -
+log()
+: qpid::messaging::Logger
+, qpid::messaging::LoggerOutput
+
+
+
+
+- n -
+nextReceiver()
+: qpid::messaging::Session
+
+
+
+
+- o -
+operator bool()
+: qpid::messaging::Handle<
T >
+
+operator!()
+: qpid::messaging::Handle<
T >
+
+operator!=
+: qpid::types::Uuid
+
+operator<<
+: qpid::types::Uuid
+
+operator==
+: qpid::types::Uuid
+
+operator>>
+: qpid::types::Uuid
+
+
+
+
+- p -
+parse()
+: qpid::types::Variant
+
+
+
+
+- r -
+reconnect()
+: qpid::messaging::Connection
+
+reject()
+: qpid::messaging::Session
+
+release()
+: qpid::messaging::Session
+
+reset()
+: qpid::types::Variant
+
+
+
+
+- s -
+send()
+: qpid::messaging::Sender
+
+setCapacity()
+: qpid::messaging::Receiver
+, qpid::messaging::Sender
+
+setContent()
+: qpid::messaging::Message
+
+setContentBytes()
+: qpid::messaging::Message
+
+setContentObject()
+: qpid::messaging::Message
+
+setContentType()
+: qpid::messaging::Message
+
+setCorrelationId()
+: qpid::messaging::Message
+
+setDescriptor()
+: qpid::types::Variant
+
+setDurable()
+: qpid::messaging::Message
+
+setMessageId()
+: qpid::messaging::Message
+
+setOutput()
+: qpid::messaging::Logger
+
+setPriority()
+: qpid::messaging::Message
+
+setRedelivered()
+: qpid::messaging::Message
+
+setTtl()
+: qpid::messaging::Message
+
+setType()
+: qpid::messaging::Address
+
+setUserId()
+: qpid::messaging::Message
+
+str()
+: qpid::types::Uuid
+
+sync()
+: qpid::messaging::Session
+
+
+
+
+- u -
+usage()
+: qpid::me
[30/51] [partial] qpid-site git commit: QPID-8250: Update for Qpid C++ 1.39.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/classqpid_1_1messaging_1_1Session-members.html
--
diff --git
a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/classqpid_1_1messaging_1_1Session-members.html
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/classqpid_1_1messaging_1_1Session-members.html
new file mode 100755
index 000..e39ba46
--- /dev/null
+++
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/classqpid_1_1messaging_1_1Session-members.html
@@ -0,0 +1,145 @@
+http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd";>
+http://www.w3.org/1999/xhtml";>
+
+
+
+
+
+Qpid C++ Messaging API: Member List
+
+
+
+
+
+
+
+
+ $(document).ready(initResizable);
+
+
+
+
+
+ $(document).ready(function() { init_search(); });
+
+
+
+
+
+
+
+
+
+
+ Qpid C++ Messaging API
+ 1.39.0
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+var searchBox = new SearchBox("searchBox", "search",false,'Search');
+
+
+
+
+
+
+
+
+
+
+
+
+$(document).ready(function(){initNavTree('classqpid_1_1messaging_1_1Session.html','');});
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+qpid::messaging::Session Member List
+
+
+
+This is the complete list of members for qpid::messaging::Session,
including all inherited members.
+
+ acknowledge(bool
sync=false)qpid::messaging::Session
+ acknowledge(Message
&, bool sync=false)qpid::messaging::Session
+ acknowledgeUpTo(Message
&, bool sync=false)qpid::messaging::Session
+ checkError()qpid::messaging::Session
+ close()qpid::messaging::Session
+ commit()qpid::messaging::Session
+ createReceiver(const
Address &address)qpid::messaging::Session
+ createReceiver(const
std::string &address)qpid::messaging::Session
+ createSender(const
Address &address)qpid::messaging::Session
+ createSender(const
std::string &address)qpid::messaging::Session
+ getConnection()
constqpid::messaging::Session
+ getReceivable()qpid::messaging::Session
+ getReceiver(const
std::string &name) constqpid::messaging::Session
+ getSender(const
std::string &name) constqpid::messaging::Session
+ getUnsettledAcks()qpid::messaging::Session
+ Handle() (defined in qpid::messaging::Handle<
SessionImpl >)qpid::messaging::Handle<
SessionImpl >inlineprotected
+ hasError()qpid::messaging::Session
+ Impl typedef (defined in qpid::messaging::Handle<
SessionImpl >)qpid::messaging::Handle<
SessionImpl >protected
+ impl (defined in
qpid::messaging::Handle<
SessionImpl >)qpid::messaging::Handle<
SessionImpl >protected
+ isNull()
constqpid::messaging::Handle<
SessionImpl >inline
+ isValid()
constqpid::messaging::Handle<
SessionImpl >inline
+ nextReceiver(Receiver
&, Duration timeout=Duration::FOREVER)qpid::messaging::Session
+ nextReceiver(Duration
timeout=Duration::FOREVER)qpid::messaging::Session
+ operator
bool() constqpid::messaging::Handle<
SessionImpl >inline
+ operator!()
constqpid::messaging::Handle<
SessionImpl >inline
+ operator=(const Session
&) (defined in qpid::messaging::Session)qpid::messaging::Session
+ qpid::messaging::PrivateImplRef< Session > (defined
in qpid::messaging::Session)qpid::messaging::Sessionfriend
+ reject(Message
&)qpid::messaging::Session
+ release(Message
&)qpid::messaging::Session
+ rollback() (defined in qpid::messaging::Session)qpid::messaging::Session
+ Session(SessionImpl *impl=0) (defined in qpid::messaging::Session)qpid::messaging::Session
+ Session(const Session &)
(defined in qpid::messaging::Session)qpid::messaging::Session
+ swap(Handle<
SessionImpl > &h) (defined in qpid::messaging::Handle<
SessionImpl >)qpid::messaging::Handle<
SessionImpl >inline
+ sync(bool
block=true)qpid::messaging::Session
+ ~Session()
(defined in qpid::messaging::Session)qpid::messaging::Session
+
+
+
+
+
+Generated by
+http://www.doxygen.org/index.html";>
+ 1.8.13
+
+
+
+
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/classqpid_1_1messaging_1_1Session.html
--
diff --git
a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/classqpid_1_1messaging_1_1Session.html
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/classqpid_1_1messaging_1_1Session.html
new file mode 100755
index 000..70778be
--- /dev/null
+++
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/classqpid_1_1messaging_1_1Session.html
@@ -0,0 +1,699 @@
+http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd";>
+http://www.w3.org/1999/xhtml";>
+
+
+
+
+
+Qpid C++ Messaging API: qpid::messaging::Session Class Reference
+
+
+
+
+
+
+
+
+ $(document).ready(initResizable);
+
+
+
+
+
+ $(document).ready(function() { init_search(); });
+
+
+
+
+
+
+
+
+
+
+ Qpid C++
[25/51] [partial] qpid-site git commit: QPID-8250: Update for Qpid C++ 1.39.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/jquery.js
--
diff --git a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/jquery.js
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/jquery.js
new file mode 100755
index 000..f5343ed
--- /dev/null
+++ b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/jquery.js
@@ -0,0 +1,87 @@
+/*!
+ * jQuery JavaScript Library v1.7.1
+ * http://jquery.com/
+ *
+ * Copyright 2011, John Resig
+ * Dual licensed under the MIT or GPL Version 2 licenses.
+ * http://jquery.org/license
+ *
+ * Includes Sizzle.js
+ * http://sizzlejs.com/
+ * Copyright 2011, The Dojo Foundation
+ * Released under the MIT, BSD, and GPL Licenses.
+ *
+ * Date: Mon Nov 21 21:11:03 2011 -0500
+ */
+(function(bb,L){var av=bb.document,bu=bb.navigator,bl=bb.location;var
b=(function(){var bF=function(b0,b1){return new
bF.fn.init(b0,b1,bD)},bU=bb.jQuery,bH=bb.$,bD,bY=/^(?:[^#<]*(<[\w\W]+>)[^>]*$|#([\w\-]*)$)/,bM=/\S/,bI=/^\s+/,bE=/\s+$/,bA=/^<(\w+)\s*\/?>(?:<\/\1>)?$/,bN=/^[\],:{}\s]*$/,bW=/\\(?:["\\\/bfnrt]|u[0-9a-fA-F]{4})/g,bP=/"[^"\\\n\r]*"|true|false|null|-?\d+(?:\.\d*)?(?:[eE][+\-]?\d+)?/g,bJ=/(?:^|:|,)(?:\s*\[)+/g,by=/(webkit)[
\/]([\w.]+)/,bR=/(opera)(?:.*version)?[ \/]([\w.]+)/,bQ=/(msie)
([\w.]+)/,bS=/(mozilla)(?:.*?
rv:([\w.]+))?/,bB=/-([a-z]|[0-9])/ig,bZ=/^-ms-/,bT=function(b0,b1){return(b1+"").toUpperCase()},bX=bu.userAgent,bV,bC,e,bL=Object.prototype.toString,bG=Object.prototype.hasOwnProperty,bz=Array.prototype.push,bK=Array.prototype.slice,bO=String.prototype.trim,bv=Array.prototype.indexOf,bx={};bF.fn=bF.prototype={constructor:bF,init:function(b0,b4,b3){var
b2,b5,b1,b6;if(!b0){return
this}if(b0.nodeType){this.context=this[0]=b0;this.length=1;return
this}if(b0==="bo
dy"&&!b4&&av.body){this.context=av;this[0]=av.body;this.selector=b0;this.length=1;return
this}if(typeof
b0==="string"){if(b0.charAt(0)==="<"&&b0.charAt(b0.length-1)===">"&&b0.length>=3){b2=[null,b0,null]}else{b2=bY.exec(b0)}if(b2&&(b2[1]||!b4)){if(b2[1]){b4=b4
instanceof
bF?b4[0]:b4;b6=(b4?b4.ownerDocument||b4:av);b1=bA.exec(b0);if(b1){if(bF.isPlainObject(b4)){b0=[av.createElement(b1[1])];bF.fn.attr.call(b0,b4,true)}else{b0=[b6.createElement(b1[1])]}}else{b1=bF.buildFragment([b2[1]],[b6]);b0=(b1.cacheable?bF.clone(b1.fragment):b1.fragment).childNodes}return
bF.merge(this,b0)}else{b5=av.getElementById(b2[2]);if(b5&&b5.parentNode){if(b5.id!==b2[2]){return
b3.find(b0)}this.length=1;this[0]=b5}this.context=av;this.selector=b0;return
this}}else{if(!b4||b4.jquery){return(b4||b3).find(b0)}else{return
this.constructor(b4).find(b0)}}}else{if(bF.isFunction(b0)){return
b3.ready(b0)}}if(b0.selector!==L){this.selector=b0.selector;this.context=b0.context}return
bF.makeArray(b0,this)},selector:"",
jquery:"1.7.1",length:0,size:function(){return
this.length},toArray:function(){return bK.call(this,0)},get:function(b0){return
b0==null?this.toArray():(b0<0?this[this.length+b0]:this[b0])},pushStack:function(b1,b3,b0){var
b2=this.constructor();if(bF.isArray(b1)){bz.apply(b2,b1)}else{bF.merge(b2,b1)}b2.prevObject=this;b2.context=this.context;if(b3==="find"){b2.selector=this.selector+(this.selector?"
":"")+b0}else{if(b3){b2.selector=this.selector+"."+b3+"("+b0+")"}}return
b2},each:function(b1,b0){return
bF.each(this,b1,b0)},ready:function(b0){bF.bindReady();bC.add(b0);return
this},eq:function(b0){b0=+b0;return
b0===-1?this.slice(b0):this.slice(b0,b0+1)},first:function(){return
this.eq(0)},last:function(){return this.eq(-1)},slice:function(){return
this.pushStack(bK.apply(this,arguments),"slice",bK.call(arguments).join(","))},map:function(b0){return
this.pushStack(bF.map(this,function(b2,b1){return
b0.call(b2,b1,b2)}))},end:function(){return
this.prevObject||this.constructor(null)},pus
h:bz,sort:[].sort,splice:[].splice};bF.fn.init.prototype=bF.fn;bF.extend=bF.fn.extend=function(){var
b9,b2,b0,b1,b6,b7,b5=arguments[0]||{},b4=1,b3=arguments.length,b8=false;if(typeof
b5==="boolean"){b8=b5;b5=arguments[1]||{};b4=2}if(typeof
b5!=="object"&&!bF.isFunction(b5)){b5={}}if(b3===b4){b5=this;--b4}for(;b40){return}bC.fireWit
h(av,[bF]);if(bF.fn.trigger){bF(av).trigger("ready").off("ready")}}},bindReady:function(){if(bC){return}bC=bF.Callbacks("once
memory");if(av.readyState==="complete"){return
setTimeout(bF.ready,1)}if(av.addEventListener){av.addEventListener("DOMContentLoaded",e,false);bb.addEventListener("load",bF.ready,false)}else{if(av.attachEvent){av.attachEvent("onreadystatechange",e);bb.attachEvent("onload",bF.ready);var
b0=false;try{b0=bb.frameElement==null}catch(b1){}if(av.documentElement.doScroll&&b0){bw(),isFunction:function(b0){return
bF.type(b0)==="function"},isArray:Array.isArray||function(b0){return
bF.type(b0)==="array"},isWindow:function(b0){return b0&&typeof
b0==="object"&&"setInterval" in b0},isNumeric:function(b0){return
!isNaN(par
[43/51] [partial] qpid-site git commit: QPID-8250: Update for Qpid C++ 1.39.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/cpp-broker/book/index.html
--
diff --git a/content/releases/qpid-cpp-1.39.0/cpp-broker/book/index.html
b/content/releases/qpid-cpp-1.39.0/cpp-broker/book/index.html
new file mode 100644
index 000..8b32dfa
--- /dev/null
+++ b/content/releases/qpid-cpp-1.39.0/cpp-broker/book/index.html
@@ -0,0 +1,251 @@
+
+
+http://www.w3.org/1999/xhtml"; xml:lang="en">
+
+AMQP Messaging Broker (Implemented in C++) - Apache
Qpid™
+
+
+
+
+var _deferredFunctions = [];
+
+
+
+
+https://git-wip-us.apache.org/repos/asf/qpid-proton.git"/>
+https://github.com/apache/qpid-proton/blob/go1/README.md
+https://github.com/apache/qpid-proton/tree/go1{/dir}
+https://github.com/apache/qpid-proton/blob/go1{/dir}/{file}#L{line}"/>
+
+
+
+
+
+
+
+
+
+ Apache
Qpid™
+ Documentation
+ Download
+ Discussion
+
+
+
+
+
+
+Project
+
+
+ Overview
+ Components
+ Releases
+
+
+
+
+Messaging APIs
+
+
+ Qpid Proton
+ Qpid JMS
+ Qpid
Messaging API
+
+
+
+
+Servers and tools
+
+
+ Broker-J
+ C++
broker
+ Dispatch
router
+
+
+
+
+Resources
+
+
+ Dashboard
+ https://cwiki.apache.org/confluence/display/qpid/Index";>Wiki
+ More resources
+
+
+
+
+
+
+http://www.google.com/search"; method="get">
+
+
+ Search
+ More ways to search
+
+
+
+
+HomeReleasesQpid C++ 1.39.0AMQP
Messaging Broker (Implemented in C++)
+
+
+ AMQP Messaging Broker (Implemented in C++) NextAMQP Messaging Broker (Implemented in
C++)Table of
ContentsIntroduction1.
+ Running the AMQP Messaging Broker
+1.1.
+Running a Qpid C++ Broker
+ 1.1.1.
+Building the
+C++ Broker and Client Libraries
+ 1.1.2.
+Running the C++ Broker
+ 1.1.3.
+Most
+common questions getting qpidd running
+ 1.1.4.
+Authentication
+ 1.1.5.
+Slightly more
+complex configuration
+ 1.1.6.
+Loading extra modules
+ 1.1.7. Timestamping Received
Messages1.1.8. Logging
Options1.2.
+ Cheat Sheet for configuring Queue Options
+1.2.1.
+Configuring
+Queue Options
+ 1.3.
+Cheat Sheet for configuring Exchange Options
+ 1.3.1.
+ Configuring Exchange Options
+1.4. Broker
Federation1.4.1.
Message Routes1.4.2.
Federation Topologies1.4.3.
Federation among High Availability Message Clusters1.4.4.
The qpid-route Utility1.4.5.
Broker options affecting federation1.5.
Security1.5.1.
User Authentication1.5.2.
Authorization1.5.3.
User Connection and Queue Quotas1.5.4.
Encryption using SSL<
dt>1.6. LVQ - Last Value
Queue1.6.1. Understanding
LVQ1.6.2. Creating a Last Value
Queue1.6.3. LVQ Example1.6.4. Deprecated LVQ
Modes1.7.
+Queue State Replication
+ 1.7.1.
+ Asynchronous
+ Replication of Queue State
+1.8.
+Producer Flow Control
+ 1.8.1.
+ Overview
+1.8.2.
+User Interface
+ 1.9.
+ AMQP compatibility
+1.9.1.
+AMQP
+Compatibility of Qpid releases:
+ 1.9.2.
+Interop
+table by AMQP specification version
+ 1.10.
Qpid Interoperability Documentation1.10.1.
+SASL
+ 1.11.
+Using Message Groups
+ 1.11.1.
+ Overview
+1.11.2.
+Grouping Messages
+ 1.11.3.
+The Role of the Broker
+ 1.11.4.
+Well Behaved Consumers
+ 1.11.5.
+Broker Configuration
+ 1.12. Active-Passive Messaging
Clusters1.12.1. Overview1.12.2. Virtual IP
Addresses1.12.3. Configuring the
Brokers1.12.4. The Cluster Resource
Manager1.12.5. Configuring with rgmanager as resource
manager1.12.6. Broker Administration
Tools1.12.7. Controlling replication of
queues and
exchanges1.12.8. Client Connection and
Fail-over1.12.9. Security and Access
Control.1.12.10. Integrating with other Cluster
Resource Managers1.12.11. Using a message store in a
cluster1.12.12. Troubleshooting a
cluster1.13. Replicating Queues with the HA
module1.13.1. Replicating
queues1.13.2. Replicating
queues between clusters2.
+ Managing the AMQP Messaging Broker
+2.1.
Managing the C++ Broker 2.1.1.
+Using qpid-c
[12/51] [partial] qpid-site git commit: QPID-8250: Update for Qpid C++ 1.39.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/examples/map_receiver.cpp.html
--
diff --git
a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/examples/map_receiver.cpp.html
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/examples/map_receiver.cpp.html
new file mode 100644
index 000..cc89bff
--- /dev/null
+++
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/examples/map_receiver.cpp.html
@@ -0,0 +1,186 @@
+
+
+http://www.w3.org/1999/xhtml"; xml:lang="en">
+
+map_receiver.cpp - Apache Qpid™
+
+
+
+
+var _deferredFunctions = [];
+
+
+
+
+https://git-wip-us.apache.org/repos/asf/qpid-proton.git"/>
+https://github.com/apache/qpid-proton/blob/go1/README.md
+https://github.com/apache/qpid-proton/tree/go1{/dir}
+https://github.com/apache/qpid-proton/blob/go1{/dir}/{file}#L{line}"/>
+
+
+
+
+
+
+
+
+
+ Apache
Qpid™
+ Documentation
+ Download
+ Discussion
+
+
+
+
+
+
+Project
+
+
+ Overview
+ Components
+ Releases
+
+
+
+
+Messaging APIs
+
+
+ Qpid Proton
+ Qpid JMS
+ Qpid
Messaging API
+
+
+
+
+Servers and tools
+
+
+ Broker-J
+ C++
broker
+ Dispatch
router
+
+
+
+
+Resources
+
+
+ Dashboard
+ https://cwiki.apache.org/confluence/display/qpid/Index";>Wiki
+ More resources
+
+
+
+
+
+
+http://www.google.com/search"; method="get">
+
+
+ Search
+ More ways to search
+
+
+
+
+HomeReleasesQpid C++ 1.39.0C++
Messaging API Examplesmap_receiver.cpp
+
+
+
+map_receiver.cpp
+#include
+#include
+#include
+#include
+
+#include
+#include
+
+#include
+
+using namespace qpid::messaging;
+using namespace qpid::types;
+
+using std::stringstream;
+using std::string;
+
+int main(int argc, char** argv) {
+const char* url = argc>1 ? argv[1] : "amqp:tcp:127.0.0.1:5672";
+const char* address =
argc>2
? argv[2] : "message_queue; {create:
always}";
+std::string connectionOptions = argc >
3 ? argv[3] : "";
+
+Connection connection(url, connectionOptions);
+try {
+connection.open();
+Session session = connection.createSession();
+Receiver receiver = session.createReceiver(address);
+std::cout << receiver.fetch().getContentObject() << std::endl;
+session.acknowledge();
+receiver.close();
+connection.close();
+return 0;
+} catch(const std::exception&
error) {
+std::cout << error.what() << std::endl;
+connection.close();
+}
+return 1;
+}
+
+
+Download this file
+
+
+
+
+
+http://www.apache.org/";>Apache
+http://www.apache.org/licenses/";>License
+http://www.apache.org/foundation/sponsorship.html";>Sponsorship
+http://www.apache.org/foundation/thanks.html";>Thanks!
+Security
+http://www.apache.org/";>
+
+
+
+Apache Qpid, Messaging built on AMQP; Copyright © 2015
+The Apache Software Foundation; Licensed under
+the http://www.apache.org/licenses/LICENSE-2.0";>Apache
+License, Version 2.0; Apache Qpid, Qpid, Qpid Proton,
+Proton, Apache, the Apache feather logo, and the Apache Qpid
+project logo are trademarks of The Apache Software
+Foundation; All other marks mentioned may be trademarks or
+registered trademarks of their respective owners
+
+
+
+
+
+
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/examples/map_sender.cpp
--
diff --git
a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/examples/map_sender.cpp
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/examples/map_sender.cpp
new file mode 100755
index 000..81ac732
--- /dev/null
+++ b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/examples/map_sender.cpp
@@ -0,0 +1,73 @@
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regard
[27/51] [partial] qpid-site git commit: QPID-8250: Update for Qpid C++ 1.39.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/doxygen.css
--
diff --git a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/doxygen.css
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/doxygen.css
new file mode 100755
index 000..4f1ab91
--- /dev/null
+++ b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/doxygen.css
@@ -0,0 +1,1596 @@
+/* The standard CSS for doxygen 1.8.13 */
+
+body, table, div, p, dl {
+ font: 400 14px/22px Roboto,sans-serif;
+}
+
+p.reference, p.definition {
+ font: 400 14px/22px Roboto,sans-serif;
+}
+
+/* @group Heading Levels */
+
+h1.groupheader {
+ font-size: 150%;
+}
+
+.title {
+ font: 400 14px/28px Roboto,sans-serif;
+ font-size: 150%;
+ font-weight: bold;
+ margin: 10px 2px;
+}
+
+h2.groupheader {
+ border-bottom: 1px solid #879ECB;
+ color: #354C7B;
+ font-size: 150%;
+ font-weight: normal;
+ margin-top: 1.75em;
+ padding-top: 8px;
+ padding-bottom: 4px;
+ width: 100%;
+}
+
+h3.groupheader {
+ font-size: 100%;
+}
+
+h1, h2, h3, h4, h5, h6 {
+ -webkit-transition: text-shadow 0.5s linear;
+ -moz-transition: text-shadow 0.5s linear;
+ -ms-transition: text-shadow 0.5s linear;
+ -o-transition: text-shadow 0.5s linear;
+ transition: text-shadow 0.5s linear;
+ margin-right: 15px;
+}
+
+h1.glow, h2.glow, h3.glow, h4.glow, h5.glow, h6.glow {
+ text-shadow: 0 0 15px cyan;
+}
+
+dt {
+ font-weight: bold;
+}
+
+div.multicol {
+ -moz-column-gap: 1em;
+ -webkit-column-gap: 1em;
+ -moz-column-count: 3;
+ -webkit-column-count: 3;
+}
+
+p.startli, p.startdd {
+ margin-top: 2px;
+}
+
+p.starttd {
+ margin-top: 0px;
+}
+
+p.endli {
+ margin-bottom: 0px;
+}
+
+p.enddd {
+ margin-bottom: 4px;
+}
+
+p.endtd {
+ margin-bottom: 2px;
+}
+
+/* @end */
+
+caption {
+ font-weight: bold;
+}
+
+span.legend {
+font-size: 70%;
+text-align: center;
+}
+
+h3.version {
+font-size: 90%;
+text-align: center;
+}
+
+div.qindex, div.navtab{
+ background-color: #EBEFF6;
+ border: 1px solid #A3B4D7;
+ text-align: center;
+}
+
+div.qindex, div.navpath {
+ width: 100%;
+ line-height: 140%;
+}
+
+div.navtab {
+ margin-right: 15px;
+}
+
+/* @group Link Styling */
+
+a {
+ color: #3D578C;
+ font-weight: normal;
+ text-decoration: none;
+}
+
+.contents a:visited {
+ color: #4665A2;
+}
+
+a:hover {
+ text-decoration: underline;
+}
+
+a.qindex {
+ font-weight: bold;
+}
+
+a.qindexHL {
+ font-weight: bold;
+ background-color: #9CAFD4;
+ color: #ff;
+ border: 1px double #869DCA;
+}
+
+.contents a.qindexHL:visited {
+color: #ff;
+}
+
+a.el {
+ font-weight: bold;
+}
+
+a.elRef {
+}
+
+a.code, a.code:visited, a.line, a.line:visited {
+ color: #4665A2;
+}
+
+a.codeRef, a.codeRef:visited, a.lineRef, a.lineRef:visited {
+ color: #4665A2;
+}
+
+/* @end */
+
+dl.el {
+ margin-left: -1cm;
+}
+
+pre.fragment {
+border: 1px solid #C4CFE5;
+background-color: #FBFCFD;
+padding: 4px 6px;
+margin: 4px 8px 4px 2px;
+overflow: auto;
+word-wrap: break-word;
+font-size: 9pt;
+line-height: 125%;
+font-family: monospace, fixed;
+font-size: 105%;
+}
+
+div.fragment {
+padding: 0px;
+margin: 4px 8px 4px 2px;
+ background-color: #FBFCFD;
+ border: 1px solid #C4CFE5;
+}
+
+div.line {
+ font-family: monospace, fixed;
+font-size: 13px;
+ min-height: 13px;
+ line-height: 1.0;
+ text-wrap: unrestricted;
+ white-space: -moz-pre-wrap; /* Moz */
+ white-space: -pre-wrap; /* Opera 4-6 */
+ white-space: -o-pre-wrap; /* Opera 7 */
+ white-space: pre-wrap; /* CSS3 */
+ word-wrap: break-word; /* IE 5.5+ */
+ text-indent: -53px;
+ padding-left: 53px;
+ padding-bottom: 0px;
+ margin: 0px;
+ -webkit-transition-property: background-color, box-shadow;
+ -webkit-transition-duration: 0.5s;
+ -moz-transition-property: background-color, box-shadow;
+ -moz-transition-duration: 0.5s;
+ -ms-transition-property: background-color, box-shadow;
+ -ms-transition-duration: 0.5s;
+ -o-transition-property: background-color, box-shadow;
+ -o-transition-duration: 0.5s;
+ transition-property: background-color, box-shadow;
+ transition-duration: 0.5s;
+}
+
+div.line:after {
+content:"\000A";
+white-space: pre;
+}
+
+div.line.glow {
+ background-color: cyan;
+ box-shadow: 0 0 10px cyan;
+}
+
+
+span.lineno {
+ padding-right: 4px;
+ text-align: right;
+ bor
[28/51] [partial] qpid-site git commit: QPID-8250: Update for Qpid C++ 1.39.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/classqpid_1_1types_1_1Variant.html
--
diff --git
a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/classqpid_1_1types_1_1Variant.html
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/classqpid_1_1types_1_1Variant.html
new file mode 100755
index 000..0beebb6
--- /dev/null
+++
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/classqpid_1_1types_1_1Variant.html
@@ -0,0 +1,601 @@
+http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd";>
+http://www.w3.org/1999/xhtml";>
+
+
+
+
+
+Qpid C++ Messaging API: qpid::types::Variant Class Reference
+
+
+
+
+
+
+
+
+ $(document).ready(initResizable);
+
+
+
+
+
+ $(document).ready(function() { init_search(); });
+
+
+
+
+
+
+
+
+
+
+ Qpid C++ Messaging API
+ 1.39.0
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+var searchBox = new SearchBox("searchBox", "search",false,'Search');
+
+
+
+
+
+
+
+
+
+
+
+
+$(document).ready(function(){initNavTree('classqpid_1_1types_1_1Variant.html','');});
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+Public Types |
+Public Member Functions |
+Static Public Member Functions |
+List of all members
+
+qpid::types::Variant Class Reference
+
+
+
+#include
+
+
+Public Types
+
+typedef std::map< std::string, Variant > Map
+
+
+typedef std::list< Variant > List
+
+
+
+Public Member Functions
+
+QPID_TYPES_EXTERN Variant (bool)
+
+
+QPID_TYPES_EXTERN Variant (uint8_t)
+
+
+QPID_TYPES_EXTERN Variant (uint16_t)
+
+
+QPID_TYPES_EXTERN Variant (uint32_t)
+
+
+QPID_TYPES_EXTERN Variant (uint64_t)
+
+
+QPID_TYPES_EXTERN Variant (int8_t)
+
+
+QPID_TYPES_EXTERN Variant (int16_t)
+
+
+QPID_TYPES_EXTERN Variant (int32_t)
+
+
+QPID_TYPES_EXTERN Variant (int64_t)
+
+
+QPID_TYPES_EXTERN Variant (float)
+
+
+QPID_TYPES_EXTERN Variant (double)
+
+
+QPID_TYPES_EXTERN Variant (const std::string &)
+
+
+QPID_TYPES_EXTERN Variant (const std::string &value, const std::string
&encoding)
+
+
+QPID_TYPES_EXTERN Variant (const char *)
+
+
+QPID_TYPES_EXTERN Variant (const char *value, const char
*encoding)
+
+
+QPID_TYPES_EXTERN Variant (const Map &)
+
+
+QPID_TYPES_EXTERN Variant (const List &)
+
+
+QPID_TYPES_EXTERN Variant (const Variant &)
+
+
+QPID_TYPES_EXTERN Variant (const Uuid &)
+
+
+QPID_TYPES_EXTERN VariantType getType () const
+
+
+QPID_TYPES_EXTERN bool isVoid () const
+
+
+QPID_TYPES_EXTERN Variant & operator= (bool)
+
+
+QPID_TYPES_EXTERN Variant & operator= (uint8_t)
+
+
+QPID_TYPES_EXTERN Variant & operator= (uint16_t)
+
+
+QPID_TYPES_EXTERN Variant & operator= (uint32_t)
+
+
+QPID_TYPES_EXTERN Variant & operator= (uint64_t)
+
+
+QPID_TYPES_EXTERN Variant & operator= (int8_t)
+
+
+QPID_TYPES_EXTERN Variant & operator= (int16_t)
+
+
+QPID_TYPES_EXTERN Variant & operator= (int32_t)
+
+
+QPID_TYPES_EXTERN Variant & operator= (int64_t)
+
+
+QPID_TYPES_EXTERN Variant & operator= (float)
+
+
+QPID_TYPES_EXTERN Variant & operator= (double)
+
+
+QPID_TYPES_EXTERN Variant & operator= (const std::string
&)
+
+
+QPID_TYPES_EXTERN Variant & operator= (const char *)
+
+
+QPID_TYPES_EXTERN Variant & operator= (const Map
&)
+
+
+QPID_TYPES_EXTERN Variant & operator= (const List
&)
+
+
+QPID_TYPES_EXTERN Variant & operator= (const Variant &)
+
+
+QPID_TYPES_EXTERN Variant & operator= (const Uuid &)
+
+QPID_TYPES_EXTERN Variant & parse
(const std::string &)
+
+
+QPID_TYPES_EXTERN bool asBool () const
+
+
+QPID_TYPES_EXTERN uint8_t asUint8 () const
+
+
+QPID_TYPES_EXTERN uint16_t asUint16 () const
+
+
+QPID_TYPES_EXTERN uint32_t asUint32 () const
+
+
+QPID_TYPES_EXTERN uint64_t asUint64 () const
+
+
+QPID_TYPES_EXTERN int8_t asInt8 () const
+
+
+QPID_TYPES_EXTERN int16_t asInt16 () const
+
+
+QPID_TYPES_EXTERN int32_t asInt32 () const
+
+
+QPID_TYPES_EXTERN int64_t asInt64 () const
+
+
+QPID_TYPES_EXTERN float asFloat () const
+
+
+QPID_TYPES_EXTERN double asDouble () const
+
+
+QPID_TYPES_EXTERN std::string asString () const
+
+
+QPID_TYPES_EXTERN Uuid asUuid () const
+
+
+QPID_TYPES_EXTERN operator bool () const
+
+
+QPID_TYPES_EXTERN operator uint8_t () const
+
+
+QPID_TYPES_EXTERN operator uint16_t () const
+
+
+QPID_TYPES_EXTERN operator uint32_t () const
+
+
+QPID_TYPES_EXTERN operator uint64_t () const
+
+
+QPID_TYPES_EXTERN operator int8_t () const
+
+
+QPID_TYPES_EXTERN operator int16_t () const
+
+
+QPID_TYPES_EXTERN operator int32_t () const
+
+
+QPID_TYPES_EXTERN operator int64_t () const
+
+
+QPID_TYPES_EXTERN operator float () const
+
+
+QPID_TYPES_EXTERN operator double () const
+
+
+QPID_TYPES_EXTERN operator std::string () const
+
+
+QPID_TYPES_EXTERN operator Uuid () const
+
+
+QPID_TYPES_EXTERN const Map & asMap () const
+
+
+QPID_TYPES_EXTERN Map & asMap
[31/51] [partial] qpid-site git commit: QPID-8250: Update for Qpid C++ 1.39.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/classqpid_1_1messaging_1_1Receiver.html
--
diff --git
a/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/classqpid_1_1messaging_1_1Receiver.html
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/classqpid_1_1messaging_1_1Receiver.html
new file mode 100755
index 000..ca89320
--- /dev/null
+++
b/content/releases/qpid-cpp-1.39.0/messaging-api/cpp/api/classqpid_1_1messaging_1_1Receiver.html
@@ -0,0 +1,469 @@
+http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd";>
+http://www.w3.org/1999/xhtml";>
+
+
+
+
+
+Qpid C++ Messaging API: qpid::messaging::Receiver Class
Reference
+
+
+
+
+
+
+
+
+ $(document).ready(initResizable);
+
+
+
+
+
+ $(document).ready(function() { init_search(); });
+
+
+
+
+
+
+
+
+
+
+ Qpid C++ Messaging API
+ 1.39.0
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+var searchBox = new SearchBox("searchBox", "search",false,'Search');
+
+
+
+
+
+
+
+
+
+
+
+
+$(document).ready(function(){initNavTree('classqpid_1_1messaging_1_1Receiver.html','');});
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+Public Member Functions |
+Friends |
+List of all
members
+
+qpid::messaging::Receiver Class Reference
+
+
+
+#include
+
+Inheritance diagram for qpid::messaging::Receiver:
+
+
+
+
+
+
+
+
+
+Public Member Functions
+
+QPID_MESSAGING_EXTERN Receiver (ReceiverImpl *impl=0)
+
+
+QPID_MESSAGING_EXTERN Receiver (const Receiver &)
+
+
+QPID_MESSAGING_EXTERN Receiver & operator= (const Receiver &)
+
+QPID_MESSAGING_EXTERN bool get
(Message
&message, Duration
timeout=Duration::FOREVER)
+
+QPID_MESSAGING_EXTERN Message get
(Duration
timeout=Duration::FOREVER)
+
+QPID_MESSAGING_EXTERN bool fetch
(Message
&message, Duration
timeout=Duration::FOREVER)
+
+QPID_MESSAGING_EXTERN Message fetch
(Duration
timeout=Duration::FOREVER)
+
+QPID_MESSAGING_EXTERN void setCapacity
(uint32_t)
+
+QPID_MESSAGING_EXTERN uint32_t getCapacity
()
+
+QPID_MESSAGING_EXTERN uint32_t getAvailable
()
+
+QPID_MESSAGING_EXTERN uint32_t getUnsettled
()
+
+QPID_MESSAGING_EXTERN void close
()
+
+QPID_MESSAGING_EXTERN bool isClosed
() const
+
+QPID_MESSAGING_EXTERN const std::string
& getName
() const
+
+QPID_MESSAGING_EXTERN Session getSession
() const
+
+QPID_MESSAGING_EXTERN Address getAddress
() const
+
+ Public Member Functions inherited from qpid::messaging::Handle<
ReceiverImpl >
+QPID_MESSAGING_INLINE_EXTERN bool isValid
() const
+
+QPID_MESSAGING_INLINE_EXTERN bool isNull
() const
+
+QPID_MESSAGING_INLINE_EXTERN operator
bool () const
+
+QPID_MESSAGING_INLINE_EXTERN bool operator!
() const
+
+
+void swap (Handle<
ReceiverImpl > &h)
+
+
+
+Friends
+
+class qpid::messaging::PrivateImplRef< Receiver
>
+
+
+
+Additional Inherited Members
+ Protected Types inherited from qpid::messaging::Handle<
ReceiverImpl >
+
+typedef ReceiverImpl Impl
+
+ Protected Attributes inherited from qpid::messaging::Handle<
ReceiverImpl >
+
+Impl * impl
+
+
+Detailed
Description
+Interface through which messages are received.
+Member Function Documentation
+
+◆ close()
+
+
+
+
+
+ QPID_MESSAGING_EXTERN void
qpid::messaging::Receiver::close
+ (
+ )
+
+
+
+
+Cancels this Receiver.
+
+
+
+
+◆ fetch() [1/2]
+
+
+
+
+
+ QPID_MESSAGING_EXTERN bool
qpid::messaging::Receiver::fetch
+ (
+ Message &
+ message,
+
+
+
+
+ Duration
+ timeout =
Duration::FOREVER
+
+
+
+ )
+
+
+
+
+Retrieves a message from this Receiver's subscription or
waits for up to the specified timeout for one to become available. Unlike get(),
this method will check with the server that there is no message for the
subscription this receiver is serving before returning false.
+Returnsfalse if there is no message
available after waiting for the specified time period, or if the receiver is
closed, in which case isClosed()
will be true.
+
+
+
+
+◆ fetch() [2/2]
+
+
+
+
+
+ QPID_MESSAGING_EXTERN Message
qpid::messaging::Receiver::fetch
+ (
+ Duration
+ timeout =
Duration::FOREVER)
+
+
+
+
+Retrieves a message for this Receiver's subscription or
waits for up to the specified timeout for one to become available. Unlike get(),
this method will check with the server that there is no message for the
subscription this receiver is serving before throwing an exception.
+Exceptions
+
+NoMessageAvailableif
there is no message available after waiting for the specified timeout, or if
the Receiver
is closed, in which
[39/51] [partial] qpid-site git commit: QPID-8250: Update for Qpid C++ 1.39.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/book/prefetch.html
--
diff --git a/content/releases/qpid-cpp-1.39.0/messaging-api/book/prefetch.html
b/content/releases/qpid-cpp-1.39.0/messaging-api/book/prefetch.html
new file mode 100644
index 000..0ffde16
--- /dev/null
+++ b/content/releases/qpid-cpp-1.39.0/messaging-api/book/prefetch.html
@@ -0,0 +1,152 @@
+
+
+http://www.w3.org/1999/xhtml"; xml:lang="en">
+
+1.6. Receiver Capacity (Prefetch) - Apache Qpid™
+
+
+
+
+var _deferredFunctions = [];
+
+
+
+
+https://git-wip-us.apache.org/repos/asf/qpid-proton.git"/>
+https://github.com/apache/qpid-proton/blob/go1/README.md
+https://github.com/apache/qpid-proton/tree/go1{/dir}
+https://github.com/apache/qpid-proton/blob/go1{/dir}/{file}#L{line}"/>
+
+
+
+
+
+
+
+
+
+ Apache
Qpid™
+ Documentation
+ Download
+ Discussion
+
+
+
+
+
+
+Project
+
+
+ Overview
+ Components
+ Releases
+
+
+
+
+Messaging APIs
+
+
+ Qpid Proton
+ Qpid JMS
+ Qpid
Messaging API
+
+
+
+
+Servers and tools
+
+
+ Broker-J
+ C++
broker
+ Dispatch
router
+
+
+
+
+Resources
+
+
+ Dashboard
+ https://cwiki.apache.org/confluence/display/qpid/Index";>Wiki
+ More resources
+
+
+
+
+
+
+http://www.google.com/search"; method="get">
+
+
+ Search
+ More ways to search
+
+
+
+
+HomeReleasesQpid C++ 1.39.0Using the Qpid
Messaging API1.6. Receiver Capacity (Prefetch)
+
+
+ 1.6. Receiver Capacity (Prefetch)Prev Chapter 1. Using the Qpid Messaging API Next1.6. Receiver Capacity
(Prefetch)By default, a receiver requests the next
message from the
+ server in response to each fetch call, resulting in messages being
+ sent to the receiver one at a time. As in the case of sending, it
+ is often desirable to avoid this roundtrip for each message. This
+ can be achieved by allowing the receiver
+ to prefetch messages in anticipation of
+ fetch calls being made. The receiver needs to be able to store
+ these prefetched messages, the number it can hold is controlled by
+ the receivers capacity.Prev Up Next1.5. Sender Capacity and Replay Home 1.7. Acknowledging Received
Messages
+
+
+
+
+http://www.apache.org/";>Apache
+http://www.apache.org/licenses/";>License
+http://www.apache.org/foundation/sponsorship.html";>Sponsorship
+http://www.apache.org/foundation/thanks.html";>Thanks!
+Security
+http://www.apache.org/";>
+
+
+
+Apache Qpid, Messaging built on AMQP; Copyright © 2015
+The Apache Software Foundation; Licensed under
+the http://www.apache.org/licenses/LICENSE-2.0";>Apache
+License, Version 2.0; Apache Qpid, Qpid, Qpid Proton,
+Proton, Apache, the Apache feather logo, and the Apache Qpid
+project logo are trademarks of The Apache Software
+Foundation; All other marks mentioned may be trademarks or
+registered trademarks of their respective owners
+
+
+
+
+
+
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/book/replay.html
--
diff --git a/content/releases/qpid-cpp-1.39.0/messaging-api/book/replay.html
b/content/releases/qpid-cpp-1.39.0/messaging-api/book/replay.html
new file mode 100644
index 000..ee5f5ec
--- /dev/null
+++ b/content/releases/qpid-cpp-1.39.0/messaging-api/book/replay.html
@@ -0,0 +1,168 @@
+
+
+http://www.w3.org/1999/xhtml"; xml:lang="en">
+
+1.5. Sender Capacity and Replay - Apache Qpid™
+
+
+
+
+var _deferredFunctions = [];
+
+
+
+
+https://git-wip-us.apache.org/repos/asf/qpid-proton.git"/>
+https://github.com/apache/qpid-proton/blob/go1/README.md
+https://github.com/apache/qpid-proton/tree/go1{/dir}
+https://github.com/apache/qpid-proton/blob/go1{/dir}/{file}#L{line}"/>
+
+
+
+
+
+
+
+
+
+ Apache
Qpid™
+ Documentation
+ Download
+ Discussion
+
+
+
+
+
+
+Project
+
+
+ Overview
[38/51] [partial] qpid-site git commit: QPID-8250: Update for Qpid C++ 1.39.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/book/section-amqp0-10-mapping.html
--
diff --git
a/content/releases/qpid-cpp-1.39.0/messaging-api/book/section-amqp0-10-mapping.html
b/content/releases/qpid-cpp-1.39.0/messaging-api/book/section-amqp0-10-mapping.html
new file mode 100644
index 000..14e59ec
--- /dev/null
+++
b/content/releases/qpid-cpp-1.39.0/messaging-api/book/section-amqp0-10-mapping.html
@@ -0,0 +1,307 @@
+
+
+http://www.w3.org/1999/xhtml"; xml:lang="en">
+
+1.16. The AMQP 0-10 mapping - Apache Qpid™
+
+
+
+
+var _deferredFunctions = [];
+
+
+
+
+https://git-wip-us.apache.org/repos/asf/qpid-proton.git"/>
+https://github.com/apache/qpid-proton/blob/go1/README.md
+https://github.com/apache/qpid-proton/tree/go1{/dir}
+https://github.com/apache/qpid-proton/blob/go1{/dir}/{file}#L{line}"/>
+
+
+
+
+
+
+
+
+
+ Apache
Qpid™
+ Documentation
+ Download
+ Discussion
+
+
+
+
+
+
+Project
+
+
+ Overview
+ Components
+ Releases
+
+
+
+
+Messaging APIs
+
+
+ Qpid Proton
+ Qpid JMS
+ Qpid
Messaging API
+
+
+
+
+Servers and tools
+
+
+ Broker-J
+ C++
broker
+ Dispatch
router
+
+
+
+
+Resources
+
+
+ Dashboard
+ https://cwiki.apache.org/confluence/display/qpid/Index";>Wiki
+ More resources
+
+
+
+
+
+
+http://www.google.com/search"; method="get">
+
+
+ Search
+ More ways to search
+
+
+
+
+HomeReleasesQpid C++ 1.39.0Using the Qpid
Messaging API1.16. The AMQP 0-10 mapping
+
+
+ 1.16. The AMQP 0-10 mappingPrev Chapter 1. Using the Qpid Messaging
API Next1.16. The AMQP 0-10
mapping
+ This section describes the AMQP 0-10 mapping for the Qpid
+ Messaging API.
+
+The interaction with the broker triggered by creating a sender
+or receiver depends on what the specified address resolves
+to. Where the node type is not specified in the address, the
+client queries the broker to determine whether it refers to a
+queue or an exchange.
+
+When sending to a queue, the queue's name is set as the
+routing key and the message is transfered to the default (or
+nameless) exchange. When sending to an exchange, the message
+is transfered to that exchange and the routing key is set to
+the message subject if one is specified. A default subject may
+be specified in the target address. The subject may also be
+set on each message individually to override the default if
+required. In each case any specified subject is also added as
+a qpid.subject entry in the application-headers field of the
+message-properties.
+
+When receiving from a queue, any subject in the source address
+is currently ignored. The client sends a message-subscribe
+request for the queue in question. The accept-mode is
+determined by the reliability option in the link properties;
+for unreliable links the accept-mode is none, for reliable
+links it is explicit. The default for a queue is reliable. The
+acquire-mode is determined by the value of the mode option. If
+the mode is set to browse the acquire mode is not-acquired,
+otherwise it is set to pre-acquired. The exclusive and
+arguments fields in the message-subscribe command can be
+controlled using the x-subscribe map.
+
+When receiving from an exchange, the client creates a
+subscription queue and binds that to the exchange. The
+subscription queue's arguments can be specified using the
+x-declare map within the link properties. The reliability
+option determines most of the other parameters. If the
+reliability is set to unreliable then an auto-deleted,
+exclusive queue is used meaning that if the client or
+connection fails messages may be lost. For exactly-once the
+queue is not set to be auto-deleted. The durability of the
+subscription queue is determined by the durable option in the
+link properties. The binding process depends on the type of
+the exchange the source address resolves to.
+
+For a topic exchange, if no subject is specified and no
+x-bindings are defin
[42/51] [partial] qpid-site git commit: QPID-8250: Update for Qpid C++ 1.39.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/book/Message-Groups-Guide.html
--
diff --git
a/content/releases/qpid-cpp-1.39.0/messaging-api/book/Message-Groups-Guide.html
b/content/releases/qpid-cpp-1.39.0/messaging-api/book/Message-Groups-Guide.html
new file mode 100644
index 000..5552917
--- /dev/null
+++
b/content/releases/qpid-cpp-1.39.0/messaging-api/book/Message-Groups-Guide.html
@@ -0,0 +1,242 @@
+
+
+http://www.w3.org/1999/xhtml"; xml:lang="en">
+
+1.17. Using Message Groups - Apache Qpid™
+
+
+
+
+var _deferredFunctions = [];
+
+
+
+
+https://git-wip-us.apache.org/repos/asf/qpid-proton.git"/>
+https://github.com/apache/qpid-proton/blob/go1/README.md
+https://github.com/apache/qpid-proton/tree/go1{/dir}
+https://github.com/apache/qpid-proton/blob/go1{/dir}/{file}#L{line}"/>
+
+
+
+
+
+
+
+
+
+ Apache
Qpid™
+ Documentation
+ Download
+ Discussion
+
+
+
+
+
+
+Project
+
+
+ Overview
+ Components
+ Releases
+
+
+
+
+Messaging APIs
+
+
+ Qpid Proton
+ Qpid JMS
+ Qpid
Messaging API
+
+
+
+
+Servers and tools
+
+
+ Broker-J
+ C++
broker
+ Dispatch
router
+
+
+
+
+Resources
+
+
+ Dashboard
+ https://cwiki.apache.org/confluence/display/qpid/Index";>Wiki
+ More resources
+
+
+
+
+
+
+http://www.google.com/search"; method="get">
+
+
+ Search
+ More ways to search
+
+
+
+
+HomeReleasesQpid C++ 1.39.0Using the Qpid
Messaging API1.17. Using Message Groups
+
+
+ 1.17. Using Message GroupsPrev Chapter 1. Using the Qpid Messaging API Next1.17. Using Message
Groups
+This section describes how messaging applications can use the Message
Group feature
+provided by the Broker.
+ Note
+The content of this section assumes the reader is familiar with the
Message Group
+feature as described in the AMQP Messaging Broker user's guide. Please
read the
+message grouping section in the Broker user's guide before using the
+examples given in this section.
+ 1.17.1. Creating Message
Group Queues
+ The following examples show how to create a message group queue that
enforces
+ ordered group consumption across multiple consumers.
+Example 1.22. Message Group Queue Creation -
Python
+sender = connection.session().sender("msg-group-q;" +
+ " {create:always, delete:receiver," +
+ " node: {x-declare: {arguments:" +
+ " {'qpid.group_header_key':'THE-GROUP'," +
+ " 'qpid.shared_msg_group':1")
+ Example 1.23. Message Group Queue Creation -
C++
+std::string addr("msg-group-q; "
+ " {create:always, delete:receiver,"
+ " node: {x-declare: {arguments:"
+ " {qpid.group_header_key:'THE-GROUP',"
+ " qpid.shared_msg_group:1");
+Sender sender = session.createSender(addr);
+ Example 1.24. Message Group Queue Creation -
Java
+Session s = c.createSession(false, Session.CLIENT_ACKNOWLEDGE);
+String addr = "msg-group-q; {create:always, delete:receiver," +
+ " node: {x-declare: {arguments:" +
+ " {'qpid.group_header_key':'THE-GROUP'," +
+ " 'qpid.shared_msg_group':1";
+Destination d = (Destination) new AMQAnyDestination(addr);
+MessageProducer sender = s.createProducer(d);
+
+ The example code uses the x-declare map to specify the message group
configuration
+ that should be used for the queue. See the AMQP Messaging Broker user's
guide
+ for a detailed description of these arguments. Note that the
+ qpid.group_header_key's value MUST be a string type if using the C++
broker.
+1.17.2. Sending Grouped
Messages
+ When sending grouped messages, the client must add a message property
containing the
+ group identifier to the outgoing message. If using the C++ broker, the
group identifier
+ must be a string type. The key used for the property must exactly match
the value passed in the
+ 'qpid.group_header_key' configuration argument.
+Example 1.25. Sending Grouped Messages -
Python
+group = "A"
+m = Message(content="some data", properties={"THE-GROUP": group})
+sender.s
[40/51] [partial] qpid-site git commit: QPID-8250: Update for Qpid C++ 1.39.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/c3ab60f6/content/releases/qpid-cpp-1.39.0/messaging-api/book/ch02s03.html
--
diff --git a/content/releases/qpid-cpp-1.39.0/messaging-api/book/ch02s03.html
b/content/releases/qpid-cpp-1.39.0/messaging-api/book/ch02s03.html
new file mode 100644
index 000..47b8aa5
--- /dev/null
+++ b/content/releases/qpid-cpp-1.39.0/messaging-api/book/ch02s03.html
@@ -0,0 +1,182 @@
+
+
+http://www.w3.org/1999/xhtml"; xml:lang="en">
+
+2.3. .NET Binding Class Mapping to Underlying C++ Messaging
API - Apache Qpid™
+
+
+
+
+var _deferredFunctions = [];
+
+
+
+
+https://git-wip-us.apache.org/repos/asf/qpid-proton.git"/>
+https://github.com/apache/qpid-proton/blob/go1/README.md
+https://github.com/apache/qpid-proton/tree/go1{/dir}
+https://github.com/apache/qpid-proton/blob/go1{/dir}/{file}#L{line}"/>
+
+
+
+
+
+
+
+
+
+ Apache
Qpid™
+ Documentation
+ Download
+ Discussion
+
+
+
+
+
+
+Project
+
+
+ Overview
+ Components
+ Releases
+
+
+
+
+Messaging APIs
+
+
+ Qpid Proton
+ Qpid JMS
+ Qpid
Messaging API
+
+
+
+
+Servers and tools
+
+
+ Broker-J
+ C++
broker
+ Dispatch
router
+
+
+
+
+Resources
+
+
+ Dashboard
+ https://cwiki.apache.org/confluence/display/qpid/Index";>Wiki
+ More resources
+
+
+
+
+
+
+http://www.google.com/search"; method="get">
+
+
+ Search
+ More ways to search
+
+
+
+
+HomeReleasesQpid C++ 1.39.0Using the Qpid
Messaging API2.3. .NET Binding Class Mapping to Underlying
C++ Messaging API
+
+
+ 2.3. .NET Binding Class Mapping to Underlying C++ Messaging
APIPrev Chapter 2. The .NET Binding for the C++ Messaging
Client 2.3. .NET Binding Class
Mapping to Underlying C++ Messaging APIThis chapter
describes the specific mappings between
+ classes in the .NET Binding and the underlying C++ Messaging
+ API.2.3.1. .NET Binding for the
C++ Messaging API Class: AddressTable 2.9. .NET Binding for the C++ Messaging
API Class: Address.NET Binding Class:
AddressLanguageSyntaxC++class
Address.NETpublic ref class
AddressConstructorC++Address();.NETpublic
Address();ConstructorC++Address(const std::string&
address);.NETpublic Address(string
address);ConstructorC++Address(const
std::string& name, const std::string& subject, const
qpid::types::Variant::Map& options, const std::string& type =
"");.NETpublic Address(string name, string subject,
Dictionary options);.NETpublic
Address(string name, string subject, Dictionary options,
string type);Copy
constructorC++Address(const Address&
address);.NETpublic Address(Address
address);DestructorC++~Address();.NET~Address();FinalizerC++n/a.NET!Address();align="center" colspan="2">Copy assignment
>operatorC++Address& operator=(const
>Address&);.NETpublic Address op_Assign(Address
>rhs);Property:
>NameC++const std::string& getName()
>const;C++void setName(const
>std::string&);.NETpublic string Name { get;
>set; }Property:
>SubjectC++const std::string& getSubject()
>const;C++void setSubject(const
>std::string&);.NETpublic string Subject { get;
>set; }Property:
>OptionsC++const qpid::types::Variant::Map&
>getOptions() const;C++qpid::types::Variant::
Map& getOptions();C++void setOptions(const
qpid::types::Variant::Map&);.NETpublic
Dictionary Options { get; set; }Property:
TypeC++std::string getType()
const;C++void setType(const
std::string&);.NETpublic string Type { get; set;
}MiscellaneousC++std::string str()
const;.NETpublic string ToStr();MiscellaneousC++operator
bool() const;.NETn/aMiscellaneousC++bool operator !()
const;.NETn/a2.3.2. .NET Binding for the C++ Messaging API
Class: ConnectionTable 2.10. .NET Binding for the C++ Messaging
API Class: Connection.NET Binding Class:
ConnectionLanguageSyntaxC++class
Connection : public
qpid::messaging::Handle.NETpublic
ref class ConnectionConstructorC++Connection(ConnectionImpl*
impl);.NETn/aConstructorC++Connection();.NETn/aConstructorC++Connection(const
std::string& url, const qpid::types::Variant::Map& options =
qpid::types::Variant::Map());.NETpublic
Connection(string url);.NETpublic Connection(string
url, Dictionary options);ConstructorC++Connection(const
std::string& url, const std::string&
options);.NETpublic Connection(string ur
[qpid-dispatch] Git Push Summary
Repository: qpid-dispatch Updated Tags: refs/tags/1.4.1 [created] 9dbd7b17e - To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org
svn commit: r30507 - /release/qpid/dispatch/1.4.1/
Author: gmurthy Date: Tue Oct 30 00:17:10 2018 New Revision: 30507 Log: add files for qpid-dispatch-1.4.1 Added: release/qpid/dispatch/1.4.1/ - copied from r30506, dev/qpid/dispatch/1.4.1-rc3/ - To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org
