qpid-jms git commit: QPIDJMS-237 Ensure that executor threads shutdown quickly
Repository: qpid-jms Updated Branches: refs/heads/master affc435d0 -> a26b7791b QPIDJMS-237 Ensure that executor threads shutdown quickly Ensure that the scheduled executors shutdown in a timely manner when the connections are closed. Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/a26b7791 Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/a26b7791 Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/a26b7791 Branch: refs/heads/master Commit: a26b7791b85c277dcd1f6d63679e96db5e03e4d3 Parents: affc435 Author: Timothy BishAuthored: Tue Dec 13 18:34:57 2016 -0500 Committer: Timothy Bish Committed: Tue Dec 13 18:34:57 2016 -0500 -- .../qpid/jms/provider/amqp/AmqpProvider.java| 33 +++- .../jms/provider/failover/FailoverProvider.java | 17 ++ .../qpid/jms/provider/mock/MockProvider.java| 13 +--- 3 files changed, 45 insertions(+), 18 deletions(-) -- http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/a26b7791/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpProvider.java -- diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpProvider.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpProvider.java index 10f98cd..b59859b 100644 --- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpProvider.java +++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpProvider.java @@ -19,10 +19,10 @@ package org.apache.qpid.jms.provider.amqp; import java.io.IOException; import java.net.URI; import java.nio.ByteBuffer; -import java.util.concurrent.Executors; import java.util.concurrent.Future; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.ScheduledFuture; +import java.util.concurrent.ScheduledThreadPoolExecutor; import java.util.concurrent.ThreadFactory; import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicBoolean; @@ -101,12 +101,13 @@ public class AmqpProvider implements Provider, TransportListener , AmqpResourceP private static final AtomicInteger PROVIDER_SEQUENCE = new AtomicInteger(); private static final NoOpAsyncResult NOOP_REQUEST = new NoOpAsyncResult(); -private ProviderListener listener; +private volatile ProviderListener listener; private AmqpConnection connection; -private volatile AmqpSaslAuthenticator authenticator; -private org.apache.qpid.jms.transports.Transport transport; +private AmqpSaslAuthenticator authenticator; +private volatile org.apache.qpid.jms.transports.Transport transport; private String transportType = AmqpProviderFactory.DEFAULT_TRANSPORT_TYPE; private String vhost; +private String threadToken; private boolean traceFrames; private boolean traceBytes; private boolean saslLayer = true; @@ -120,7 +121,7 @@ public class AmqpProvider implements Provider, TransportListener , AmqpResourceP private final URI remoteURI; private final AtomicBoolean closed = new AtomicBoolean(); -private final ScheduledExecutorService serializer; +private ScheduledThreadPoolExecutor serializer; private final Transport protonTransport = Transport.Factory.create(); private final Collector protonCollector = new CollectorImpl(); private final Connection protonConnection = Connection.Factory.create(); @@ -136,7 +137,8 @@ public class AmqpProvider implements Provider, TransportListener , AmqpResourceP */ public AmqpProvider(URI remoteURI) { this.remoteURI = remoteURI; -this.serializer = Executors.newSingleThreadScheduledExecutor(new ThreadFactory() { + +serializer = new ScheduledThreadPoolExecutor(1, new ThreadFactory() { @Override public Thread newThread(Runnable runner) { @@ -149,6 +151,9 @@ public class AmqpProvider implements Provider, TransportListener , AmqpResourceP } }); +serializer.setExecuteExistingDelayedTasksAfterShutdownPolicy(false); +serializer.setContinueExistingPeriodicTasksAfterShutdownPolicy(false); + updateTracer(); } @@ -290,7 +295,7 @@ public class AmqpProvider implements Provider, TransportListener , AmqpResourceP } } } finally { -ThreadPoolUtils.shutdown(serializer); +ThreadPoolUtils.shutdownGraceful(serializer); } } } @@ -1218,6 +1223,20 @@ public class AmqpProvider implements Provider, TransportListener , AmqpResourceP } /** + * @return the threadToken +
svn commit: r17382 - /release/qpid/cpp/1.36.0/
Author: robbie Date: Tue Dec 13 18:29:00 2016 New Revision: 17382 Log: add files for qpid-cpp-1.36.0 Added: release/qpid/cpp/1.36.0/ - copied from r17381, dev/qpid/cpp/1.36.0-rc1/ - To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org
[qpid-cpp] Git Push Summary
Repository: qpid-cpp Updated Tags: refs/tags/1.36.0 [created] cf213ec22 - To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org
[16/51] [partial] qpid-site git commit: PROTON-1374: update the website for Proton 0.16.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/releases/qpid-proton-0.16.0/proton/c/api/group__messenger.html -- diff --git a/content/releases/qpid-proton-0.16.0/proton/c/api/group__messenger.html b/content/releases/qpid-proton-0.16.0/proton/c/api/group__messenger.html new file mode 100755 index 000..1964731 --- /dev/null +++ b/content/releases/qpid-proton-0.16.0/proton/c/api/group__messenger.html @@ -0,0 +1,2495 @@ +http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd;> +http://www.w3.org/1999/xhtml;> + + + + +Qpid Proton C API: Messenger + + + + + + + + $(document).ready(initResizable); + $(window).load(resizeHeight); + + + + + $(document).ready(function() { searchBox.OnSelectItem(0); }); + + + + + + + + + + + Qpid Proton C API + 0.16.0 + + + + + + + + + + + + + + + + + + +var searchBox = new SearchBox("searchBox", "search",false,'Search'); + + + + + + + + + + + + +$(document).ready(function(){initNavTree('group__messenger.html','');}); + + + + +AllClassesFilesFunctionsVariablesTypedefsEnumerationsEnumeratorGroupsPages + + + + + + + + + +Macros +Typedefs +Enumerations +Functions + +Messenger + + + +Deprecated - The Messenger API +More... + + +Macros + +#definePN_CUMULATIVE +Indicates that an accept or reject should operate cumulatively. + + +#definePN_FLAGS_CHECK_ROUTES +Messenger flag to indicate that a call \ to pn_messenger_start should check that \ any defined routes are valid. + + +#definePN_FLAGS_ALLOW_INSECURE_MECHS +Messenger flag to indicate that the PLAIN \ mechanism is allowed on an unencrypted \ connection. + + + +Typedefs +typedef struct pn_messenger_tpn_messenger_t +A pn_messenger_t provides a high level interface for sending and receiving messages (See pn_message_t). More... + +typedef struct pn_subscription_tpn_subscription_t +A subscription is a request for incoming messages. More... + + +typedef int64_tpn_tracker_t +Trackers provide a lightweight handle used to track the status of incoming and outgoing deliveries. + + + +Enumerations +enum pn_status_t { +PN_STATUS_UNKNOWN, +PN_STATUS_PENDING, +PN_STATUS_ACCEPTED, +PN_STATUS_REJECTED, + +PN_STATUS_RELEASED, +PN_STATUS_MODIFIED, +PN_STATUS_ABORTED, +PN_STATUS_SETTLED + + } +Describes all the possible states for a message associated with a given tracker. More... + + + +Functions +pn_messenger_t *pn_messenger (const char *name) +Construct a new pn_messenger_t with the given name. More... + +const char *pn_messenger_name (pn_messenger_t *messenger) +Get the name of a messenger. More... + +intpn_messenger_set_certificate (pn_messenger_t *messenger, const char *certificate) +Sets the path that will be used to get the certificate that will be used to identify this messenger to its peers. More... + +const char *pn_messenger_get_certificate (pn_messenger_t *messenger) +Get the certificate path. More... + +intpn_messenger_set_private_key (pn_messenger_t *messenger, const char *private_key) +Set path to the private key that was used to sign the certificate. More... + +const char *pn_messenger_get_private_key (pn_messenger_t *messenger) +Gets the private key file for a messenger. More... + +intpn_messenger_set_password (pn_messenger_t *messenger, const char *password) +Sets the private key password for a messenger. More... + +const char *pn_messenger_get_password (pn_messenger_t *messenger) +Gets the private key file password for a messenger. More... + +intpn_messenger_set_trusted_certificates (pn_messenger_t *messenger, const char *cert_db) +Sets the trusted certificates database for a messenger. More... + +const char *pn_messenger_get_trusted_certificates (pn_messenger_t *messenger) +Gets the trusted certificates database for a messenger. More... + +intpn_messenger_set_timeout (pn_messenger_t *messenger, int timeout) +Set the default timeout for a messenger. More... + +intpn_messenger_get_timeout (pn_messenger_t *messenger) +Gets the timeout for a messenger object. More... + +boolpn_messenger_is_blocking (pn_messenger_t *messenger) +Check if a messenger is in blocking mode. More... + +intpn_messenger_set_blocking (pn_messenger_t *messenger, bool blocking) +Enable or disable blocking behavior for a messenger during calls to pn_messenger_send and pn_messenger_recv. More... + +boolpn_messenger_is_passive (pn_messenger_t *messenger) +Check if a messenger is in passive mode. More... + +intpn_messenger_set_passive (pn_messenger_t *messenger, bool passive) +Set the passive mode for a messenger. More... + +voidpn_messenger_free (pn_messenger_t *messenger) +Frees a Messenger. More... + +intpn_messenger_errno (pn_messenger_t *messenger) +Get the code for a messenger's most recent error. More... + +pn_error_t
[07/51] [partial] qpid-site git commit: PROTON-1374: update the website for Proton 0.16.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/releases/qpid-proton-0.16.0/proton/c/api/link_8h_source.html -- diff --git a/content/releases/qpid-proton-0.16.0/proton/c/api/link_8h_source.html b/content/releases/qpid-proton-0.16.0/proton/c/api/link_8h_source.html new file mode 100755 index 000..6dd21ac --- /dev/null +++ b/content/releases/qpid-proton-0.16.0/proton/c/api/link_8h_source.html @@ -0,0 +1,261 @@ +http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd;> +http://www.w3.org/1999/xhtml;> + + + + +Qpid Proton C API: proton/link.h Source File + + + + + + + + $(document).ready(initResizable); + $(window).load(resizeHeight); + + + + + $(document).ready(function() { searchBox.OnSelectItem(0); }); + + + + + + + + + + + Qpid Proton C API + 0.16.0 + + + + + + + + + + + + + + + + + + +var searchBox = new SearchBox("searchBox", "search",false,'Search'); + + + + + + + + + + + + +$(document).ready(function(){initNavTree('link_8h_source.html','');}); + + + + +AllClassesFilesFunctionsVariablesTypedefsEnumerationsEnumeratorGroupsPages + + + + + + + + + +link.h + + +Go to the documentation of this file. 1#ifndef PROTON_LINK_H + 2#define PROTON_LINK_H 1 + 3 + 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 information + 9 * 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 proton/import_export.h + 26#include proton/type_compat.h + 27#include proton/condition.h + 28#include proton/terminus.h + 29#include proton/types.h + 30#include proton/object.h + 31#include stddef.h + 32 + 33#ifdef __cplusplus + 34extern C { + 35#endif + 36 + 58PN_EXTERN pn_link_t *pn_sender(pn_session_t *session, const char *name); + 59 + 72PN_EXTERN pn_link_t *pn_receiver(pn_session_t *session, const char *name); + 73 + 83PN_EXTERN void pn_link_free(pn_link_t *link); + 84 + 96PN_EXTERN void *pn_link_get_context(pn_link_t *link); + 97 + 109PN_EXTERN void pn_link_set_context(pn_link_t *link, void *context); + 110 + 117PN_EXTERN pn_record_t *pn_link_attachments(pn_link_t *link); + 118 + 125PN_EXTERN const char *pn_link_name(pn_link_t *link); + 126 + 133PN_EXTERN bool pn_link_is_sender(pn_link_t *link); + 134 + 141PN_EXTERN bool pn_link_is_receiver(pn_link_t *link); + 142 + 149PN_EXTERN pn_state_t pn_link_state(pn_link_t *link); + 150 + 167PN_EXTERN pn_error_t *pn_link_error(pn_link_t *link); + 168 + 185PN_EXTERN pn_condition_t *pn_link_condition(pn_link_t *link); + 186 + 201PN_EXTERN pn_condition_t *pn_link_remote_condition(pn_link_t *link); + 202 + 212PN_EXTERN pn_session_t *pn_link_session(pn_link_t *link); + 213 + 229PN_EXTERN pn_link_t *pn_link_head(pn_connection_t *connection, pn_state_t state); + 230 + 244PN_EXTERN pn_link_t *pn_link_next(pn_link_t *link, pn_state_t state); + 245 + 254PN_EXTERN void pn_link_open(pn_link_t *link); + 255 + 266PN_EXTERN void pn_link_close(pn_link_t *link); + 267 + 273PN_EXTERN void pn_link_detach(pn_link_t *link); + 274 + 284PN_EXTERN pn_terminus_t *pn_link_source(pn_link_t *link); + 285 + 295PN_EXTERN pn_terminus_t *pn_link_target(pn_link_t *link); + 296 + 308PN_EXTERN pn_terminus_t *pn_link_remote_source(pn_link_t *link); + 309 + 321PN_EXTERN pn_terminus_t *pn_link_remote_target(pn_link_t *link); + 322 + 338PN_EXTERN pn_delivery_t *pn_link_current(pn_link_t *link); + 339 + 364PN_EXTERN bool pn_link_advance(pn_link_t *link); + 365 + 389PN_EXTERN int pn_link_credit(pn_link_t *link); + 390 + 403PN_EXTERN int pn_link_queued(pn_link_t *link); + 404 + 416PN_EXTERN int pn_link_remote_credit(pn_link_t *link); + 417 + 430PN_EXTERN bool pn_link_get_drain(pn_link_t *link); + 431 + 451PN_EXTERN int pn_link_drained(pn_link_t *link); + 452 + 464PN_EXTERN int pn_link_available(pn_link_t *link); + 465 + 474typedef enum { + 475 PN_SND_UNSETTLED = 0, + 477
[04/51] [partial] qpid-site git commit: PROTON-1374: update the website for Proton 0.16.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/releases/qpid-proton-0.16.0/proton/c/api/messenger_8h.html -- diff --git a/content/releases/qpid-proton-0.16.0/proton/c/api/messenger_8h.html b/content/releases/qpid-proton-0.16.0/proton/c/api/messenger_8h.html new file mode 100755 index 000..8d91d92 --- /dev/null +++ b/content/releases/qpid-proton-0.16.0/proton/c/api/messenger_8h.html @@ -0,0 +1,360 @@ +http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd;> +http://www.w3.org/1999/xhtml;> + + + + +Qpid Proton C API: proton/messenger.h File Reference + + + + + + + + $(document).ready(initResizable); + $(window).load(resizeHeight); + + + + + $(document).ready(function() { searchBox.OnSelectItem(0); }); + + + + + + + + + + + Qpid Proton C API + 0.16.0 + + + + + + + + + + + + + + + + + + +var searchBox = new SearchBox("searchBox", "search",false,'Search'); + + + + + + + + + + + + +$(document).ready(function(){initNavTree('messenger_8h.html','');}); + + + + +AllClassesFilesFunctionsVariablesTypedefsEnumerationsEnumeratorGroupsPages + + + + + + + + + +Macros +Typedefs +Enumerations +Functions + +messenger.h File Reference + + + +Deprecated - The Messenger API +More... +#include proton/import_export.h +#include proton/message.h +#include proton/selectable.h +#include proton/link.h +#include proton/transport.h +#include proton/ssl.h + +Go to the source code of this file. + + +Macros + +#definePN_CUMULATIVE +Indicates that an accept or reject should operate cumulatively. + + +#definePN_FLAGS_CHECK_ROUTES +Messenger flag to indicate that a call \ to pn_messenger_start should check that \ any defined routes are valid. + + +#definePN_FLAGS_ALLOW_INSECURE_MECHS +Messenger flag to indicate that the PLAIN \ mechanism is allowed on an unencrypted \ connection. + + + +Typedefs +typedef struct pn_messenger_tpn_messenger_t +A pn_messenger_t provides a high level interface for sending and receiving messages (See pn_message_t). More... + +typedef struct pn_subscription_tpn_subscription_t +A subscription is a request for incoming messages. More... + + +typedef int64_tpn_tracker_t +Trackers provide a lightweight handle used to track the status of incoming and outgoing deliveries. + + + +Enumerations +enum pn_status_t { +PN_STATUS_UNKNOWN, +PN_STATUS_PENDING, +PN_STATUS_ACCEPTED, +PN_STATUS_REJECTED, + +PN_STATUS_RELEASED, +PN_STATUS_MODIFIED, +PN_STATUS_ABORTED, +PN_STATUS_SETTLED + + } +Describes all the possible states for a message associated with a given tracker. More... + + + +Functions +pn_messenger_t *pn_messenger (const char *name) +Construct a new pn_messenger_t with the given name. More... + +const char *pn_messenger_name (pn_messenger_t *messenger) +Get the name of a messenger. More... + +intpn_messenger_set_certificate (pn_messenger_t *messenger, const char *certificate) +Sets the path that will be used to get the certificate that will be used to identify this messenger to its peers. More... + +const char *pn_messenger_get_certificate (pn_messenger_t *messenger) +Get the certificate path. More... + +intpn_messenger_set_private_key (pn_messenger_t *messenger, const char *private_key) +Set path to the private key that was used to sign the certificate. More... + +const char *pn_messenger_get_private_key (pn_messenger_t *messenger) +Gets the private key file for a messenger. More... + +intpn_messenger_set_password (pn_messenger_t *messenger, const char *password) +Sets the private key password for a messenger. More... + +const char *pn_messenger_get_password (pn_messenger_t *messenger) +Gets the private key file password for a messenger. More... + +intpn_messenger_set_trusted_certificates (pn_messenger_t *messenger, const char *cert_db) +Sets the trusted certificates database for a messenger. More... + +const char *pn_messenger_get_trusted_certificates (pn_messenger_t *messenger) +Gets the trusted certificates database for a messenger. More... + +intpn_messenger_set_timeout (pn_messenger_t *messenger, int timeout) +Set the default timeout for a messenger. More... + +intpn_messenger_get_timeout (pn_messenger_t *messenger) +Gets the timeout for a messenger object. More... + +boolpn_messenger_is_blocking (pn_messenger_t *messenger) +Check if a messenger is in blocking mode. More... + +intpn_messenger_set_blocking (pn_messenger_t *messenger, bool blocking) +Enable or disable blocking behavior for a messenger during calls to pn_messenger_send and pn_messenger_recv. More... + +boolpn_messenger_is_passive (pn_messenger_t *messenger) +Check if a messenger is in passive mode. More... + +intpn_messenger_set_passive (pn_messenger_t *messenger, bool passive) +Set the passive mode for a messenger. More... +
[33/51] [partial] qpid-site git commit: PROTON-1374: update the website for Proton 0.16.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/releases/qpid-proton-0.16.0/proton/c/api/globals_0x6f.html -- diff --git a/content/releases/qpid-proton-0.16.0/proton/c/api/globals_0x6f.html b/content/releases/qpid-proton-0.16.0/proton/c/api/globals_0x6f.html new file mode 100755 index 000..f6e43e9 --- /dev/null +++ b/content/releases/qpid-proton-0.16.0/proton/c/api/globals_0x6f.html @@ -0,0 +1,114 @@ +http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd;> +http://www.w3.org/1999/xhtml;> + + + + +Qpid Proton C API: File Members + + + + + + + + $(document).ready(initResizable); + $(window).load(resizeHeight); + + + + + $(document).ready(function() { searchBox.OnSelectItem(0); }); + + + + + + + + + + + Qpid Proton C API + 0.16.0 + + + + + + + + + + + + + + + + + + +var searchBox = new SearchBox("searchBox", "search",false,'Search'); + + + + + + + + + + + + +$(document).ready(function(){initNavTree('globals_0x6f.html','');}); + + + + +AllClassesFilesFunctionsVariablesTypedefsEnumerationsEnumeratorGroupsPages + + + + + + + + +Here is a list of all documented file members with links to the documentation: + +- o - +PN_OK +: error.h + +PN_OUT_OF_MEMORY +: error.h + +PN_OVERFLOW +: error.h + + + + + + + +Generated by +http://www.doxygen.org/index.html;> + 1.8.3.1 + + + + http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/releases/qpid-proton-0.16.0/proton/c/api/globals_0x70.html -- diff --git a/content/releases/qpid-proton-0.16.0/proton/c/api/globals_0x70.html b/content/releases/qpid-proton-0.16.0/proton/c/api/globals_0x70.html new file mode 100755 index 000..9c43ed6 --- /dev/null +++ b/content/releases/qpid-proton-0.16.0/proton/c/api/globals_0x70.html @@ -0,0 +1,141 @@ +http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd;> +http://www.w3.org/1999/xhtml;> + + + + +Qpid Proton C API: File Members + + + + + + + + $(document).ready(initResizable); + $(window).load(resizeHeight); + + + + + $(document).ready(function() { searchBox.OnSelectItem(0); }); + + + + + + + + + + + Qpid Proton C API + 0.16.0 + + + + + + + + + + + + + + + + + + +var searchBox = new SearchBox("searchBox", "search",false,'Search'); + + + + + + + + + + + + +$(document).ready(function(){initNavTree('globals_0x70.html','');}); + + + + +AllClassesFilesFunctionsVariablesTypedefsEnumerationsEnumeratorGroupsPages + + + + + + + + +Here is a list of all documented file members with links to the documentation: + +- p - +pn_proactor() +: proactor.h + +pn_proactor_connect() +: proactor.h + +pn_proactor_done() +: proactor.h + +pn_proactor_free() +: proactor.h + +PN_PROACTOR_INACTIVE +: event.h + +pn_proactor_interrupt() +: proactor.h + +PN_PROACTOR_INTERRUPT +: event.h + +pn_proactor_listen() +: proactor.h + +pn_proactor_set_timeout() +: proactor.h + +pn_proactor_t +: proactor.h + +PN_PROACTOR_TIMEOUT +: event.h + +pn_proactor_wait() +: proactor.h + + + + + + + +Generated by +http://www.doxygen.org/index.html;> + 1.8.3.1 + + + + http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/releases/qpid-proton-0.16.0/proton/c/api/globals_0x72.html -- diff --git a/content/releases/qpid-proton-0.16.0/proton/c/api/globals_0x72.html b/content/releases/qpid-proton-0.16.0/proton/c/api/globals_0x72.html new file mode 100755 index 000..60a2542 --- /dev/null +++ b/content/releases/qpid-proton-0.16.0/proton/c/api/globals_0x72.html @@ -0,0 +1,153 @@ +http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd;> +http://www.w3.org/1999/xhtml;> + + + + +Qpid Proton C API: File Members + + + + + + + + $(document).ready(initResizable); + $(window).load(resizeHeight); + + + + + $(document).ready(function() { searchBox.OnSelectItem(0); }); + + + + + + + + + + + Qpid Proton C API + 0.16.0 + + + + + + + + + + + + + + + + + + +var searchBox = new SearchBox("searchBox", "search",false,'Search'); + + + + + + + + + + + + +$(document).ready(function(){initNavTree('globals_0x72.html','');}); + + + + +AllClassesFilesFunctionsVariablesTypedefsEnumerationsEnumeratorGroupsPages + + + + + + + + +Here is a list of all documented file members with links to the documentation: + +- r - +PN_RCV_FIRST +: link.h + +PN_RCV_SECOND +: link.h + +pn_rcv_settle_mode_t +: link.h + +PN_REACTOR_FINAL +: event.h + +PN_REACTOR_INIT +: event.h + +PN_REACTOR_QUIESCED +: event.h + +PN_RECEIVED +: disposition.h + +pn_receiver() +: link.h + +PN_REJECTED
[02/51] [partial] qpid-site git commit: PROTON-1374: update the website for Proton 0.16.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/releases/qpid-proton-0.16.0/proton/c/api/navtree.js -- diff --git a/content/releases/qpid-proton-0.16.0/proton/c/api/navtree.js b/content/releases/qpid-proton-0.16.0/proton/c/api/navtree.js new file mode 100755 index 000..fdaeffa --- /dev/null +++ b/content/releases/qpid-proton-0.16.0/proton/c/api/navtree.js @@ -0,0 +1,534 @@ +var NAVTREE = +[ + [ "Qpid Proton C API", "index.html", [ +[ "Introduction", "md_index.html", null ], +[ "Deprecated List", "deprecated.html", null ], +[ "Modules", "modules.html", "modules" ], +[ "Classes", null, [ + [ "Class List", "annotated.html", "annotated" ], + [ "Class Members", "functions.html", [ +[ "All", "functions.html", null ], +[ "Variables", "functions_vars.html", null ] + ] ] +] ], +[ "Files", null, [ + [ "File List", "files.html", "files" ], + [ "File Members", "globals.html", [ +[ "All", "globals.html", "globals_dup" ], +[ "Functions", "globals_func.html", "globals_func" ], +[ "Typedefs", "globals_type.html", null ], +[ "Enumerations", "globals_enum.html", null ], +[ "Enumerator", "globals_eval.html", null ], +[ "Macros", "globals_defs.html", null ] + ] ] +] ], +[ "Examples", "examples.html", "examples" ] + ] ] +]; + +var NAVTREEINDEX = +[ +"annotated.html", +"error_8h.html#ga15440ed9515967950fa4504a53fc0b64", +"group__connection__driver.html", +"group__link.html#ga0bc65ff494e2860e6227f68c72468101", +"group__session.html#gaedc306d86e778cbf8eaaf528c3eacae9", +"message_8h.html#gaaf98d84b9ddc1c65374c9c5b979e", +"transport_8h.html#ga26cff9ffda93e2ffc8606e19eefe7f84" +]; + +var SYNCONMSG = 'click to disable panel synchronisation'; +var SYNCOFFMSG = 'click to enable panel synchronisation'; +var navTreeSubIndices = new Array(); + +function getData(varName) +{ + var i = varName.lastIndexOf('/'); + var n = i>=0 ? varName.substring(i+1) : varName; + return eval(n.replace(/\-/g,'_')); +} + +function stripPath(uri) +{ + return uri.substring(uri.lastIndexOf('/')+1); +} + +function stripPath2(uri) +{ + var i = uri.lastIndexOf('/'); + var s = uri.substring(i+1); + var m = uri.substring(0,i+1).match(/\/d\w\/d\w\w\/$/); + return m ? uri.substring(i-6) : s; +} + +function localStorageSupported() +{ + try { +return 'localStorage' in window && window['localStorage'] !== null && window.localStorage.getItem; + } + catch(e) { +return false; + } +} + + +function storeLink(link) +{ + if (!$("#nav-sync").hasClass('sync') && localStorageSupported()) { + window.localStorage.setItem('navpath',link); + } +} + +function deleteLink() +{ + if (localStorageSupported()) { +window.localStorage.setItem('navpath',''); + } +} + +function cachedLink() +{ + if (localStorageSupported()) { +return window.localStorage.getItem('navpath'); + } else { +return ''; + } +} + +function getScript(scriptName,func,show) +{ + var head = document.getElementsByTagName("head")[0]; + var script = document.createElement('script'); + script.id = scriptName; + script.type = 'text/javascript'; + script.onload = func; + script.src = scriptName+'.js'; + if ($.browser.msie && $.browser.version<=8) { +// script.onload does not work with older versions of IE +script.onreadystatechange = function() { + if (script.readyState=='complete' || script.readyState=='loaded') { +func(); if (show) showRoot(); + } +} + } + head.appendChild(script); +} + +function createIndent(o,domNode,node,level) +{ + var level=-1; + var n = node; + while (n.parentNode) { level++; n=n.parentNode; } + var imgNode = document.createElement("img"); + imgNode.style.paddingLeft=(16*level).toString()+'px'; + imgNode.width = 16; + imgNode.height = 22; + imgNode.border = 0; + if (node.childrenData) { +node.plus_img = imgNode; +node.expandToggle = document.createElement("a"); +node.expandToggle.href = "javascript:void(0)"; +node.expandToggle.onclick = function() { + if (node.expanded) { +$(node.getChildrenUL()).slideUp("fast"); +node.plus_img.src = node.relpath+"ftv2pnode.png"; +node.expanded = false; + } else { +expandNode(o, node, false, false); + } +} +node.expandToggle.appendChild(imgNode); +domNode.appendChild(node.expandToggle); +imgNode.src = node.relpath+"ftv2pnode.png"; + } else { +imgNode.src = node.relpath+"ftv2node.png"; +domNode.appendChild(imgNode); + } +} + +var animationInProgress = false; + +function gotoAnchor(anchor,aname,updateLocation) +{ + var pos, docContent = $('#doc-content'); + if (anchor.parent().attr('class')=='memItemLeft' || + anchor.parent().attr('class')=='fieldtype' || + anchor.parent().is(':header')) + { +pos = anchor.parent().position().top; + } else if
[26/51] [partial] qpid-site git commit: PROTON-1374: update the website for Proton 0.16.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/releases/qpid-proton-0.16.0/proton/c/api/group__data.html -- diff --git a/content/releases/qpid-proton-0.16.0/proton/c/api/group__data.html b/content/releases/qpid-proton-0.16.0/proton/c/api/group__data.html new file mode 100755 index 000..c12edcc --- /dev/null +++ b/content/releases/qpid-proton-0.16.0/proton/c/api/group__data.html @@ -0,0 +1,2886 @@ +http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd;> +http://www.w3.org/1999/xhtml;> + + + + +Qpid Proton C API: Data + + + + + + + + $(document).ready(initResizable); + $(window).load(resizeHeight); + + + + + $(document).ready(function() { searchBox.OnSelectItem(0); }); + + + + + + + + + + + Qpid Proton C API + 0.16.0 + + + + + + + + + + + + + + + + + + +var searchBox = new SearchBox("searchBox", "search",false,'Search'); + + + + + + + + + + + + +$(document).ready(function(){initNavTree('group__data.html','');}); + + + + +AllClassesFilesFunctionsVariablesTypedefsEnumerationsEnumeratorGroupsPages + + + + + + + + + +Typedefs +Functions + +DataCodec + + + +A data structure for AMQP data. +More... + + +Typedefs +typedef struct pn_data_tpn_data_t +An AMQP Data object. More... + + + +Functions +pn_data_t *pn_data (size_t capacity) +Construct a pn_data_t object with the supplied initial capacity. More... + +voidpn_data_free (pn_data_t *data) +Free a pn_data_t object. More... + +intpn_data_errno (pn_data_t *data) +Access the current error code for a given pn_data_t. More... + +pn_error_t *pn_data_error (pn_data_t *data) +Access the current error for a givn pn_data_t. More... + +voidpn_data_clear (pn_data_t *data) +Clears a pn_data_t object. More... + +size_tpn_data_size (pn_data_t *data) +Returns the total number of nodes contained in a pn_data_t object. More... + +voidpn_data_rewind (pn_data_t *data) +Clears current node pointer and sets the parent to the root node. More... + +boolpn_data_next (pn_data_t *data) +Advances the current node to its next sibling and returns true. More... + +boolpn_data_prev (pn_data_t *data) +Moves the current node to its previous sibling and returns true. More... + +boolpn_data_enter (pn_data_t *data) +Sets the parent node to the current node and clears the current node. More... + +boolpn_data_exit (pn_data_t *data) +Sets the current node to the parent node and the parent node to its own parent. More... + +pn_type_tpn_data_type (pn_data_t *data) +Access the type of the current node. More... + +intpn_data_print (pn_data_t *data) +Prints the contents of a pn_data_t object using pn_data_format() to stdout. More... + +intpn_data_format (pn_data_t *data, char *bytes, size_t *size) +Formats the contents of a pn_data_t object in a human readable way and writes them to the indicated location. More... + +ssize_tpn_data_encode (pn_data_t *data, char *bytes, size_t size) +Writes the contents of a data object to the given buffer as an AMQP data stream. More... + +ssize_tpn_data_encoded_size (pn_data_t *data) +Returns the number of bytes needed to encode a data object. More... + +ssize_tpn_data_decode (pn_data_t *data, const char *bytes, size_t size) +Decodes a single value from the contents of the AMQP data stream into the current data object. More... + +intpn_data_put_list (pn_data_t *data) +Puts an empty list value into a pn_data_t. More... + +intpn_data_put_map (pn_data_t *data) +Puts an empty map value into a pn_data_t. More... + +intpn_data_put_array (pn_data_t *data, bool described, pn_type_t type) +Puts an empty array value into a pn_data_t. More... + +intpn_data_put_described (pn_data_t *data) +Puts a described value into a pn_data_t object. More... + +intpn_data_put_null (pn_data_t *data) +Puts a PN_NULL value. More... + +intpn_data_put_bool (pn_data_t *data, bool b) +Puts a PN_BOOL value. More... + +intpn_data_put_ubyte (pn_data_t *data, uint8_t ub) +Puts a PN_UBYTE value. More... + +intpn_data_put_byte (pn_data_t *data, int8_t b) +Puts a PN_BYTE value. More... + +intpn_data_put_ushort (pn_data_t *data, uint16_t us) +Puts a PN_USHORT value. More... + +intpn_data_put_short (pn_data_t *data, int16_t s) +Puts a PN_SHORT value. More... + +intpn_data_put_uint (pn_data_t *data, uint32_t ui) +Puts a PN_UINT value. More... + +intpn_data_put_int (pn_data_t *data, int32_t i) +Puts a PN_INT value. More... + +intpn_data_put_char (pn_data_t *data, pn_char_t c) +Puts a PN_CHAR value. More... + +intpn_data_put_ulong (pn_data_t *data, uint64_t ul) +Puts a PN_ULONG value. More... + +intpn_data_put_long (pn_data_t *data, int64_t l) +Puts a PN_LONG value. More... + +intpn_data_put_timestamp (pn_data_t *data, pn_timestamp_t t) +Puts a PN_TIMESTAMP value. More... +
[30/51] [partial] qpid-site git commit: PROTON-1374: update the website for Proton 0.16.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/releases/qpid-proton-0.16.0/proton/c/api/globals_type.html -- diff --git a/content/releases/qpid-proton-0.16.0/proton/c/api/globals_type.html b/content/releases/qpid-proton-0.16.0/proton/c/api/globals_type.html new file mode 100755 index 000..ad62655 --- /dev/null +++ b/content/releases/qpid-proton-0.16.0/proton/c/api/globals_type.html @@ -0,0 +1,256 @@ +http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd;> +http://www.w3.org/1999/xhtml;> + + + + +Qpid Proton C API: File Members + + + + + + + + $(document).ready(initResizable); + $(window).load(resizeHeight); + + + + + $(document).ready(function() { searchBox.OnSelectItem(0); }); + + + + + + + + + + + Qpid Proton C API + 0.16.0 + + + + + + + + + + + + + + + + + + +var searchBox = new SearchBox("searchBox", "search",false,'Search'); + + + + + + + + + + + + +$(document).ready(function(){initNavTree('globals_type.html','');}); + + + + +AllClassesFilesFunctionsVariablesTypedefsEnumerationsEnumeratorGroupsPages + + + + + + + + + + +- b - +pn_bytes_t +: types.h + + + + +- c - +pn_char_t +: types.h + +pn_collector_t +: types.h + +pn_condition_t +: condition.h + +pn_connection_driver_t +: connection_driver.h + +pn_connection_t +: types.h + + + + +- d - +pn_data_t +: codec.h + +pn_decimal32_t +: types.h + +pn_decimal64_t +: types.h + +pn_delivery_t +: types.h + +pn_delivery_tag_t +: delivery.h + +pn_disposition_t +: disposition.h + + + + +- e - +pn_error_t +: error.h + +pn_event_batch_t +: event.h + +pn_event_t +: event.h + + + + +- l - +pn_link_t +: types.h + +pn_listener_t +: listener.h + + + + +- m - +pn_message_t +: message.h + +pn_messenger_t +: messenger.h + +pn_millis_t +: types.h + + + + +- p - +pn_proactor_t +: proactor.h + + + + +- r - +pn_rwbytes_t +: types.h + + + + +- s - +pn_sasl_t +: sasl.h + +pn_seconds_t +: types.h + +pn_sequence_t +: types.h + +pn_session_t +: types.h + +pn_ssl_domain_t +: ssl.h + +pn_ssl_t +: ssl.h + +pn_state_t +: types.h + +pn_subscription_t +: messenger.h + + + + +- t - +pn_terminus_t +: terminus.h + +pn_timestamp_t +: types.h + +pn_trace_t +: transport.h + +pn_tracer_t +: transport.h + +pn_tracker_t +: messenger.h + +pn_transport_t +: types.h + + + + +- u - +pn_url_t +: url.h + + + + + + + +Generated by +http://www.doxygen.org/index.html;> + 1.8.3.1 + + + + http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/releases/qpid-proton-0.16.0/proton/c/api/group__amqp__types.html -- diff --git a/content/releases/qpid-proton-0.16.0/proton/c/api/group__amqp__types.html b/content/releases/qpid-proton-0.16.0/proton/c/api/group__amqp__types.html new file mode 100755 index 000..25a95ae --- /dev/null +++ b/content/releases/qpid-proton-0.16.0/proton/c/api/group__amqp__types.html @@ -0,0 +1,378 @@ +http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd;> +http://www.w3.org/1999/xhtml;> + + + + +Qpid Proton C API: AMQP data types + + + + + + + + $(document).ready(initResizable); + $(window).load(resizeHeight); + + + + + $(document).ready(function() { searchBox.OnSelectItem(0); }); + + + + + + + + + + + Qpid Proton C API + 0.16.0 + + + + + + + + + + + + + + + + + + +var searchBox = new SearchBox("searchBox", "search",false,'Search'); + + + + + + + + + + + + +$(document).ready(function(){initNavTree('group__amqp__types.html','');}); + + + + +AllClassesFilesFunctionsVariablesTypedefsEnumerationsEnumeratorGroupsPages + + + + + + + + + +Classes +Typedefs +Enumerations +Functions + +AMQP data typesTypes + + + +AMQP data types. +More... + + +Classes +struct pn_decimal128_t +A 128-bit decimal floating-point number. More... + +struct pn_uuid_t +A 16-byte universally unique identifier. More... + + + +Typedefs + +typedef int64_tpn_timestamp_t +A 64-bit timestamp in milliseconds since the Unix epoch. + + +typedef uint32_tpn_char_t +A 32-bit Unicode code point. + + +typedef uint32_tpn_decimal32_t +A 32-bit decimal floating-point number. + + +typedef uint64_tpn_decimal64_t +A 64-bit decimal floating-point number. + + + +Enumerations +enum pn_type_t { +PN_NULL, +PN_BOOL, +PN_UBYTE, +PN_BYTE, + +PN_USHORT, +PN_SHORT, +PN_UINT, +PN_INT, + +PN_CHAR, +PN_ULONG, +PN_LONG, +PN_TIMESTAMP, + +PN_FLOAT, +PN_DOUBLE, +PN_DECIMAL32, +PN_DECIMAL64, + +PN_DECIMAL128, +PN_UUID, +PN_BINARY, +PN_STRING, + +PN_SYMBOL, +PN_DESCRIBED, +PN_ARRAY, +PN_LIST, + +PN_MAP, +PN_INVALID + + } +Identifies an AMQP type. More... + + + +Functions +const char *pn_type_name (pn_type_t type) +Return a string name for an AMQP
[42/51] [partial] qpid-site git commit: PROTON-1374: update the website for Proton 0.16.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/releases/qpid-proton-0.16.0/proton/c/api/codec_8h.js -- diff --git a/content/releases/qpid-proton-0.16.0/proton/c/api/codec_8h.js b/content/releases/qpid-proton-0.16.0/proton/c/api/codec_8h.js new file mode 100755 index 000..377e4a1 --- /dev/null +++ b/content/releases/qpid-proton-0.16.0/proton/c/api/codec_8h.js @@ -0,0 +1,113 @@ +var codec_8h = +[ +[ "pn_data_t", "codec_8h.html#ga5d6cf528776e8b6ad6d67caf095986bf", null ], +[ "pn_type_t", "codec_8h.html#ga4465b5ea7d3c4f15c1dffa4deda905db", [ + [ "PN_NULL", "codec_8h.html#gga4465b5ea7d3c4f15c1dffa4deda905dbaee48efaa3cb0c5b5d16c5b869b7e8fbe", null ], + [ "PN_BOOL", "codec_8h.html#gga4465b5ea7d3c4f15c1dffa4deda905dba2d6444a931a66258de3c73ad01238ae7", null ], + [ "PN_UBYTE", "codec_8h.html#gga4465b5ea7d3c4f15c1dffa4deda905dba99223ec8d1ae5d915a1eaa7e8fef0256", null ], + [ "PN_BYTE", "codec_8h.html#gga4465b5ea7d3c4f15c1dffa4deda905dba32d7a9a461945791cb02902af9ff6592", null ], + [ "PN_USHORT", "codec_8h.html#gga4465b5ea7d3c4f15c1dffa4deda905dba657a836a5ee74d9468924982ba3a3b41", null ], + [ "PN_SHORT", "codec_8h.html#gga4465b5ea7d3c4f15c1dffa4deda905dba3dbf1221e02329a7f41b41e597833d97", null ], + [ "PN_UINT", "codec_8h.html#gga4465b5ea7d3c4f15c1dffa4deda905dbaa7a251ed9fe5c31f0473976467bfefdd", null ], + [ "PN_INT", "codec_8h.html#gga4465b5ea7d3c4f15c1dffa4deda905dba175c594857c135ea2a9c3a2d415366ab", null ], + [ "PN_CHAR", "codec_8h.html#gga4465b5ea7d3c4f15c1dffa4deda905dba905512ea57a64d4e2aecf4877b192124", null ], + [ "PN_ULONG", "codec_8h.html#gga4465b5ea7d3c4f15c1dffa4deda905dba5f6b5fd2edbedf3f21285b69b8864777", null ], + [ "PN_LONG", "codec_8h.html#gga4465b5ea7d3c4f15c1dffa4deda905dba7a1b08f15b17b3d820a6fb50e65ffe1c", null ], + [ "PN_TIMESTAMP", "codec_8h.html#gga4465b5ea7d3c4f15c1dffa4deda905dbaca241b4fa6cd92fdf26b4460d02a17b1", null ], + [ "PN_FLOAT", "codec_8h.html#gga4465b5ea7d3c4f15c1dffa4deda905dba9c27cba605584c7d093f26e7270bfaa0", null ], + [ "PN_DOUBLE", "codec_8h.html#gga4465b5ea7d3c4f15c1dffa4deda905dbaa1367e8029855849dc4e0d3f027279a5", null ], + [ "PN_DECIMAL32", "codec_8h.html#gga4465b5ea7d3c4f15c1dffa4deda905dbae998dd044ac55b959427fc90531b14ca", null ], + [ "PN_DECIMAL64", "codec_8h.html#gga4465b5ea7d3c4f15c1dffa4deda905dbacb54239601b8bf4795e34417425b92ae", null ], + [ "PN_DECIMAL128", "codec_8h.html#gga4465b5ea7d3c4f15c1dffa4deda905dbae54cf8095578932042be640555855cd4", null ], + [ "PN_UUID", "codec_8h.html#gga4465b5ea7d3c4f15c1dffa4deda905dba0a6946e5c032bae8d108100e2c56ac13", null ], + [ "PN_BINARY", "codec_8h.html#gga4465b5ea7d3c4f15c1dffa4deda905dba7dc0fd4874c2b57a8249614d348643e9", null ], + [ "PN_STRING", "codec_8h.html#gga4465b5ea7d3c4f15c1dffa4deda905dba88421417c7be2caf88c2d243cb73da6b", null ], + [ "PN_SYMBOL", "codec_8h.html#gga4465b5ea7d3c4f15c1dffa4deda905dbad5f0929805f481d3ca6089ed172451e9", null ], + [ "PN_DESCRIBED", "codec_8h.html#gga4465b5ea7d3c4f15c1dffa4deda905dbaff3c998d4a4a4be01cac89418d07", null ], + [ "PN_ARRAY", "codec_8h.html#gga4465b5ea7d3c4f15c1dffa4deda905dba2c6f15d0ad9e27f040382ef4a2be807d", null ], + [ "PN_LIST", "codec_8h.html#gga4465b5ea7d3c4f15c1dffa4deda905dba653d98ae82ff7048973b4c755d2b2804", null ], + [ "PN_MAP", "codec_8h.html#gga4465b5ea7d3c4f15c1dffa4deda905dba3295ee98cb6c69f50951aea30ffe46dd", null ], + [ "PN_INVALID", "codec_8h.html#gga4465b5ea7d3c4f15c1dffa4deda905dba891d1f2ee5621729cd5a07593042dce6", null ] +] ], +[ "pn_data", "codec_8h.html#gac21c6f1c517ac486e2923baa3d0c5db4", null ], +[ "pn_data_append", "codec_8h.html#ga0a98b8f17784460034c240ed4b6b47d7", null ], +[ "pn_data_appendn", "codec_8h.html#ga9a048cfd78ca76604b667d170eac0136", null ], +[ "pn_data_clear", "codec_8h.html#ga7611c1394e80b5166b8b8647659f97e6", null ], +[ "pn_data_copy", "codec_8h.html#gaf0e0fbb9c8c757f94b9636a6b54dc332", null ], +[ "pn_data_decode", "codec_8h.html#ga74430b712be334a05861cfd5e9b312b9", null ], +[ "pn_data_dump", "codec_8h.html#ga502e9571b513b58bce5a5ae442951400", null ], +[ "pn_data_encode", "codec_8h.html#ga5502724bcde68615bc47e09a3335b527", null ], +[ "pn_data_encoded_size", "codec_8h.html#gae71bfb440cc4f0b15fe958bf55a3f6af", null ], +[ "pn_data_enter", "codec_8h.html#ga1093449b80357dabf3f70a4bf804f4f7", null ], +[ "pn_data_errno", "codec_8h.html#ga68e94dfa5d7ab568425c4a6587bac1db", null ], +[ "pn_data_error", "codec_8h.html#gada171f4740e6a1132b4d4b9c0aea645c", null ], +[ "pn_data_exit", "codec_8h.html#ga67a656cbdbf0a47a223ff1c8507ecf48", null ], +[ "pn_data_format", "codec_8h.html#gaa63068cf2ed94f05b20f6c49c908a2c6", null ], +[ "pn_data_free", "codec_8h.html#ga2c02eee58084ba9b77a37c086e195802", null ], +
[36/51] [partial] qpid-site git commit: PROTON-1374: update the website for Proton 0.16.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/releases/qpid-proton-0.16.0/proton/c/api/event_8h.html -- diff --git a/content/releases/qpid-proton-0.16.0/proton/c/api/event_8h.html b/content/releases/qpid-proton-0.16.0/proton/c/api/event_8h.html new file mode 100755 index 000..99d6847 --- /dev/null +++ b/content/releases/qpid-proton-0.16.0/proton/c/api/event_8h.html @@ -0,0 +1,265 @@ +http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd;> +http://www.w3.org/1999/xhtml;> + + + + +Qpid Proton C API: proton/event.h File Reference + + + + + + + + $(document).ready(initResizable); + $(window).load(resizeHeight); + + + + + $(document).ready(function() { searchBox.OnSelectItem(0); }); + + + + + + + + + + + Qpid Proton C API + 0.16.0 + + + + + + + + + + + + + + + + + + +var searchBox = new SearchBox("searchBox", "search",false,'Search'); + + + + + + + + + + + + +$(document).ready(function(){initNavTree('event_8h.html','');}); + + + + +AllClassesFilesFunctionsVariablesTypedefsEnumerationsEnumeratorGroupsPages + + + + + + + + + +Typedefs +Enumerations +Functions + +event.h File Reference + + + +Protocol and transport events. +More... +#include proton/import_export.h +#include proton/type_compat.h +#include proton/object.h +#include stddef.h + +Go to the source code of this file. + + +Typedefs +typedef struct pn_event_tpn_event_t +Notification of a state change in the protocol engine. More... + +typedef struct pn_event_batch_tpn_event_batch_t +Experimental - A batch of events to handle. More... + + + +Enumerations +enum pn_event_type_t { +PN_EVENT_NONE, +PN_REACTOR_INIT, +PN_REACTOR_QUIESCED, +PN_REACTOR_FINAL, + +PN_TIMER_TASK, +PN_CONNECTION_INIT, +PN_CONNECTION_BOUND, +PN_CONNECTION_UNBOUND, + +PN_CONNECTION_LOCAL_OPEN, +PN_CONNECTION_REMOTE_OPEN, +PN_CONNECTION_LOCAL_CLOSE, +PN_CONNECTION_REMOTE_CLOSE, + +PN_CONNECTION_FINAL, +PN_SESSION_INIT, +PN_SESSION_LOCAL_OPEN, +PN_SESSION_REMOTE_OPEN, + +PN_SESSION_LOCAL_CLOSE, +PN_SESSION_REMOTE_CLOSE, +PN_SESSION_FINAL, +PN_LINK_INIT, + +PN_LINK_LOCAL_OPEN, +PN_LINK_REMOTE_OPEN, +PN_LINK_LOCAL_CLOSE, +PN_LINK_REMOTE_CLOSE, + +PN_LINK_LOCAL_DETACH, +PN_LINK_REMOTE_DETACH, +PN_LINK_FLOW, +PN_LINK_FINAL, + +PN_DELIVERY, +PN_TRANSPORT, +PN_TRANSPORT_AUTHENTICATED, +PN_TRANSPORT_ERROR, + +PN_TRANSPORT_HEAD_CLOSED, +PN_TRANSPORT_WRITE_CLOSED, +PN_TRANSPORT_TAIL_CLOSED, +PN_TRANSPORT_READ_CLOSED, + +PN_TRANSPORT_CLOSED, +PN_SELECTABLE_INIT, +PN_SELECTABLE_UPDATED, +PN_SELECTABLE_READABLE, + +PN_SELECTABLE_WRITABLE, +PN_SELECTABLE_ERROR, +PN_SELECTABLE_EXPIRED, +PN_SELECTABLE_FINAL, + +PN_CONNECTION_WAKE, +PN_LISTENER_ACCEPT, +PN_LISTENER_CLOSE, +PN_PROACTOR_INTERRUPT, + +PN_PROACTOR_TIMEOUT, +PN_PROACTOR_INACTIVE + + } +An event type. More... + + + +Functions +const char *pn_event_type_name (pn_event_type_t type) +Get a human readable name for an event type. More... + +pn_collector_t *pn_collector (void) +Construct a collector. More... + +voidpn_collector_free (pn_collector_t *collector) +Free a collector. More... + +voidpn_collector_release (pn_collector_t *collector) +Release a collector. More... + +pn_event_t *pn_collector_put (pn_collector_t *collector, const pn_class_t *clazz, void *context, pn_event_type_t type) +Place a new event on a collector. More... + +pn_event_t *pn_collector_peek (pn_collector_t *collector) +Access the head event contained by a collector. More... + +boolpn_collector_pop (pn_collector_t *collector) +Clear the head event on a collector. More... + +pn_event_t *pn_collector_next (pn_collector_t *collector) +Return the next event to be handled. More... + +pn_event_t *pn_collector_prev (pn_collector_t *collector) +Return the same event as the previous call to pn_collector_next() More... + +boolpn_collector_more (pn_collector_t *collector) +Check if there are more events after the current event. More... + +pn_event_type_tpn_event_type (pn_event_t *event) +Get the type of an event. More... + +const pn_class_t *pn_event_class (pn_event_t *event) +Get the class associated with the event context. More... + + +void *pn_event_context (pn_event_t *event) +Get the context associated with an event. + +pn_connection_t *pn_event_connection (pn_event_t *event) +Get the connection associated with an event. More... + +pn_session_t *pn_event_session (pn_event_t *event) +Get the session associated with an event. More... + +pn_link_t *pn_event_link (pn_event_t *event) +Get the link associated with an event. More... + +pn_delivery_t *pn_event_delivery (pn_event_t *event) +Get the delivery associated with an event. More... + +pn_transport_t *pn_event_transport (pn_event_t
[09/51] [partial] qpid-site git commit: PROTON-1374: update the website for Proton 0.16.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/releases/qpid-proton-0.16.0/proton/c/api/jquery.js -- diff --git a/content/releases/qpid-proton-0.16.0/proton/c/api/jquery.js b/content/releases/qpid-proton-0.16.0/proton/c/api/jquery.js new file mode 100755 index 000..78ad0bd --- /dev/null +++ b/content/releases/qpid-proton-0.16.0/proton/c/api/jquery.js @@ -0,0 +1,77 @@ +/*! jQuery v1.7.1 jquery.com | jquery.org/license */ +(function(a,b){function cy(a){return f.isWindow(a)?a:a.nodeType===9?a.defaultView||a.parentWindow:!1}function cv(a){if(!ck[a]){var b=c.body,d=f("<"+a+">").appendTo(b),e=d.css("display");d.remove();if(e==="none"||e===""){cl||(cl=c.createElement("iframe"),cl.frameBorder=cl.width=cl.height=0),b.appendChild(cl);if(!cm||!cl.createElement)cm=(cl.contentWindow||cl.contentDocument).document,cm.write((c.compatMode==="CSS1Compat"?"":"")+""),cm.close();d=cm.createElement(a),cm.body.appendChild(d),e=f.css(d,"display"),b.removeChild(cl)}ck[a]=e}return ck[a]}function cu(a,b){var c={};f.each(cq.concat.apply([],cq.slice(0,b)),function(){c[this]=a});return c}function ct(){cr=b}function cs(){setTimeout(ct,0);return cr=f.now()}function cj(){try{return new a.ActiveXObject("Microsoft.XMLHTTP")}catch(b){}}function ci(){try{return new a.XMLHttpRequest}catch(b){}}function cc(a,c){a.dataFilter&&(c=a.dataFilter(c,a.dataType));var d=a.dataTypes,e={},g,h,i=d.length,j,k=d[0],l,m,n,o,p ;for(g=1;g0){if(c!=="border")for(;g
[48/51] [partial] qpid-site git commit: PROTON-1374: update the website for Proton 0.16.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/releases/qpid-proton-0.16.0/messenger/perl/examples/index.html -- diff --git a/content/releases/qpid-proton-0.16.0/messenger/perl/examples/index.html b/content/releases/qpid-proton-0.16.0/messenger/perl/examples/index.html new file mode 100644 index 000..cce265c --- /dev/null +++ b/content/releases/qpid-proton-0.16.0/messenger/perl/examples/index.html @@ -0,0 +1,162 @@ + + +http://www.w3.org/1999/xhtml; xml:lang="en"> + +Perl AMQP Messenger Examples - 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 for Java + 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 Proton 0.16.0Perl AMQP Messenger Examples + + + Perl AMQP Messenger Examples + +Example files + + +client.pl +recv.pl +recv_async.pl +send.pl +send_async.pl +server.pl + + +More information + + +https://github.com/apache/qpid-proton/tree/0.16.0/examples/perl/messenger;>Source location + + + + + + +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/7833dc2a/content/releases/qpid-proton-0.16.0/messenger/perl/examples/recv.pl -- diff --git a/content/releases/qpid-proton-0.16.0/messenger/perl/examples/recv.pl b/content/releases/qpid-proton-0.16.0/messenger/perl/examples/recv.pl new file mode 100755 index 000..801f6a2 --- /dev/null +++ b/content/releases/qpid-proton-0.16.0/messenger/perl/examples/recv.pl @@ -0,0 +1,99 @@ +#!/usr/bin/env perl +# +# 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. +# + +use warnings; + +use Scalar::Util qw(reftype); +use Data::Dumper; + +use qpid_proton; + +sub usage { +exit(0); +} + +my @addresses = @ARGV; +@addresses = ("~0.0.0.0") unless $addresses[0]; + +my $messenger = new qpid::proton::Messenger(); +my $msg = new qpid::proton::Message(); + +$messenger->start(); + +foreach (@addresses) +{ +print "Subscribing to $_\n"; +
[24/51] [partial] qpid-site git commit: PROTON-1374: update the website for Proton 0.16.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/releases/qpid-proton-0.16.0/proton/c/api/group__delivery.html -- diff --git a/content/releases/qpid-proton-0.16.0/proton/c/api/group__delivery.html b/content/releases/qpid-proton-0.16.0/proton/c/api/group__delivery.html new file mode 100755 index 000..c457a3c --- /dev/null +++ b/content/releases/qpid-proton-0.16.0/proton/c/api/group__delivery.html @@ -0,0 +1,1430 @@ +http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd;> +http://www.w3.org/1999/xhtml;> + + + + +Qpid Proton C API: Delivery + + + + + + + + $(document).ready(initResizable); + $(window).load(resizeHeight); + + + + + $(document).ready(function() { searchBox.OnSelectItem(0); }); + + + + + + + + + + + Qpid Proton C API + 0.16.0 + + + + + + + + + + + + + + + + + + +var searchBox = new SearchBox("searchBox", "search",false,'Search'); + + + + + + + + + + + + +$(document).ready(function(){initNavTree('group__delivery.html','');}); + + + + +AllClassesFilesFunctionsVariablesTypedefsEnumerationsEnumeratorGroupsPages + + + + + + + + + +Macros +Typedefs +Functions + +DeliveryCore + + + +A message transfer. +More... + + +Macros + +#definePN_RECEIVED +The PN_RECEIVED delivery state is a non terminal state indicating how much (if any) message data has been received for a delivery. + +#definePN_ACCEPTED +The PN_ACCEPTED delivery state is a terminal state indicating that the delivery was successfully processed. More... + +#definePN_REJECTED +The PN_REJECTED delivery state is a terminal state indicating that the delivery could not be processed due to some error condition. More... + +#definePN_RELEASED +The PN_RELEASED delivery state is a terminal state indicating that the delivery is being returned to the sender. More... + +#definePN_MODIFIED +The PN_MODIFIED delivery state is a terminal state indicating that the delivery is being returned to the sender and should be annotated by the sender prior to further delivery attempts. More... + + + +Typedefs + +typedef pn_bytes_tpn_delivery_tag_t +An AMQP delivery tag. + +typedef struct pn_disposition_tpn_disposition_t +Dispositions record the current state and/or final outcome of a transfer. More... + +typedef struct pn_delivery_tpn_delivery_t +An AMQP Delivery object. More... + + + +Functions +pn_delivery_tag_tpn_dtag (const char *bytes, size_t size) +Construct a delivery tag. More... + +pn_delivery_t *pn_delivery (pn_link_t *link, pn_delivery_tag_t tag) +Create a delivery on a link. More... + +void *pn_delivery_get_context (pn_delivery_t *delivery) + +voidpn_delivery_set_context (pn_delivery_t *delivery, void *context) + +pn_record_t *pn_delivery_attachments (pn_delivery_t *delivery) +Get the attachments that are associated with a delivery object. More... + +pn_delivery_tag_tpn_delivery_tag (pn_delivery_t *delivery) +Get the tag for a delivery object. More... + +pn_link_t *pn_delivery_link (pn_delivery_t *delivery) +Get the parent link for a delivery object. More... + +pn_disposition_t *pn_delivery_local (pn_delivery_t *delivery) +Get the local disposition for a delivery. More... + +uint64_tpn_delivery_local_state (pn_delivery_t *delivery) +Get the local disposition state for a delivery. More... + +pn_disposition_t *pn_delivery_remote (pn_delivery_t *delivery) +Get the remote disposition for a delivery. More... + +uint64_tpn_delivery_remote_state (pn_delivery_t *delivery) +Get the remote disposition state for a delivery. More... + +boolpn_delivery_settled (pn_delivery_t *delivery) +Check if a delivery is remotely settled. More... + +size_tpn_delivery_pending (pn_delivery_t *delivery) +Get the amount of pending message data for a delivery. More... + +boolpn_delivery_partial (pn_delivery_t *delivery) +Check if a delivery only has partial message data. More... + +boolpn_delivery_writable (pn_delivery_t *delivery) +Check if a delivery is writable. More... + +boolpn_delivery_readable (pn_delivery_t *delivery) +Check if a delivery is readable. More... + +boolpn_delivery_updated (pn_delivery_t *delivery) +Check if a delivery is updated. More... + +voidpn_delivery_update (pn_delivery_t *delivery, uint64_t state) +Update the disposition of a delivery. More... + +voidpn_delivery_clear (pn_delivery_t *delivery) +Clear the updated flag for a delivery. More... + +boolpn_delivery_current (pn_delivery_t *delivery) +Return true if delivery is the current delivery for its link. More... + +voidpn_delivery_settle (pn_delivery_t *delivery) +Settle a delivery. More... + +voidpn_delivery_dump (pn_delivery_t *delivery) +Utility function for printing details of a delivery. More... + +boolpn_delivery_buffered (pn_delivery_t *delivery) +Check if a delivery is
[38/51] [partial] qpid-site git commit: PROTON-1374: update the website for Proton 0.16.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/releases/qpid-proton-0.16.0/proton/c/api/deprecated.html -- diff --git a/content/releases/qpid-proton-0.16.0/proton/c/api/deprecated.html b/content/releases/qpid-proton-0.16.0/proton/c/api/deprecated.html new file mode 100755 index 000..b9ac7e5 --- /dev/null +++ b/content/releases/qpid-proton-0.16.0/proton/c/api/deprecated.html @@ -0,0 +1,147 @@ +http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd;> +http://www.w3.org/1999/xhtml;> + + + + +Qpid Proton C API: Deprecated List + + + + + + + + $(document).ready(initResizable); + $(window).load(resizeHeight); + + + + + $(document).ready(function() { searchBox.OnSelectItem(0); }); + + + + + + + + + + + Qpid Proton C API + 0.16.0 + + + + + + + + + + + + + + + + + + +var searchBox = new SearchBox("searchBox", "search",false,'Search'); + + + + + + + + + + + + +$(document).ready(function(){initNavTree('deprecated.html','');}); + + + + +AllClassesFilesFunctionsVariablesTypedefsEnumerationsEnumeratorGroupsPages + + + + + + + + + +Deprecated List + + + +Group messenger + +File messenger.h + +Member pn_connection_error (pn_connection_t *connection) + +Member pn_connection_get_context (pn_connection_t *connection) + +Member pn_connection_set_context (pn_connection_t *connection, void *context) + +Member pn_delivery_get_context (pn_delivery_t *delivery) + +Member pn_delivery_set_context (pn_delivery_t *delivery, void *context) + +Member pn_link_error (pn_link_t *link) + +Member pn_link_get_context (pn_link_t *link) + +Member pn_link_set_context (pn_link_t *link, void *context) + +Member pn_session_error (pn_session_t *session) + +Member pn_session_get_context (pn_session_t *session) + +Member pn_session_set_context (pn_session_t *session, void *context) + +Member pn_transport_error (pn_transport_t *transport) + +Member pn_transport_get_context (pn_transport_t *transport) + +Member pn_transport_input (pn_transport_t *transport, const char *bytes, size_t available) + +Member pn_transport_output (pn_transport_t *transport, char *bytes, size_t size) + +Member pn_transport_set_context (pn_transport_t *transport, void *context) + +Group url + +File url.h + + + + + + + +Generated by +http://www.doxygen.org/index.html;> + 1.8.3.1 + + + + http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/releases/qpid-proton-0.16.0/proton/c/api/dir_25143d27009f52d175c1d192441a738a.html -- diff --git a/content/releases/qpid-proton-0.16.0/proton/c/api/dir_25143d27009f52d175c1d192441a738a.html b/content/releases/qpid-proton-0.16.0/proton/c/api/dir_25143d27009f52d175c1d192441a738a.html new file mode 100755 index 000..e2ef66e --- /dev/null +++ b/content/releases/qpid-proton-0.16.0/proton/c/api/dir_25143d27009f52d175c1d192441a738a.html @@ -0,0 +1,172 @@ +http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd;> +http://www.w3.org/1999/xhtml;> + + + + +Qpid Proton C API: proton Directory Reference + + + + + + + + $(document).ready(initResizable); + $(window).load(resizeHeight); + + + + + $(document).ready(function() { searchBox.OnSelectItem(0); }); + + + + + + + + + + + Qpid Proton C API + 0.16.0 + + + + + + + + + + + + + + + + + + +var searchBox = new SearchBox("searchBox", "search",false,'Search'); + + + + + + + + + + + + +$(document).ready(function(){initNavTree('dir_25143d27009f52d175c1d192441a738a.html','');}); + + + + +AllClassesFilesFunctionsVariablesTypedefsEnumerationsEnumeratorGroupsPages + + + + + + + + + +proton Directory Reference + + + + +Files +file codec.h [code] +AMQP data encoding and decoding. + +file condition.h [code] +An endpoint error state. + +file connection.h [code] +A channel for communication between two peers on a network. + +file connection_driver.h [code] +Experimental - Low-level IO integration + +file delivery.h [code] +A message transfer. + +file disposition.h [code] +Delivery state. + +file error.h [code] +A Proton API error. + +file event.h [code] +Protocol and transport events. + +file link.h [code] +A channel for transferring messages. + +file listener.h [code] +Experimental - A listener for incoming connections for the Proactor. + +file message.h [code] +A mutable holder of application content. + +file messenger.h [code] +Deprecated - The Messenger API + +file proactor.h [code] +Experimental - Multithreaded IO + +file sasl.h [code] +SASL secure transport layer. + +file session.h [code] +A container of links. + +file ssl.h [code] +SSL secure transport layer. + +file terminus.h [code] +A source or target for
[45/51] [partial] qpid-site git commit: PROTON-1374: update the website for Proton 0.16.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/releases/qpid-proton-0.16.0/messenger/ruby/examples/index.html -- diff --git a/content/releases/qpid-proton-0.16.0/messenger/ruby/examples/index.html b/content/releases/qpid-proton-0.16.0/messenger/ruby/examples/index.html new file mode 100644 index 000..6824da8 --- /dev/null +++ b/content/releases/qpid-proton-0.16.0/messenger/ruby/examples/index.html @@ -0,0 +1,161 @@ + + +http://www.w3.org/1999/xhtml; xml:lang="en"> + +Ruby AMQP Messenger Examples - 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 for Java + 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 Proton 0.16.0Ruby AMQP Messenger Examples + + + Ruby AMQP Messenger Examples + +Example files + + +client.rb +mailserver.rb +nonblocking_recv.rb +recv.rb +send.rb + + +More information + + +https://github.com/apache/qpid-proton/tree/0.16.0/examples/ruby/messenger;>Source location + + + + + + +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/7833dc2a/content/releases/qpid-proton-0.16.0/messenger/ruby/examples/mailserver.rb -- diff --git a/content/releases/qpid-proton-0.16.0/messenger/ruby/examples/mailserver.rb b/content/releases/qpid-proton-0.16.0/messenger/ruby/examples/mailserver.rb new file mode 100755 index 000..594a0e3 --- /dev/null +++ b/content/releases/qpid-proton-0.16.0/messenger/ruby/examples/mailserver.rb @@ -0,0 +1,84 @@ +#!/usr/bin/env ruby +# +# 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. +# + +require 'qpid_proton' +require 'optparse' + +FAILED = 0 +CONNECTION_UP = 1 +AUTHENTICATING = 2 + +$options = { + :verbose => false, + :address => ["amqp://~0.0.0.0"], +} + +OptionParser.new do |opts| + opts.banner = "Usage: mailserver [options] ... " + + opts.on("-v", "--verbose", :NONE, + "Print status messages to stdout") do
[06/51] [partial] qpid-site git commit: PROTON-1374: update the website for Proton 0.16.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/releases/qpid-proton-0.16.0/proton/c/api/message_8h.html -- diff --git a/content/releases/qpid-proton-0.16.0/proton/c/api/message_8h.html b/content/releases/qpid-proton-0.16.0/proton/c/api/message_8h.html new file mode 100755 index 000..5bc4a97 --- /dev/null +++ b/content/releases/qpid-proton-0.16.0/proton/c/api/message_8h.html @@ -0,0 +1,295 @@ +http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd;> +http://www.w3.org/1999/xhtml;> + + + + +Qpid Proton C API: proton/message.h File Reference + + + + + + + + $(document).ready(initResizable); + $(window).load(resizeHeight); + + + + + $(document).ready(function() { searchBox.OnSelectItem(0); }); + + + + + + + + + + + Qpid Proton C API + 0.16.0 + + + + + + + + + + + + + + + + + + +var searchBox = new SearchBox("searchBox", "search",false,'Search'); + + + + + + + + + + + + +$(document).ready(function(){initNavTree('message_8h.html','');}); + + + + +AllClassesFilesFunctionsVariablesTypedefsEnumerationsEnumeratorGroupsPages + + + + + + + + + +Macros +Typedefs +Functions + +message.h File Reference + + + +A mutable holder of application content. +More... +#include proton/import_export.h +#include proton/types.h +#include proton/codec.h +#include proton/error.h +#include proton/type_compat.h + +Go to the source code of this file. + + +Macros + +#definePN_DEFAULT_PRIORITY +Default priority for messages. + + + +Typedefs +typedef struct pn_message_tpn_message_t +An AMQP Message object. More... + + + +Functions +pn_message_t *pn_message (void) +Construct a new pn_message_t. More... + +voidpn_message_free (pn_message_t *msg) +Free a previously constructed pn_message_t. More... + +voidpn_message_clear (pn_message_t *msg) +Clears the content of a pn_message_t. More... + +intpn_message_errno (pn_message_t *msg) +Access the error code of a message. More... + +pn_error_t *pn_message_error (pn_message_t *msg) +Access the error information for a message. More... + +boolpn_message_is_inferred (pn_message_t *msg) +Get the inferred flag for a message. More... + +intpn_message_set_inferred (pn_message_t *msg, bool inferred) +Set the inferred flag for a message. More... + +boolpn_message_is_durable (pn_message_t *msg) +Get the durable flag for a message. More... + +intpn_message_set_durable (pn_message_t *msg, bool durable) +Set the durable flag for a message. More... + +uint8_tpn_message_get_priority (pn_message_t *msg) +Get the priority for a message. More... + +intpn_message_set_priority (pn_message_t *msg, uint8_t priority) +Set the priority for a message. More... + +pn_millis_tpn_message_get_ttl (pn_message_t *msg) +Get the ttl for a message. More... + +intpn_message_set_ttl (pn_message_t *msg, pn_millis_t ttl) +Set the ttl for a message. More... + +boolpn_message_is_first_acquirer (pn_message_t *msg) +Get the first acquirer flag for a message. More... + +intpn_message_set_first_acquirer (pn_message_t *msg, bool first) +Set the first acquirer flag for a message. More... + +uint32_tpn_message_get_delivery_count (pn_message_t *msg) +Get the delivery count for a message. More... + +intpn_message_set_delivery_count (pn_message_t *msg, uint32_t count) +Set the delivery count for a message. More... + +pn_data_t *pn_message_id (pn_message_t *msg) +Get/set the id for a message. More... + +pn_atom_tpn_message_get_id (pn_message_t *msg) +Get the id for a message. More... + +intpn_message_set_id (pn_message_t *msg, pn_atom_t id) +Set the id for a message. More... + +pn_bytes_tpn_message_get_user_id (pn_message_t *msg) +Get the user id for a message. More... + +intpn_message_set_user_id (pn_message_t *msg, pn_bytes_t user_id) +Set the user id for a message. More... + +const char *pn_message_get_address (pn_message_t *msg) +Get the address for a message. More... + +intpn_message_set_address (pn_message_t *msg, const char *address) +Set the address for a message. More... + +const char *pn_message_get_subject (pn_message_t *msg) +Get the subject for a message. More... + +intpn_message_set_subject (pn_message_t *msg, const char *subject) +Set the subject for a message. More... + +const char *pn_message_get_reply_to (pn_message_t *msg) +Get the reply_to for a message. More... + +intpn_message_set_reply_to (pn_message_t *msg, const char *reply_to) +Set the reply_to for a message. More... + +pn_data_t *pn_message_correlation_id (pn_message_t *msg) +Get/set the correlation id for a message. More... + +pn_atom_tpn_message_get_correlation_id (pn_message_t *msg) +Get the correlation id for a message. More... + +intpn_message_set_correlation_id (pn_message_t *msg, pn_atom_t id) +Set the correlation id
[35/51] [partial] qpid-site git commit: PROTON-1374: update the website for Proton 0.16.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/releases/qpid-proton-0.16.0/proton/c/api/examples.html -- diff --git a/content/releases/qpid-proton-0.16.0/proton/c/api/examples.html b/content/releases/qpid-proton-0.16.0/proton/c/api/examples.html new file mode 100755 index 000..135e50c --- /dev/null +++ b/content/releases/qpid-proton-0.16.0/proton/c/api/examples.html @@ -0,0 +1,113 @@ +http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd;> +http://www.w3.org/1999/xhtml;> + + + + +Qpid Proton C API: Examples + + + + + + + + $(document).ready(initResizable); + $(window).load(resizeHeight); + + + + + $(document).ready(function() { searchBox.OnSelectItem(0); }); + + + + + + + + + + + Qpid Proton C API + 0.16.0 + + + + + + + + + + + + + + + + + + +var searchBox = new SearchBox("searchBox", "search",false,'Search'); + + + + + + + + + + + + +$(document).ready(function(){initNavTree('examples.html','');}); + + + + +AllClassesFilesFunctionsVariablesTypedefsEnumerationsEnumeratorGroupsPages + + + + + + + + + +Examples + + +Here is a list of all examples: +broker.c + +receive.c + +send.c + + + + + + + +Generated by +http://www.doxygen.org/index.html;> + 1.8.3.1 + + + + http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/releases/qpid-proton-0.16.0/proton/c/api/examples.js -- diff --git a/content/releases/qpid-proton-0.16.0/proton/c/api/examples.js b/content/releases/qpid-proton-0.16.0/proton/c/api/examples.js new file mode 100755 index 000..a6fda03 --- /dev/null +++ b/content/releases/qpid-proton-0.16.0/proton/c/api/examples.js @@ -0,0 +1,6 @@ +var examples = +[ +[ "broker.c", "broker_8c-example.html", null ], +[ "receive.c", "receive_8c-example.html", null ], +[ "send.c", "send_8c-example.html", null ] +]; \ No newline at end of file http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/releases/qpid-proton-0.16.0/proton/c/api/files.html -- diff --git a/content/releases/qpid-proton-0.16.0/proton/c/api/files.html b/content/releases/qpid-proton-0.16.0/proton/c/api/files.html new file mode 100755 index 000..2a43839 --- /dev/null +++ b/content/releases/qpid-proton-0.16.0/proton/c/api/files.html @@ -0,0 +1,131 @@ +http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd;> +http://www.w3.org/1999/xhtml;> + + + + +Qpid Proton C API: File List + + + + + + + + $(document).ready(initResizable); + $(window).load(resizeHeight); + + + + + $(document).ready(function() { searchBox.OnSelectItem(0); }); + + + + + + + + + + + Qpid Proton C API + 0.16.0 + + + + + + + + + + + + + + + + + + +var searchBox = new SearchBox("searchBox", "search",false,'Search'); + + + + + + + + + + + + +$(document).ready(function(){initNavTree('files.html','');}); + + + + +AllClassesFilesFunctionsVariablesTypedefsEnumerationsEnumeratorGroupsPages + + + + + + + + + +File List + + +Here is a list of all documented files with brief descriptions: +[detail level 12] +proton +codec.hAMQP data encoding and decoding. +condition.hAn endpoint error state. +connection.hA channel for communication between two peers on a network. +connection_driver.hExperimental - Low-level IO integration +delivery.hA message transfer. +disposition.hDelivery state +error.hA Proton API error. +event.hProtocol and transport events. +link.hA channel for transferring messages. +listener.hExperimental - A listener for incoming connections for the Proactor +message.hA mutable holder of application content. +messenger.hDeprecated - The Messenger API +proactor.hExperimental - Multithreaded IO +sasl.hSASL secure transport layer. +session.hA container of links. +ssl.hSSL secure transport layer. +terminus.hA source or target for messages. +transport.hA network channel supporting an AMQP connection. +types.hAMQP and API data types. +url.hDeprecated - A URL parser +version.h + + + + + + + +Generated by +http://www.doxygen.org/index.html;> + 1.8.3.1 + + + + http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/releases/qpid-proton-0.16.0/proton/c/api/files.js -- diff --git a/content/releases/qpid-proton-0.16.0/proton/c/api/files.js b/content/releases/qpid-proton-0.16.0/proton/c/api/files.js new file mode 100755 index 000..ea134f4 --- /dev/null +++ b/content/releases/qpid-proton-0.16.0/proton/c/api/files.js @@ -0,0 +1,4 @@ +var files = +[ +[ "proton", "dir_25143d27009f52d175c1d192441a738a.html",
[22/51] [partial] qpid-site git commit: PROTON-1374: update the website for Proton 0.16.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/releases/qpid-proton-0.16.0/proton/c/api/group__event.html -- diff --git a/content/releases/qpid-proton-0.16.0/proton/c/api/group__event.html b/content/releases/qpid-proton-0.16.0/proton/c/api/group__event.html new file mode 100755 index 000..cda7a74 --- /dev/null +++ b/content/releases/qpid-proton-0.16.0/proton/c/api/group__event.html @@ -0,0 +1,1003 @@ +http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd;> +http://www.w3.org/1999/xhtml;> + + + + +Qpid Proton C API: Event + + + + + + + + $(document).ready(initResizable); + $(window).load(resizeHeight); + + + + + $(document).ready(function() { searchBox.OnSelectItem(0); }); + + + + + + + + + + + Qpid Proton C API + 0.16.0 + + + + + + + + + + + + + + + + + + +var searchBox = new SearchBox("searchBox", "search",false,'Search'); + + + + + + + + + + + + +$(document).ready(function(){initNavTree('group__event.html','');}); + + + + +AllClassesFilesFunctionsVariablesTypedefsEnumerationsEnumeratorGroupsPages + + + + + + + + + +Typedefs +Enumerations +Functions + +EventCore + + + +Protocol and transport events. +More... + + +Typedefs +typedef struct pn_event_tpn_event_t +Notification of a state change in the protocol engine. More... + +typedef struct pn_event_batch_tpn_event_batch_t +Experimental - A batch of events to handle. More... + +typedef struct pn_collector_tpn_collector_t +An event collector. More... + + + +Enumerations +enum pn_event_type_t { +PN_EVENT_NONE, +PN_REACTOR_INIT, +PN_REACTOR_QUIESCED, +PN_REACTOR_FINAL, + +PN_TIMER_TASK, +PN_CONNECTION_INIT, +PN_CONNECTION_BOUND, +PN_CONNECTION_UNBOUND, + +PN_CONNECTION_LOCAL_OPEN, +PN_CONNECTION_REMOTE_OPEN, +PN_CONNECTION_LOCAL_CLOSE, +PN_CONNECTION_REMOTE_CLOSE, + +PN_CONNECTION_FINAL, +PN_SESSION_INIT, +PN_SESSION_LOCAL_OPEN, +PN_SESSION_REMOTE_OPEN, + +PN_SESSION_LOCAL_CLOSE, +PN_SESSION_REMOTE_CLOSE, +PN_SESSION_FINAL, +PN_LINK_INIT, + +PN_LINK_LOCAL_OPEN, +PN_LINK_REMOTE_OPEN, +PN_LINK_LOCAL_CLOSE, +PN_LINK_REMOTE_CLOSE, + +PN_LINK_LOCAL_DETACH, +PN_LINK_REMOTE_DETACH, +PN_LINK_FLOW, +PN_LINK_FINAL, + +PN_DELIVERY, +PN_TRANSPORT, +PN_TRANSPORT_AUTHENTICATED, +PN_TRANSPORT_ERROR, + +PN_TRANSPORT_HEAD_CLOSED, +PN_TRANSPORT_WRITE_CLOSED, +PN_TRANSPORT_TAIL_CLOSED, +PN_TRANSPORT_READ_CLOSED, + +PN_TRANSPORT_CLOSED, +PN_SELECTABLE_INIT, +PN_SELECTABLE_UPDATED, +PN_SELECTABLE_READABLE, + +PN_SELECTABLE_WRITABLE, +PN_SELECTABLE_ERROR, +PN_SELECTABLE_EXPIRED, +PN_SELECTABLE_FINAL, + +PN_CONNECTION_WAKE, +PN_LISTENER_ACCEPT, +PN_LISTENER_CLOSE, +PN_PROACTOR_INTERRUPT, + +PN_PROACTOR_TIMEOUT, +PN_PROACTOR_INACTIVE + + } +An event type. More... + + + +Functions +const char *pn_event_type_name (pn_event_type_t type) +Get a human readable name for an event type. More... + +pn_collector_t *pn_collector (void) +Construct a collector. More... + +voidpn_collector_free (pn_collector_t *collector) +Free a collector. More... + +voidpn_collector_release (pn_collector_t *collector) +Release a collector. More... + +pn_event_t *pn_collector_put (pn_collector_t *collector, const pn_class_t *clazz, void *context, pn_event_type_t type) +Place a new event on a collector. More... + +pn_event_t *pn_collector_peek (pn_collector_t *collector) +Access the head event contained by a collector. More... + +boolpn_collector_pop (pn_collector_t *collector) +Clear the head event on a collector. More... + +pn_event_t *pn_collector_next (pn_collector_t *collector) +Return the next event to be handled. More... + +pn_event_t *pn_collector_prev (pn_collector_t *collector) +Return the same event as the previous call to pn_collector_next() More... + +boolpn_collector_more (pn_collector_t *collector) +Check if there are more events after the current event. More... + +pn_event_type_tpn_event_type (pn_event_t *event) +Get the type of an event. More... + +const pn_class_t *pn_event_class (pn_event_t *event) +Get the class associated with the event context. More... + + +void *pn_event_context (pn_event_t *event) +Get the context associated with an event. + +pn_connection_t *pn_event_connection (pn_event_t *event) +Get the connection associated with an event. More... + +pn_session_t *pn_event_session (pn_event_t *event) +Get the session associated with an event. More... + +pn_link_t *pn_event_link (pn_event_t *event) +Get the link associated with an event. More... + +pn_delivery_t *pn_event_delivery (pn_event_t *event) +Get the delivery associated with an event. More... + +pn_transport_t *pn_event_transport (pn_event_t *event) +Get the transport associated with an event. More... + +pn_record_t
[20/51] [partial] qpid-site git commit: PROTON-1374: update the website for Proton 0.16.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/releases/qpid-proton-0.16.0/proton/c/api/group__link.html -- diff --git a/content/releases/qpid-proton-0.16.0/proton/c/api/group__link.html b/content/releases/qpid-proton-0.16.0/proton/c/api/group__link.html new file mode 100755 index 000..2b08208 --- /dev/null +++ b/content/releases/qpid-proton-0.16.0/proton/c/api/group__link.html @@ -0,0 +1,1820 @@ +http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd;> +http://www.w3.org/1999/xhtml;> + + + + +Qpid Proton C API: Link + + + + + + + + $(document).ready(initResizable); + $(window).load(resizeHeight); + + + + + $(document).ready(function() { searchBox.OnSelectItem(0); }); + + + + + + + + + + + Qpid Proton C API + 0.16.0 + + + + + + + + + + + + + + + + + + +var searchBox = new SearchBox("searchBox", "search",false,'Search'); + + + + + + + + + + + + +$(document).ready(function(){initNavTree('group__link.html','');}); + + + + +AllClassesFilesFunctionsVariablesTypedefsEnumerationsEnumeratorGroupsPages + + + + + + + + + +Typedefs +Enumerations +Functions + +LinkCore + + + +A channel for transferring messages. +More... + + +Typedefs +typedef struct pn_link_tpn_link_t +An AMQP Link object. More... + + + +Enumerations +enum pn_snd_settle_mode_t { PN_SND_UNSETTLED, +PN_SND_SETTLED, +PN_SND_MIXED + } +Describes the permitted/expected settlement behaviours of a sending link. More... + +enum pn_rcv_settle_mode_t { PN_RCV_FIRST, +PN_RCV_SECOND + } +Describes the permitted/expected settlement behaviours of a receiving link. More... + + + +Functions +pn_link_t *pn_sender (pn_session_t *session, const char *name) +Construct a new sender on a session. More... + +pn_link_t *pn_receiver (pn_session_t *session, const char *name) +Construct a new receiver on a session. More... + +voidpn_link_free (pn_link_t *link) +Free a link object. More... + +void *pn_link_get_context (pn_link_t *link) + +voidpn_link_set_context (pn_link_t *link, void *context) + +pn_record_t *pn_link_attachments (pn_link_t *link) +Get the attachments that are associated with a link object. More... + +const char *pn_link_name (pn_link_t *link) +Get the name of a link. More... + +boolpn_link_is_sender (pn_link_t *link) +Test if a link is a sender. More... + +boolpn_link_is_receiver (pn_link_t *link) +Test if a link is a receiver. More... + +pn_state_tpn_link_state (pn_link_t *link) +Get the endpoint state flags for a link. More... + +pn_error_t *pn_link_error (pn_link_t *link) + +pn_condition_t *pn_link_condition (pn_link_t *link) +Get the local condition associated with a link endpoint. More... + +pn_condition_t *pn_link_remote_condition (pn_link_t *link) +Get the remote condition associated with a link endpoint. More... + +pn_session_t *pn_link_session (pn_link_t *link) +Get the parent session for a link object. More... + +pn_link_t *pn_link_head (pn_connection_t *connection, pn_state_t state) +Retrieve the first link that matches the given state mask. More... + +pn_link_t *pn_link_next (pn_link_t *link, pn_state_t state) +Retrieve the next link that matches the given state mask. More... + +voidpn_link_open (pn_link_t *link) +Open a link. More... + +voidpn_link_close (pn_link_t *link) +Close a link. More... + +voidpn_link_detach (pn_link_t *link) +Detach a link. More... + +pn_terminus_t *pn_link_source (pn_link_t *link) +Access the locally defined source definition for a link. More... + +pn_terminus_t *pn_link_target (pn_link_t *link) +Access the locally defined target definition for a link. More... + +pn_terminus_t *pn_link_remote_source (pn_link_t *link) +Access the remotely defined source definition for a link. More... + +pn_terminus_t *pn_link_remote_target (pn_link_t *link) +Access the remotely defined target definition for a link. More... + +pn_delivery_t *pn_link_current (pn_link_t *link) +Get the current delivery for a link. More... + +boolpn_link_advance (pn_link_t *link) +Advance the current delivery of a link to the next delivery on the link. More... + +intpn_link_credit (pn_link_t *link) +Get the credit balance for a link. More... + +intpn_link_queued (pn_link_t *link) +Get the number of queued deliveries for a link. More... + +intpn_link_remote_credit (pn_link_t *link) +Get the remote view of the credit for a link. More... + +boolpn_link_get_drain (pn_link_t *link) +Get the drain flag for a link. More... + +intpn_link_drained (pn_link_t *link) +Drain excess credit for a link. More... + +intpn_link_available (pn_link_t *link) +Get the available deliveries hint for a link. More... + +pn_snd_settle_mode_tpn_link_snd_settle_mode (pn_link_t *link) +Get the local sender settle mode for a link.
[15/51] [partial] qpid-site git commit: PROTON-1374: update the website for Proton 0.16.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/releases/qpid-proton-0.16.0/proton/c/api/group__messenger.js -- diff --git a/content/releases/qpid-proton-0.16.0/proton/c/api/group__messenger.js b/content/releases/qpid-proton-0.16.0/proton/c/api/group__messenger.js new file mode 100755 index 000..caef443 --- /dev/null +++ b/content/releases/qpid-proton-0.16.0/proton/c/api/group__messenger.js @@ -0,0 +1,81 @@ +var group__messenger = +[ +[ "PN_CUMULATIVE", "group__messenger.html#ga6c2e8d006ec05b913fa1e6dc510d23b9", null ], +[ "PN_FLAGS_ALLOW_INSECURE_MECHS", "group__messenger.html#ga118fb0c2384257dff5d72eea787e4a0c", null ], +[ "PN_FLAGS_CHECK_ROUTES", "group__messenger.html#gad5ad0b67fef0e761dc0138b9621ffa14", null ], +[ "pn_messenger_t", "group__messenger.html#ga0d342bb795d48591ad6b3f867766b8b1", null ], +[ "pn_subscription_t", "group__messenger.html#gabd73703511b9dae193765e9e57864291", null ], +[ "pn_tracker_t", "group__messenger.html#gab1173cfe4bcaa0a530c8035dc75f42c7", null ], +[ "pn_status_t", "group__messenger.html#ga242e4ee54b9c0a416443c7da5f6e045b", [ + [ "PN_STATUS_UNKNOWN", "group__messenger.html#gga242e4ee54b9c0a416443c7da5f6e045ba0b46b1041679460baaba2ddcdb2173f2", null ], + [ "PN_STATUS_PENDING", "group__messenger.html#gga242e4ee54b9c0a416443c7da5f6e045ba4b0354a77173cd75c69159e15c23f611", null ], + [ "PN_STATUS_ACCEPTED", "group__messenger.html#gga242e4ee54b9c0a416443c7da5f6e045ba693fd9044a50a4f02e842d04a4bf1467", null ], + [ "PN_STATUS_REJECTED", "group__messenger.html#gga242e4ee54b9c0a416443c7da5f6e045baf109df703952744009b3547f3b8f32bf", null ], + [ "PN_STATUS_RELEASED", "group__messenger.html#gga242e4ee54b9c0a416443c7da5f6e045ba67079750477effb7935df83381c47852", null ], + [ "PN_STATUS_MODIFIED", "group__messenger.html#gga242e4ee54b9c0a416443c7da5f6e045ba77d94a6b6b745eef9307f144b57e81e8", null ], + [ "PN_STATUS_ABORTED", "group__messenger.html#gga242e4ee54b9c0a416443c7da5f6e045ba1239e8ada7eabe2aeab98f2c881cd2ee", null ], + [ "PN_STATUS_SETTLED", "group__messenger.html#gga242e4ee54b9c0a416443c7da5f6e045ba1181bc7f51502ae11ed240866cd64583", null ] +] ], +[ "pn_messenger", "group__messenger.html#gabe045d16ca8eb1e3cc87387e2ae82433", null ], +[ "pn_messenger_accept", "group__messenger.html#ga11cd0d3423482e1ddda7a8b0cbb581c7", null ], +[ "pn_messenger_buffered", "group__messenger.html#ga15adeb707f15b86df1e5486c34a060e6", null ], +[ "pn_messenger_deadline", "group__messenger.html#ga223e7c16f3e84f4e573864c3881b3b4b", null ], +[ "pn_messenger_delivery", "group__messenger.html#ga65f22122f08bc93de2bfe155aa12d0b0", null ], +[ "pn_messenger_errno", "group__messenger.html#gacfd10311abca28521fe7aa9cabfff61c", null ], +[ "pn_messenger_error", "group__messenger.html#ga0301664be9c54b3a573578776ad2a5d2", null ], +[ "pn_messenger_free", "group__messenger.html#ga530295575eda95e3c19316d41bd1baa7", null ], +[ "pn_messenger_get", "group__messenger.html#gaa6d85929e4b4b574690927ddde00c540", null ], +[ "pn_messenger_get_certificate", "group__messenger.html#ga1d0c003a1fb5e20b894e2deb8b43118b", null ], +[ "pn_messenger_get_flags", "group__messenger.html#ga9f4e2fbfb7eb7bfd9acd7ad758d24085", null ], +[ "pn_messenger_get_incoming_window", "group__messenger.html#ga45d578f39673ad59ca65d2042054abee", null ], +[ "pn_messenger_get_link", "group__messenger.html#ga757aeef23d47ecc2a9a461b882686417", null ], +[ "pn_messenger_get_outgoing_window", "group__messenger.html#gac191bdb410b7839d6306a0d8e5ac19e1", null ], +[ "pn_messenger_get_password", "group__messenger.html#ga3f02ad7340a59c5982e6223aaeea803a", null ], +[ "pn_messenger_get_private_key", "group__messenger.html#gab692f989aed2aa83bd71b7fa7196aeb1", null ], +[ "pn_messenger_get_remote_idle_timeout", "group__messenger.html#ga9be25d57cda5a6e1c5658b0f362c41c7", null ], +[ "pn_messenger_get_timeout", "group__messenger.html#ga083ba6296a1ae1dfe45c0fb82da823eb", null ], +[ "pn_messenger_get_trusted_certificates", "group__messenger.html#ga955b218a8f58560e9e228ca14fba21f2", null ], +[ "pn_messenger_incoming", "group__messenger.html#ga43cf91b5528c2729b3ff9ae1d2a7d257", null ], +[ "pn_messenger_incoming_subscription", "group__messenger.html#gae351d031d2ef29bdb137a59d461c4253", null ], +[ "pn_messenger_incoming_tracker", "group__messenger.html#gafe31e771826f8107d93fc276c9715aab", null ], +[ "pn_messenger_interrupt", "group__messenger.html#ga9da14c67acc17bc5fec6f34e2749534f", null ], +[ "pn_messenger_is_blocking", "group__messenger.html#gaf572cbf224105d08898d2906336712f7", null ], +[ "pn_messenger_is_passive", "group__messenger.html#ga63805c35f18ef041c69a14564dc1bce4", null ], +[ "pn_messenger_name", "group__messenger.html#ga71197163a69770575df74e3cee617429", null ], +[
[18/51] [partial] qpid-site git commit: PROTON-1374: update the website for Proton 0.16.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/releases/qpid-proton-0.16.0/proton/c/api/group__message.html -- diff --git a/content/releases/qpid-proton-0.16.0/proton/c/api/group__message.html b/content/releases/qpid-proton-0.16.0/proton/c/api/group__message.html new file mode 100755 index 000..1a32abd --- /dev/null +++ b/content/releases/qpid-proton-0.16.0/proton/c/api/group__message.html @@ -0,0 +1,1946 @@ +http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd;> +http://www.w3.org/1999/xhtml;> + + + + +Qpid Proton C API: Message + + + + + + + + $(document).ready(initResizable); + $(window).load(resizeHeight); + + + + + $(document).ready(function() { searchBox.OnSelectItem(0); }); + + + + + + + + + + + Qpid Proton C API + 0.16.0 + + + + + + + + + + + + + + + + + + +var searchBox = new SearchBox("searchBox", "search",false,'Search'); + + + + + + + + + + + + +$(document).ready(function(){initNavTree('group__message.html','');}); + + + + +AllClassesFilesFunctionsVariablesTypedefsEnumerationsEnumeratorGroupsPages + + + + + + + + + +Macros +Typedefs +Functions + +MessageCore + + + +A mutable holder of application content. +More... + + +Macros + +#definePN_DEFAULT_PRIORITY +Default priority for messages. + + + +Typedefs +typedef struct pn_message_tpn_message_t +An AMQP Message object. More... + + + +Functions +pn_message_t *pn_message (void) +Construct a new pn_message_t. More... + +voidpn_message_free (pn_message_t *msg) +Free a previously constructed pn_message_t. More... + +voidpn_message_clear (pn_message_t *msg) +Clears the content of a pn_message_t. More... + +intpn_message_errno (pn_message_t *msg) +Access the error code of a message. More... + +pn_error_t *pn_message_error (pn_message_t *msg) +Access the error information for a message. More... + +boolpn_message_is_inferred (pn_message_t *msg) +Get the inferred flag for a message. More... + +intpn_message_set_inferred (pn_message_t *msg, bool inferred) +Set the inferred flag for a message. More... + +boolpn_message_is_durable (pn_message_t *msg) +Get the durable flag for a message. More... + +intpn_message_set_durable (pn_message_t *msg, bool durable) +Set the durable flag for a message. More... + +uint8_tpn_message_get_priority (pn_message_t *msg) +Get the priority for a message. More... + +intpn_message_set_priority (pn_message_t *msg, uint8_t priority) +Set the priority for a message. More... + +pn_millis_tpn_message_get_ttl (pn_message_t *msg) +Get the ttl for a message. More... + +intpn_message_set_ttl (pn_message_t *msg, pn_millis_t ttl) +Set the ttl for a message. More... + +boolpn_message_is_first_acquirer (pn_message_t *msg) +Get the first acquirer flag for a message. More... + +intpn_message_set_first_acquirer (pn_message_t *msg, bool first) +Set the first acquirer flag for a message. More... + +uint32_tpn_message_get_delivery_count (pn_message_t *msg) +Get the delivery count for a message. More... + +intpn_message_set_delivery_count (pn_message_t *msg, uint32_t count) +Set the delivery count for a message. More... + +pn_data_t *pn_message_id (pn_message_t *msg) +Get/set the id for a message. More... + +pn_atom_tpn_message_get_id (pn_message_t *msg) +Get the id for a message. More... + +intpn_message_set_id (pn_message_t *msg, pn_atom_t id) +Set the id for a message. More... + +pn_bytes_tpn_message_get_user_id (pn_message_t *msg) +Get the user id for a message. More... + +intpn_message_set_user_id (pn_message_t *msg, pn_bytes_t user_id) +Set the user id for a message. More... + +const char *pn_message_get_address (pn_message_t *msg) +Get the address for a message. More... + +intpn_message_set_address (pn_message_t *msg, const char *address) +Set the address for a message. More... + +const char *pn_message_get_subject (pn_message_t *msg) +Get the subject for a message. More... + +intpn_message_set_subject (pn_message_t *msg, const char *subject) +Set the subject for a message. More... + +const char *pn_message_get_reply_to (pn_message_t *msg) +Get the reply_to for a message. More... + +intpn_message_set_reply_to (pn_message_t *msg, const char *reply_to) +Set the reply_to for a message. More... + +pn_data_t *pn_message_correlation_id (pn_message_t *msg) +Get/set the correlation id for a message. More... + +pn_atom_tpn_message_get_correlation_id (pn_message_t *msg) +Get the correlation id for a message. More... + +intpn_message_set_correlation_id (pn_message_t *msg, pn_atom_t id) +Set the correlation id for a message. More... + +const char *pn_message_get_content_type (pn_message_t *msg) +Get the content_type for a message. More... + +intpn_message_set_content_type (pn_message_t *msg,
[50/51] [partial] qpid-site git commit: PROTON-1374: update the website for Proton 0.16.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/documentation.html -- diff --git a/content/documentation.html b/content/documentation.html index 719f297..15b4478 100644 --- a/content/documentation.html +++ b/content/documentation.html @@ -133,10 +133,10 @@ You can find older versions with our Overview -C API reference -C++ API reference -Java API reference -Python API reference +C API reference +C++ API reference +Java API reference +Python API reference http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/download.html -- diff --git a/content/download.html b/content/download.html index 16c713e..8f528a3 100644 --- a/content/download.html +++ b/content/download.html @@ -138,8 +138,8 @@ process. The downloads on this page are from our Qpid Proton - http://www.apache.org/dyn/closer.lua/qpid/proton/0.15.0/qpid-proton-0.15.0.tar.gz;>qpid-proton-0.15.0.tar.gz - http://www.apache.org/dist/qpid/proton/0.15.0/qpid-proton-0.15.0.tar.gz.asc;>ASC, http://www.apache.org/dist/qpid/proton/0.15.0/qpid-proton-0.15.0.tar.gz.md5;>MD5, http://www.apache.org/dist/qpid/proton/0.15.0/qpid-proton-0.15.0.tar.gz.sha1;>SHA1 + http://www.apache.org/dyn/closer.lua/qpid/proton/0.16.0/qpid-proton-0.16.0.tar.gz;>qpid-proton-0.16.0.tar.gz + http://www.apache.org/dist/qpid/proton/0.16.0/qpid-proton-0.16.0.tar.gz.asc;>ASC, http://www.apache.org/dist/qpid/proton/0.16.0/qpid-proton-0.16.0.tar.gz.md5;>MD5, http://www.apache.org/dist/qpid/proton/0.16.0/qpid-proton-0.16.0.tar.gz.sha1;>SHA1 Qpid JMS (AMQP 1.0) http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/maven.html -- diff --git a/content/maven.html b/content/maven.html index 1b09459..92aec4c 100644 --- a/content/maven.html +++ b/content/maven.html @@ -149,7 +149,7 @@ https://github.com/apache/qpid-proton/blob/go1{/dir}/{file}#L{line}"/> dependency groupIdorg.apache.qpid/groupId artifactIdproton-j/artifactId - version0.15.0/version + version0.16.0/version /dependency http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/proton/index.html -- diff --git a/content/proton/index.html b/content/proton/index.html index 366be94..04d9c55 100644 --- a/content/proton/index.html +++ b/content/proton/index.html @@ -147,17 +147,17 @@ platform, environment, or language. More about -C API reference -C++ introduction -C++ tutorial -C++ examples -C++ API reference -Java API reference -Python overview -Python tutorial -Python examples -Python API reference -https://git-wip-us.apache.org/repos/asf?p=qpid-proton.git;a=blob_plain;f=INSTALL.md;hb=0.15.0;>Installing Qpid Proton +C API reference +C++ introduction +C++ tutorial +C++ examples +C++ API reference +Java API reference +Python overview +Python tutorial +Python examples +Python API reference +https://git-wip-us.apache.org/repos/asf?p=qpid-proton.git;a=blob_plain;f=INSTALL.md;hb=0.16.0;>Installing Qpid Proton @@ -169,7 +169,7 @@ platform, environment, or language. More about Releases -Qpid Proton 0.15.0 +Qpid Proton 0.16.0 Past releases Work in progress http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/proton/messenger.html -- diff --git a/content/proton/messenger.html b/content/proton/messenger.html index 99484fa..9a2dda1 100644 --- a/content/proton/messenger.html +++ b/content/proton/messenger.html @@ -129,14 +129,14 @@ find previous versions with our -C API reference -C examples -Java API reference -Perl examples -PHP examples -Python API reference -Python examples -Ruby examples +C API reference +C examples +Java API reference +Perl examples +PHP examples +Python API reference +Python examples +Ruby examples http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/releases/index.html -- diff --git a/content/releases/index.html b/content/releases/index.html index 6ca84b1..e09661a 100644 --- a/content/releases/index.html +++ b/content/releases/index.html @@ -124,8 +124,8 @@ the Current releases +Qpid Proton 0.16.0, December 2016 Qpid for Java 6.1.0, November 2016 -Qpid Proton 0.15.0, October 2016 Qpid JMS 0.11.1, October 2016 Qpid C++ 1.35.0, September 2016 Qpid Python 1.35.0, August 2016 @@ -138,6 +138,7 @@ the Qpid for Java 6.0.5, November 2016 +Qpid Proton 0.15.0, October 2016 Qpid JMS 0.11.0, September 2016 Qpid Proton 0.14.0, August 2016 Qpid for Java 6.0.4, July 2016 http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/releases/qpid-proton-0.10/index.html
[47/51] [partial] qpid-site git commit: PROTON-1374: update the website for Proton 0.16.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/releases/qpid-proton-0.16.0/messenger/perl/examples/server.pl.html -- diff --git a/content/releases/qpid-proton-0.16.0/messenger/perl/examples/server.pl.html b/content/releases/qpid-proton-0.16.0/messenger/perl/examples/server.pl.html new file mode 100644 index 000..9eef553 --- /dev/null +++ b/content/releases/qpid-proton-0.16.0/messenger/perl/examples/server.pl.html @@ -0,0 +1,252 @@ + + +http://www.w3.org/1999/xhtml; xml:lang="en"> + +server.pl - 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 for Java + 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 Proton 0.16.0Perl AMQP Messenger Examplesserver.pl + + + +server.pl +use strict; +use warnings; +use Getopt::Long; +use Pod::Usage; + +use qpid_proton; + +my $help = 0; +my $man = 0; + +GetOptions( +man = \$man, +help|? = \$help +) or pod2usage(2); + +pod2usage(1) if $help; +pod2usage(-exitval = 0, -verbose = 2) if $man; + +pod2usage(2) unless scalar(@ARGV); + +# create a messenger for receiving and holding +# incoming messages +our $messenger = new qpid::proton::Messenger; +$messenger-start; + +# subscribe the messenger to all addresses specified sources +foreach (@ARGV) { +$messenger-subscribe($_); +} + +sub dispatch { +my $request = $_[0]; +my $reply = $_[1]; + +if ($request-get_subject) { +$reply-set_subject(Re: . $request-get_subject); +} + +$reply-set_properties($request-get_properties); +print Dispatched . $request-get_subject . \n; +my $properties = $request-get_properties; +foreach (keys %{$properties}) { +my $value = $properties-{%_}; +print \t$_: $value\n; +} +} + +our $message = new qpid::proton::Message; +our $reply = new qpid::proton::Message; + +while(1) { +$messenger-receive(1) if $messenger-incoming 10; + +if ($messenger-incoming 0) { +$messenger-get($message); + +if ($message-get_reply_to) { +print $message-get_reply_to . \n; +$reply-set_address($message-get_reply_to); +$reply-set_correlation_id($message-get_correlation_id); +$reply-set_body($message-get_body); +} +dispatch($message, $reply); +$messenger-put($reply); +$messenger-send; +} +} + +$message-stop; + +__END__ + +=head1 NAME + +server - Proton example server application for Perl. + +=head1 SYNOPSIS + +server.pl [OPTIONS] addr1 ... addrn + + Options: + --help - This help message. + --man - Show the full documentation. + +=over 8 + +=item B--help + +Prints a brief help message and exits. + +=item B--man + +Prints the man page and exits. + +=back + +=head2 ADDRESS + +The form an address takes is: + +[amqp://]domain[/name] + +=cut + + +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 +
[46/51] [partial] qpid-site git commit: PROTON-1374: update the website for Proton 0.16.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/releases/qpid-proton-0.16.0/messenger/python/examples/recv.py.html -- diff --git a/content/releases/qpid-proton-0.16.0/messenger/python/examples/recv.py.html b/content/releases/qpid-proton-0.16.0/messenger/python/examples/recv.py.html new file mode 100644 index 000..19544c3 --- /dev/null +++ b/content/releases/qpid-proton-0.16.0/messenger/python/examples/recv.py.html @@ -0,0 +1,185 @@ + + +http://www.w3.org/1999/xhtml; xml:lang="en"> + +recv.py - 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 for Java + 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 Proton 0.16.0Python AMQP Messenger Examplesrecv.py + + + +recv.py +from __future__ import print_function +import sys, optparse +from proton import * + +parser = optparse.OptionParser(usage=usage: %prog [options] addr_1 ... addr_n, + description=simple message receiver) +parser.add_option(-c, --certificate, help=path to certificate file) +parser.add_option(-k, --private-key, help=path to private key file) +parser.add_option(-p, --password, help=password for private key file) + +opts, args = parser.parse_args() + +if not args: + args = [amqp://~0.0.0.0] + +mng = Messenger() +mng.certificate=opts.certificate +mng.private_key=opts.private_key +mng.password=opts.password +mng.start() + +for a in args: + mng.subscribe(a) + +msg = Message() +while True: + mng.recv() + while mng.incoming: +try: + mng.get(msg) +except Exception as e: + print(e) +else: + print(msg.address, msg.subject or (no subject), msg.properties, msg.body) + +mng.stop() + + +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/7833dc2a/content/releases/qpid-proton-0.16.0/messenger/python/examples/recv_async.py -- diff --git a/content/releases/qpid-proton-0.16.0/messenger/python/examples/recv_async.py b/content/releases/qpid-proton-0.16.0/messenger/python/examples/recv_async.py new file mode 100755 index 000..b38c31a --- /dev/null +++ b/content/releases/qpid-proton-0.16.0/messenger/python/examples/recv_async.py @@ -0,0 +1,56 @@ +#!/usr/bin/python +# +# 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
[49/51] [partial] qpid-site git commit: PROTON-1374: update the website for Proton 0.16.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/releases/qpid-proton-0.16.0/messenger/c/examples/recv.c.html -- diff --git a/content/releases/qpid-proton-0.16.0/messenger/c/examples/recv.c.html b/content/releases/qpid-proton-0.16.0/messenger/c/examples/recv.c.html new file mode 100644 index 000..579b360 --- /dev/null +++ b/content/releases/qpid-proton-0.16.0/messenger/c/examples/recv.c.html @@ -0,0 +1,283 @@ + + +http://www.w3.org/1999/xhtml; xml:lang="en"> + +recv.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 for Java + 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 Proton 0.16.0C AMQP Messenger Examplesrecv.c + + + +recv.c +#include proton/message.h +#include proton/messenger.h + +#include pncompat/misc_funcs.inc +#include stdio.h +#include stdlib.h +#include ctype.h + +#define check(messenger) \ + { \ +if(pn_messenger_errno(messenger)) \ +{ \ + die(__FILE__, __LINE__, pn_error_text(pn_messenger_error(messenger))); \ +} \ + } \ + +void die(const char *file, int line, const char *message) +{ + fprintf(stderr, %s:%i: %s\n, file, line, message); + exit(1); +} + +void usage(void) +{ + printf(Usage: recv [options] addr\n); + printf(-c\tPath to the certificate file.\n); + printf(-k\tPath to the private key file.\n); + printf(-p\tPassword for the private key.\n); + printf(addr\tAn address.\n); + exit(0); +} + +int main(int argc, char** argv) +{ + char* certificate = NULL; + char* privatekey = NULL; + char* password = NULL; + char* address = (char *) amqp://~0.0.0.0; + int c; + + pn_message_t * message; + pn_messenger_t * messenger; + + message = pn_message(); + messenger = pn_messenger(NULL); + + opterr = 0; + + while((c = getopt(argc, argv, hc:k:p:)) != -1) + { +switch(c) +{ +case h: + usage(); + break; + +case c: certificate = optarg; break; +case k: privatekey = optarg; break; +case p: password = optarg; break; + +case ?: + if(optopt == c || + optopt == k || + optopt == p) + { +fprintf(stderr, Option -%c requires an argument.\n, optopt); + } + else if(isprint(optopt)) + { +fprintf(stderr, Unknown option `-%c.\n, optopt); + } + else + { +fprintf(stderr, Unknown option character `\\x%x.\n, optopt); + } + return 1; +default: + abort(); +} + } + + if (optind argc) + { +address = argv[optind]; + } + + + if(certificate) + { +pn_messenger_set_certificate(messenger, certificate); + } + + if(privatekey) + { +pn_messenger_set_private_key(messenger, privatekey); + } + + if(password) + { +pn_messenger_set_password(messenger, password); + } + + pn_messenger_start(messenger); + check(messenger); + + pn_messenger_subscribe(messenger, address); + check(messenger); + + for(;;) + { +pn_messenger_recv(messenger, 1024); +check(messenger); + +while(pn_messenger_incoming(messenger)) +{ + pn_messenger_get(messenger, message); + check(messenger); + + { + char buffer[1024]; + size_t buffsize = sizeof(buffer); + const char* subject
[39/51] [partial] qpid-site git commit: PROTON-1374: update the website for Proton 0.16.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/releases/qpid-proton-0.16.0/proton/c/api/connection__driver_8h_source.html -- diff --git a/content/releases/qpid-proton-0.16.0/proton/c/api/connection__driver_8h_source.html b/content/releases/qpid-proton-0.16.0/proton/c/api/connection__driver_8h_source.html new file mode 100755 index 000..88b6143 --- /dev/null +++ b/content/releases/qpid-proton-0.16.0/proton/c/api/connection__driver_8h_source.html @@ -0,0 +1,191 @@ +http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd;> +http://www.w3.org/1999/xhtml;> + + + + +Qpid Proton C API: proton/connection_driver.h Source File + + + + + + + + $(document).ready(initResizable); + $(window).load(resizeHeight); + + + + + $(document).ready(function() { searchBox.OnSelectItem(0); }); + + + + + + + + + + + Qpid Proton C API + 0.16.0 + + + + + + + + + + + + + + + + + + +var searchBox = new SearchBox("searchBox", "search",false,'Search'); + + + + + + + + + + + + +$(document).ready(function(){initNavTree('connection__driver_8h_source.html','');}); + + + + +AllClassesFilesFunctionsVariablesTypedefsEnumerationsEnumeratorGroupsPages + + + + + + + + + +connection_driver.h + + +Go to the documentation of this file.1#ifndef PROTON_CONNECTION_DRIVER_H + 2#define PROTON_CONNECTION_DRIVER_H 1 + 3 + 4/* + 5 * Licensed to the Apache Software Foundation (ASF) under one + 6 * or more contributor license agreements. See the NOTICE file + 7 * distributed with this work for additional information + 8 * regarding copyright ownership. The ASF licenses this file + 9 * 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/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 limitations + 20 * under the License. + 21 */ + 22 + 77#include proton/import_export.h + 78#include proton/event.h + 79#include proton/types.h + 80 + 81#include stdarg.h + 82 + 83#ifdef __cplusplus + 84extern C { + 85#endif + 86 + 90typedef struct pn_connection_driver_t { + 91 pn_connection_t *connection; + 92 pn_transport_t *transport; + 93 pn_event_batch_t batch; + 94} pn_connection_driver_t; + 95 + 112PN_EXTERN int pn_connection_driver_init(pn_connection_driver_t*, pn_connection_t*, pn_transport_t*); + 113 + 119PN_EXTERN int pn_connection_driver_bind(pn_connection_driver_t *d); + 120 + 125PN_EXTERN void pn_connection_driver_destroy(pn_connection_driver_t *); + 126 + 135PN_EXTERN pn_rwbytes_t pn_connection_driver_read_buffer(pn_connection_driver_t *); + 136 + 141PN_EXTERN void pn_connection_driver_read_done(pn_connection_driver_t *, size_t n); + 142 + 146PN_EXTERN void pn_connection_driver_read_close(pn_connection_driver_t *); + 147 + 151PN_EXTERN bool pn_connection_driver_read_closed(pn_connection_driver_t *); + 152 + 161 PN_EXTERN pn_bytes_t pn_connection_driver_write_buffer(pn_connection_driver_t *); + 162 + 167PN_EXTERN void pn_connection_driver_write_done(pn_connection_driver_t *, size_t n); + 168 + 172PN_EXTERN void pn_connection_driver_write_close(pn_connection_driver_t *); + 173 + 177PN_EXTERN bool pn_connection_driver_write_closed(pn_connection_driver_t *); + 178 + 182PN_EXTERN void pn_connection_driver_close(pn_connection_driver_t * c); + 183 + 191PN_EXTERN pn_event_t* pn_connection_driver_next_event(pn_connection_driver_t *); + 192 + 196PN_EXTERN bool pn_connection_driver_has_event(pn_connection_driver_t *); + 197 + 204PN_EXTERN bool pn_connection_driver_finished(pn_connection_driver_t *); + 205 + 215PN_EXTERN void pn_connection_driver_errorf(pn_connection_driver_t *d, const char *name, const char *fmt, ...); + 216 + 220PN_EXTERN void pn_connection_driver_verrorf(pn_connection_driver_t *d, const char *name, const char *fmt, va_list); + 221 + 225PN_EXTERN void pn_connection_driver_log(pn_connection_driver_t *d, const char *msg); + 226 + 230PN_EXTERN void pn_connection_driver_logf(pn_connection_driver_t *d, char *fmt, ...); + 231 + 235PN_EXTERN void pn_connection_driver_vlogf(pn_connection_driver_t *d, const char *fmt, va_list ap); + 236 + 241PN_EXTERN pn_connection_driver_t* pn_event_batch_connection_driver(pn_event_batch_t *batch); + 242 + 247#ifdef __cplusplus +
[13/51] [partial] qpid-site git commit: PROTON-1374: update the website for Proton 0.16.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/releases/qpid-proton-0.16.0/proton/c/api/group__ssl.html -- diff --git a/content/releases/qpid-proton-0.16.0/proton/c/api/group__ssl.html b/content/releases/qpid-proton-0.16.0/proton/c/api/group__ssl.html new file mode 100755 index 000..adc8e95 --- /dev/null +++ b/content/releases/qpid-proton-0.16.0/proton/c/api/group__ssl.html @@ -0,0 +1,984 @@ +http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd;> +http://www.w3.org/1999/xhtml;> + + + + +Qpid Proton C API: SSL + + + + + + + + $(document).ready(initResizable); + $(window).load(resizeHeight); + + + + + $(document).ready(function() { searchBox.OnSelectItem(0); }); + + + + + + + + + + + Qpid Proton C API + 0.16.0 + + + + + + + + + + + + + + + + + + +var searchBox = new SearchBox("searchBox", "search",false,'Search'); + + + + + + + + + + + + +$(document).ready(function(){initNavTree('group__ssl.html','');}); + + + + +AllClassesFilesFunctionsVariablesTypedefsEnumerationsEnumeratorGroupsPages + + + + + + + + + +Typedefs +Enumerations +Functions + +SSLCore + + + +SSL secure transport layer. +More... + + +Typedefs +typedef struct pn_ssl_domain_tpn_ssl_domain_t +API for using SSL with the Transport Layer. More... + +typedef struct pn_ssl_tpn_ssl_t + + + +Enumerations +enum pn_ssl_mode_t { PN_SSL_MODE_CLIENT, +PN_SSL_MODE_SERVER + } +Determines the type of SSL endpoint. More... + +enum pn_ssl_resume_status_t { PN_SSL_RESUME_UNKNOWN, +PN_SSL_RESUME_NEW, +PN_SSL_RESUME_REUSED + } +Indicates whether an SSL session has been resumed. More... + +enum pn_ssl_verify_mode_t { PN_SSL_VERIFY_NULL, +PN_SSL_VERIFY_PEER, +PN_SSL_ANONYMOUS_PEER, +PN_SSL_VERIFY_PEER_NAME + } +Determines the level of peer validation. More... + +enum pn_ssl_cert_subject_subfield { +PN_SSL_CERT_SUBJECT_COUNTRY_NAME, +PN_SSL_CERT_SUBJECT_STATE_OR_PROVINCE, +PN_SSL_CERT_SUBJECT_CITY_OR_LOCALITY, +PN_SSL_CERT_SUBJECT_ORGANIZATION_NAME, + +PN_SSL_CERT_SUBJECT_ORGANIZATION_UNIT, +PN_SSL_CERT_SUBJECT_COMMON_NAME + + } +Enumeration identifying the sub fields of the subject field in the ssl certificate. + +enum pn_ssl_hash_alg { PN_SSL_SHA1, +PN_SSL_SHA256, +PN_SSL_SHA512, +PN_SSL_MD5 + } +Enumeration identifying hashing algorithm. + + + +Functions +boolpn_ssl_present (void) +Tests for SSL implementation present. More... + +pn_ssl_domain_t *pn_ssl_domain (pn_ssl_mode_t mode) +Create an SSL configuration domain. More... + +voidpn_ssl_domain_free (pn_ssl_domain_t *domain) +Release an SSL configuration domain. More... + +intpn_ssl_domain_set_credentials (pn_ssl_domain_t *domain, const char *credential_1, const char *credential_2, const char *password) +Set the certificate that identifies the local node to the remote. More... + +intpn_ssl_domain_set_trusted_ca_db (pn_ssl_domain_t *domain, const char *certificate_db) +Configure the set of trusted CA certificates used by this domain to verify peers. More... + +intpn_ssl_domain_set_peer_authentication (pn_ssl_domain_t *domain, const pn_ssl_verify_mode_t mode, const char *trusted_CAs) +Configure the level of verification used on the peer certificate. More... + +intpn_ssl_domain_allow_unsecured_client (pn_ssl_domain_t *domain) +Permit a server to accept connection requests from non-SSL clients. More... + +pn_ssl_t *pn_ssl (pn_transport_t *transport) +Create a new SSL session object associated with a transport. More... + +intpn_ssl_init (pn_ssl_t *ssl, pn_ssl_domain_t *domain, const char *session_id) +Initialize an SSL session. More... + +boolpn_ssl_get_cipher_name (pn_ssl_t *ssl, char *buffer, size_t size) +Get the name of the Cipher that is currently in use. More... + +intpn_ssl_get_ssf (pn_ssl_t *ssl) +Get the SSF (security strength factor) of the Cipher that is currently in use. More... + +boolpn_ssl_get_protocol_name (pn_ssl_t *ssl, char *buffer, size_t size) +Get the name of the SSL protocol that is currently in use. More... + +pn_ssl_resume_status_tpn_ssl_resume_status (pn_ssl_t *ssl) +Check whether the state has been resumed. More... + +intpn_ssl_set_peer_hostname (pn_ssl_t *ssl, const char *hostname) +Set the expected identity of the remote peer. More... + +intpn_ssl_get_peer_hostname (pn_ssl_t *ssl, char *hostname, size_t *bufsize) +Access the configured peer identity. More... + +const char *pn_ssl_get_remote_subject (pn_ssl_t *ssl) +Get the subject from the peers certificate. More... + +intpn_ssl_get_cert_fingerprint (pn_ssl_t *ssl0, char *fingerprint, size_t fingerprint_length, pn_ssl_hash_alg hash_alg) +Get the fingerprint of the certificate. More... + +const char *pn_ssl_get_remote_subject_subfield (pn_ssl_t *ssl0, pn_ssl_cert_subject_subfield field) +Returns a char
[05/51] [partial] qpid-site git commit: PROTON-1374: update the website for Proton 0.16.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/releases/qpid-proton-0.16.0/proton/c/api/message_8h_source.html -- diff --git a/content/releases/qpid-proton-0.16.0/proton/c/api/message_8h_source.html b/content/releases/qpid-proton-0.16.0/proton/c/api/message_8h_source.html new file mode 100755 index 000..99e8938 --- /dev/null +++ b/content/releases/qpid-proton-0.16.0/proton/c/api/message_8h_source.html @@ -0,0 +1,255 @@ +http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd;> +http://www.w3.org/1999/xhtml;> + + + + +Qpid Proton C API: proton/message.h Source File + + + + + + + + $(document).ready(initResizable); + $(window).load(resizeHeight); + + + + + $(document).ready(function() { searchBox.OnSelectItem(0); }); + + + + + + + + + + + Qpid Proton C API + 0.16.0 + + + + + + + + + + + + + + + + + + +var searchBox = new SearchBox("searchBox", "search",false,'Search'); + + + + + + + + + + + + +$(document).ready(function(){initNavTree('message_8h_source.html','');}); + + + + +AllClassesFilesFunctionsVariablesTypedefsEnumerationsEnumeratorGroupsPages + + + + + + + + + +message.h + + +Go to the documentation of this file. 1#ifndef PROTON_MESSAGE_H + 2#define PROTON_MESSAGE_H 1 + 3 + 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 information + 9 * 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 proton/import_export.h + 26#include proton/types.h + 27#include proton/codec.h + 28#include proton/error.h + 29#include proton/type_compat.h + 30 + 31#ifdef __cplusplus + 32extern C { + 33#endif + 34 + 51typedef struct pn_message_t pn_message_t; + 52 + 56#define PN_DEFAULT_PRIORITY (4) + 57 + 66PN_EXTERN pn_message_t * pn_message(void); + 67 + 73PN_EXTERN void pn_message_free(pn_message_t *msg); + 74 + 84PN_EXTERN void pn_message_clear(pn_message_t *msg); + 85 + 97PN_EXTERN intpn_message_errno(pn_message_t *msg); + 98 + 111PN_EXTERN pn_error_t*pn_message_error(pn_message_t *msg); + 112 + 127PN_EXTERN bool pn_message_is_inferred(pn_message_t *msg); + 128 + 139PN_EXTERN intpn_message_set_inferred(pn_message_t *msg, bool inferred); + 140 + 141// standard message headers and properties + 142 + 152PN_EXTERN bool pn_message_is_durable (pn_message_t *msg); + 153 + 164PN_EXTERN intpn_message_set_durable (pn_message_t *msg, bool durable); + 165 + 176PN_EXTERN uint8_tpn_message_get_priority (pn_message_t *msg); + 177 + 187PN_EXTERN intpn_message_set_priority (pn_message_t *msg, uint8_t priority); + 188 + 201PN_EXTERN pn_millis_tpn_message_get_ttl (pn_message_t *msg); + 202 + 212PN_EXTERN intpn_message_set_ttl (pn_message_t *msg, pn_millis_t ttl); + 213 + 226PN_EXTERN bool pn_message_is_first_acquirer (pn_message_t *msg); + 227 + 238PN_EXTERN intpn_message_set_first_acquirer(pn_message_t *msg, bool first); + 239 + 250PN_EXTERN uint32_t pn_message_get_delivery_count(pn_message_t *msg); + 251 + 262PN_EXTERN intpn_message_set_delivery_count (pn_message_t *msg, uint32_t count); + 263 + 277PN_EXTERN pn_data_t *pn_message_id(pn_message_t *msg); + 278 + 291PN_EXTERN pn_atom_t pn_message_get_id(pn_message_t *msg); + 292 + 304PN_EXTERN intpn_message_set_id(pn_message_t *msg, pn_atom_t id); + 305 + 319PN_EXTERN pn_bytes_t pn_message_get_user_id (pn_message_t *msg); + 320 + 331PN_EXTERN intpn_message_set_user_id (pn_message_t *msg, pn_bytes_t user_id); + 332 + 347PN_EXTERN const char * pn_message_get_address (pn_message_t *msg); + 348 + 361PN_EXTERN int
[43/51] [partial] qpid-site git commit: PROTON-1374: update the website for Proton 0.16.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/releases/qpid-proton-0.16.0/proton/c/api/codec_8h.html -- diff --git a/content/releases/qpid-proton-0.16.0/proton/c/api/codec_8h.html b/content/releases/qpid-proton-0.16.0/proton/c/api/codec_8h.html new file mode 100755 index 000..65346fc --- /dev/null +++ b/content/releases/qpid-proton-0.16.0/proton/c/api/codec_8h.html @@ -0,0 +1,423 @@ +http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd;> +http://www.w3.org/1999/xhtml;> + + + + +Qpid Proton C API: proton/codec.h File Reference + + + + + + + + $(document).ready(initResizable); + $(window).load(resizeHeight); + + + + + $(document).ready(function() { searchBox.OnSelectItem(0); }); + + + + + + + + + + + Qpid Proton C API + 0.16.0 + + + + + + + + + + + + + + + + + + +var searchBox = new SearchBox("searchBox", "search",false,'Search'); + + + + + + + + + + + + +$(document).ready(function(){initNavTree('codec_8h.html','');}); + + + + +AllClassesFilesFunctionsVariablesTypedefsEnumerationsEnumeratorGroupsPages + + + + + + + + + +Classes +Typedefs +Enumerations +Functions + +codec.h File Reference + + + +AMQP data encoding and decoding. +More... +#include proton/import_export.h +#include proton/object.h +#include proton/types.h +#include proton/error.h +#include proton/type_compat.h +#include stdarg.h + +Go to the source code of this file. + + +Classes +struct pn_atom_t +A descriminated union that holds any scalar AMQP value. More... + + + +Typedefs +typedef struct pn_data_tpn_data_t +An AMQP Data object. More... + + + +Enumerations +enum pn_type_t { +PN_NULL, +PN_BOOL, +PN_UBYTE, +PN_BYTE, + +PN_USHORT, +PN_SHORT, +PN_UINT, +PN_INT, + +PN_CHAR, +PN_ULONG, +PN_LONG, +PN_TIMESTAMP, + +PN_FLOAT, +PN_DOUBLE, +PN_DECIMAL32, +PN_DECIMAL64, + +PN_DECIMAL128, +PN_UUID, +PN_BINARY, +PN_STRING, + +PN_SYMBOL, +PN_DESCRIBED, +PN_ARRAY, +PN_LIST, + +PN_MAP, +PN_INVALID + + } +Identifies an AMQP type. More... + + + +Functions +const char *pn_type_name (pn_type_t type) +Return a string name for an AMQP type. More... + +pn_data_t *pn_data (size_t capacity) +Construct a pn_data_t object with the supplied initial capacity. More... + +voidpn_data_free (pn_data_t *data) +Free a pn_data_t object. More... + +intpn_data_errno (pn_data_t *data) +Access the current error code for a given pn_data_t. More... + +pn_error_t *pn_data_error (pn_data_t *data) +Access the current error for a givn pn_data_t. More... + +voidpn_data_clear (pn_data_t *data) +Clears a pn_data_t object. More... + +size_tpn_data_size (pn_data_t *data) +Returns the total number of nodes contained in a pn_data_t object. More... + +voidpn_data_rewind (pn_data_t *data) +Clears current node pointer and sets the parent to the root node. More... + +boolpn_data_next (pn_data_t *data) +Advances the current node to its next sibling and returns true. More... + +boolpn_data_prev (pn_data_t *data) +Moves the current node to its previous sibling and returns true. More... + +boolpn_data_enter (pn_data_t *data) +Sets the parent node to the current node and clears the current node. More... + +boolpn_data_exit (pn_data_t *data) +Sets the current node to the parent node and the parent node to its own parent. More... + +pn_type_tpn_data_type (pn_data_t *data) +Access the type of the current node. More... + +intpn_data_print (pn_data_t *data) +Prints the contents of a pn_data_t object using pn_data_format() to stdout. More... + +intpn_data_format (pn_data_t *data, char *bytes, size_t *size) +Formats the contents of a pn_data_t object in a human readable way and writes them to the indicated location. More... + +ssize_tpn_data_encode (pn_data_t *data, char *bytes, size_t size) +Writes the contents of a data object to the given buffer as an AMQP data stream. More... + +ssize_tpn_data_encoded_size (pn_data_t *data) +Returns the number of bytes needed to encode a data object. More... + +ssize_tpn_data_decode (pn_data_t *data, const char *bytes, size_t size) +Decodes a single value from the contents of the AMQP data stream into the current data object. More... + +intpn_data_put_list (pn_data_t *data) +Puts an empty list value into a pn_data_t. More... + +intpn_data_put_map (pn_data_t *data) +Puts an empty map value into a pn_data_t. More... + +intpn_data_put_array (pn_data_t *data, bool described, pn_type_t type) +Puts an empty array value into a pn_data_t. More... + +intpn_data_put_described (pn_data_t *data) +Puts a described value into a pn_data_t object. More... + +intpn_data_put_null (pn_data_t *data) +Puts a PN_NULL value. More... + +intpn_data_put_bool (pn_data_t *data, bool b) +Puts a PN_BOOL value. More... +
[34/51] [partial] qpid-site git commit: PROTON-1374: update the website for Proton 0.16.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/releases/qpid-proton-0.16.0/proton/c/api/globals_0x64.html -- diff --git a/content/releases/qpid-proton-0.16.0/proton/c/api/globals_0x64.html b/content/releases/qpid-proton-0.16.0/proton/c/api/globals_0x64.html new file mode 100755 index 000..420a135 --- /dev/null +++ b/content/releases/qpid-proton-0.16.0/proton/c/api/globals_0x64.html @@ -0,0 +1,507 @@ +http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd;> +http://www.w3.org/1999/xhtml;> + + + + +Qpid Proton C API: File Members + + + + + + + + $(document).ready(initResizable); + $(window).load(resizeHeight); + + + + + $(document).ready(function() { searchBox.OnSelectItem(0); }); + + + + + + + + + + + Qpid Proton C API + 0.16.0 + + + + + + + + + + + + + + + + + + +var searchBox = new SearchBox("searchBox", "search",false,'Search'); + + + + + + + + + + + + +$(document).ready(function(){initNavTree('globals_0x64.html','');}); + + + + +AllClassesFilesFunctionsVariablesTypedefsEnumerationsEnumeratorGroupsPages + + + + + + + + +Here is a list of all documented file members with links to the documentation: + +- d - +pn_data() +: codec.h + +pn_data_append() +: codec.h + +pn_data_appendn() +: codec.h + +pn_data_clear() +: codec.h + +pn_data_copy() +: codec.h + +pn_data_decode() +: codec.h + +pn_data_dump() +: codec.h + +pn_data_encode() +: codec.h + +pn_data_encoded_size() +: codec.h + +pn_data_enter() +: codec.h + +pn_data_errno() +: codec.h + +pn_data_error() +: codec.h + +pn_data_exit() +: codec.h + +pn_data_format() +: codec.h + +pn_data_free() +: codec.h + +pn_data_get_array() +: codec.h + +pn_data_get_array_type() +: codec.h + +pn_data_get_atom() +: codec.h + +pn_data_get_binary() +: codec.h + +pn_data_get_bool() +: codec.h + +pn_data_get_byte() +: codec.h + +pn_data_get_bytes() +: codec.h + +pn_data_get_char() +: codec.h + +pn_data_get_decimal128() +: codec.h + +pn_data_get_decimal32() +: codec.h + +pn_data_get_decimal64() +: codec.h + +pn_data_get_double() +: codec.h + +pn_data_get_float() +: codec.h + +pn_data_get_int() +: codec.h + +pn_data_get_list() +: codec.h + +pn_data_get_long() +: codec.h + +pn_data_get_map() +: codec.h + +pn_data_get_short() +: codec.h + +pn_data_get_string() +: codec.h + +pn_data_get_symbol() +: codec.h + +pn_data_get_timestamp() +: codec.h + +pn_data_get_ubyte() +: codec.h + +pn_data_get_uint() +: codec.h + +pn_data_get_ulong() +: codec.h + +pn_data_get_ushort() +: codec.h + +pn_data_get_uuid() +: codec.h + +pn_data_is_array_described() +: codec.h + +pn_data_is_described() +: codec.h + +pn_data_is_null() +: codec.h + +pn_data_narrow() +: codec.h + +pn_data_next() +: codec.h + +pn_data_point() +: codec.h + +pn_data_prev() +: codec.h + +pn_data_print() +: codec.h + +pn_data_put_array() +: codec.h + +pn_data_put_atom() +: codec.h + +pn_data_put_binary() +: codec.h + +pn_data_put_bool() +: codec.h + +pn_data_put_byte() +: codec.h + +pn_data_put_char() +: codec.h + +pn_data_put_decimal128() +: codec.h + +pn_data_put_decimal32() +: codec.h + +pn_data_put_decimal64() +: codec.h + +pn_data_put_described() +: codec.h + +pn_data_put_double() +: codec.h + +pn_data_put_float() +: codec.h + +pn_data_put_int() +: codec.h + +pn_data_put_list() +: codec.h + +pn_data_put_long() +: codec.h + +pn_data_put_map() +: codec.h + +pn_data_put_null() +: codec.h + +pn_data_put_short() +: codec.h + +pn_data_put_string() +: codec.h + +pn_data_put_symbol() +: codec.h + +pn_data_put_timestamp() +: codec.h + +pn_data_put_ubyte() +: codec.h + +pn_data_put_uint() +: codec.h + +pn_data_put_ulong() +: codec.h + +pn_data_put_ushort() +: codec.h + +pn_data_put_uuid() +: codec.h + +pn_data_restore() +: codec.h + +pn_data_rewind() +: codec.h + +pn_data_size() +: codec.h + +pn_data_t +: codec.h + +pn_data_type() +: codec.h + +pn_data_widen() +: codec.h + +PN_DECIMAL128 +: codec.h + +PN_DECIMAL32 +: codec.h + +pn_decimal32_t +: types.h + +PN_DECIMAL64 +: codec.h + +pn_decimal64_t +: types.h + +PN_DEFAULT_PRIORITY +: message.h + +PN_DELIVERIES +: terminus.h + +PN_DELIVERY +: event.h + +pn_delivery() +: delivery.h + +pn_delivery_attachments() +: delivery.h + +pn_delivery_buffered() +: delivery.h + +pn_delivery_clear() +: delivery.h + +pn_delivery_current() +: delivery.h + +pn_delivery_dump() +: delivery.h + +pn_delivery_get_context() +: delivery.h + +pn_delivery_link() +: delivery.h + +pn_delivery_local() +: delivery.h + +pn_delivery_local_state() +: delivery.h + +pn_delivery_partial() +: delivery.h + +pn_delivery_pending() +: delivery.h + +pn_delivery_readable() +: delivery.h + +pn_delivery_remote() +: delivery.h + +pn_delivery_remote_state() +: delivery.h + +pn_delivery_set_context() +: delivery.h + +pn_delivery_settle() +: delivery.h + +pn_delivery_settled() +: delivery.h + +pn_delivery_t +: types.h +
[29/51] [partial] qpid-site git commit: PROTON-1374: update the website for Proton 0.16.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/releases/qpid-proton-0.16.0/proton/c/api/group__condition.html -- diff --git a/content/releases/qpid-proton-0.16.0/proton/c/api/group__condition.html b/content/releases/qpid-proton-0.16.0/proton/c/api/group__condition.html new file mode 100755 index 000..7369be7 --- /dev/null +++ b/content/releases/qpid-proton-0.16.0/proton/c/api/group__condition.html @@ -0,0 +1,471 @@ +http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd;> +http://www.w3.org/1999/xhtml;> + + + + +Qpid Proton C API: Condition + + + + + + + + $(document).ready(initResizable); + $(window).load(resizeHeight); + + + + + $(document).ready(function() { searchBox.OnSelectItem(0); }); + + + + + + + + + + + Qpid Proton C API + 0.16.0 + + + + + + + + + + + + + + + + + + +var searchBox = new SearchBox("searchBox", "search",false,'Search'); + + + + + + + + + + + + +$(document).ready(function(){initNavTree('group__condition.html','');}); + + + + +AllClassesFilesFunctionsVariablesTypedefsEnumerationsEnumeratorGroupsPages + + + + + + + + + +Typedefs +Functions + +ConditionCore + + + +An endpoint error state. +More... + + +Typedefs +typedef struct pn_condition_tpn_condition_t +An AMQP Condition object. More... + + + +Functions +boolpn_condition_is_set (pn_condition_t *condition) +Returns true if the condition object is holding some information, i.e. More... + +voidpn_condition_clear (pn_condition_t *condition) +Clears the condition object of any exceptional information. More... + +const char *pn_condition_get_name (pn_condition_t *condition) +Returns the name associated with the exceptional condition, or NULL if there is no conditional information set. More... + +intpn_condition_set_name (pn_condition_t *condition, const char *name) +Sets the name associated with the exceptional condition. More... + +const char *pn_condition_get_description (pn_condition_t *condition) +Gets the description associated with the exceptional condition. More... + +intpn_condition_set_description (pn_condition_t *condition, const char *description) +Sets the description associated with the exceptional condition. More... + +pn_data_t *pn_condition_info (pn_condition_t *condition) +Returns a data object that holds the additional information associated with the condition. More... + + +intpn_condition_vformat (pn_condition_t *, const char *name, const char *fmt, va_list ap) +Set the name and printf-style formatted description. + + +intpn_condition_format (pn_condition_t *, const char *name, const char *fmt,...) +Set the name and printf-style formatted description. + +boolpn_condition_is_redirect (pn_condition_t *condition) +Returns true if the condition is a redirect. More... + +const char *pn_condition_redirect_host (pn_condition_t *condition) +Retrieves the redirect host from the additional information associated with the condition. More... + +intpn_condition_redirect_port (pn_condition_t *condition) +Retrieves the redirect port from the additional information associated with the condition. More... + + +intpn_condition_copy (pn_condition_t *dest, pn_condition_t *src) +Copy the src condition to the dst condition. + + +pn_condition_t *pn_condition (void) +Create a condition object. + + +voidpn_condition_free (pn_condition_t *) +Free a condition object. + + +Detailed Description +An endpoint error state. +Typedef Documentation + + + + + + typedef struct pn_condition_t pn_condition_t + + + + +An AMQP Condition object. +Conditions hold exceptional information pertaining to the closing of an AMQP endpoint such as a Connection, Session, or Link. Conditions also hold similar information pertaining to deliveries that have reached terminal states. Connections, Sessions, Links, and Deliveries may all have local and remote conditions associated with them. +The local condition may be modified by the local endpoint to signal a particular condition to the remote peer. The remote condition may be examined by the local endpoint to detect whatever condition the remote peer may be signaling. Although often conditions are used to indicate errors, not all conditions are errors per/se, e.g. conditions may be used to redirect a connection from one host to another. +Every condition has a short symbolic name, a longer description, and an additional info map associated with it. The name identifies the formally defined condition, and the map contains additional information relevant to the identified condition. + + + +Function Documentation + + + + + + void pn_condition_clear + ( + pn_condition_t * + condition) + + + + + +Clears the condition
[40/51] [partial] qpid-site git commit: PROTON-1374: update the website for Proton 0.16.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/releases/qpid-proton-0.16.0/proton/c/api/connection_8h_source.html -- diff --git a/content/releases/qpid-proton-0.16.0/proton/c/api/connection_8h_source.html b/content/releases/qpid-proton-0.16.0/proton/c/api/connection_8h_source.html new file mode 100755 index 000..129449c --- /dev/null +++ b/content/releases/qpid-proton-0.16.0/proton/c/api/connection_8h_source.html @@ -0,0 +1,228 @@ +http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd;> +http://www.w3.org/1999/xhtml;> + + + + +Qpid Proton C API: proton/connection.h Source File + + + + + + + + $(document).ready(initResizable); + $(window).load(resizeHeight); + + + + + $(document).ready(function() { searchBox.OnSelectItem(0); }); + + + + + + + + + + + Qpid Proton C API + 0.16.0 + + + + + + + + + + + + + + + + + + +var searchBox = new SearchBox("searchBox", "search",false,'Search'); + + + + + + + + + + + + +$(document).ready(function(){initNavTree('connection_8h_source.html','');}); + + + + +AllClassesFilesFunctionsVariablesTypedefsEnumerationsEnumeratorGroupsPages + + + + + + + + + +connection.h + + +Go to the documentation of this file. 1#ifndef PROTON_CONNECTION_H + 2#define PROTON_CONNECTION_H 1 + 3 + 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 information + 9 * 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 proton/import_export.h + 26#include proton/codec.h + 27#include proton/condition.h + 28#include proton/error.h + 29#include proton/type_compat.h + 30#include proton/types.h + 31 + 32#include stddef.h + 33 + 34#ifdef __cplusplus + 35extern C { + 36#endif + 37 + 50#define PN_LOCAL_UNINIT (1) + 51 + 56#define PN_LOCAL_ACTIVE (2) + 57 + 61#define PN_LOCAL_CLOSED (4) + 62 + 66#define PN_REMOTE_UNINIT (8) + 67 + 71#define PN_REMOTE_ACTIVE (16) + 72 + 76#define PN_REMOTE_CLOSED (32) + 77 + 82#define PN_LOCAL_MASK (PN_LOCAL_UNINIT | PN_LOCAL_ACTIVE | PN_LOCAL_CLOSED) + 83 + 88#define PN_REMOTE_MASK (PN_REMOTE_UNINIT | PN_REMOTE_ACTIVE | PN_REMOTE_CLOSED) + 89 + 90PN_EXTERN pn_connection_t *pn_connection(void); + 91 + 97PN_EXTERN pn_connection_t *pn_connection(void); + 98 + 108PN_EXTERN void pn_connection_free(pn_connection_t *connection); + 109 + 119PN_EXTERN void pn_connection_release(pn_connection_t *connection); + 120 + 137PN_EXTERN pn_error_t *pn_connection_error(pn_connection_t *connection); + 138 + 157PN_EXTERN void pn_connection_collect(pn_connection_t *connection, pn_collector_t *collector); + 158 + 163PN_EXTERN pn_collector_t* pn_connection_collector(pn_connection_t *connection); + 164 + 177PN_EXTERN void *pn_connection_get_context(pn_connection_t *connection); + 178 + 190PN_EXTERN void pn_connection_set_context(pn_connection_t *connection, void *context); + 191 + 198PN_EXTERN pn_record_t *pn_connection_attachments(pn_connection_t *connection); + 199 + 206PN_EXTERN pn_state_t pn_connection_state(pn_connection_t *connection); + 207 + 216PN_EXTERN void pn_connection_open(pn_connection_t *connection); + 217 + 228PN_EXTERN void pn_connection_close(pn_connection_t *connection); + 229 + 238PN_EXTERN void pn_connection_reset(pn_connection_t *connection); + 239 + 256PN_EXTERN pn_condition_t *pn_connection_condition(pn_connection_t *connection); + 257 + 272PN_EXTERN pn_condition_t *pn_connection_remote_condition(pn_connection_t *connection); + 273 + 284PN_EXTERN const char *pn_connection_get_container(pn_connection_t *connection); + 285 + 292PN_EXTERN void pn_connection_set_container(pn_connection_t *connection, const char *container); + 293 + 308PN_EXTERN void pn_connection_set_user(pn_connection_t *connection, const char *user); + 309 + 323PN_EXTERN void pn_connection_set_password(pn_connection_t *connection, const char *password); + 324
[23/51] [partial] qpid-site git commit: PROTON-1374: update the website for Proton 0.16.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/releases/qpid-proton-0.16.0/proton/c/api/group__delivery.js -- diff --git a/content/releases/qpid-proton-0.16.0/proton/c/api/group__delivery.js b/content/releases/qpid-proton-0.16.0/proton/c/api/group__delivery.js new file mode 100755 index 000..2dac077 --- /dev/null +++ b/content/releases/qpid-proton-0.16.0/proton/c/api/group__delivery.js @@ -0,0 +1,48 @@ +var group__delivery = +[ +[ "PN_ACCEPTED", "group__delivery.html#gac64952b813a707586c6b3898e09552e4", null ], +[ "PN_MODIFIED", "group__delivery.html#ga247e3d1ac7c9096cdd28424353582962", null ], +[ "PN_RECEIVED", "group__delivery.html#gaae349c977b37b584aa62fff6515802ca", null ], +[ "PN_REJECTED", "group__delivery.html#ga44a2635392fe2e6f8869a7e1cd64db2f", null ], +[ "PN_RELEASED", "group__delivery.html#ga628179c16c4a5f5fd7734bc1bfc6edc3", null ], +[ "pn_delivery_t", "group__delivery.html#gacdfce854066c0a4ff4db9f9a0478f340", null ], +[ "pn_delivery_tag_t", "group__delivery.html#ga085159cb4136f84a02777bcc72c73fa3", null ], +[ "pn_disposition_t", "group__delivery.html#ga4b28f6cd033babd8a7595fc5d292dca1", null ], +[ "pn_delivery", "group__delivery.html#ga6a7ef2e317b4ed292cafbb358f0ba6ad", null ], +[ "pn_delivery_attachments", "group__delivery.html#ga3e014fc1759a212bc3ee9e513a274331", null ], +[ "pn_delivery_buffered", "group__delivery.html#ga1b7d56bd985e12a524c5cc5bc969bbdf", null ], +[ "pn_delivery_clear", "group__delivery.html#ga2e5da4adf0738458ba8568d894e6ea5b", null ], +[ "pn_delivery_current", "group__delivery.html#ga365b3efbdd225a239dcf4746127c5f33", null ], +[ "pn_delivery_dump", "group__delivery.html#ga0dbbc51564aea5b181d161ee7add1ddb", null ], +[ "pn_delivery_get_context", "group__delivery.html#ga17c16f34252597f9e737efae1e2ebb81", null ], +[ "pn_delivery_link", "group__delivery.html#gad3dd82fe9a649d70d4f3430c34699638", null ], +[ "pn_delivery_local", "group__delivery.html#ga404728c55cb6984dbb51956d764265a0", null ], +[ "pn_delivery_local_state", "group__delivery.html#gaee6fa7698d4b7cf335c2d7a4c7622898", null ], +[ "pn_delivery_partial", "group__delivery.html#ga23c7b3c678228ccb21378e7c8ec9a72d", null ], +[ "pn_delivery_pending", "group__delivery.html#ga17523835dbc8d1906bd71df69d09cc40", null ], +[ "pn_delivery_readable", "group__delivery.html#ga13364206124b653b90f5ee3ddae9ff35", null ], +[ "pn_delivery_remote", "group__delivery.html#ga2a666cb1a4cec190f0c9d20a7bcfae3f", null ], +[ "pn_delivery_remote_state", "group__delivery.html#gac1c3f2e7217b51f0e2f8c4264b0689d1", null ], +[ "pn_delivery_set_context", "group__delivery.html#ga91519d3e4568ee8b622d3653e20f60a6", null ], +[ "pn_delivery_settle", "group__delivery.html#ga98c275fd7158e8b9d7d48d70503d68df", null ], +[ "pn_delivery_settled", "group__delivery.html#ga516aee25357ac7cfde863bbceef02529", null ], +[ "pn_delivery_tag", "group__delivery.html#ga6b4029fa3c5a04c3e2320b9fdd0a76c5", null ], +[ "pn_delivery_update", "group__delivery.html#ga570c54003c2ba18b84405737925e5176", null ], +[ "pn_delivery_updated", "group__delivery.html#ga56d7f16a93e5dd16147a2ecd4896fcb9", null ], +[ "pn_delivery_writable", "group__delivery.html#ga533bd8dd766786695b6e71f8505252f1", null ], +[ "pn_disposition_annotations", "group__delivery.html#ga6ffa5f235cb616c823746a592a191fdb", null ], +[ "pn_disposition_condition", "group__delivery.html#ga8989de9cdcbbc7d0fadc1bba1f71d991", null ], +[ "pn_disposition_data", "group__delivery.html#ga9c168eb2b16c68d20b1e46ab904963cb", null ], +[ "pn_disposition_get_section_number", "group__delivery.html#ga5d0a4239487a90010403007f6cb268f0", null ], +[ "pn_disposition_get_section_offset", "group__delivery.html#ga7c5a14c31891750fcd211d90770a96d7", null ], +[ "pn_disposition_is_failed", "group__delivery.html#ga62d917e8a18288fdb1719bf5488c3f53", null ], +[ "pn_disposition_is_undeliverable", "group__delivery.html#gae4d5ce97c27e18d3dd843b829b81c585", null ], +[ "pn_disposition_set_failed", "group__delivery.html#ga8001f9574b5f37dff71ccfbc0524672e", null ], +[ "pn_disposition_set_section_number", "group__delivery.html#ga102eb1d46ff8fbed816d5c619e5fa52f", null ], +[ "pn_disposition_set_section_offset", "group__delivery.html#ga5940110912277fbd543f8be3066be98b", null ], +[ "pn_disposition_set_undeliverable", "group__delivery.html#ga805e6f4953eb559d5acfcfd7084fc4b3", null ], +[ "pn_disposition_type", "group__delivery.html#ga42387f728f4817fdd393cc98315db332", null ], +[ "pn_dtag", "group__delivery.html#gaea4522ac1fef9228fb6c743d2a36fd27", null ], +[ "pn_work_head", "group__delivery.html#ga5cb4f352dafe1b4866b68f27c37cbeac", null ], +[ "pn_work_next", "group__delivery.html#gad7b9248f26e4787983378e5310e4ffdd", null ] +]; \ No newline at end of file
[41/51] [partial] qpid-site git commit: PROTON-1374: update the website for Proton 0.16.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/releases/qpid-proton-0.16.0/proton/c/api/condition_8h.html -- diff --git a/content/releases/qpid-proton-0.16.0/proton/c/api/condition_8h.html b/content/releases/qpid-proton-0.16.0/proton/c/api/condition_8h.html new file mode 100755 index 000..34ce96d --- /dev/null +++ b/content/releases/qpid-proton-0.16.0/proton/c/api/condition_8h.html @@ -0,0 +1,180 @@ +http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd;> +http://www.w3.org/1999/xhtml;> + + + + +Qpid Proton C API: proton/condition.h File Reference + + + + + + + + $(document).ready(initResizable); + $(window).load(resizeHeight); + + + + + $(document).ready(function() { searchBox.OnSelectItem(0); }); + + + + + + + + + + + Qpid Proton C API + 0.16.0 + + + + + + + + + + + + + + + + + + +var searchBox = new SearchBox("searchBox", "search",false,'Search'); + + + + + + + + + + + + +$(document).ready(function(){initNavTree('condition_8h.html','');}); + + + + +AllClassesFilesFunctionsVariablesTypedefsEnumerationsEnumeratorGroupsPages + + + + + + + + + +Typedefs +Functions + +condition.h File Reference + + + +An endpoint error state. +More... +#include proton/import_export.h +#include proton/codec.h +#include proton/type_compat.h +#include stddef.h + +Go to the source code of this file. + + +Typedefs +typedef struct pn_condition_tpn_condition_t +An AMQP Condition object. More... + + + +Functions +boolpn_condition_is_set (pn_condition_t *condition) +Returns true if the condition object is holding some information, i.e. More... + +voidpn_condition_clear (pn_condition_t *condition) +Clears the condition object of any exceptional information. More... + +const char *pn_condition_get_name (pn_condition_t *condition) +Returns the name associated with the exceptional condition, or NULL if there is no conditional information set. More... + +intpn_condition_set_name (pn_condition_t *condition, const char *name) +Sets the name associated with the exceptional condition. More... + +const char *pn_condition_get_description (pn_condition_t *condition) +Gets the description associated with the exceptional condition. More... + +intpn_condition_set_description (pn_condition_t *condition, const char *description) +Sets the description associated with the exceptional condition. More... + +pn_data_t *pn_condition_info (pn_condition_t *condition) +Returns a data object that holds the additional information associated with the condition. More... + + +intpn_condition_vformat (pn_condition_t *, const char *name, const char *fmt, va_list ap) +Set the name and printf-style formatted description. + + +intpn_condition_format (pn_condition_t *, const char *name, const char *fmt,...) +Set the name and printf-style formatted description. + +boolpn_condition_is_redirect (pn_condition_t *condition) +Returns true if the condition is a redirect. More... + +const char *pn_condition_redirect_host (pn_condition_t *condition) +Retrieves the redirect host from the additional information associated with the condition. More... + +intpn_condition_redirect_port (pn_condition_t *condition) +Retrieves the redirect port from the additional information associated with the condition. More... + + +intpn_condition_copy (pn_condition_t *dest, pn_condition_t *src) +Copy the src condition to the dst condition. + + +pn_condition_t *pn_condition (void) +Create a condition object. + + +voidpn_condition_free (pn_condition_t *) +Free a condition object. + + +Detailed Description +An endpoint error state. + + + + + +protoncondition.h +Generated by +http://www.doxygen.org/index.html;> + 1.8.3.1 + + + + http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/releases/qpid-proton-0.16.0/proton/c/api/condition_8h.js -- diff --git a/content/releases/qpid-proton-0.16.0/proton/c/api/condition_8h.js b/content/releases/qpid-proton-0.16.0/proton/c/api/condition_8h.js new file mode 100755 index 000..24b7558 --- /dev/null +++ b/content/releases/qpid-proton-0.16.0/proton/c/api/condition_8h.js @@ -0,0 +1,19 @@ +var condition_8h = +[ +[ "pn_condition_t", "condition_8h.html#ga11eb7db7d2c205169fe3d47c996a95a5", null ], +[ "pn_condition", "condition_8h.html#gac798dc9acd131cb47a3e7291efffbc02", null ], +[ "pn_condition_clear", "condition_8h.html#gab91d5be5be6a61dc3d9dfaa4e01372b4", null ], +[ "pn_condition_copy", "condition_8h.html#gae495a2885d97a9f167e297efd6974a1e", null ], +[ "pn_condition_format", "condition_8h.html#ga65d9818487fc61e7ca75a9ec4abc8676", null ], +[ "pn_condition_free", "condition_8h.html#gad1f52a60bcc855702cfe51e6703625bb", null ], +[
[10/51] [partial] qpid-site git commit: PROTON-1374: update the website for Proton 0.16.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/releases/qpid-proton-0.16.0/proton/c/api/group__transport.js -- diff --git a/content/releases/qpid-proton-0.16.0/proton/c/api/group__transport.js b/content/releases/qpid-proton-0.16.0/proton/c/api/group__transport.js new file mode 100755 index 000..09ec1a9 --- /dev/null +++ b/content/releases/qpid-proton-0.16.0/proton/c/api/group__transport.js @@ -0,0 +1,59 @@ +var group__transport = +[ +[ "PN_TRACE_DRV", "group__transport.html#ga7065ad65f95c995a24e416edc95aead4", null ], +[ "PN_TRACE_EVT", "group__transport.html#ga3bde88d15fcfda400a36d8f9e5d51688", null ], +[ "PN_TRACE_FRM", "group__transport.html#gab8e04b4c128379ff27e6b801c0bce494", null ], +[ "PN_TRACE_OFF", "group__transport.html#gae8f32e46e94953bab10bee530eee9044", null ], +[ "PN_TRACE_RAW", "group__transport.html#gafde0eb3c73fb98816f4238d42d48f3d8", null ], +[ "pn_trace_t", "group__transport.html#ga4695788da8491f0c7104bfe36634ff94", null ], +[ "pn_tracer_t", "group__transport.html#ga3481dace48ff59d216127a63720038cd", null ], +[ "pn_transport_t", "group__transport.html#gac26eda05f649bbf0399f3d8d78d12fa8", null ], +[ "pn_transport", "group__transport.html#gaf9833d93faf6a6ed68039e4a909cdd77", null ], +[ "pn_transport_attachments", "group__transport.html#gabdd6d56837a028097b1676350d65a864", null ], +[ "pn_transport_bind", "group__transport.html#ga1a769e2e6c900c78c710407296cb4e13", null ], +[ "pn_transport_capacity", "group__transport.html#gaa079bb5f5b9ea10734c9d8af26fba333", null ], +[ "pn_transport_close_head", "group__transport.html#gab8d0c7878d3d8ecda627678a6ec55072", null ], +[ "pn_transport_close_tail", "group__transport.html#gaa8304f8719610e384aa9a3f5f3c98289", null ], +[ "pn_transport_closed", "group__transport.html#ga55c589d9b3e69057b130036c3c2173df", null ], +[ "pn_transport_condition", "group__transport.html#gac458d9fdb684f9501e89b96fc51f5c34", null ], +[ "pn_transport_connection", "group__transport.html#ga2b98f594e012c24e7b17dcc91e3d4caf", null ], +[ "pn_transport_error", "group__transport.html#gaede0bc2a0038ccdc7e1b193e322147fa", null ], +[ "pn_transport_free", "group__transport.html#ga6ab28051242631d9bea4814e8670ab90", null ], +[ "pn_transport_get_channel_max", "group__transport.html#gac14e93cc5e8bc949fe7a0800ebd6e052", null ], +[ "pn_transport_get_context", "group__transport.html#ga000b2b9ab82139defb1a103f220ec58e", null ], +[ "pn_transport_get_frames_input", "group__transport.html#ga92ce0b44ab956c182d646824b4e9ed61", null ], +[ "pn_transport_get_frames_output", "group__transport.html#ga3887e8d8c60d06df9978947edaf4d461", null ], +[ "pn_transport_get_idle_timeout", "group__transport.html#ga6980396c3d890b86656167c3a063eee7", null ], +[ "pn_transport_get_max_frame", "group__transport.html#ga46552ed46e59de6530d2eee03707a51b", null ], +[ "pn_transport_get_remote_idle_timeout", "group__transport.html#gabdcbd5d08c5b5cd3603dee74421985b5", null ], +[ "pn_transport_get_remote_max_frame", "group__transport.html#ga351823e18e043576078f361d7dfe1cce", null ], +[ "pn_transport_get_tracer", "group__transport.html#ga30d129d04a387ea34515c1641b83521b", null ], +[ "pn_transport_get_user", "group__transport.html#ga6b2750a2d313c65aabe5dc8a99f1de58", null ], +[ "pn_transport_head", "group__transport.html#ga3ef8b0032b2a012c697e853e363338ea", null ], +[ "pn_transport_input", "group__transport.html#ga93f5efd9d63ebd1b1498fdace388ec3d", null ], +[ "pn_transport_is_authenticated", "group__transport.html#ga8a60f6a48e4bd2d090f5bd264cf7f90d", null ], +[ "pn_transport_is_encrypted", "group__transport.html#ga737021ca419e948932071aad2ad38c5b", null ], +[ "pn_transport_log", "group__transport.html#gad603e8d72578bcedd2d9235f74f28f37", null ], +[ "pn_transport_logf", "group__transport.html#ga26cff9ffda93e2ffc8606e19eefe7f84", null ], +[ "pn_transport_output", "group__transport.html#gae72fdee3b8aae3cb484b0ed98c2b802e", null ], +[ "pn_transport_peek", "group__transport.html#ga09a0d15514ca9a14eb40f12425a52797", null ], +[ "pn_transport_pending", "group__transport.html#ga81adf1fd6fa28054f2f80c424aa98122", null ], +[ "pn_transport_pop", "group__transport.html#ga31470f0b0dbfd2c8c2929cc170858dc9", null ], +[ "pn_transport_process", "group__transport.html#ga1f52a6f11322873e74b9daf004269a91", null ], +[ "pn_transport_push", "group__transport.html#ga50c63f26b8b16f45e6e7912ca54de94b", null ], +[ "pn_transport_quiesced", "group__transport.html#gab8d9e4729b8835d3740de8d2c78831ef", null ], +[ "pn_transport_remote_channel_max", "group__transport.html#gaff7c08aeb92596ad9d269468d1557647", null ], +[ "pn_transport_require_auth", "group__transport.html#ga285b4cced59c665ae178adf26128d3fc", null ], +[ "pn_transport_require_encryption",
[19/51] [partial] qpid-site git commit: PROTON-1374: update the website for Proton 0.16.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/releases/qpid-proton-0.16.0/proton/c/api/group__link.js -- diff --git a/content/releases/qpid-proton-0.16.0/proton/c/api/group__link.js b/content/releases/qpid-proton-0.16.0/proton/c/api/group__link.js new file mode 100755 index 000..4b3d08d --- /dev/null +++ b/content/releases/qpid-proton-0.16.0/proton/c/api/group__link.js @@ -0,0 +1,63 @@ +var group__link = +[ +[ "pn_link_t", "group__link.html#ga89dad3aa7934329a7ff467c636687bc0", null ], +[ "pn_rcv_settle_mode_t", "group__link.html#gad1c2388cdae687be26222a5d66fd2d58", [ + [ "PN_RCV_FIRST", "group__link.html#ggad1c2388cdae687be26222a5d66fd2d58ac22b82396bd686940dfcc861302a8262", null ], + [ "PN_RCV_SECOND", "group__link.html#ggad1c2388cdae687be26222a5d66fd2d58ac79dc7f63fce078a8f0fe268c81dcaf3", null ] +] ], +[ "pn_snd_settle_mode_t", "group__link.html#ga3fb58bd0b88d37407ebb615c2630e608", [ + [ "PN_SND_UNSETTLED", "group__link.html#gga3fb58bd0b88d37407ebb615c2630e608a8bd9806d2f8d8c1724ed26bb0543bade", null ], + [ "PN_SND_SETTLED", "group__link.html#gga3fb58bd0b88d37407ebb615c2630e608ac159f0edca565961b554768a42e82bf0", null ], + [ "PN_SND_MIXED", "group__link.html#gga3fb58bd0b88d37407ebb615c2630e608ac33a5700d0247976b465aeb7c1437fd1", null ] +] ], +[ "pn_link_advance", "group__link.html#ga93824a3859c37463e44458cd2f63d31f", null ], +[ "pn_link_attachments", "group__link.html#ga8b19ffdb7934940fa7c5fd75c5fe2d69", null ], +[ "pn_link_available", "group__link.html#ga7f1742528b32c3c9609b97a3ed449639", null ], +[ "pn_link_close", "group__link.html#ga4851693eb6a16fd9ab61e2df6f00770d", null ], +[ "pn_link_condition", "group__link.html#ga52c99044eabb7712efa2f1098c760804", null ], +[ "pn_link_credit", "group__link.html#ga55428637f3b8c446efd5fea3f26c932d", null ], +[ "pn_link_current", "group__link.html#gad7e426b0cc4759568b3fd2b4fb176260", null ], +[ "pn_link_detach", "group__link.html#ga1dc327c52ac24a0d65a17c88ce685b0b", null ], +[ "pn_link_drain", "group__link.html#gad7ad9bc5c9ea7e8a21cd4fa472d2c8df", null ], +[ "pn_link_drained", "group__link.html#ga95c4018a1f1fe0e7c2e7fd02fe062d23", null ], +[ "pn_link_draining", "group__link.html#ga4a821eaf6298b94522572fad73b8e2d1", null ], +[ "pn_link_error", "group__link.html#gaf6f11d778aa4622d8aa5db8962bb1f0a", null ], +[ "pn_link_flow", "group__link.html#gafec44cf1c79ec03f3ac009e1879e71a9", null ], +[ "pn_link_free", "group__link.html#gadd3b8899fe023d3506fb88d228d6b1b7", null ], +[ "pn_link_get_context", "group__link.html#ga93e6b527743f433da2ff367c1b2c500a", null ], +[ "pn_link_get_drain", "group__link.html#ga40dd26f3d035c54056e2649aeb78d8ac", null ], +[ "pn_link_head", "group__link.html#ga7c9434c40eb653f007ff5721e2ebf73e", null ], +[ "pn_link_is_receiver", "group__link.html#gae7045dd02f2c9450ff8737e005628d81", null ], +[ "pn_link_is_sender", "group__link.html#ga7c48ef214568267839aea04ed337926b", null ], +[ "pn_link_max_message_size", "group__link.html#gac282341dacff892eba8e224eca5c5c52", null ], +[ "pn_link_name", "group__link.html#gaa44112980ebabbb5cbd002670073a751", null ], +[ "pn_link_next", "group__link.html#ga9b2a9cfa00dfdae4e01bf75483433925", null ], +[ "pn_link_offered", "group__link.html#gaef3f2e4bca87f9adc70e90dce7cd42b2", null ], +[ "pn_link_open", "group__link.html#gaabaca3f5d03970a122240eebc588add6", null ], +[ "pn_link_queued", "group__link.html#ga57a00950e2eeef378fd6c0a3b3b5bfe9", null ], +[ "pn_link_rcv_settle_mode", "group__link.html#ga0bc65ff494e2860e6227f68c72468101", null ], +[ "pn_link_recv", "group__link.html#ga06c97ce7396973dca0d311567f25f95a", null ], +[ "pn_link_remote_condition", "group__link.html#ga97dc5133125c9b7e4afbb1b76e6efe7b", null ], +[ "pn_link_remote_credit", "group__link.html#gab16f14d071548c5c9ab22924ee5b1ebb", null ], +[ "pn_link_remote_max_message_size", "group__link.html#ga9fc507fe3e207e84f2fc251cf9bd833d", null ], +[ "pn_link_remote_rcv_settle_mode", "group__link.html#ga378e4bb5a0519a75c3c151c15809dda5", null ], +[ "pn_link_remote_snd_settle_mode", "group__link.html#ga92592155f2afcf6b9aabfb4fc64c140f", null ], +[ "pn_link_remote_source", "group__link.html#gadf6b8ff6223465f21a481e9287f60671", null ], +[ "pn_link_remote_target", "group__link.html#gabf61668a66ae189dbb4820da6ee30d90", null ], +[ "pn_link_send", "group__link.html#gaa825fac21730f3f9fff37d156e5f88e9", null ], +[ "pn_link_session", "group__link.html#gac63e43305fb1a5e3b14399a9ddc8f24d", null ], +[ "pn_link_set_context", "group__link.html#ga376f2cc18bbd771d95aa8222586d19b2", null ], +[ "pn_link_set_drain", "group__link.html#gaeb417e6b7e99c76f61549f5ed5519395", null ], +[ "pn_link_set_max_message_size",
[32/51] [partial] qpid-site git commit: PROTON-1374: update the website for Proton 0.16.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/releases/qpid-proton-0.16.0/proton/c/api/globals_enum.html -- diff --git a/content/releases/qpid-proton-0.16.0/proton/c/api/globals_enum.html b/content/releases/qpid-proton-0.16.0/proton/c/api/globals_enum.html new file mode 100755 index 000..a56429f --- /dev/null +++ b/content/releases/qpid-proton-0.16.0/proton/c/api/globals_enum.html @@ -0,0 +1,148 @@ +http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd;> +http://www.w3.org/1999/xhtml;> + + + + +Qpid Proton C API: File Members + + + + + + + + $(document).ready(initResizable); + $(window).load(resizeHeight); + + + + + $(document).ready(function() { searchBox.OnSelectItem(0); }); + + + + + + + + + + + Qpid Proton C API + 0.16.0 + + + + + + + + + + + + + + + + + + +var searchBox = new SearchBox("searchBox", "search",false,'Search'); + + + + + + + + + + + + +$(document).ready(function(){initNavTree('globals_enum.html','');}); + + + + +AllClassesFilesFunctionsVariablesTypedefsEnumerationsEnumeratorGroupsPages + + + + + + + + + +pn_distribution_mode_t +: terminus.h + +pn_durability_t +: terminus.h + +pn_event_type_t +: event.h + +pn_expiry_policy_t +: terminus.h + +pn_rcv_settle_mode_t +: link.h + +pn_sasl_outcome_t +: sasl.h + +pn_snd_settle_mode_t +: link.h + +pn_ssl_cert_subject_subfield +: ssl.h + +pn_ssl_hash_alg +: ssl.h + +pn_ssl_mode_t +: ssl.h + +pn_ssl_resume_status_t +: ssl.h + +pn_ssl_verify_mode_t +: ssl.h + +pn_status_t +: messenger.h + +pn_terminus_type_t +: terminus.h + +pn_type_t +: codec.h + + + + + + + +Generated by +http://www.doxygen.org/index.html;> + 1.8.3.1 + + + + http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/releases/qpid-proton-0.16.0/proton/c/api/globals_eval.html -- diff --git a/content/releases/qpid-proton-0.16.0/proton/c/api/globals_eval.html b/content/releases/qpid-proton-0.16.0/proton/c/api/globals_eval.html new file mode 100755 index 000..2188e69 --- /dev/null +++ b/content/releases/qpid-proton-0.16.0/proton/c/api/globals_eval.html @@ -0,0 +1,491 @@ +http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd;> +http://www.w3.org/1999/xhtml;> + + + + +Qpid Proton C API: File Members + + + + + + + + $(document).ready(initResizable); + $(window).load(resizeHeight); + + + + + $(document).ready(function() { searchBox.OnSelectItem(0); }); + + + + + + + + + + + Qpid Proton C API + 0.16.0 + + + + + + + + + + + + + + + + + + +var searchBox = new SearchBox("searchBox", "search",false,'Search'); + + + + + + + + + + + + +$(document).ready(function(){initNavTree('globals_eval.html','');}); + + + + +AllClassesFilesFunctionsVariablesTypedefsEnumerationsEnumeratorGroupsPages + + + + + + + + + + +- a - +PN_ARRAY +: codec.h + + + + +- b - +PN_BINARY +: codec.h + +PN_BOOL +: codec.h + +PN_BYTE +: codec.h + + + + +- c - +PN_CHAR +: codec.h + +PN_CONFIGURATION +: terminus.h + +PN_CONNECTION_BOUND +: event.h + +PN_CONNECTION_FINAL +: event.h + +PN_CONNECTION_INIT +: event.h + +PN_CONNECTION_LOCAL_CLOSE +: event.h + +PN_CONNECTION_LOCAL_OPEN +: event.h + +PN_CONNECTION_REMOTE_CLOSE +: event.h + +PN_CONNECTION_REMOTE_OPEN +: event.h + +PN_CONNECTION_UNBOUND +: event.h + +PN_CONNECTION_WAKE +: event.h + +PN_COORDINATOR +: terminus.h + + + + +- d - +PN_DECIMAL128 +: codec.h + +PN_DECIMAL32 +: codec.h + +PN_DECIMAL64 +: codec.h + +PN_DELIVERIES +: terminus.h + +PN_DELIVERY +: event.h + +PN_DESCRIBED +: codec.h + +PN_DIST_MODE_COPY +: terminus.h + +PN_DIST_MODE_MOVE +: terminus.h + +PN_DIST_MODE_UNSPECIFIED +: terminus.h + +PN_DOUBLE +: codec.h + + + + +- e - +PN_EVENT_NONE +: event.h + +PN_EXPIRE_NEVER +: terminus.h + +PN_EXPIRE_WITH_CONNECTION +: terminus.h + +PN_EXPIRE_WITH_LINK +: terminus.h + +PN_EXPIRE_WITH_SESSION +: terminus.h + + + + +- f - +PN_FLOAT +: codec.h + + + + +- i - +PN_INT +: codec.h + +PN_INVALID +: codec.h + + + + +- l - +PN_LINK_FINAL +: event.h + +PN_LINK_FLOW +: event.h + +PN_LINK_INIT +: event.h + +PN_LINK_LOCAL_CLOSE +: event.h + +PN_LINK_LOCAL_DETACH +: event.h + +PN_LINK_LOCAL_OPEN +: event.h + +PN_LINK_REMOTE_CLOSE +: event.h + +PN_LINK_REMOTE_DETACH +: event.h + +PN_LINK_REMOTE_OPEN +: event.h + +PN_LIST +: codec.h + +PN_LISTENER_ACCEPT +: event.h + +PN_LISTENER_CLOSE +: event.h + +PN_LONG +: codec.h + + + + +- m - +PN_MAP +: codec.h + + + + +- n - +PN_NONDURABLE +: terminus.h + +PN_NULL +: codec.h + + + + +- p - +PN_PROACTOR_INACTIVE +: event.h + +PN_PROACTOR_INTERRUPT +: event.h + +PN_PROACTOR_TIMEOUT +: event.h + + + + +- r - +PN_RCV_FIRST +: link.h + +PN_RCV_SECOND +: link.h + +PN_REACTOR_FINAL +: event.h + +PN_REACTOR_INIT +:
[27/51] [partial] qpid-site git commit: PROTON-1374: update the website for Proton 0.16.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/releases/qpid-proton-0.16.0/proton/c/api/group__connection.js -- diff --git a/content/releases/qpid-proton-0.16.0/proton/c/api/group__connection.js b/content/releases/qpid-proton-0.16.0/proton/c/api/group__connection.js new file mode 100755 index 000..8b47a6a --- /dev/null +++ b/content/releases/qpid-proton-0.16.0/proton/c/api/group__connection.js @@ -0,0 +1,44 @@ +var group__connection = +[ +[ "PN_LOCAL_ACTIVE", "group__connection.html#ga0c3bf54f0991944a2f6eea36b561fa2b", null ], +[ "PN_LOCAL_CLOSED", "group__connection.html#ga602c2c870ebed1d9bfe100876909225b", null ], +[ "PN_LOCAL_MASK", "group__connection.html#ga32329c4bb3e23607a243cd8100c01264", null ], +[ "PN_LOCAL_UNINIT", "group__connection.html#gac83dd8123b992813be86fe0f7eaf8f61", null ], +[ "PN_REMOTE_ACTIVE", "group__connection.html#gad96220f2886c21a4f2eebc9487f53a87", null ], +[ "PN_REMOTE_CLOSED", "group__connection.html#ga764c602a20457f9aa8862825b6d13a8d", null ], +[ "PN_REMOTE_MASK", "group__connection.html#ga695af0c2d90d50f4baf403ea60710fa3", null ], +[ "PN_REMOTE_UNINIT", "group__connection.html#ga4c35fcb0aacd254d586df8594ee770d3", null ], +[ "pn_connection_t", "group__connection.html#ga886351d81ff3a977a284a206526c5aff", null ], +[ "pn_state_t", "group__connection.html#gaa83193a655e32bffc18624acc2c39233", null ], +[ "pn_connection", "group__connection.html#gaa9e59c468ec0568b1528f5f83c4b301d", null ], +[ "pn_connection_attachments", "group__connection.html#gad8b6c777b525c9da9401e3a770db15da", null ], +[ "pn_connection_close", "group__connection.html#gac25afdf810ad188b2cb3bf31a7482ca0", null ], +[ "pn_connection_collect", "group__connection.html#ga2fd2089e8eaa2a362606498f233ada61", null ], +[ "pn_connection_collector", "group__connection.html#ga663c29ee6de4d522ba061224bc6240ad", null ], +[ "pn_connection_condition", "group__connection.html#gaace04a030192f34747bb1ff3675c58f1", null ], +[ "pn_connection_desired_capabilities", "group__connection.html#ga241faafc5a98cf9b91aa919263bd9bd8", null ], +[ "pn_connection_error", "group__connection.html#gad3aad758ccb4690e78d40c1a73567d73", null ], +[ "pn_connection_free", "group__connection.html#ga00cbef1a9f5062a6e1f113fda923f65e", null ], +[ "pn_connection_get_container", "group__connection.html#ga61e1f6386d18a568da50b998200eb87b", null ], +[ "pn_connection_get_context", "group__connection.html#ga50613e6c09186dc3f1a2f36238c61f07", null ], +[ "pn_connection_get_hostname", "group__connection.html#ga3ab6a8a556270cff74c39da910a89b5c", null ], +[ "pn_connection_get_user", "group__connection.html#ga5f4b94211f97bbc3bb64642f6f597fe8", null ], +[ "pn_connection_offered_capabilities", "group__connection.html#gabc8d505108a850837a0d2fb204875390", null ], +[ "pn_connection_open", "group__connection.html#ga4c0a2d40bb95202477ccc5aaa7456670", null ], +[ "pn_connection_properties", "group__connection.html#gac26de255ed04e73295d6aa973a663142", null ], +[ "pn_connection_release", "group__connection.html#ga7c88b4833cf81d801b27d00b45d137b5", null ], +[ "pn_connection_remote_condition", "group__connection.html#ga72a362389b99d8e891bf2e4fb4290754", null ], +[ "pn_connection_remote_container", "group__connection.html#gabb5b585ee8bae0e88d2b42b87772082a", null ], +[ "pn_connection_remote_desired_capabilities", "group__connection.html#ga722d53b6063278fbcab5f814613c70ec", null ], +[ "pn_connection_remote_hostname", "group__connection.html#gabf25d7b763951b4a9c856536d6db0600", null ], +[ "pn_connection_remote_offered_capabilities", "group__connection.html#ga9bf90f0f395d26e320293063b70d040f", null ], +[ "pn_connection_remote_properties", "group__connection.html#ga24a2d5aba432db549257993bfaa761dd", null ], +[ "pn_connection_reset", "group__connection.html#ga3a76135d214e12a0735441c1ba2c28d3", null ], +[ "pn_connection_set_container", "group__connection.html#gac4a34e0b1fc5665b26ae47a80a422a1a", null ], +[ "pn_connection_set_context", "group__connection.html#gad3203b366cb1ff5becd1778a8dd6b1a6", null ], +[ "pn_connection_set_hostname", "group__connection.html#ga0c3bed8e6764915a137a9daff199ecbb", null ], +[ "pn_connection_set_password", "group__connection.html#ga8be7fdeb5a229d16e45fa122844fb285", null ], +[ "pn_connection_set_user", "group__connection.html#gafb84dd2ef7551ad864be08cb31010d19", null ], +[ "pn_connection_state", "group__connection.html#ga277d01dc2f87870ee260d43cf40abe13", null ], +[ "pn_connection_transport", "group__connection.html#gad8bd46661ca997b9b2c2c38cb6983c59", null ] +]; \ No newline at end of file http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/releases/qpid-proton-0.16.0/proton/c/api/group__connection__driver.html
[17/51] [partial] qpid-site git commit: PROTON-1374: update the website for Proton 0.16.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/releases/qpid-proton-0.16.0/proton/c/api/group__message.js -- diff --git a/content/releases/qpid-proton-0.16.0/proton/c/api/group__message.js b/content/releases/qpid-proton-0.16.0/proton/c/api/group__message.js new file mode 100755 index 000..6611043 --- /dev/null +++ b/content/releases/qpid-proton-0.16.0/proton/c/api/group__message.js @@ -0,0 +1,57 @@ +var group__message = +[ +[ "PN_DEFAULT_PRIORITY", "group__message.html#ga732b155202644a5c5be75a651a3c4fac", null ], +[ "pn_message_t", "group__message.html#gad9259fa9271e8844c8e05a7e8978e3b2", null ], +[ "pn_message", "group__message.html#gaaf98d84b9ddc1c65374c9c5b979e", null ], +[ "pn_message_annotations", "group__message.html#gadadb16710eccb6d332d039acc9dc1042", null ], +[ "pn_message_body", "group__message.html#ga145c06edbcccfbe97136bfb5cb2b22b1", null ], +[ "pn_message_clear", "group__message.html#ga918c90a049d6b39041b0a2044f9048c6", null ], +[ "pn_message_correlation_id", "group__message.html#gaceb08618e468fdb4a95e103cce6e7cbd", null ], +[ "pn_message_data", "group__message.html#ga013d429f94d653bc1e00f1f438a079a6", null ], +[ "pn_message_decode", "group__message.html#gab0bae90838f4661b0c82c15f25e1e988", null ], +[ "pn_message_encode", "group__message.html#ga2173bbce3c1f4b04074e42d2fe7da473", null ], +[ "pn_message_errno", "group__message.html#gac10c5d8f12e4817fec126fdb608baf53", null ], +[ "pn_message_error", "group__message.html#ga9ad09178e7682efde76e2d39f352dfe8", null ], +[ "pn_message_free", "group__message.html#ga69aadbc3a80f1fa16962774e711392f8", null ], +[ "pn_message_get_address", "group__message.html#gaa4f5b4884d5422123a4e6f48bf00701c", null ], +[ "pn_message_get_content_encoding", "group__message.html#gacb97f21822b058b6297bc618f6d190b0", null ], +[ "pn_message_get_content_type", "group__message.html#ga280a96bf80dd37a4062432f45e679ea1", null ], +[ "pn_message_get_correlation_id", "group__message.html#ga7c7a49b84141d130f885e3a6b357d65a", null ], +[ "pn_message_get_creation_time", "group__message.html#ga4a18377a68cc26d68141e1b1afd82a52", null ], +[ "pn_message_get_delivery_count", "group__message.html#gad514ef95e642698876bedf6ec772eb72", null ], +[ "pn_message_get_expiry_time", "group__message.html#ga8fdfd3daca961bbfaa7affacee6047ce", null ], +[ "pn_message_get_group_id", "group__message.html#ga4ebc7c7e7f524f5bf36214ff0ccaa00b", null ], +[ "pn_message_get_group_sequence", "group__message.html#ga4c33c1f6b80dd62e2b4bdf23d0b2dbf4", null ], +[ "pn_message_get_id", "group__message.html#gad7d3aa060b7666dce6a6d955945bedce", null ], +[ "pn_message_get_priority", "group__message.html#ga5e6769354fcb71c9053fff0045301a0e", null ], +[ "pn_message_get_reply_to", "group__message.html#ga5b9e011902e7bd3a9f94ecf52b723c33", null ], +[ "pn_message_get_reply_to_group_id", "group__message.html#ga7163a0174e7c71361172a1f6387f232a", null ], +[ "pn_message_get_subject", "group__message.html#gaf35cc7fb503f99b434a970ff669e5c4c", null ], +[ "pn_message_get_ttl", "group__message.html#ga2ade598da4a8bb0464980ae227f29d5c", null ], +[ "pn_message_get_user_id", "group__message.html#ga957f54f40b8a297cdf9ceee8a71b3c1c", null ], +[ "pn_message_id", "group__message.html#ga296bd7b984c4b9cfabc297ab5badf7de", null ], +[ "pn_message_instructions", "group__message.html#ga02347ad161f972e4b94567f329b53a8a", null ], +[ "pn_message_is_durable", "group__message.html#gaf9e131dcfb094bebc3424661042d3c36", null ], +[ "pn_message_is_first_acquirer", "group__message.html#gac8a1e35c70d625b69e0d1769d9c898d2", null ], +[ "pn_message_is_inferred", "group__message.html#ga5d9367609d74ca3511d4172806eeb55b", null ], +[ "pn_message_properties", "group__message.html#ga43c7ee6ab70316145fb2bb5fcad210ad", null ], +[ "pn_message_set_address", "group__message.html#ga38ecee233f94e128bed9be3e530f27e5", null ], +[ "pn_message_set_content_encoding", "group__message.html#gafc79b5a0c8bd56aaa07f1357ba07475b", null ], +[ "pn_message_set_content_type", "group__message.html#gaa0247560f0cd4590bc8ece20565eb611", null ], +[ "pn_message_set_correlation_id", "group__message.html#ga2179a56c66e47eb65c61a8f84ae4488a", null ], +[ "pn_message_set_creation_time", "group__message.html#gab7f1c0d93b93dee6c3eef730e35ef5e2", null ], +[ "pn_message_set_delivery_count", "group__message.html#ga195472fabe3416dccf8a4bfcdacfa6c0", null ], +[ "pn_message_set_durable", "group__message.html#ga63f6065e770ddf435e38d8c0e01bc5ad", null ], +[ "pn_message_set_expiry_time", "group__message.html#ga6c108bc39b13c5257671aee68ea981c7", null ], +[ "pn_message_set_first_acquirer", "group__message.html#ga64240467da74892010a7282116b0b234", null ], +[ "pn_message_set_group_id",
[21/51] [partial] qpid-site git commit: PROTON-1374: update the website for Proton 0.16.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/releases/qpid-proton-0.16.0/proton/c/api/group__io.html -- diff --git a/content/releases/qpid-proton-0.16.0/proton/c/api/group__io.html b/content/releases/qpid-proton-0.16.0/proton/c/api/group__io.html new file mode 100755 index 000..dbcffc1 --- /dev/null +++ b/content/releases/qpid-proton-0.16.0/proton/c/api/group__io.html @@ -0,0 +1,122 @@ +http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd;> +http://www.w3.org/1999/xhtml;> + + + + +Qpid Proton C API: IO + + + + + + + + $(document).ready(initResizable); + $(window).load(resizeHeight); + + + + + $(document).ready(function() { searchBox.OnSelectItem(0); }); + + + + + + + + + + + Qpid Proton C API + 0.16.0 + + + + + + + + + + + + + + + + + + +var searchBox = new SearchBox("searchBox", "search",false,'Search'); + + + + + + + + + + + + +$(document).ready(function(){initNavTree('group__io.html','');}); + + + + +AllClassesFilesFunctionsVariablesTypedefsEnumerationsEnumeratorGroupsPages + + + + + + + + + +Modules + +IO + + + +IO integration interfaces. +More... + + +Modules +Proactor +Experimental - Multithreaded IO + +Connection driver +Experimental - Low-level IO integration + + +Detailed Description +IO integration interfaces. + + + + + +Generated by +http://www.doxygen.org/index.html;> + 1.8.3.1 + + + + http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/releases/qpid-proton-0.16.0/proton/c/api/group__io.js -- diff --git a/content/releases/qpid-proton-0.16.0/proton/c/api/group__io.js b/content/releases/qpid-proton-0.16.0/proton/c/api/group__io.js new file mode 100755 index 000..e348370 --- /dev/null +++ b/content/releases/qpid-proton-0.16.0/proton/c/api/group__io.js @@ -0,0 +1,5 @@ +var group__io = +[ +[ "Proactor", "group__proactor.html", "group__proactor" ], +[ "Connection driver", "group__connection__driver.html", "group__connection__driver" ] +]; \ No newline at end of file - To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org
[01/51] [partial] qpid-site git commit: PROTON-1374: update the website for Proton 0.16.0
Repository: qpid-site Updated Branches: refs/heads/asf-site 27c60c337 -> 7833dc2af http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/releases/qpid-proton-0.16.0/proton/c/api/navtreeindex3.js -- diff --git a/content/releases/qpid-proton-0.16.0/proton/c/api/navtreeindex3.js b/content/releases/qpid-proton-0.16.0/proton/c/api/navtreeindex3.js new file mode 100755 index 000..ec32cf2 --- /dev/null +++ b/content/releases/qpid-proton-0.16.0/proton/c/api/navtreeindex3.js @@ -0,0 +1,253 @@ +var NAVTREEINDEX3 = +{ +"group__link.html#ga0bc65ff494e2860e6227f68c72468101":[2,0,2,28], +"group__link.html#ga1dc327c52ac24a0d65a17c88ce685b0b":[2,0,2,10], +"group__link.html#ga2421a9ddebba208338412dea365cf6ad":[2,0,2,41], +"group__link.html#ga2c8985a9d44a813ab1739a91ae3708a3":[2,0,2,45], +"group__link.html#ga376f2cc18bbd771d95aa8222586d19b2":[2,0,2,39], +"group__link.html#ga378e4bb5a0519a75c3c151c15809dda5":[2,0,2,33], +"group__link.html#ga3fb58bd0b88d37407ebb615c2630e608":[2,0,2,2], +"group__link.html#ga40dd26f3d035c54056e2649aeb78d8ac":[2,0,2,18], +"group__link.html#ga469bef2e81c53e85899ffbb277616a8c":[2,0,2,50], +"group__link.html#ga4851693eb6a16fd9ab61e2df6f00770d":[2,0,2,6], +"group__link.html#ga4a821eaf6298b94522572fad73b8e2d1":[2,0,2,13], +"group__link.html#ga52c99044eabb7712efa2f1098c760804":[2,0,2,7], +"group__link.html#ga55428637f3b8c446efd5fea3f26c932d":[2,0,2,8], +"group__link.html#ga57a00950e2eeef378fd6c0a3b3b5bfe9":[2,0,2,27], +"group__link.html#ga5e314b3e07b48ebcffbac63f265fa69f":[2,0,2,49], +"group__link.html#ga6206e3d4efe0ebe0491955006930fa18":[2,0,2,51], +"group__link.html#ga677c416a6365cedd23b43043dff0b89f":[2,0,2,43], +"group__link.html#ga6dc9ad6d95d1cccd6f3d29b782269cce":[2,0,2,52], +"group__link.html#ga7c48ef214568267839aea04ed337926b":[2,0,2,21], +"group__link.html#ga7c9434c40eb653f007ff5721e2ebf73e":[2,0,2,19], +"group__link.html#ga7f1742528b32c3c9609b97a3ed449639":[2,0,2,5], +"group__link.html#ga89dad3aa7934329a7ff467c636687bc0":[2,0,2,0], +"group__link.html#ga8b19ffdb7934940fa7c5fd75c5fe2d69":[2,0,2,4], +"group__link.html#ga92592155f2afcf6b9aabfb4fc64c140f":[2,0,2,34], +"group__link.html#ga93824a3859c37463e44458cd2f63d31f":[2,0,2,3], +"group__link.html#ga93e6b527743f433da2ff367c1b2c500a":[2,0,2,17], +"group__link.html#ga95c4018a1f1fe0e7c2e7fd02fe062d23":[2,0,2,12], +"group__link.html#ga97dc5133125c9b7e4afbb1b76e6efe7b":[2,0,2,30], +"group__link.html#ga997c85388b9fb30151ea3b40b946e958":[2,0,2,47], +"group__link.html#ga9b2a9cfa00dfdae4e01bf75483433925":[2,0,2,24], +"group__link.html#ga9fc507fe3e207e84f2fc251cf9bd833d":[2,0,2,32], +"group__link.html#gaa44112980ebabbb5cbd002670073a751":[2,0,2,23], +"group__link.html#gaa825fac21730f3f9fff37d156e5f88e9":[2,0,2,37], +"group__link.html#gaabaca3f5d03970a122240eebc588add6":[2,0,2,26], +"group__link.html#gab16f14d071548c5c9ab22924ee5b1ebb":[2,0,2,31], +"group__link.html#gab6441a917c291e68984405057eb56ab8":[2,0,2,42], +"group__link.html#gabf61668a66ae189dbb4820da6ee30d90":[2,0,2,36], +"group__link.html#gac282341dacff892eba8e224eca5c5c52":[2,0,2,22], +"group__link.html#gac63e43305fb1a5e3b14399a9ddc8f24d":[2,0,2,38], +"group__link.html#gac7309a622f3f2296261ff8fa9bc33ba1":[2,0,2,48], +"group__link.html#gacef130ca5cc6eb3eec2dd48c8bf5c7e6":[2,0,2,44], +"group__link.html#gad1c2388cdae687be26222a5d66fd2d58":[2,0,2,1], +"group__link.html#gad502b38bc184ad0bfaa86dede81f62c9":[2,0,2,46], +"group__link.html#gad7ad9bc5c9ea7e8a21cd4fa472d2c8df":[2,0,2,11], +"group__link.html#gad7e426b0cc4759568b3fd2b4fb176260":[2,0,2,9], +"group__link.html#gadd3b8899fe023d3506fb88d228d6b1b7":[2,0,2,16], +"group__link.html#gadf6b8ff6223465f21a481e9287f60671":[2,0,2,35], +"group__link.html#gae7045dd02f2c9450ff8737e005628d81":[2,0,2,20], +"group__link.html#gaeb417e6b7e99c76f61549f5ed5519395":[2,0,2,40], +"group__link.html#gaef3f2e4bca87f9adc70e90dce7cd42b2":[2,0,2,25], +"group__link.html#gaf6f11d778aa4622d8aa5db8962bb1f0a":[2,0,2,14], +"group__link.html#gafec44cf1c79ec03f3ac009e1879e71a9":[2,0,2,15], +"group__link.html#gga3fb58bd0b88d37407ebb615c2630e608a8bd9806d2f8d8c1724ed26bb0543bade":[2,0,2,2,0], +"group__link.html#gga3fb58bd0b88d37407ebb615c2630e608ac159f0edca565961b554768a42e82bf0":[2,0,2,2,1], +"group__link.html#gga3fb58bd0b88d37407ebb615c2630e608ac33a5700d0247976b465aeb7c1437fd1":[2,0,2,2,2], +"group__link.html#ggad1c2388cdae687be26222a5d66fd2d58ac22b82396bd686940dfcc861302a8262":[2,0,2,1,0], +"group__link.html#ggad1c2388cdae687be26222a5d66fd2d58ac79dc7f63fce078a8f0fe268c81dcaf3":[2,0,2,1,1], +"group__message.html":[2,0,4], +"group__message.html#ga013d429f94d653bc1e00f1f438a079a6":[2,0,4,7], +"group__message.html#ga02347ad161f972e4b94567f329b53a8a":[2,0,4,30], +"group__message.html#ga0ec7ed8750b4d418c60aa77e4b1812bc":[2,0,4,44], +"group__message.html#ga145c06edbcccfbe97136bfb5cb2b22b1":[2,0,4,4], +"group__message.html#ga195472fabe3416dccf8a4bfcdacfa6c0":[2,0,4,40],
[11/51] [partial] qpid-site git commit: PROTON-1374: update the website for Proton 0.16.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/releases/qpid-proton-0.16.0/proton/c/api/group__transport.html -- diff --git a/content/releases/qpid-proton-0.16.0/proton/c/api/group__transport.html b/content/releases/qpid-proton-0.16.0/proton/c/api/group__transport.html new file mode 100755 index 000..fe32397 --- /dev/null +++ b/content/releases/qpid-proton-0.16.0/proton/c/api/group__transport.html @@ -0,0 +1,1793 @@ +http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd;> +http://www.w3.org/1999/xhtml;> + + + + +Qpid Proton C API: Transport + + + + + + + + $(document).ready(initResizable); + $(window).load(resizeHeight); + + + + + $(document).ready(function() { searchBox.OnSelectItem(0); }); + + + + + + + + + + + Qpid Proton C API + 0.16.0 + + + + + + + + + + + + + + + + + + +var searchBox = new SearchBox("searchBox", "search",false,'Search'); + + + + + + + + + + + + +$(document).ready(function(){initNavTree('group__transport.html','');}); + + + + +AllClassesFilesFunctionsVariablesTypedefsEnumerationsEnumeratorGroupsPages + + + + + + + + + +Macros +Typedefs +Functions + +TransportCore + + + +A network channel supporting an AMQP connection. +More... + + +Macros + +#definePN_TRACE_OFF +Turn logging off entirely. + + +#definePN_TRACE_RAW +Log raw binary data into/out of the transport. + + +#definePN_TRACE_FRM +Log frames into/out of the transport. + +#definePN_TRACE_DRV +Log driver related events, e.g. More... + + +#definePN_TRACE_EVT +Log events. + + + +Typedefs +typedef intpn_trace_t +Holds the trace flags for an AMQP transport. More... + + +typedef void(*pn_tracer_t )(pn_transport_t *transport, const char *message) +Callback for customizing logging behaviour. + +typedef struct pn_transport_tpn_transport_t +An AMQP Transport object. More... + + + +Functions +pn_transport_t *pn_transport (void) +Factory for creating a transport. More... + +voidpn_transport_set_server (pn_transport_t *transport) +Configure a transport as a server. More... + +voidpn_transport_free (pn_transport_t *transport) +Free a transport object. More... + +const char *pn_transport_get_user (pn_transport_t *transport) +Retrieve the authenticated user. More... + +voidpn_transport_require_auth (pn_transport_t *transport, bool required) +Set whether a non-authenticated transport connection is allowed. More... + +boolpn_transport_is_authenticated (pn_transport_t *transport) +Tell whether the transport connection is authenticated. More... + +voidpn_transport_require_encryption (pn_transport_t *transport, bool required) +Set whether a non encrypted transport connection is allowed. More... + +boolpn_transport_is_encrypted (pn_transport_t *transport) +Tell whether the transport connection is encrypted. More... + +pn_condition_t *pn_transport_condition (pn_transport_t *transport) +Get additional information about the condition of the transport. More... + +pn_error_t *pn_transport_error (pn_transport_t *transport) + +intpn_transport_bind (pn_transport_t *transport, pn_connection_t *connection) +Binds the transport to an AMQP connection. More... + +intpn_transport_unbind (pn_transport_t *transport) +Unbinds a transport from its AMQP connection. More... + +voidpn_transport_trace (pn_transport_t *transport, pn_trace_t trace) +Update a transports trace flags. More... + +voidpn_transport_set_tracer (pn_transport_t *transport, pn_tracer_t tracer) +Set the tracing function used by a transport. More... + +pn_tracer_tpn_transport_get_tracer (pn_transport_t *transport) +Get the tracing function used by a transport. More... + +void *pn_transport_get_context (pn_transport_t *transport) + +voidpn_transport_set_context (pn_transport_t *transport, void *context) + +pn_record_t *pn_transport_attachments (pn_transport_t *transport) +Get the attachments that are associated with a transport object. More... + +voidpn_transport_log (pn_transport_t *transport, const char *message) +Log a message using a transport's logging mechanism. More... + +voidpn_transport_vlogf (pn_transport_t *transport, const char *fmt, va_list ap) +Log a printf formatted message using a transport's logging mechanism. More... + +voidpn_transport_logf (pn_transport_t *transport, const char *fmt,...) +Log a printf formatted message using a transport's logging mechanism. More... + +uint16_tpn_transport_get_channel_max (pn_transport_t *transport) +Get the maximum allowed channel for a transport. More... + +intpn_transport_set_channel_max (pn_transport_t *transport, uint16_t channel_max) +Set the maximum allowed channel number for a transport. More... + +uint16_tpn_transport_remote_channel_max (pn_transport_t *transport) +Get the maximum allowed channel of a
[28/51] [partial] qpid-site git commit: PROTON-1374: update the website for Proton 0.16.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/releases/qpid-proton-0.16.0/proton/c/api/group__connection.html -- diff --git a/content/releases/qpid-proton-0.16.0/proton/c/api/group__connection.html b/content/releases/qpid-proton-0.16.0/proton/c/api/group__connection.html new file mode 100755 index 000..553a9ce --- /dev/null +++ b/content/releases/qpid-proton-0.16.0/proton/c/api/group__connection.html @@ -0,0 +1,1148 @@ +http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd;> +http://www.w3.org/1999/xhtml;> + + + + +Qpid Proton C API: Connection + + + + + + + + $(document).ready(initResizable); + $(window).load(resizeHeight); + + + + + $(document).ready(function() { searchBox.OnSelectItem(0); }); + + + + + + + + + + + Qpid Proton C API + 0.16.0 + + + + + + + + + + + + + + + + + + +var searchBox = new SearchBox("searchBox", "search",false,'Search'); + + + + + + + + + + + + +$(document).ready(function(){initNavTree('group__connection.html','');}); + + + + +AllClassesFilesFunctionsVariablesTypedefsEnumerationsEnumeratorGroupsPages + + + + + + + + + +Macros +Typedefs +Functions + +ConnectionCore + + + +A channel for communication between two peers on a network. +More... + + +Macros + +#definePN_LOCAL_UNINIT +The local endpoint state is uninitialized. + + +#definePN_LOCAL_ACTIVE +The local endpoint state is active. + + +#definePN_LOCAL_CLOSED +The local endpoint state is closed. + + +#definePN_REMOTE_UNINIT +The remote endpoint state is uninitialized. + + +#definePN_REMOTE_ACTIVE +The remote endpoint state is active. + + +#definePN_REMOTE_CLOSED +The remote endpoint state is closed. + + +#definePN_LOCAL_MASK +A mask for values of pn_state_t that preserves only the local bits of an endpoint's state. + + +#definePN_REMOTE_MASK +A mask for values of pn_state_t that preserves only the remote bits of an endpoint's state. + + + +Typedefs +typedef intpn_state_t +Holds the state flags for an AMQP endpoint. More... + +typedef struct pn_connection_tpn_connection_t +An AMQP Connection object. More... + + + +Functions +pn_connection_t *pn_connection (void) +Factory to construct a new Connection. More... + +voidpn_connection_free (pn_connection_t *connection) +Free a connection object. More... + +voidpn_connection_release (pn_connection_t *connection) +Release a connection object. More... + +pn_error_t *pn_connection_error (pn_connection_t *connection) + +voidpn_connection_collect (pn_connection_t *connection, pn_collector_t *collector) +Associate a connection object with an event collector. More... + +pn_collector_t *pn_connection_collector (pn_connection_t *connection) +Get the collector set with pn_connection_collect() More... + +void *pn_connection_get_context (pn_connection_t *connection) + +voidpn_connection_set_context (pn_connection_t *connection, void *context) + +pn_record_t *pn_connection_attachments (pn_connection_t *connection) +Get the attachments that are associated with a connection object. More... + +pn_state_tpn_connection_state (pn_connection_t *connection) +Get the endpoint state flags for a connection. More... + +voidpn_connection_open (pn_connection_t *connection) +Open a connection. More... + +voidpn_connection_close (pn_connection_t *connection) +Close a connection. More... + +voidpn_connection_reset (pn_connection_t *connection) +Reset a connection object back to the uninitialized state. More... + +pn_condition_t *pn_connection_condition (pn_connection_t *connection) +Get the local condition associated with the connection endpoint. More... + +pn_condition_t *pn_connection_remote_condition (pn_connection_t *connection) +Get the remote condition associated with the connection endpoint. More... + +const char *pn_connection_get_container (pn_connection_t *connection) +Get the AMQP Container name advertised by a connection object. More... + +voidpn_connection_set_container (pn_connection_t *connection, const char *container) +Set the AMQP Container name advertised by a connection object. More... + +voidpn_connection_set_user (pn_connection_t *connection, const char *user) +Set the authentication username for a client connection. More... + +voidpn_connection_set_password (pn_connection_t *connection, const char *password) +Set the authentication password for a client connection. More... + +const char *pn_connection_get_user (pn_connection_t *connection) +Get the authentication username for a client connection. More... + +const char *pn_connection_get_hostname (pn_connection_t *connection) +Get the value of the AMQP Hostname used by a connection object. More... + +voidpn_connection_set_hostname (pn_connection_t *connection, const char *hostname) +Set the name of the
[08/51] [partial] qpid-site git commit: PROTON-1374: update the website for Proton 0.16.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/releases/qpid-proton-0.16.0/proton/c/api/link_8h.html -- diff --git a/content/releases/qpid-proton-0.16.0/proton/c/api/link_8h.html b/content/releases/qpid-proton-0.16.0/proton/c/api/link_8h.html new file mode 100755 index 000..2103735 --- /dev/null +++ b/content/releases/qpid-proton-0.16.0/proton/c/api/link_8h.html @@ -0,0 +1,288 @@ +http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd;> +http://www.w3.org/1999/xhtml;> + + + + +Qpid Proton C API: proton/link.h File Reference + + + + + + + + $(document).ready(initResizable); + $(window).load(resizeHeight); + + + + + $(document).ready(function() { searchBox.OnSelectItem(0); }); + + + + + + + + + + + Qpid Proton C API + 0.16.0 + + + + + + + + + + + + + + + + + + +var searchBox = new SearchBox("searchBox", "search",false,'Search'); + + + + + + + + + + + + +$(document).ready(function(){initNavTree('link_8h.html','');}); + + + + +AllClassesFilesFunctionsVariablesTypedefsEnumerationsEnumeratorGroupsPages + + + + + + + + + +Enumerations +Functions + +link.h File Reference + + + +A channel for transferring messages. +More... +#include proton/import_export.h +#include proton/type_compat.h +#include proton/condition.h +#include proton/terminus.h +#include proton/types.h +#include proton/object.h +#include stddef.h + +Go to the source code of this file. + + +Enumerations +enum pn_snd_settle_mode_t { PN_SND_UNSETTLED, +PN_SND_SETTLED, +PN_SND_MIXED + } +Describes the permitted/expected settlement behaviours of a sending link. More... + +enum pn_rcv_settle_mode_t { PN_RCV_FIRST, +PN_RCV_SECOND + } +Describes the permitted/expected settlement behaviours of a receiving link. More... + + + +Functions +pn_link_t *pn_sender (pn_session_t *session, const char *name) +Construct a new sender on a session. More... + +pn_link_t *pn_receiver (pn_session_t *session, const char *name) +Construct a new receiver on a session. More... + +voidpn_link_free (pn_link_t *link) +Free a link object. More... + +void *pn_link_get_context (pn_link_t *link) + +voidpn_link_set_context (pn_link_t *link, void *context) + +pn_record_t *pn_link_attachments (pn_link_t *link) +Get the attachments that are associated with a link object. More... + +const char *pn_link_name (pn_link_t *link) +Get the name of a link. More... + +boolpn_link_is_sender (pn_link_t *link) +Test if a link is a sender. More... + +boolpn_link_is_receiver (pn_link_t *link) +Test if a link is a receiver. More... + +pn_state_tpn_link_state (pn_link_t *link) +Get the endpoint state flags for a link. More... + +pn_error_t *pn_link_error (pn_link_t *link) + +pn_condition_t *pn_link_condition (pn_link_t *link) +Get the local condition associated with a link endpoint. More... + +pn_condition_t *pn_link_remote_condition (pn_link_t *link) +Get the remote condition associated with a link endpoint. More... + +pn_session_t *pn_link_session (pn_link_t *link) +Get the parent session for a link object. More... + +pn_link_t *pn_link_head (pn_connection_t *connection, pn_state_t state) +Retrieve the first link that matches the given state mask. More... + +pn_link_t *pn_link_next (pn_link_t *link, pn_state_t state) +Retrieve the next link that matches the given state mask. More... + +voidpn_link_open (pn_link_t *link) +Open a link. More... + +voidpn_link_close (pn_link_t *link) +Close a link. More... + +voidpn_link_detach (pn_link_t *link) +Detach a link. More... + +pn_terminus_t *pn_link_source (pn_link_t *link) +Access the locally defined source definition for a link. More... + +pn_terminus_t *pn_link_target (pn_link_t *link) +Access the locally defined target definition for a link. More... + +pn_terminus_t *pn_link_remote_source (pn_link_t *link) +Access the remotely defined source definition for a link. More... + +pn_terminus_t *pn_link_remote_target (pn_link_t *link) +Access the remotely defined target definition for a link. More... + +pn_delivery_t *pn_link_current (pn_link_t *link) +Get the current delivery for a link. More... + +boolpn_link_advance (pn_link_t *link) +Advance the current delivery of a link to the next delivery on the link. More... + +intpn_link_credit (pn_link_t *link) +Get the credit balance for a link. More... + +intpn_link_queued (pn_link_t *link) +Get the number of queued deliveries for a link. More... + +intpn_link_remote_credit (pn_link_t *link) +Get the remote view of the credit for a link. More... + +boolpn_link_get_drain (pn_link_t *link) +Get the drain flag for a link. More... + +intpn_link_drained (pn_link_t *link) +Drain excess credit for a link. More... + +intpn_link_available (pn_link_t *link) +Get the
[25/51] [partial] qpid-site git commit: PROTON-1374: update the website for Proton 0.16.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/7833dc2a/content/releases/qpid-proton-0.16.0/proton/c/api/group__data.js -- diff --git a/content/releases/qpid-proton-0.16.0/proton/c/api/group__data.js b/content/releases/qpid-proton-0.16.0/proton/c/api/group__data.js new file mode 100755 index 000..097f5bc --- /dev/null +++ b/content/releases/qpid-proton-0.16.0/proton/c/api/group__data.js @@ -0,0 +1,84 @@ +var group__data = +[ +[ "pn_data_t", "group__data.html#ga5d6cf528776e8b6ad6d67caf095986bf", null ], +[ "pn_data", "group__data.html#gac21c6f1c517ac486e2923baa3d0c5db4", null ], +[ "pn_data_append", "group__data.html#ga0a98b8f17784460034c240ed4b6b47d7", null ], +[ "pn_data_appendn", "group__data.html#ga9a048cfd78ca76604b667d170eac0136", null ], +[ "pn_data_clear", "group__data.html#ga7611c1394e80b5166b8b8647659f97e6", null ], +[ "pn_data_copy", "group__data.html#gaf0e0fbb9c8c757f94b9636a6b54dc332", null ], +[ "pn_data_decode", "group__data.html#ga74430b712be334a05861cfd5e9b312b9", null ], +[ "pn_data_dump", "group__data.html#ga502e9571b513b58bce5a5ae442951400", null ], +[ "pn_data_encode", "group__data.html#ga5502724bcde68615bc47e09a3335b527", null ], +[ "pn_data_encoded_size", "group__data.html#gae71bfb440cc4f0b15fe958bf55a3f6af", null ], +[ "pn_data_enter", "group__data.html#ga1093449b80357dabf3f70a4bf804f4f7", null ], +[ "pn_data_errno", "group__data.html#ga68e94dfa5d7ab568425c4a6587bac1db", null ], +[ "pn_data_error", "group__data.html#gada171f4740e6a1132b4d4b9c0aea645c", null ], +[ "pn_data_exit", "group__data.html#ga67a656cbdbf0a47a223ff1c8507ecf48", null ], +[ "pn_data_format", "group__data.html#gaa63068cf2ed94f05b20f6c49c908a2c6", null ], +[ "pn_data_free", "group__data.html#ga2c02eee58084ba9b77a37c086e195802", null ], +[ "pn_data_get_array", "group__data.html#gab0f8eefe5f89362ffe186a092044d936", null ], +[ "pn_data_get_array_type", "group__data.html#ga11c026fb5ec5e8620258f52ed86229b4", null ], +[ "pn_data_get_atom", "group__data.html#gac5d5c6e6bf24597caf63d35b1755e646", null ], +[ "pn_data_get_binary", "group__data.html#gaee6e7a4f78d202cc81657e3976fd68ae", null ], +[ "pn_data_get_bool", "group__data.html#gaeab50c7bd297665714861cfcb8f51124", null ], +[ "pn_data_get_byte", "group__data.html#gaa756be79ecfab947ecea57ed8a9089f7", null ], +[ "pn_data_get_bytes", "group__data.html#gad03a049653bec28d20dc7587f7e544de", null ], +[ "pn_data_get_char", "group__data.html#ga9deeb028b90df8bfa3cad7928348b46b", null ], +[ "pn_data_get_decimal128", "group__data.html#gaeb8b424245ca352fb63dce8ca03cd8da", null ], +[ "pn_data_get_decimal32", "group__data.html#gabdbfa1e913c490d3b1ad6ca169910482", null ], +[ "pn_data_get_decimal64", "group__data.html#ga3bdeb99d1275d7fe06a46818467d03d9", null ], +[ "pn_data_get_double", "group__data.html#ga97c448c037e34404df782c82d77b2bc3", null ], +[ "pn_data_get_float", "group__data.html#gabf41ef79c9a4f7e3fd673b0999e63a41", null ], +[ "pn_data_get_int", "group__data.html#ga4f9ccacd002e89127b278703a6c680da", null ], +[ "pn_data_get_list", "group__data.html#ga3af18fc419995766f83a4b4ac07c31ce", null ], +[ "pn_data_get_long", "group__data.html#ga8d813db46df4e635b1ab2c400403560c", null ], +[ "pn_data_get_map", "group__data.html#gadbd4c895a1e10266d20898996ce53bc0", null ], +[ "pn_data_get_short", "group__data.html#gafe894205eaba01d1caf8ee2aa68ed55c", null ], +[ "pn_data_get_string", "group__data.html#gafccb5008960eb8dc757cb7f9941e5013", null ], +[ "pn_data_get_symbol", "group__data.html#ga3c64a188867ebb19c8d4e3908e6f8e20", null ], +[ "pn_data_get_timestamp", "group__data.html#gac8cf4d1cb60c3313f4d61f45bceda5ba", null ], +[ "pn_data_get_ubyte", "group__data.html#ga7582b8fd0ecdf0368a600b9c4f22faa8", null ], +[ "pn_data_get_uint", "group__data.html#ga9541c1ee071c7d0b38805e1b01672ccc", null ], +[ "pn_data_get_ulong", "group__data.html#gaef4aa1c6873eb59a46ccaf76c492826f", null ], +[ "pn_data_get_ushort", "group__data.html#ga254abc4df02a5c2e87fd3bdac2e14846", null ], +[ "pn_data_get_uuid", "group__data.html#ga5ba3f8eb5a972b9a579bc5af9e7fbde2", null ], +[ "pn_data_is_array_described", "group__data.html#ga122e7f20f958d51900675d37d80bd37e", null ], +[ "pn_data_is_described", "group__data.html#gad7fac25ba5589ff0374442cf7ecbbd9c", null ], +[ "pn_data_is_null", "group__data.html#gabba00ce3862818acd8ca91c2a8af348b", null ], +[ "pn_data_narrow", "group__data.html#gaac08905c5bfb2371951914e0fb2793b9", null ], +[ "pn_data_next", "group__data.html#ga96c9a1c5f179036cd9513c50c0ac57de", null ], +[ "pn_data_point", "group__data.html#ga61162ca933ab6b957270f27910981eef", null ], +[ "pn_data_prev", "group__data.html#ga9ee214dd19c845f76e29651682732e16", null ], +[ "pn_data_print",
qpid-jms git commit: QPIDJMS-238: update to proton-j 0.16.0
Repository: qpid-jms Updated Branches: refs/heads/master 56d1622a6 -> affc435d0 QPIDJMS-238: update to proton-j 0.16.0 Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/affc435d Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/affc435d Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/affc435d Branch: refs/heads/master Commit: affc435d007376cf8f78fb51fc2e6707c5b6d53f Parents: 56d1622 Author: Robert GemmellAuthored: Tue Dec 13 17:35:27 2016 + Committer: Robert Gemmell Committed: Tue Dec 13 17:35:27 2016 + -- pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) -- http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/affc435d/pom.xml -- diff --git a/pom.xml b/pom.xml index 0c9e046..87fec07 100644 --- a/pom.xml +++ b/pom.xml @@ -43,7 +43,7 @@ 1.7 -0.16.0-SNAPSHOT +0.16.0 4.1.5.Final 1.7.21 1.0-alpha-2 - To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org
[1/2] qpid-jms git commit: QPIDJMS-207: remove redundant test, covered in client module, and elsewhere using proper ActiveMQ messages
Repository: qpid-jms Updated Branches: refs/heads/master b558fff36 -> 56d1622a6 QPIDJMS-207: remove redundant test, covered in client module, and elsewhere using proper ActiveMQ messages Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/720c6501 Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/720c6501 Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/720c6501 Branch: refs/heads/master Commit: 720c65010a6e61483402693e8f58093c96b763ec Parents: b558fff Author: Robert GemmellAuthored: Tue Dec 13 16:50:14 2016 + Committer: Robert Gemmell Committed: Tue Dec 13 16:50:14 2016 + -- .../qpid/jms/JmsMessageIntegrityTest.java | 314 --- 1 file changed, 314 deletions(-) -- http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/720c6501/qpid-jms-interop-tests/qpid-jms-activemq-tests/src/test/java/org/apache/qpid/jms/JmsMessageIntegrityTest.java -- diff --git a/qpid-jms-interop-tests/qpid-jms-activemq-tests/src/test/java/org/apache/qpid/jms/JmsMessageIntegrityTest.java b/qpid-jms-interop-tests/qpid-jms-activemq-tests/src/test/java/org/apache/qpid/jms/JmsMessageIntegrityTest.java index c9ca39e..f6f96de 100644 --- a/qpid-jms-interop-tests/qpid-jms-activemq-tests/src/test/java/org/apache/qpid/jms/JmsMessageIntegrityTest.java +++ b/qpid-jms-interop-tests/qpid-jms-activemq-tests/src/test/java/org/apache/qpid/jms/JmsMessageIntegrityTest.java @@ -22,18 +22,13 @@ import static org.junit.Assert.assertNull; import static org.junit.Assert.assertTrue; import static org.junit.Assert.fail; -import java.util.Enumeration; -import java.util.HashMap; import java.util.UUID; -import java.util.Vector; import javax.jms.BytesMessage; import javax.jms.Destination; -import javax.jms.JMSException; import javax.jms.MapMessage; import javax.jms.MessageConsumer; import javax.jms.MessageEOFException; -import javax.jms.MessageFormatException; import javax.jms.MessageProducer; import javax.jms.ObjectMessage; import javax.jms.Session; @@ -208,313 +203,4 @@ public class JmsMessageIntegrityTest extends AmqpTestSupport { } assertNull(consumer.receiveNoWait()); } - -static class ForeignMessage implements TextMessage { - -public int deliveryMode; - -private long deliveryTime; -private String messageId; -private long timestamp; -private String correlationId; -private Destination replyTo; -private Destination destination; -private boolean redelivered; -private String type; -private long expiration; -private int priority; -private String text; -private final HashMap props = new HashMap (); - -@Override -public String getJMSMessageID() throws JMSException { -return messageId; -} - -@Override -public void setJMSMessageID(String arg0) throws JMSException { -messageId = arg0; -} - -@Override -public long getJMSTimestamp() throws JMSException { -return timestamp; -} - -@Override -public void setJMSTimestamp(long arg0) throws JMSException { -timestamp = arg0; -} - -@Override -public byte[] getJMSCorrelationIDAsBytes() throws JMSException { -return null; -} - -@Override -public void setJMSCorrelationIDAsBytes(byte[] arg0) throws JMSException { -} - -@Override -public void setJMSCorrelationID(String arg0) throws JMSException { -correlationId = arg0; -} - -@Override -public String getJMSCorrelationID() throws JMSException { -return correlationId; -} - -@Override -public Destination getJMSReplyTo() throws JMSException { -return replyTo; -} - -@Override -public void setJMSReplyTo(Destination arg0) throws JMSException { -replyTo = arg0; -} - -@Override -public Destination getJMSDestination() throws JMSException { -return destination; -} - -@Override -public void setJMSDestination(Destination arg0) throws JMSException { -destination = arg0; -} - -@Override -public int getJMSDeliveryMode() throws JMSException { -return deliveryMode; -} - -@Override -public void setJMSDeliveryMode(int arg0) throws JMSException { -deliveryMode = arg0; -} - -@Override -public boolean getJMSRedelivered() throws JMSException { -
svn commit: r1774053 - in /qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/ack: AcknowledgeOnMessageTest.java AcknowledgeTest.java
Author: lquack Date: Tue Dec 13 16:50:08 2016 New Revision: 1774053 URL: http://svn.apache.org/viewvc?rev=1774053=rev Log: QPID-7546: AcknowledgeOnMessageTest: fix race condition for Qpid JMS AMQP 1.0 client Also see this email thread about the client behaviour: http://mail-archives.apache.org/mod_mbox/qpid-dev/201612.mbox/%3CCAP3WMuTWKa3bvuqDoJ-iWp1as0Ob4aKnojOVP06ZJTo%2B%3Dh647A%40mail.gmail.com%3E Modified: qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/ack/AcknowledgeOnMessageTest.java qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/ack/AcknowledgeTest.java Modified: qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/ack/AcknowledgeOnMessageTest.java URL: http://svn.apache.org/viewvc/qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/ack/AcknowledgeOnMessageTest.java?rev=1774053=1774052=1774053=diff == --- qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/ack/AcknowledgeOnMessageTest.java (original) +++ qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/ack/AcknowledgeOnMessageTest.java Tue Dec 13 16:50:08 2016 @@ -93,6 +93,7 @@ public class AcknowledgeOnMessageTest ex // Wait for messages to arrive boolean complete = _receivedAll.await(1L, TimeUnit.MILLISECONDS); +syncIfNotTransacted(transacted); // If the messasges haven't arrived while (!complete) Modified: qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/ack/AcknowledgeTest.java URL: http://svn.apache.org/viewvc/qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/ack/AcknowledgeTest.java?rev=1774053=1774052=1774053=diff == --- qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/ack/AcknowledgeTest.java (original) +++ qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/ack/AcknowledgeTest.java Tue Dec 13 16:50:08 2016 @@ -179,7 +179,7 @@ public class AcknowledgeTest extends Qpi testAcking(false, AMQSession.PRE_ACKNOWLEDGE); } -private void syncIfNotTransacted(boolean transacted) throws Exception +protected void syncIfNotTransacted(boolean transacted) throws Exception { if(!transacted) { - To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org
svn commit: r1774045 - in /qpid/java/branches/6.1.x/broker-core/src: main/java/org/apache/qpid/server/security/auth/manager/AuthenticationResultCacher.java test/java/org/apache/qpid/server/security/au
Author: lquack Date: Tue Dec 13 16:02:30 2016 New Revision: 1774045 URL: http://svn.apache.org/viewvc?rev=1774045=rev Log: QPID-7549: [Java Broker] Guard agains NPE in AuthenticationResultCacher Modified: qpid/java/branches/6.1.x/broker-core/src/main/java/org/apache/qpid/server/security/auth/manager/AuthenticationResultCacher.java qpid/java/branches/6.1.x/broker-core/src/test/java/org/apache/qpid/server/security/auth/manager/AuthenticationResultCacherTest.java Modified: qpid/java/branches/6.1.x/broker-core/src/main/java/org/apache/qpid/server/security/auth/manager/AuthenticationResultCacher.java URL: http://svn.apache.org/viewvc/qpid/java/branches/6.1.x/broker-core/src/main/java/org/apache/qpid/server/security/auth/manager/AuthenticationResultCacher.java?rev=1774045=1774044=1774045=diff == --- qpid/java/branches/6.1.x/broker-core/src/main/java/org/apache/qpid/server/security/auth/manager/AuthenticationResultCacher.java (original) +++ qpid/java/branches/6.1.x/broker-core/src/main/java/org/apache/qpid/server/security/auth/manager/AuthenticationResultCacher.java Tue Dec 13 16:02:30 2016 @@ -71,13 +71,14 @@ public class AuthenticationResultCacher { try { -if (_authenticationCache == null) +final Subject subject = Subject.getSubject(AccessController.getContext()); +if (_authenticationCache == null || subject == null) { return loader.call(); } else { -String credentialDigest = digestCredentials(credentials); +String credentialDigest = digestCredentials(subject, credentials); return _authenticationCache.get(credentialDigest, new Callable() { @Override @@ -106,13 +107,12 @@ public class AuthenticationResultCacher } } -private String digestCredentials(final String... content) +private String digestCredentials(final Subject subject, final String... content) { try { MessageDigest md = MessageDigest.getInstance("SHA-256"); -Subject subject = Subject.getSubject(AccessController.getContext()); Set connectionPrincipals = subject.getPrincipals(SocketConnectionPrincipal.class); if (connectionPrincipals != null && !connectionPrincipals.isEmpty()) { Modified: qpid/java/branches/6.1.x/broker-core/src/test/java/org/apache/qpid/server/security/auth/manager/AuthenticationResultCacherTest.java URL: http://svn.apache.org/viewvc/qpid/java/branches/6.1.x/broker-core/src/test/java/org/apache/qpid/server/security/auth/manager/AuthenticationResultCacherTest.java?rev=1774045=1774044=1774045=diff == --- qpid/java/branches/6.1.x/broker-core/src/test/java/org/apache/qpid/server/security/auth/manager/AuthenticationResultCacherTest.java (original) +++ qpid/java/branches/6.1.x/broker-core/src/test/java/org/apache/qpid/server/security/auth/manager/AuthenticationResultCacherTest.java Tue Dec 13 16:02:30 2016 @@ -138,4 +138,34 @@ public class AuthenticationResultCacherT } }); } + + +public void testCacheMissForNullSubject() throws Exception +{ +Subject.doAs(null, new PrivilegedAction() +{ +@Override +public Void run() +{ +AuthenticationResult result= _authenticationResultCacher.getOrLoad(new String[]{"credentials"}, _loader); +assertEquals("Unexpected AuthenticationResult", _successfulAuthenticationResult, result); +assertEquals("Unexpected number of loads before cache hit", 1, _loadCallCount); +return null; +} +}); + +when(_connection.getRemoteSocketAddress()).thenReturn(new InetSocketAddress("example.com", )); +Subject.doAs(null, new PrivilegedAction() +{ +@Override +public Void run() +{ +AuthenticationResult result= _authenticationResultCacher.getOrLoad(new String[]{"credentials"}, _loader); +assertEquals("Unexpected AuthenticationResult", _successfulAuthenticationResult, result); +assertEquals("Unexpected number of loads before cache hit", 2, _loadCallCount); +return null; +} +}); +} + } - To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org
svn commit: r1774041 - in /qpid/java/branches/6.1.x: ./ broker-core/src/main/java/org/apache/qpid/server/security/auth/manager/AuthenticationResultCacher.java
Author: lquack Date: Tue Dec 13 15:49:26 2016 New Revision: 1774041 URL: http://svn.apache.org/viewvc?rev=1774041=rev Log: QPID-7549: [Java Broker] Cache authentication results on http path in addition to amqp merged from trunk using svn merge -c r1774039 ^/qpid/java/trunk Modified: qpid/java/branches/6.1.x/ (props changed) qpid/java/branches/6.1.x/broker-core/src/main/java/org/apache/qpid/server/security/auth/manager/AuthenticationResultCacher.java Propchange: qpid/java/branches/6.1.x/ -- --- svn:mergeinfo (original) +++ svn:mergeinfo Tue Dec 13 15:49:26 2016 @@ -9,5 +9,5 @@ /qpid/branches/java-broker-vhost-refactor/java:1493674-1494547 /qpid/branches/java-network-refactor/qpid/java:805429-821809 /qpid/branches/qpid-2935/qpid/java:1061302-1072333 -/qpid/java/trunk:1766544,1766547,1766553,176,1766796-1766797,1766806,1767251,1767267-1767268,1767275,1767310,1767326,1767329,1767332,1767514,1767523,1767738,1767825,1767847-1767849,1767882,1767909,1767914,1768016-1768017,1768065,1768643,1768704,1768854,1768875,1768914,1768963,1768967,1768976,1769007,1769009,1769087,1769138-1769139,1769597,1769879,1770236,1770716,1772241,1773057 +/qpid/java/trunk:1766544,1766547,1766553,176,1766796-1766797,1766806,1767251,1767267-1767268,1767275,1767310,1767326,1767329,1767332,1767514,1767523,1767738,1767825,1767847-1767849,1767882,1767909,1767914,1768016-1768017,1768065,1768643,1768704,1768854,1768875,1768914,1768963,1768967,1768976,1769007,1769009,1769087,1769138-1769139,1769597,1769879,1770236,1770716,1772241,1773057,1774039 /qpid/trunk/qpid:796646-796653 Modified: qpid/java/branches/6.1.x/broker-core/src/main/java/org/apache/qpid/server/security/auth/manager/AuthenticationResultCacher.java URL: http://svn.apache.org/viewvc/qpid/java/branches/6.1.x/broker-core/src/main/java/org/apache/qpid/server/security/auth/manager/AuthenticationResultCacher.java?rev=1774041=1774040=1774041=diff == --- qpid/java/branches/6.1.x/broker-core/src/main/java/org/apache/qpid/server/security/auth/manager/AuthenticationResultCacher.java (original) +++ qpid/java/branches/6.1.x/broker-core/src/main/java/org/apache/qpid/server/security/auth/manager/AuthenticationResultCacher.java Tue Dec 13 15:49:26 2016 @@ -38,8 +38,8 @@ import com.google.common.util.concurrent import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import org.apache.qpid.server.connection.ConnectionPrincipal; import org.apache.qpid.server.security.auth.AuthenticationResult; +import org.apache.qpid.server.security.auth.SocketConnectionPrincipal; public class AuthenticationResultCacher { @@ -113,10 +113,10 @@ public class AuthenticationResultCacher MessageDigest md = MessageDigest.getInstance("SHA-256"); Subject subject = Subject.getSubject(AccessController.getContext()); -Set connectionPrincipals = subject.getPrincipals(ConnectionPrincipal.class); +Set connectionPrincipals = subject.getPrincipals(SocketConnectionPrincipal.class); if (connectionPrincipals != null && !connectionPrincipals.isEmpty()) { -ConnectionPrincipal connectionPrincipal = connectionPrincipals.iterator().next(); +SocketConnectionPrincipal connectionPrincipal = connectionPrincipals.iterator().next(); md.update(connectionPrincipal.getRemoteAddress().toString().getBytes(UTF8)); } - To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org
svn commit: r1774039 - /qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/security/auth/manager/AuthenticationResultCacher.java
Author: lquack Date: Tue Dec 13 15:45:05 2016 New Revision: 1774039 URL: http://svn.apache.org/viewvc?rev=1774039=rev Log: QPID-7549: [Java Broker] Cache authentication results on http path in addition to amqp Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/security/auth/manager/AuthenticationResultCacher.java Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/security/auth/manager/AuthenticationResultCacher.java URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/security/auth/manager/AuthenticationResultCacher.java?rev=1774039=1774038=1774039=diff == --- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/security/auth/manager/AuthenticationResultCacher.java (original) +++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/security/auth/manager/AuthenticationResultCacher.java Tue Dec 13 15:45:05 2016 @@ -38,8 +38,8 @@ import com.google.common.util.concurrent import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import org.apache.qpid.server.connection.ConnectionPrincipal; import org.apache.qpid.server.security.auth.AuthenticationResult; +import org.apache.qpid.server.security.auth.SocketConnectionPrincipal; public class AuthenticationResultCacher { @@ -113,10 +113,10 @@ public class AuthenticationResultCacher MessageDigest md = MessageDigest.getInstance("SHA-256"); Subject subject = Subject.getSubject(AccessController.getContext()); -Set connectionPrincipals = subject.getPrincipals(ConnectionPrincipal.class); +Set connectionPrincipals = subject.getPrincipals(SocketConnectionPrincipal.class); if (connectionPrincipals != null && !connectionPrincipals.isEmpty()) { -ConnectionPrincipal connectionPrincipal = connectionPrincipals.iterator().next(); +SocketConnectionPrincipal connectionPrincipal = connectionPrincipals.iterator().next(); md.update(connectionPrincipal.getRemoteAddress().toString().getBytes(UTF8)); } - To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org
svn commit: r1774022 - in /qpid/java/trunk: broker-core/src/main/java/org/apache/qpid/server/logging/ broker-core/src/main/java/org/apache/qpid/server/logging/subjects/ broker-core/src/main/java/org/a
Author: lquack Date: Tue Dec 13 14:27:19 2016 New Revision: 1774022 URL: http://svn.apache.org/viewvc?rev=1774022=rev Log: QPID-7549: [Java Broker] Ensure subject is created for REST requests * change the format of operational logging for management operations * refactor HTTP Filters Added: qpid/java/trunk/broker-plugins/management-http/src/main/java/org/apache/qpid/server/management/plugin/filter/AuthenticationCheckFilter.java qpid/java/trunk/broker-plugins/management-http/src/main/java/org/apache/qpid/server/management/plugin/filter/RedirectingFilter.java - copied, changed from r1774020, qpid/java/trunk/broker-plugins/management-http/src/main/java/org/apache/qpid/server/management/plugin/filter/RedirectingAuthorisationFilter.java Removed: qpid/java/trunk/broker-plugins/management-http/src/main/java/org/apache/qpid/server/management/plugin/filter/ForbiddingAuthorisationFilter.java qpid/java/trunk/broker-plugins/management-http/src/main/java/org/apache/qpid/server/management/plugin/filter/PreemptiveSessionInvalidationFilter.java qpid/java/trunk/broker-plugins/management-http/src/main/java/org/apache/qpid/server/management/plugin/filter/RedirectingAuthorisationFilter.java qpid/java/trunk/broker-plugins/management-http/src/test/java/org/apache/qpid/server/management/plugin/filter/ Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/logging/AbstractMessageLogger.java qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/logging/subjects/LogSubjectFormat.java qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/security/auth/ManagementConnectionPrincipal.java qpid/java/trunk/broker-core/src/test/java/org/apache/qpid/server/logging/actors/HttpManagementActorTest.java qpid/java/trunk/broker-plugins/management-http/src/main/java/org/apache/qpid/server/management/plugin/HttpManagement.java qpid/java/trunk/broker-plugins/management-http/src/main/java/org/apache/qpid/server/management/plugin/HttpManagementUtil.java qpid/java/trunk/broker-plugins/management-http/src/main/java/org/apache/qpid/server/management/plugin/servlet/ServletConnectionPrincipal.java qpid/java/trunk/broker-plugins/management-http/src/main/java/org/apache/qpid/server/management/plugin/servlet/rest/AbstractServlet.java qpid/java/trunk/broker-plugins/management-http/src/main/java/org/apache/qpid/server/management/plugin/servlet/rest/ApiDocsServlet.java qpid/java/trunk/broker-plugins/management-http/src/main/java/org/apache/qpid/server/management/plugin/servlet/rest/JsonValueServlet.java qpid/java/trunk/broker-plugins/management-http/src/main/java/org/apache/qpid/server/management/plugin/servlet/rest/MetaDataServlet.java qpid/java/trunk/broker-plugins/management-http/src/main/java/org/apache/qpid/server/management/plugin/servlet/rest/QueryServlet.java qpid/java/trunk/broker-plugins/management-http/src/main/java/org/apache/qpid/server/management/plugin/servlet/rest/QueueReportServlet.java qpid/java/trunk/broker-plugins/management-http/src/main/java/org/apache/qpid/server/management/plugin/servlet/rest/RestServlet.java qpid/java/trunk/broker-plugins/management-http/src/main/java/org/apache/qpid/server/management/plugin/servlet/rest/SaslServlet.java qpid/java/trunk/broker-plugins/management-http/src/main/java/org/apache/qpid/server/management/plugin/servlet/rest/StructureServlet.java qpid/java/trunk/broker-plugins/management-http/src/main/java/org/apache/qpid/server/management/plugin/servlet/rest/TimeZoneServlet.java qpid/java/trunk/systests/src/test/java/org/apache/qpid/systest/rest/BrokerRestHttpsClientCertAuthTest.java qpid/java/trunk/systests/src/test/java/org/apache/qpid/systest/rest/PreemtiveAuthRestTest.java Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/logging/AbstractMessageLogger.java URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/logging/AbstractMessageLogger.java?rev=1774022=1774021=1774022=diff == --- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/logging/AbstractMessageLogger.java (original) +++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/logging/AbstractMessageLogger.java Tue Dec 13 14:27:19 2016 @@ -21,6 +21,18 @@ package org.apache.qpid.server.logging; +import static org.apache.qpid.server.logging.subjects.LogSubjectFormat.CHANNEL_FORMAT; +import static org.apache.qpid.server.logging.subjects.LogSubjectFormat.CONNECTION_FORMAT; +import static org.apache.qpid.server.logging.subjects.LogSubjectFormat.SOCKET_FORMAT; +import static org.apache.qpid.server.logging.subjects.LogSubjectFormat.USER_FORMAT; + +import java.security.AccessController; +import java.security.Principal; +import java.text.MessageFormat; +import java.util.Set; + +import
svn commit: r1774020 - /qpid/java/trunk/broker/scripts/
Author: rgodfrey Date: Tue Dec 13 14:15:42 2016 New Revision: 1774020 URL: http://svn.apache.org/viewvc?rev=1774020=rev Log: QPID-3260 : Remove a script that relies on tooling that was deleted back in 2011 Removed: qpid/java/trunk/broker/scripts/ - To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org
qpid-jms git commit: QPIDJMS-207: more fixups for sending foreign JMS 1.1 message
Repository: qpid-jms Updated Branches: refs/heads/master 2bacb1738 -> b558fff36 QPIDJMS-207: more fixups for sending foreign JMS 1.1 message Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/b558fff3 Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/b558fff3 Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/b558fff3 Branch: refs/heads/master Commit: b558fff36dadd5e09ed5c6041eabd983cd203d45 Parents: 2bacb17 Author: Robert GemmellAuthored: Tue Dec 13 13:36:47 2016 + Committer: Robert Gemmell Committed: Tue Dec 13 13:36:47 2016 + -- .../java/org/apache/qpid/jms/JmsSession.java| 8 +++-- .../jms/message/JmsMessageTransformation.java | 25 - .../jms/producer/JmsMessageProducerTest.java| 38 3 files changed, 68 insertions(+), 3 deletions(-) -- http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/b558fff3/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsSession.java -- diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsSession.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsSession.java index 74b6c70..604d92f 100644 --- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsSession.java +++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsSession.java @@ -18,6 +18,7 @@ package org.apache.qpid.jms; import java.io.Serializable; import java.lang.reflect.Method; +import java.lang.reflect.Modifier; import java.util.ArrayList; import java.util.Deque; import java.util.Iterator; @@ -867,13 +868,16 @@ public class JmsSession implements AutoCloseable, Session, QueueSession, TopicSe Method deliveryTimeMethod = null; try { Class clazz = foreignMessage.getClass(); -deliveryTimeMethod = clazz.getMethod("setJMSDeliveryTime", new Class[] { long.class }); +Method method = clazz.getMethod("setJMSDeliveryTime", new Class[] { long.class }); +if (!Modifier.isAbstract(method.getModifiers())) { +deliveryTimeMethod = method; +} } catch (NoSuchMethodException e) { // Assume its a JMS 1.1 Message, we will no-op. } if (deliveryTimeMethod != null) { -// Method exists, so use it +// Method exists, isn't abstract, so use it. foreignMessage.setJMSDeliveryTime(deliveryTime); } } http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/b558fff3/qpid-jms-client/src/main/java/org/apache/qpid/jms/message/JmsMessageTransformation.java -- diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/message/JmsMessageTransformation.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/message/JmsMessageTransformation.java index 9ab4af6..4f94db7 100644 --- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/message/JmsMessageTransformation.java +++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/message/JmsMessageTransformation.java @@ -16,6 +16,8 @@ */ package org.apache.qpid.jms.message; +import java.lang.reflect.Method; +import java.lang.reflect.Modifier; import java.util.Enumeration; import javax.jms.BytesMessage; @@ -194,7 +196,7 @@ public final class JmsMessageTransformation { target.setJMSReplyTo(transformDestination(connection, source.getJMSReplyTo())); target.setJMSDestination(transformDestination(connection, source.getJMSDestination())); target.setJMSDeliveryMode(source.getJMSDeliveryMode()); -target.setJMSDeliveryTime(source.getJMSDeliveryTime()); +target.setJMSDeliveryTime(getForeignMessageDeliveryTime(source)); target.setJMSRedelivered(source.getJMSRedelivered()); target.setJMSType(source.getJMSType()); target.setJMSExpiration(source.getJMSExpiration()); @@ -221,4 +223,25 @@ public final class JmsMessageTransformation { return unresolvedDestinationHandler; } + +private static long getForeignMessageDeliveryTime(Message foreignMessage) throws JMSException { +// Verify if the getJMSDeliveryTime method exists, i.e the foreign provider isn't only JMS 1.1. +Method deliveryTimeMethod = null; +try { +Class clazz = foreignMessage.getClass(); +Method method = clazz.getMethod("getJMSDeliveryTime", (Class[]) null); +if (!Modifier.isAbstract(method.getModifiers())) { +deliveryTimeMethod = method; +} +} catch (NoSuchMethodException e) { +// Assume its a JMS 1.1 Message, we will return 0. +} + +if (deliveryTimeMethod != null) {
qpid-jms git commit: QPIDJMS-232: fix javadoc error, remove defunct param details
Repository: qpid-jms Updated Branches: refs/heads/master 7f666272e -> 2bacb1738 QPIDJMS-232: fix javadoc error, remove defunct param details Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/2bacb173 Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/2bacb173 Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/2bacb173 Branch: refs/heads/master Commit: 2bacb1738cda817fc57629a6c0285ea885c63881 Parents: 7f66627 Author: Robert GemmellAuthored: Tue Dec 13 13:05:54 2016 + Committer: Robert Gemmell Committed: Tue Dec 13 13:05:54 2016 + -- .../org/apache/qpid/jms/provider/amqp/AmqpSaslAuthenticator.java | 3 --- 1 file changed, 3 deletions(-) -- http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/2bacb173/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpSaslAuthenticator.java -- diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpSaslAuthenticator.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpSaslAuthenticator.java index 52b7674..96168f2 100644 --- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpSaslAuthenticator.java +++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpSaslAuthenticator.java @@ -81,9 +81,6 @@ public class AmqpSaslAuthenticator { * successful authentication or a JMSSecurityException is thrown indicating that the * handshake failed. * - * @param authenticationRequest - * The request that is awaiting the result of authentication. - * * @return true if the authentication process completed. */ public boolean authenticate() throws JMSSecurityException { - To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org
[1/2] qpid-jms git commit: NO-JIRA: adjust test to avoid race
Repository: qpid-jms Updated Branches: refs/heads/master 1201c2561 -> 7f666272e NO-JIRA: adjust test to avoid race Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/05dd7b68 Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/05dd7b68 Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/05dd7b68 Branch: refs/heads/master Commit: 05dd7b681b000d4fc8b50ef17a3aa0474d6d15e5 Parents: 1201c25 Author: Robert GemmellAuthored: Tue Dec 13 11:55:36 2016 + Committer: Robert Gemmell Committed: Tue Dec 13 11:55:36 2016 + -- .../qpid/jms/integration/MessageExpirationIntegrationTest.java | 2 ++ 1 file changed, 2 insertions(+) -- http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/05dd7b68/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/MessageExpirationIntegrationTest.java -- diff --git a/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/MessageExpirationIntegrationTest.java b/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/MessageExpirationIntegrationTest.java index 16a8af9..346019f 100644 --- a/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/MessageExpirationIntegrationTest.java +++ b/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/MessageExpirationIntegrationTest.java @@ -274,6 +274,8 @@ public class MessageExpirationIntegrationTest extends QpidJmsTestCase { assertTrue("didn't get expected messages", success.await(5, TimeUnit.SECONDS)); assertFalse("There was a failure in the listener, see logs", listenerFailure.get()); +testPeer.waitForAllHandlersToComplete(3000); + testPeer.expectClose(); connection.close(); - To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org
[2/2] qpid-jms git commit: QPIDJMS-207: update handling of delivery-delay to account for foreign messages that may not support it
QPIDJMS-207: update handling of delivery-delay to account for foreign messages that may not support it Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/7f666272 Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/7f666272 Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/7f666272 Branch: refs/heads/master Commit: 7f666272e1bd4b7fc5e70c3129dadfc3ce23ef95 Parents: 05dd7b6 Author: Robert GemmellAuthored: Tue Dec 13 12:55:18 2016 + Committer: Robert Gemmell Committed: Tue Dec 13 12:55:18 2016 + -- .../java/org/apache/qpid/jms/JmsSession.java| 30 +++-- .../ForeignMessageIntegrationTest.java | 70 .../integration/ProducerIntegrationTest.java| 29 +++- 3 files changed, 122 insertions(+), 7 deletions(-) -- http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/7f666272/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsSession.java -- diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsSession.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsSession.java index 6ad8729..74b6c70 100644 --- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsSession.java +++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsSession.java @@ -17,6 +17,7 @@ package org.apache.qpid.jms; import java.io.Serializable; +import java.lang.reflect.Method; import java.util.ArrayList; import java.util.Deque; import java.util.Iterator; @@ -754,6 +755,8 @@ public class JmsSession implements AutoCloseable, Session, QueueSession, TopicSe boolean hasTTL = timeToLive > Message.DEFAULT_TIME_TO_LIVE; boolean hasDelay = deliveryDelay > Message.DEFAULT_DELIVERY_DELAY; +boolean isJmsMessage = original instanceof JmsMessage; + if (!disableTimestamp) { original.setJMSTimestamp(timeStamp); } else { @@ -766,13 +769,16 @@ public class JmsSession implements AutoCloseable, Session, QueueSession, TopicSe original.setJMSExpiration(0); } +long deliveryTime = 0; if (hasDelay) { -original.setJMSDeliveryTime(timeStamp + deliveryDelay); -} else { -original.setJMSDeliveryTime(0); +deliveryTime = timeStamp + deliveryDelay; } -boolean isJmsMessage = original instanceof JmsMessage; +if(isJmsMessage) { +original.setJMSDeliveryTime(deliveryTime); +} else { +setForeignMessageDeliveryTime(original, deliveryTime); +} long messageSequence = producer.getNextMessageSequence(); Object messageId = null; @@ -856,6 +862,22 @@ public class JmsSession implements AutoCloseable, Session, QueueSession, TopicSe } } +private void setForeignMessageDeliveryTime(Message foreignMessage, long deliveryTime) throws JMSException { +// Verify if the setJMSDeliveryTime method exists, i.e the foreign provider isn't only JMS 1.1. +Method deliveryTimeMethod = null; +try { +Class clazz = foreignMessage.getClass(); +deliveryTimeMethod = clazz.getMethod("setJMSDeliveryTime", new Class[] { long.class }); +} catch (NoSuchMethodException e) { +// Assume its a JMS 1.1 Message, we will no-op. +} + +if (deliveryTimeMethod != null) { +// Method exists, so use it +foreignMessage.setJMSDeliveryTime(deliveryTime); +} +} + void acknowledge(JmsInboundMessageDispatch envelope, ACK_TYPE ackType) throws JMSException { transactionContext.acknowledge(connection, envelope, ackType); } http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/7f666272/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/ForeignMessageIntegrationTest.java -- diff --git a/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/ForeignMessageIntegrationTest.java b/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/ForeignMessageIntegrationTest.java index c775cba..61dee9f 100644 --- a/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/ForeignMessageIntegrationTest.java +++ b/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/ForeignMessageIntegrationTest.java @@ -18,7 +18,11 @@ */ package org.apache.qpid.jms.integration; +import static org.apache.qpid.jms.provider.amqp.AmqpSupport.DELAYED_DELIVERY; +import static org.hamcrest.Matchers.both; import static org.hamcrest.Matchers.equalTo; +import static
qpid-jms git commit: QPIDJMS-207: ensure resource clean up for JMSContextTest
Repository: qpid-jms Updated Branches: refs/heads/master f3e676e9c -> 1201c2561 QPIDJMS-207: ensure resource clean up for JMSContextTest Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/1201c256 Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/1201c256 Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/1201c256 Branch: refs/heads/master Commit: 1201c25619a692e51ceb1231c42854711973871d Parents: f3e676e Author: Robert GemmellAuthored: Tue Dec 13 11:44:48 2016 + Committer: Robert Gemmell Committed: Tue Dec 13 11:44:48 2016 + -- .../qpid/jms/JmsConnectionTestSupport.java | 4 ++- .../org/apache/qpid/jms/JmsContextTest.java | 28 2 files changed, 26 insertions(+), 6 deletions(-) -- http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/1201c256/qpid-jms-client/src/test/java/org/apache/qpid/jms/JmsConnectionTestSupport.java -- diff --git a/qpid-jms-client/src/test/java/org/apache/qpid/jms/JmsConnectionTestSupport.java b/qpid-jms-client/src/test/java/org/apache/qpid/jms/JmsConnectionTestSupport.java index 5514c61..8dd5656 100644 --- a/qpid-jms-client/src/test/java/org/apache/qpid/jms/JmsConnectionTestSupport.java +++ b/qpid-jms-client/src/test/java/org/apache/qpid/jms/JmsConnectionTestSupport.java @@ -17,6 +17,7 @@ package org.apache.qpid.jms; import java.net.URI; +import java.util.concurrent.atomic.AtomicLong; import javax.jms.JMSContext; @@ -37,6 +38,7 @@ import org.junit.Before; */ public class JmsConnectionTestSupport extends QpidJmsTestCase { +private static final AtomicLong CONN_ID_SUFFIX = new AtomicLong(); private final IdGenerator clientIdGenerator = new IdGenerator(); protected final MockProviderFactory mockFactory = new MockProviderFactory(); @@ -80,7 +82,7 @@ public class JmsConnectionTestSupport extends QpidJmsTestCase { @Before public void setUp() throws Exception { super.setUp(); -connectionInfo = new JmsConnectionInfo(new JmsConnectionId("ID:TEST:1")); +connectionInfo = new JmsConnectionInfo(new JmsConnectionId("ID:JCTS(" + CONN_ID_SUFFIX.incrementAndGet() + "):" + getClass().getName())); connectionInfo.setClientId(clientIdGenerator.generateId(), false); } http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/1201c256/qpid-jms-client/src/test/java/org/apache/qpid/jms/JmsContextTest.java -- diff --git a/qpid-jms-client/src/test/java/org/apache/qpid/jms/JmsContextTest.java b/qpid-jms-client/src/test/java/org/apache/qpid/jms/JmsContextTest.java index aa8b90e..4f88d7b 100644 --- a/qpid-jms-client/src/test/java/org/apache/qpid/jms/JmsContextTest.java +++ b/qpid-jms-client/src/test/java/org/apache/qpid/jms/JmsContextTest.java @@ -44,6 +44,7 @@ import javax.jms.Topic; import org.apache.qpid.jms.provider.ProviderConstants.ACK_TYPE; import org.apache.qpid.jms.provider.mock.MockRemotePeer; +import org.junit.After; import org.junit.Before; import org.junit.Test; import org.mockito.Matchers; @@ -66,13 +67,26 @@ public class JmsContextTest extends JmsConnectionTestSupport { context = createJMSContextToMockProvider(); } +@Override +@After +public void tearDown() throws Exception { +super.tearDown(); +if (context != null) { +context.close(); +} +} + //- Test basic interface behaviors ---// @Test public void testCreateContextWithNewAcknowledgementMode() { JMSContext newContext = context.createContext(JMSContext.CLIENT_ACKNOWLEDGE); -assertNotNull(newContext); -assertEquals(JMSContext.CLIENT_ACKNOWLEDGE, newContext.getSessionMode()); +try { +assertNotNull(newContext); +assertEquals(JMSContext.CLIENT_ACKNOWLEDGE, newContext.getSessionMode()); +} finally { +newContext.close(); +} } @Test @@ -84,9 +98,13 @@ public class JmsContextTest extends JmsConnectionTestSupport { public void testGetTransactedFromContext() { assertFalse(context.getTransacted()); JMSContext newContext = context.createContext(JMSContext.SESSION_TRANSACTED); -assertNotNull(newContext); -assertEquals(JMSContext.SESSION_TRANSACTED, newContext.getSessionMode()); -assertTrue(newContext.getTransacted()); +try { +assertNotNull(newContext); +assertEquals(JMSContext.SESSION_TRANSACTED, newContext.getSessionMode()); +assertTrue(newContext.getTransacted()); +} finally { +
qpid-jms git commit: QPIDJMS-237: some more test cleanup
Repository: qpid-jms Updated Branches: refs/heads/master c05146612 -> f3e676e9c QPIDJMS-237: some more test cleanup Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/f3e676e9 Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/f3e676e9 Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/f3e676e9 Branch: refs/heads/master Commit: f3e676e9c5f1f2ce5926d759b4143fd81e043c73 Parents: c051466 Author: Robert GemmellAuthored: Tue Dec 13 10:55:51 2016 + Committer: Robert Gemmell Committed: Tue Dec 13 10:55:51 2016 + -- .../qpid/jms/JmsConnectionFactoryTest.java | 30 .../apache/qpid/jms/JmsQueueConnectionTest.java | 6 .../qpid/jms/consumer/JmsConsumerTest.java | 3 +- .../jms/producer/JmsMessageProducerTest.java| 7 +++-- .../qpid/jms/producer/JmsProducerTest.java | 11 +++ .../qpid/jms/producer/JmsQueueSenderTest.java | 7 +++-- .../jms/producer/JmsTopicPublisherTest.java | 7 +++-- 7 files changed, 57 insertions(+), 14 deletions(-) -- http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/f3e676e9/qpid-jms-client/src/test/java/org/apache/qpid/jms/JmsConnectionFactoryTest.java -- diff --git a/qpid-jms-client/src/test/java/org/apache/qpid/jms/JmsConnectionFactoryTest.java b/qpid-jms-client/src/test/java/org/apache/qpid/jms/JmsConnectionFactoryTest.java index 465ac6d..601e1de 100644 --- a/qpid-jms-client/src/test/java/org/apache/qpid/jms/JmsConnectionFactoryTest.java +++ b/qpid-jms-client/src/test/java/org/apache/qpid/jms/JmsConnectionFactoryTest.java @@ -108,6 +108,8 @@ public class JmsConnectionFactoryTest extends QpidJmsTestCase { assertEquals(TimeUnit.SECONDS.toMillis(30), connection.getConnectTimeout()); assertEquals(TimeUnit.SECONDS.toMillis(45), connection.getCloseTimeout()); + +connection.close(); } @Test @@ -131,6 +133,8 @@ public class JmsConnectionFactoryTest extends QpidJmsTestCase { assertEquals(1, prefetchPolicy.getQueuePrefetch()); assertEquals(1, prefetchPolicy.getQueueBrowserPrefetch()); assertEquals(1, prefetchPolicy.getDurableTopicPrefetch()); + +connection.close(); } @Test @@ -151,6 +155,8 @@ public class JmsConnectionFactoryTest extends QpidJmsTestCase { assertNotSame(factory.getPresettlePolicy(), presettlePolicy); assertTrue(presettlePolicy.isPresettleAll()); + +connection.close(); } @Test @@ -171,6 +177,8 @@ public class JmsConnectionFactoryTest extends QpidJmsTestCase { assertNotSame(factory.getRedeliveryPolicy(), redeliveryPolicy); assertEquals(100, redeliveryPolicy.getMaxRedeliveries()); + +connection.close(); } @Test @@ -206,6 +214,8 @@ public class JmsConnectionFactoryTest extends QpidJmsTestCase { assertEquals(mock, connection.getConfiguredURI()); connection.start(); assertEquals(mock, connection.getConnectedURI()); + +connection.close(); } @Test @@ -224,6 +234,8 @@ public class JmsConnectionFactoryTest extends QpidJmsTestCase { assertNotNull(connection); assertNotNull(connection.getExceptionListener()); assertSame(listener, connection.getExceptionListener()); + +connection.close(); } @Test @@ -236,6 +248,8 @@ public class JmsConnectionFactoryTest extends QpidJmsTestCase { JmsConnection connection = (JmsConnection) factory.createConnection(); assertNotNull(connection); assertTrue("Connection ID = " + connection.getId(), connection.getId().toString().startsWith("TEST-ID:")); + +connection.close(); } @Test @@ -246,6 +260,8 @@ public class JmsConnectionFactoryTest extends QpidJmsTestCase { JmsConnection connection = (JmsConnection) factory.createConnection(); assertNotNull(connection); assertTrue("Connection ID = " + connection.getId(), connection.getId().toString().startsWith("TEST-ID:")); + +connection.close(); } @Test @@ -260,6 +276,8 @@ public class JmsConnectionFactoryTest extends QpidJmsTestCase { assertNotNull(connection); assertTrue("Connection ID = " + connection.getClientID(), connection.getClientID().startsWith("TEST-ID:")); + +connection.close(); } @Test @@ -272,6 +290,8 @@ public class JmsConnectionFactoryTest extends QpidJmsTestCase { assertNotNull(connection); assertTrue("Client ID = " + connection.getClientID(), connection.getClientID().startsWith("TEST-ID:")); + +connection.close(); } @Test @@ -757,6 +777,8 @@ public class