You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ro...@apache.org on 2017/11/26 18:22:43 UTC
[23/42] qpid-site git commit: QPID-8051: update site content for
qpid-python-1.37.0
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/e970301e/content/releases/qpid-python-1.37.0/messaging-api/api/toc-qpid.messaging.address-module.html
----------------------------------------------------------------------
diff --git a/content/releases/qpid-python-1.37.0/messaging-api/api/toc-qpid.messaging.address-module.html b/content/releases/qpid-python-1.37.0/messaging-api/api/toc-qpid.messaging.address-module.html
new file mode 100755
index 0000000..9a1f5f5
--- /dev/null
+++ b/content/releases/qpid-python-1.37.0/messaging-api/api/toc-qpid.messaging.address-module.html
@@ -0,0 +1,31 @@
+<?xml version="1.0" encoding="ascii"?>
+<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN"
+ "DTD/xhtml1-transitional.dtd">
+<html xmlns="http://www.w3.org/1999/xhtml" xml:lang="en" lang="en">
+<head>
+ <title>address</title>
+ <link rel="stylesheet" href="epydoc.css" type="text/css" />
+ <script type="text/javascript" src="epydoc.js"></script>
+</head>
+
+<body bgcolor="white" text="black" link="blue" vlink="#204080"
+ alink="#204080">
+<h1 class="toc">Module address</h1>
+<hr />
+ <h2 class="toc">Classes</h2>
+ <a target="mainFrame" href="qpid.parser.ParseError-class.html"
+ >ParseError</a><br /> <h2 class="toc">Functions</h2>
+ <a target="mainFrame" href="qpid.messaging.address-module.html#parse"
+ >parse</a><br /><hr />
+
+<script type="text/javascript">
+ <!--
+ // Private objects are initially displayed (because if
+ // javascript is turned off then we want them to be
+ // visible); but by default, we want to hide them. So hide
+ // them unless we have a cookie that says to show them.
+ checkCookie();
+ // -->
+</script>
+</body>
+</html>
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/e970301e/content/releases/qpid-python-1.37.0/messaging-api/api/toc-qpid.messaging.constants-module.html
----------------------------------------------------------------------
diff --git a/content/releases/qpid-python-1.37.0/messaging-api/api/toc-qpid.messaging.constants-module.html b/content/releases/qpid-python-1.37.0/messaging-api/api/toc-qpid.messaging.constants-module.html
new file mode 100755
index 0000000..bb47268
--- /dev/null
+++ b/content/releases/qpid-python-1.37.0/messaging-api/api/toc-qpid.messaging.constants-module.html
@@ -0,0 +1,37 @@
+<?xml version="1.0" encoding="ascii"?>
+<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN"
+ "DTD/xhtml1-transitional.dtd">
+<html xmlns="http://www.w3.org/1999/xhtml" xml:lang="en" lang="en">
+<head>
+ <title>constants</title>
+ <link rel="stylesheet" href="epydoc.css" type="text/css" />
+ <script type="text/javascript" src="epydoc.js"></script>
+</head>
+
+<body bgcolor="white" text="black" link="blue" vlink="#204080"
+ alink="#204080">
+<h1 class="toc">Module constants</h1>
+<hr />
+ <h2 class="toc">Classes</h2>
+ <a target="mainFrame" href="qpid.messaging.constants.Constant-class.html"
+ >Constant</a><br /> <h2 class="toc">Variables</h2>
+ <a target="mainFrame" href="qpid.messaging.constants-module.html#AMQPS_PORT"
+ >AMQPS_PORT</a><br /> <a target="mainFrame" href="qpid.messaging.constants-module.html#AMQP_PORT"
+ >AMQP_PORT</a><br /> <a target="mainFrame" href="qpid.messaging.constants-module.html#REJECTED"
+ >REJECTED</a><br /> <a target="mainFrame" href="qpid.messaging.constants-module.html#RELEASED"
+ >RELEASED</a><br /> <a target="mainFrame" href="qpid.messaging.constants-module.html#UNLIMITED"
+ >UNLIMITED</a><br /> <a target="mainFrame" href="qpid.messaging.constants-module.html#__SELF__"
+ >__SELF__</a><br /> <a target="mainFrame" href="qpid.messaging.constants-module.html#__package__"
+ >__package__</a><br /><hr />
+
+<script type="text/javascript">
+ <!--
+ // Private objects are initially displayed (because if
+ // javascript is turned off then we want them to be
+ // visible); but by default, we want to hide them. So hide
+ // them unless we have a cookie that says to show them.
+ checkCookie();
+ // -->
+</script>
+</body>
+</html>
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/e970301e/content/releases/qpid-python-1.37.0/messaging-api/api/toc-qpid.messaging.driver-module.html
----------------------------------------------------------------------
diff --git a/content/releases/qpid-python-1.37.0/messaging-api/api/toc-qpid.messaging.driver-module.html b/content/releases/qpid-python-1.37.0/messaging-api/api/toc-qpid.messaging.driver-module.html
new file mode 100755
index 0000000..b0e2026
--- /dev/null
+++ b/content/releases/qpid-python-1.37.0/messaging-api/api/toc-qpid.messaging.driver-module.html
@@ -0,0 +1,70 @@
+<?xml version="1.0" encoding="ascii"?>
+<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN"
+ "DTD/xhtml1-transitional.dtd">
+<html xmlns="http://www.w3.org/1999/xhtml" xml:lang="en" lang="en">
+<head>
+ <title>driver</title>
+ <link rel="stylesheet" href="epydoc.css" type="text/css" />
+ <script type="text/javascript" src="epydoc.js"></script>
+</head>
+
+<body bgcolor="white" text="black" link="blue" vlink="#204080"
+ alink="#204080">
+<h1 class="toc">Module driver</h1>
+<hr />
+ <h2 class="toc">Classes</h2>
+ <a target="mainFrame" href="qpid.messaging.driver.Attachment-class.html"
+ >Attachment</a><br /> <a target="mainFrame" href="qpid.messaging.driver.Cache-class.html"
+ >Cache</a><br /> <a target="mainFrame" href="qpid.messaging.driver.Driver-class.html"
+ >Driver</a><br /> <a target="mainFrame" href="qpid.messaging.driver.Engine-class.html"
+ >Engine</a><br /> <a target="mainFrame" href="qpid.messaging.driver.LinkIn-class.html"
+ >LinkIn</a><br /> <a target="mainFrame" href="qpid.messaging.driver.LinkOut-class.html"
+ >LinkOut</a><br /> <a target="mainFrame" href="qpid.messaging.driver.Pattern-class.html"
+ >Pattern</a><br /> <a target="mainFrame" href="qpid.messaging.driver.SessionState-class.html"
+ >SessionState</a><br /> <h2 class="toc">Functions</h2>
+ <a target="mainFrame" href="qpid.messaging.driver-module.html#addr2reply_to"
+ >addr2reply_to</a><br /> <a target="mainFrame" href="qpid.messaging.driver-module.html#get_bindings"
+ >get_bindings</a><br /> <a target="mainFrame" href="qpid.messaging.driver-module.html#noop"
+ >noop</a><br /> <a target="mainFrame" href="qpid.messaging.driver-module.html#reply_to2addr"
+ >reply_to2addr</a><br /> <a target="mainFrame" href="qpid.messaging.driver-module.html#sync_noop"
+ >sync_noop</a><br /> <h2 class="toc">Variables</h2>
+ <a target="mainFrame" href="qpid.messaging.driver-module.html#BINDINGS"
+ >BINDINGS</a><br /> <a target="mainFrame" href="qpid.messaging.driver-module.html#CLOSED"
+ >CLOSED</a><br /> <a target="mainFrame" href="qpid.messaging.driver-module.html#COMMON_OPTS"
+ >COMMON_OPTS</a><br /> <a target="mainFrame" href="qpid.messaging.driver-module.html#CONNECTION_ERRS"
+ >CONNECTION_ERRS</a><br /> <a target="mainFrame" href="qpid.messaging.driver-module.html#DECLARE"
+ >DECLARE</a><br /> <a target="mainFrame" href="qpid.messaging.driver-module.html#DEFAULT_DISPOSITION"
+ >DEFAULT_DISPOSITION</a><br /> <a target="mainFrame" href="qpid.messaging.driver-module.html#DURABLE_DEFAULT"
+ >DURABLE_DEFAULT</a><br /> <a target="mainFrame" href="qpid.messaging.driver-module.html#EMPTY_DP"
+ >EMPTY_DP</a><br /> <a target="mainFrame" href="qpid.messaging.driver-module.html#EMPTY_MP"
+ >EMPTY_MP</a><br /> <a target="mainFrame" href="qpid.messaging.driver-module.html#HEADER"
+ >HEADER</a><br /> <a target="mainFrame" href="qpid.messaging.driver-module.html#OPEN"
+ >OPEN</a><br /> <a target="mainFrame" href="qpid.messaging.driver-module.html#POLICIES"
+ >POLICIES</a><br /> <a target="mainFrame" href="qpid.messaging.driver-module.html#READ_ONLY"
+ >READ_ONLY</a><br /> <a target="mainFrame" href="qpid.messaging.driver-module.html#RECEIVE_MODES"
+ >RECEIVE_MODES</a><br /> <a target="mainFrame" href="qpid.messaging.driver-module.html#RELIABILITY"
+ >RELIABILITY</a><br /> <a target="mainFrame" href="qpid.messaging.driver-module.html#SESSION_ERRS"
+ >SESSION_ERRS</a><br /> <a target="mainFrame" href="qpid.messaging.driver-module.html#SOURCE_OPTS"
+ >SOURCE_OPTS</a><br /> <a target="mainFrame" href="qpid.messaging.driver-module.html#SUBJECT"
+ >SUBJECT</a><br /> <a target="mainFrame" href="qpid.messaging.driver-module.html#SUBJECT_DEFAULTS"
+ >SUBJECT_DEFAULTS</a><br /> <a target="mainFrame" href="qpid.messaging.driver-module.html#TARGET_OPTS"
+ >TARGET_OPTS</a><br /> <a target="mainFrame" href="qpid.messaging.driver-module.html#WRITE_ONLY"
+ >WRITE_ONLY</a><br /> <a target="mainFrame" href="qpid.messaging.driver-module.html#__package__"
+ >__package__</a><br /> <a target="mainFrame" href="qpid.messaging.driver-module.html#bases"
+ >bases</a><br /> <a target="mainFrame" href="qpid.messaging.driver-module.html#log"
+ >log</a><br /> <a target="mainFrame" href="qpid.messaging.driver-module.html#name"
+ >name</a><br /> <a target="mainFrame" href="qpid.messaging.driver-module.html#opslog"
+ >opslog</a><br /> <a target="mainFrame" href="qpid.messaging.driver-module.html#rawlog"
+ >rawlog</a><br /><hr />
+
+<script type="text/javascript">
+ <!--
+ // Private objects are initially displayed (because if
+ // javascript is turned off then we want them to be
+ // visible); but by default, we want to hide them. So hide
+ // them unless we have a cookie that says to show them.
+ checkCookie();
+ // -->
+</script>
+</body>
+</html>
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/e970301e/content/releases/qpid-python-1.37.0/messaging-api/api/toc-qpid.messaging.endpoints-module.html
----------------------------------------------------------------------
diff --git a/content/releases/qpid-python-1.37.0/messaging-api/api/toc-qpid.messaging.endpoints-module.html b/content/releases/qpid-python-1.37.0/messaging-api/api/toc-qpid.messaging.endpoints-module.html
new file mode 100755
index 0000000..51ed570
--- /dev/null
+++ b/content/releases/qpid-python-1.37.0/messaging-api/api/toc-qpid.messaging.endpoints-module.html
@@ -0,0 +1,33 @@
+<?xml version="1.0" encoding="ascii"?>
+<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN"
+ "DTD/xhtml1-transitional.dtd">
+<html xmlns="http://www.w3.org/1999/xhtml" xml:lang="en" lang="en">
+<head>
+ <title>endpoints</title>
+ <link rel="stylesheet" href="epydoc.css" type="text/css" />
+ <script type="text/javascript" src="epydoc.js"></script>
+</head>
+
+<body bgcolor="white" text="black" link="blue" vlink="#204080"
+ alink="#204080">
+<h1 class="toc">Module endpoints</h1>
+<hr />
+ <h2 class="toc">Classes</h2>
+ <a target="mainFrame" href="qpid.messaging.endpoints.Connection-class.html"
+ >Connection</a><br /> <a target="mainFrame" href="qpid.messaging.endpoints.Endpoint-class.html"
+ >Endpoint</a><br /> <a target="mainFrame" href="qpid.messaging.endpoints.Receiver-class.html"
+ >Receiver</a><br /> <a target="mainFrame" href="qpid.messaging.endpoints.Sender-class.html"
+ >Sender</a><br /> <a target="mainFrame" href="qpid.messaging.endpoints.Session-class.html"
+ >Session</a><br /><hr />
+
+<script type="text/javascript">
+ <!--
+ // Private objects are initially displayed (because if
+ // javascript is turned off then we want them to be
+ // visible); but by default, we want to hide them. So hide
+ // them unless we have a cookie that says to show them.
+ checkCookie();
+ // -->
+</script>
+</body>
+</html>
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/e970301e/content/releases/qpid-python-1.37.0/messaging-api/api/toc-qpid.messaging.exceptions-module.html
----------------------------------------------------------------------
diff --git a/content/releases/qpid-python-1.37.0/messaging-api/api/toc-qpid.messaging.exceptions-module.html b/content/releases/qpid-python-1.37.0/messaging-api/api/toc-qpid.messaging.exceptions-module.html
new file mode 100755
index 0000000..df5eae0
--- /dev/null
+++ b/content/releases/qpid-python-1.37.0/messaging-api/api/toc-qpid.messaging.exceptions-module.html
@@ -0,0 +1,66 @@
+<?xml version="1.0" encoding="ascii"?>
+<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN"
+ "DTD/xhtml1-transitional.dtd">
+<html xmlns="http://www.w3.org/1999/xhtml" xml:lang="en" lang="en">
+<head>
+ <title>exceptions</title>
+ <link rel="stylesheet" href="epydoc.css" type="text/css" />
+ <script type="text/javascript" src="epydoc.js"></script>
+</head>
+
+<body bgcolor="white" text="black" link="blue" vlink="#204080"
+ alink="#204080">
+<h1 class="toc">Module exceptions</h1>
+<hr />
+ <h2 class="toc">Classes</h2>
+ <a target="mainFrame" href="qpid.messaging.exceptions.AddressError-class.html"
+ >AddressError</a><br /> <a target="mainFrame" href="qpid.messaging.exceptions.AssertionFailed-class.html"
+ >AssertionFailed</a><br /> <a target="mainFrame" href="qpid.messaging.exceptions.AuthenticationFailure-class.html"
+ >AuthenticationFailure</a><br /> <a target="mainFrame" href="qpid.messaging.exceptions.ConnectError-class.html"
+ >ConnectError</a><br /> <a target="mainFrame" href="qpid.messaging.exceptions.ConnectionClosed-class.html"
+ >ConnectionClosed</a><br /> <a target="mainFrame" href="qpid.messaging.exceptions.ConnectionError-class.html"
+ >ConnectionError</a><br /> <a target="mainFrame" href="qpid.messaging.exceptions.ContentError-class.html"
+ >ContentError</a><br /> <a target="mainFrame" href="qpid.messaging.exceptions.DecodeError-class.html"
+ >DecodeError</a><br /> <a target="mainFrame" href="qpid.messaging.exceptions.Detached-class.html"
+ >Detached</a><br /> <a target="mainFrame" href="qpid.messaging.exceptions.Empty-class.html"
+ >Empty</a><br /> <a target="mainFrame" href="qpid.messaging.exceptions.EncodeError-class.html"
+ >EncodeError</a><br /> <a target="mainFrame" href="qpid.messaging.exceptions.FetchError-class.html"
+ >FetchError</a><br /> <a target="mainFrame" href="qpid.messaging.exceptions.HeartbeatTimeout-class.html"
+ >HeartbeatTimeout</a><br /> <a target="mainFrame" href="qpid.messaging.exceptions.InsufficientCapacity-class.html"
+ >InsufficientCapacity</a><br /> <a target="mainFrame" href="qpid.messaging.exceptions.InternalError-class.html"
+ >InternalError</a><br /> <a target="mainFrame" href="qpid.messaging.exceptions.InvalidOption-class.html"
+ >InvalidOption</a><br /> <a target="mainFrame" href="qpid.messaging.exceptions.LinkClosed-class.html"
+ >LinkClosed</a><br /> <a target="mainFrame" href="qpid.messaging.exceptions.LinkError-class.html"
+ >LinkError</a><br /> <a target="mainFrame" href="qpid.messaging.exceptions.MalformedAddress-class.html"
+ >MalformedAddress</a><br /> <a target="mainFrame" href="qpid.messaging.exceptions.MessagingError-class.html"
+ >MessagingError</a><br /> <a target="mainFrame" href="qpid.messaging.exceptions.NontransactionalSession-class.html"
+ >NontransactionalSession</a><br /> <a target="mainFrame" href="qpid.messaging.exceptions.NotFound-class.html"
+ >NotFound</a><br /> <a target="mainFrame" href="qpid.messaging.exceptions.ReceiverError-class.html"
+ >ReceiverError</a><br /> <a target="mainFrame" href="qpid.messaging.exceptions.ResolutionError-class.html"
+ >ResolutionError</a><br /> <a target="mainFrame" href="qpid.messaging.exceptions.SendError-class.html"
+ >SendError</a><br /> <a target="mainFrame" href="qpid.messaging.exceptions.SenderError-class.html"
+ >SenderError</a><br /> <a target="mainFrame" href="qpid.messaging.exceptions.ServerError-class.html"
+ >ServerError</a><br /> <a target="mainFrame" href="qpid.messaging.exceptions.SessionClosed-class.html"
+ >SessionClosed</a><br /> <a target="mainFrame" href="qpid.messaging.exceptions.SessionError-class.html"
+ >SessionError</a><br /> <a target="mainFrame" href="qpid.messaging.exceptions.TargetCapacityExceeded-class.html"
+ >TargetCapacityExceeded</a><br /> <a target="mainFrame" href="qpid.messaging.exceptions.Timeout-class.html"
+ >Timeout</a><br /> <a target="mainFrame" href="qpid.messaging.exceptions.TransactionAborted-class.html"
+ >TransactionAborted</a><br /> <a target="mainFrame" href="qpid.messaging.exceptions.TransactionError-class.html"
+ >TransactionError</a><br /> <a target="mainFrame" href="qpid.messaging.exceptions.TransactionUnknown-class.html"
+ >TransactionUnknown</a><br /> <a target="mainFrame" href="qpid.messaging.exceptions.UnauthorizedAccess-class.html"
+ >UnauthorizedAccess</a><br /> <a target="mainFrame" href="qpid.messaging.exceptions.VersionError-class.html"
+ >VersionError</a><br /> <h2 class="toc">Variables</h2>
+ <a target="mainFrame" href="qpid.messaging.exceptions-module.html#__package__"
+ >__package__</a><br /><hr />
+
+<script type="text/javascript">
+ <!--
+ // Private objects are initially displayed (because if
+ // javascript is turned off then we want them to be
+ // visible); but by default, we want to hide them. So hide
+ // them unless we have a cookie that says to show them.
+ checkCookie();
+ // -->
+</script>
+</body>
+</html>
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/e970301e/content/releases/qpid-python-1.37.0/messaging-api/api/toc-qpid.messaging.message-module.html
----------------------------------------------------------------------
diff --git a/content/releases/qpid-python-1.37.0/messaging-api/api/toc-qpid.messaging.message-module.html b/content/releases/qpid-python-1.37.0/messaging-api/api/toc-qpid.messaging.message-module.html
new file mode 100755
index 0000000..43565c1
--- /dev/null
+++ b/content/releases/qpid-python-1.37.0/messaging-api/api/toc-qpid.messaging.message-module.html
@@ -0,0 +1,30 @@
+<?xml version="1.0" encoding="ascii"?>
+<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN"
+ "DTD/xhtml1-transitional.dtd">
+<html xmlns="http://www.w3.org/1999/xhtml" xml:lang="en" lang="en">
+<head>
+ <title>message</title>
+ <link rel="stylesheet" href="epydoc.css" type="text/css" />
+ <script type="text/javascript" src="epydoc.js"></script>
+</head>
+
+<body bgcolor="white" text="black" link="blue" vlink="#204080"
+ alink="#204080">
+<h1 class="toc">Module message</h1>
+<hr />
+ <h2 class="toc">Classes</h2>
+ <a target="mainFrame" href="qpid.messaging.message.Disposition-class.html"
+ >Disposition</a><br /> <a target="mainFrame" href="qpid.messaging.message.Message-class.html"
+ >Message</a><br /><hr />
+
+<script type="text/javascript">
+ <!--
+ // Private objects are initially displayed (because if
+ // javascript is turned off then we want them to be
+ // visible); but by default, we want to hide them. So hide
+ // them unless we have a cookie that says to show them.
+ checkCookie();
+ // -->
+</script>
+</body>
+</html>
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/e970301e/content/releases/qpid-python-1.37.0/messaging-api/api/toc-qpid.messaging.transports-module.html
----------------------------------------------------------------------
diff --git a/content/releases/qpid-python-1.37.0/messaging-api/api/toc-qpid.messaging.transports-module.html b/content/releases/qpid-python-1.37.0/messaging-api/api/toc-qpid.messaging.transports-module.html
new file mode 100755
index 0000000..d5f6a60
--- /dev/null
+++ b/content/releases/qpid-python-1.37.0/messaging-api/api/toc-qpid.messaging.transports-module.html
@@ -0,0 +1,37 @@
+<?xml version="1.0" encoding="ascii"?>
+<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN"
+ "DTD/xhtml1-transitional.dtd">
+<html xmlns="http://www.w3.org/1999/xhtml" xml:lang="en" lang="en">
+<head>
+ <title>transports</title>
+ <link rel="stylesheet" href="epydoc.css" type="text/css" />
+ <script type="text/javascript" src="epydoc.js"></script>
+</head>
+
+<body bgcolor="white" text="black" link="blue" vlink="#204080"
+ alink="#204080">
+<h1 class="toc">Module transports</h1>
+<hr />
+ <h2 class="toc">Classes</h2>
+ <a target="mainFrame" href="qpid.messaging.transports.SocketTransport-class.html"
+ >SocketTransport</a><br /> <a target="mainFrame" href="qpid.messaging.transports.old_ssl-class.html"
+ >old_ssl</a><br /> <a target="mainFrame" href="qpid.messaging.transports.tcp-class.html"
+ >tcp</a><br /> <a target="mainFrame" href="qpid.messaging.transports.tls-class.html"
+ >tls</a><br /> <h2 class="toc">Functions</h2>
+ <a target="mainFrame" href="qpid.messaging.transports-module.html#verify_hostname"
+ >verify_hostname</a><br /> <h2 class="toc">Variables</h2>
+ <a target="mainFrame" href="qpid.messaging.transports-module.html#TRANSPORTS"
+ >TRANSPORTS</a><br /> <a target="mainFrame" href="qpid.messaging.transports-module.html#__package__"
+ >__package__</a><br /><hr />
+
+<script type="text/javascript">
+ <!--
+ // Private objects are initially displayed (because if
+ // javascript is turned off then we want them to be
+ // visible); but by default, we want to hide them. So hide
+ // them unless we have a cookie that says to show them.
+ checkCookie();
+ // -->
+</script>
+</body>
+</html>
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/e970301e/content/releases/qpid-python-1.37.0/messaging-api/api/toc-qpid.messaging.util-module.html
----------------------------------------------------------------------
diff --git a/content/releases/qpid-python-1.37.0/messaging-api/api/toc-qpid.messaging.util-module.html b/content/releases/qpid-python-1.37.0/messaging-api/api/toc-qpid.messaging.util-module.html
new file mode 100755
index 0000000..543b471
--- /dev/null
+++ b/content/releases/qpid-python-1.37.0/messaging-api/api/toc-qpid.messaging.util-module.html
@@ -0,0 +1,30 @@
+<?xml version="1.0" encoding="ascii"?>
+<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN"
+ "DTD/xhtml1-transitional.dtd">
+<html xmlns="http://www.w3.org/1999/xhtml" xml:lang="en" lang="en">
+<head>
+ <title>util</title>
+ <link rel="stylesheet" href="epydoc.css" type="text/css" />
+ <script type="text/javascript" src="epydoc.js"></script>
+</head>
+
+<body bgcolor="white" text="black" link="blue" vlink="#204080"
+ alink="#204080">
+<h1 class="toc">Module util</h1>
+<hr />
+ <h2 class="toc">Functions</h2>
+ <a target="mainFrame" href="qpid.messaging.util-module.html#auto_fetch_reconnect_urls"
+ >auto_fetch_reconnect_urls</a><br /> <a target="mainFrame" href="qpid.messaging.util-module.html#set_reconnect_urls"
+ >set_reconnect_urls</a><br /><hr />
+
+<script type="text/javascript">
+ <!--
+ // Private objects are initially displayed (because if
+ // javascript is turned off then we want them to be
+ // visible); but by default, we want to hide them. So hide
+ // them unless we have a cookie that says to show them.
+ checkCookie();
+ // -->
+</script>
+</body>
+</html>
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/e970301e/content/releases/qpid-python-1.37.0/messaging-api/api/toc.html
----------------------------------------------------------------------
diff --git a/content/releases/qpid-python-1.37.0/messaging-api/api/toc.html b/content/releases/qpid-python-1.37.0/messaging-api/api/toc.html
new file mode 100755
index 0000000..4f6f84a
--- /dev/null
+++ b/content/releases/qpid-python-1.37.0/messaging-api/api/toc.html
@@ -0,0 +1,39 @@
+<?xml version="1.0" encoding="ascii"?>
+<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN"
+ "DTD/xhtml1-transitional.dtd">
+<html xmlns="http://www.w3.org/1999/xhtml" xml:lang="en" lang="en">
+<head>
+ <title>Table of Contents</title>
+ <link rel="stylesheet" href="epydoc.css" type="text/css" />
+ <script type="text/javascript" src="epydoc.js"></script>
+</head>
+
+<body bgcolor="white" text="black" link="blue" vlink="#204080"
+ alink="#204080">
+<h1 class="toc">Table of Contents</h1>
+<hr />
+ <a target="moduleFrame" href="toc-everything.html">Everything</a>
+ <br />
+ <h2 class="toc">Modules</h2>
+ <a target="moduleFrame" href="toc-qpid.messaging-module.html"
+ onclick="setFrame('toc-qpid.messaging-module.html','qpid.messaging-module.html');" >qpid.messaging</a><br /> <a target="moduleFrame" href="toc-qpid.messaging.address-module.html"
+ onclick="setFrame('toc-qpid.messaging.address-module.html','qpid.messaging.address-module.html');" >qpid.messaging.address</a><br /> <a target="moduleFrame" href="toc-qpid.messaging.constants-module.html"
+ onclick="setFrame('toc-qpid.messaging.constants-module.html','qpid.messaging.constants-module.html');" >qpid.messaging.constants</a><br /> <a target="moduleFrame" href="toc-qpid.messaging.driver-module.html"
+ onclick="setFrame('toc-qpid.messaging.driver-module.html','qpid.messaging.driver-module.html');" >qpid.messaging.driver</a><br /> <a target="moduleFrame" href="toc-qpid.messaging.endpoints-module.html"
+ onclick="setFrame('toc-qpid.messaging.endpoints-module.html','qpid.messaging.endpoints-module.html');" >qpid.messaging.endpoints</a><br /> <a target="moduleFrame" href="toc-qpid.messaging.exceptions-module.html"
+ onclick="setFrame('toc-qpid.messaging.exceptions-module.html','qpid.messaging.exceptions-module.html');" >qpid.messaging.exceptions</a><br /> <a target="moduleFrame" href="toc-qpid.messaging.message-module.html"
+ onclick="setFrame('toc-qpid.messaging.message-module.html','qpid.messaging.message-module.html');" >qpid.messaging.message</a><br /> <a target="moduleFrame" href="toc-qpid.messaging.transports-module.html"
+ onclick="setFrame('toc-qpid.messaging.transports-module.html','qpid.messaging.transports-module.html');" >qpid.messaging.transports</a><br /> <a target="moduleFrame" href="toc-qpid.messaging.util-module.html"
+ onclick="setFrame('toc-qpid.messaging.util-module.html','qpid.messaging.util-module.html');" >qpid.messaging.util</a><br /><hr />
+
+<script type="text/javascript">
+ <!--
+ // Private objects are initially displayed (because if
+ // javascript is turned off then we want them to be
+ // visible); but by default, we want to hide them. So hide
+ // them unless we have a cookie that says to show them.
+ checkCookie();
+ // -->
+</script>
+</body>
+</html>
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/e970301e/content/releases/qpid-python-1.37.0/messaging-api/examples/drain
----------------------------------------------------------------------
diff --git a/content/releases/qpid-python-1.37.0/messaging-api/examples/drain b/content/releases/qpid-python-1.37.0/messaging-api/examples/drain
new file mode 100755
index 0000000..5e30153
--- /dev/null
+++ b/content/releases/qpid-python-1.37.0/messaging-api/examples/drain
@@ -0,0 +1,97 @@
+#!/usr/bin/env 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 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.
+#
+
+import optparse
+from qpid.messaging import *
+from qpid.util import URL
+from qpid.log import enable, DEBUG, WARN
+
+parser = optparse.OptionParser(usage="usage: %prog [options] ADDRESS ...",
+ description="Drain messages from the supplied address.")
+parser.add_option("-b", "--broker", default="localhost",
+ help="connect to specified BROKER (default %default)")
+parser.add_option("-c", "--count", type="int",
+ help="number of messages to drain")
+parser.add_option("-f", "--forever", action="store_true",
+ help="ignore timeout and wait forever")
+parser.add_option("-r", "--reconnect", action="store_true",
+ help="enable auto reconnect")
+parser.add_option("-i", "--reconnect-interval", type="float", default=3,
+ help="interval between reconnect attempts")
+parser.add_option("-l", "--reconnect-limit", type="int",
+ help="maximum number of reconnect attempts")
+parser.add_option("-t", "--timeout", type="float", default=0,
+ help="timeout in seconds to wait before exiting (default %default)")
+parser.add_option("-p", "--print", dest="format", default="%(M)s",
+ help="format string for printing messages (default %default)")
+parser.add_option("-v", dest="verbose", action="store_true",
+ help="enable logging")
+
+opts, args = parser.parse_args()
+
+if opts.verbose:
+ enable("qpid", DEBUG)
+else:
+ enable("qpid", WARN)
+
+if args:
+ addr = args.pop(0)
+else:
+ parser.error("address is required")
+if opts.forever:
+ timeout = None
+else:
+ timeout = opts.timeout
+
+class Formatter:
+
+ def __init__(self, message):
+ self.message = message
+ self.environ = {"M": self.message,
+ "P": self.message.properties,
+ "C": self.message.content}
+
+ def __getitem__(self, st):
+ return eval(st, self.environ)
+
+conn = Connection(opts.broker,
+ reconnect=opts.reconnect,
+ reconnect_interval=opts.reconnect_interval,
+ reconnect_limit=opts.reconnect_limit)
+try:
+ conn.open()
+ ssn = conn.session()
+ rcv = ssn.receiver(addr)
+
+ count = 0
+ while not opts.count or count < opts.count:
+ try:
+ msg = rcv.fetch(timeout=timeout)
+ print opts.format % Formatter(msg)
+ count += 1
+ ssn.acknowledge()
+ except Empty:
+ break
+except ReceiverError, e:
+ print e
+except KeyboardInterrupt:
+ pass
+
+conn.close()
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/e970301e/content/releases/qpid-python-1.37.0/messaging-api/examples/drain.html
----------------------------------------------------------------------
diff --git a/content/releases/qpid-python-1.37.0/messaging-api/examples/drain.html b/content/releases/qpid-python-1.37.0/messaging-api/examples/drain.html
new file mode 100644
index 0000000..3cef891
--- /dev/null
+++ b/content/releases/qpid-python-1.37.0/messaging-api/examples/drain.html
@@ -0,0 +1,226 @@
+<!DOCTYPE html>
+<!--
+ -
+ - 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.
+ -
+-->
+<html xmlns="http://www.w3.org/1999/xhtml" xml:lang="en">
+ <head>
+ <title>drain - Apache Qpid™</title>
+ <meta http-equiv="X-UA-Compatible" content="IE=edge"/>
+ <meta name="viewport" content="width=device-width, initial-scale=1.0"/>
+ <link rel="stylesheet" href="/site.css" type="text/css" async="async"/>
+ <link rel="stylesheet" href="/deferred.css" type="text/css" defer="defer"/>
+ <script type="text/javascript">var _deferredFunctions = [];</script>
+ <script type="text/javascript" src="/deferred.js" defer="defer"></script>
+ <!--[if lte IE 8]>
+ <link rel="stylesheet" href="/ie.css" type="text/css"/>
+ <script type="text/javascript" src="/html5shiv.js"></script>
+ <![endif]-->
+
+ <!-- Redirects for `go get` and godoc.org -->
+ <meta name="go-import"
+ content="qpid.apache.org git https://git-wip-us.apache.org/repos/asf/qpid-proton.git"/>
+ <meta name="go-source"
+ content="qpid.apache.org
+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}"/>
+ </head>
+ <body>
+ <div id="-content">
+ <div id="-top" class="panel">
+ <a id="-menu-link"><img width="16" height="16" src="" alt="Menu"/></a>
+
+ <a id="-search-link"><img width="22" height="16" src="" alt="Search"/></a>
+
+ <ul id="-global-navigation">
+ <li><a id="-logotype" href="/index.html">Apache Qpid<sup>™</sup></a></li>
+ <li><a href="/documentation.html">Documentation</a></li>
+ <li><a href="/download.html">Download</a></li>
+ <li><a href="/discussion.html">Discussion</a></li>
+ </ul>
+ </div>
+
+ <div id="-menu" class="panel" style="display: none;">
+ <div class="flex">
+ <section>
+ <h3>Project</h3>
+
+ <ul>
+ <li><a href="/overview.html">Overview</a></li>
+ <li><a href="/components/index.html">Components</a></li>
+ <li><a href="/releases/index.html">Releases</a></li>
+ </ul>
+ </section>
+
+ <section>
+ <h3>Messaging APIs</h3>
+
+ <ul>
+ <li><a href="/proton/index.html">Qpid Proton</a></li>
+ <li><a href="/components/jms/index.html">Qpid JMS</a></li>
+ <li><a href="/components/messaging-api/index.html">Qpid Messaging API</a></li>
+ </ul>
+ </section>
+
+ <section>
+ <h3>Servers and tools</h3>
+
+ <ul>
+ <li><a href="/components/broker-j/index.html">Broker-J</a></li>
+ <li><a href="/components/cpp-broker/index.html">C++ broker</a></li>
+ <li><a href="/components/dispatch-router/index.html">Dispatch router</a></li>
+ </ul>
+ </section>
+
+ <section>
+ <h3>Resources</h3>
+
+ <ul>
+ <li><a href="/dashboard.html">Dashboard</a></li>
+ <li><a href="https://cwiki.apache.org/confluence/display/qpid/Index">Wiki</a></li>
+ <li><a href="/resources.html">More resources</a></li>
+ </ul>
+ </section>
+ </div>
+ </div>
+
+ <div id="-search" class="panel" style="display: none;">
+ <form action="http://www.google.com/search" method="get">
+ <input type="hidden" name="sitesearch" value="qpid.apache.org"/>
+ <input type="text" name="q" maxlength="255" autofocus="autofocus" tabindex="1"/>
+ <button type="submit">Search</button>
+ <a href="/search.html">More ways to search</a>
+ </form>
+ </div>
+
+ <div id="-middle" class="panel">
+ <ul id="-path-navigation"><li><a href="/index.html">Home</a></li><li><a href="/releases/index.html">Releases</a></li><li><a href="/releases/qpid-python-1.37.0/index.html">Qpid Python 1.37.0</a></li><li><a href="/releases/qpid-python-1.37.0/messaging-api/examples/index.html">Python Messaging API Examples</a></li><li>drain</li></ul>
+
+ <div id="-middle-content">
+
+<h1>drain</h1>
+<div class="highlight"><pre><span></span><span class="kn">import</span> <span class="nn">optparse</span>
+<span class="kn">from</span> <span class="nn">qpid.messaging</span> <span class="kn">import</span> <span class="o">*</span>
+<span class="kn">from</span> <span class="nn">qpid.util</span> <span class="kn">import</span> <span class="n">URL</span>
+<span class="kn">from</span> <span class="nn">qpid.log</span> <span class="kn">import</span> <span class="n">enable</span><span class="p">,</span> <span class="n">DEBUG</span><span class="p">,</span> <span class="n">WARN</span>
+
+<span class="n">parser</span> <span class="o">=</span> <span class="n">optparse</span><span class="o">.</span><span class="n">OptionParser</span><span class="p">(</span><span class="n">usage</span><span class="o">=</span><span class="s2">"usage: %prog [options] ADDRESS ..."</span><span class="p">,</span>
+ <span class="n">description</span><span class="o">=</span><span class="s2">"Drain messages from the supplied address."</span><span class="p">)</span>
+<span class="n">parser</span><span class="o">.</span><span class="n">add_option</span><span class="p">(</span><span class="s2">"-b"</span><span class="p">,</span> <span class="s2">"--broker"</span><span class="p">,</span> <span class="n">default</span><span class="o">=</span><span class="s2">"localhost"</span><span class="p">,</span>
+ <span class="n">help</span><span class="o">=</span><span class="s2">"connect to specified BROKER (default </span><span class="si">%d</span><span class="s2">efault)"</span><span class="p">)</span>
+<span class="n">parser</span><span class="o">.</span><span class="n">add_option</span><span class="p">(</span><span class="s2">"-c"</span><span class="p">,</span> <span class="s2">"--count"</span><span class="p">,</span> <span class="nb">type</span><span class="o">=</span><span class="s2">"int"</span><span class="p">,</span>
+ <span class="n">help</span><span class="o">=</span><span class="s2">"number of messages to drain"</span><span class="p">)</span>
+<span class="n">parser</span><span class="o">.</span><span class="n">add_option</span><span class="p">(</span><span class="s2">"-f"</span><span class="p">,</span> <span class="s2">"--forever"</span><span class="p">,</span> <span class="n">action</span><span class="o">=</span><span class="s2">"store_true"</span><span class="p">,</span>
+ <span class="n">help</span><span class="o">=</span><span class="s2">"ignore timeout and wait forever"</span><span class="p">)</span>
+<span class="n">parser</span><span class="o">.</span><span class="n">add_option</span><span class="p">(</span><span class="s2">"-r"</span><span class="p">,</span> <span class="s2">"--reconnect"</span><span class="p">,</span> <span class="n">action</span><span class="o">=</span><span class="s2">"store_true"</span><span class="p">,</span>
+ <span class="n">help</span><span class="o">=</span><span class="s2">"enable auto reconnect"</span><span class="p">)</span>
+<span class="n">parser</span><span class="o">.</span><span class="n">add_option</span><span class="p">(</span><span class="s2">"-i"</span><span class="p">,</span> <span class="s2">"--reconnect-interval"</span><span class="p">,</span> <span class="nb">type</span><span class="o">=</span><span class="s2">"float"</span><span class="p">,</span> <span class="n">default</span><span class="o">=</span><span class="mi">3</span><span class="p">,</span>
+ <span class="n">help</span><span class="o">=</span><span class="s2">"interval between reconnect attempts"</span><span class="p">)</span>
+<span class="n">parser</span><span class="o">.</span><span class="n">add_option</span><span class="p">(</span><span class="s2">"-l"</span><span class="p">,</span> <span class="s2">"--reconnect-limit"</span><span class="p">,</span> <span class="nb">type</span><span class="o">=</span><span class="s2">"int"</span><span class="p">,</span>
+ <span class="n">help</span><span class="o">=</span><span class="s2">"maximum number of reconnect attempts"</span><span class="p">)</span>
+<span class="n">parser</span><span class="o">.</span><span class="n">add_option</span><span class="p">(</span><span class="s2">"-t"</span><span class="p">,</span> <span class="s2">"--timeout"</span><span class="p">,</span> <span class="nb">type</span><span class="o">=</span><span class="s2">"float"</span><span class="p">,</span> <span class="n">default</span><span class="o">=</span><span class="mi">0</span><span class="p">,</span>
+ <span class="n">help</span><span class="o">=</span><span class="s2">"timeout in seconds to wait before exiting (default </span><span class="si">%d</span><span class="s2">efault)"</span><span class="p">)</span>
+<span class="n">parser</span><span class="o">.</span><span class="n">add_option</span><span class="p">(</span><span class="s2">"-p"</span><span class="p">,</span> <span class="s2">"--print"</span><span class="p">,</span> <span class="n">dest</span><span class="o">=</span><span class="s2">"format"</span><span class="p">,</span> <span class="n">default</span><span class="o">=</span><span class="s2">"</span><span class="si">%(M)s</span><span class="s2">"</span><span class="p">,</span>
+ <span class="n">help</span><span class="o">=</span><span class="s2">"format string for printing messages (default </span><span class="si">%d</span><span class="s2">efault)"</span><span class="p">)</span>
+<span class="n">parser</span><span class="o">.</span><span class="n">add_option</span><span class="p">(</span><span class="s2">"-v"</span><span class="p">,</span> <span class="n">dest</span><span class="o">=</span><span class="s2">"verbose"</span><span class="p">,</span> <span class="n">action</span><span class="o">=</span><span class="s2">"store_true"</span><span class="p">,</span>
+ <span class="n">help</span><span class="o">=</span><span class="s2">"enable logging"</span><span class="p">)</span>
+
+<span class="n">opts</span><span class="p">,</span> <span class="n">args</span> <span class="o">=</span> <span class="n">parser</span><span class="o">.</span><span class="n">parse_args</span><span class="p">()</span>
+
+<span class="k">if</span> <span class="n">opts</span><span class="o">.</span><span class="n">verbose</span><span class="p">:</span>
+ <span class="n">enable</span><span class="p">(</span><span class="s2">"qpid"</span><span class="p">,</span> <span class="n">DEBUG</span><span class="p">)</span>
+<span class="k">else</span><span class="p">:</span>
+ <span class="n">enable</span><span class="p">(</span><span class="s2">"qpid"</span><span class="p">,</span> <span class="n">WARN</span><span class="p">)</span>
+
+<span class="k">if</span> <span class="n">args</span><span class="p">:</span>
+ <span class="n">addr</span> <span class="o">=</span> <span class="n">args</span><span class="o">.</span><span class="n">pop</span><span class="p">(</span><span class="mi">0</span><span class="p">)</span>
+<span class="k">else</span><span class="p">:</span>
+ <span class="n">parser</span><span class="o">.</span><span class="n">error</span><span class="p">(</span><span class="s2">"address is required"</span><span class="p">)</span>
+<span class="k">if</span> <span class="n">opts</span><span class="o">.</span><span class="n">forever</span><span class="p">:</span>
+ <span class="n">timeout</span> <span class="o">=</span> <span class="bp">None</span>
+<span class="k">else</span><span class="p">:</span>
+ <span class="n">timeout</span> <span class="o">=</span> <span class="n">opts</span><span class="o">.</span><span class="n">timeout</span>
+
+<span class="k">class</span> <span class="nc">Formatter</span><span class="p">:</span>
+
+ <span class="k">def</span> <span class="fm">__init__</span><span class="p">(</span><span class="bp">self</span><span class="p">,</span> <span class="n">message</span><span class="p">):</span>
+ <span class="bp">self</span><span class="o">.</span><span class="n">message</span> <span class="o">=</span> <span class="n">message</span>
+ <span class="bp">self</span><span class="o">.</span><span class="n">environ</span> <span class="o">=</span> <span class="p">{</span><span class="s2">"M"</span><span class="p">:</span> <span class="bp">self</span><span class="o">.</span><span class="n">message</span><span class="p">,</span>
+ <span class="s2">"P"</span><span class="p">:</span> <span class="bp">self</span><span class="o">.</span><span class="n">message</span><span class="o">.</span><span class="n">properties</span><span class="p">,</span>
+ <span class="s2">"C"</span><span class="p">:</span> <span class="bp">self</span><span class="o">.</span><span class="n">message</span><span class="o">.</span><span class="n">content</span><span class="p">}</span>
+
+ <span class="k">def</span> <span class="fm">__getitem__</span><span class="p">(</span><span class="bp">self</span><span class="p">,</span> <span class="n">st</span><span class="p">):</span>
+ <span class="k">return</span> <span class="nb">eval</span><span class="p">(</span><span class="n">st</span><span class="p">,</span> <span class="bp">self</span><span class="o">.</span><span class="n">environ</span><span class="p">)</span>
+
+<span class="n">conn</span> <span class="o">=</span> <span class="n">Connection</span><span class="p">(</span><span class="n">opts</span><span class="o">.</span><span class="n">broker</span><span class="p">,</span>
+ <span class="n">reconnect</span><span class="o">=</span><span class="n">opts</span><span class="o">.</span><span class="n">reconnect</span><span class="p">,</span>
+ <span class="n">reconnect_interval</span><span class="o">=</span><span class="n">opts</span><span class="o">.</span><span class="n">reconnect_interval</span><span class="p">,</span>
+ <span class="n">reconnect_limit</span><span class="o">=</span><span class="n">opts</span><span class="o">.</span><span class="n">reconnect_limit</span><span class="p">)</span>
+<span class="k">try</span><span class="p">:</span>
+ <span class="n">conn</span><span class="o">.</span><span class="n">open</span><span class="p">()</span>
+ <span class="n">ssn</span> <span class="o">=</span> <span class="n">conn</span><span class="o">.</span><span class="n">session</span><span class="p">()</span>
+ <span class="n">rcv</span> <span class="o">=</span> <span class="n">ssn</span><span class="o">.</span><span class="n">receiver</span><span class="p">(</span><span class="n">addr</span><span class="p">)</span>
+
+ <span class="n">count</span> <span class="o">=</span> <span class="mi">0</span>
+ <span class="k">while</span> <span class="ow">not</span> <span class="n">opts</span><span class="o">.</span><span class="n">count</span> <span class="ow">or</span> <span class="n">count</span> <span class="o"><</span> <span class="n">opts</span><span class="o">.</span><span class="n">count</span><span class="p">:</span>
+ <span class="k">try</span><span class="p">:</span>
+ <span class="n">msg</span> <span class="o">=</span> <span class="n">rcv</span><span class="o">.</span><span class="n">fetch</span><span class="p">(</span><span class="n">timeout</span><span class="o">=</span><span class="n">timeout</span><span class="p">)</span>
+ <span class="k">print</span> <span class="n">opts</span><span class="o">.</span><span class="n">format</span> <span class="o">%</span> <span class="n">Formatter</span><span class="p">(</span><span class="n">msg</span><span class="p">)</span>
+ <span class="n">count</span> <span class="o">+=</span> <span class="mi">1</span>
+ <span class="n">ssn</span><span class="o">.</span><span class="n">acknowledge</span><span class="p">()</span>
+ <span class="k">except</span> <span class="n">Empty</span><span class="p">:</span>
+ <span class="k">break</span>
+<span class="k">except</span> <span class="n">ReceiverError</span><span class="p">,</span> <span class="n">e</span><span class="p">:</span>
+ <span class="k">print</span> <span class="n">e</span>
+<span class="k">except</span> <span class="ne">KeyboardInterrupt</span><span class="p">:</span>
+ <span class="k">pass</span>
+
+<span class="n">conn</span><span class="o">.</span><span class="n">close</span><span class="p">()</span>
+</pre></div>
+
+<p><a href="drain">Download this file</a></p>
+
+
+ <hr/>
+
+ <ul id="-apache-navigation">
+ <li><a href="http://www.apache.org/">Apache</a></li>
+ <li><a href="http://www.apache.org/licenses/">License</a></li>
+ <li><a href="http://www.apache.org/foundation/sponsorship.html">Sponsorship</a></li>
+ <li><a href="http://www.apache.org/foundation/thanks.html">Thanks!</a></li>
+ <li><a href="/security.html">Security</a></li>
+ <li><a href="http://www.apache.org/"><img id="-apache-feather" width="48" height="14" src="" alt="Apache"/></a></li>
+ </ul>
+
+ <p id="-legal">
+ Apache Qpid, Messaging built on AMQP; Copyright © 2015
+ The Apache Software Foundation; Licensed under
+ the <a href="http://www.apache.org/licenses/LICENSE-2.0">Apache
+ License, Version 2.0</a>; 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
+ </p>
+ </div>
+ </div>
+ </div>
+ </body>
+</html>
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/e970301e/content/releases/qpid-python-1.37.0/messaging-api/examples/hello
----------------------------------------------------------------------
diff --git a/content/releases/qpid-python-1.37.0/messaging-api/examples/hello b/content/releases/qpid-python-1.37.0/messaging-api/examples/hello
new file mode 100755
index 0000000..ad314da
--- /dev/null
+++ b/content/releases/qpid-python-1.37.0/messaging-api/examples/hello
@@ -0,0 +1,52 @@
+#!/usr/bin/env 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 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.
+#
+
+import sys
+from qpid.messaging import *
+
+if len(sys.argv)<2:
+ broker = "localhost:5672"
+else:
+ broker = sys.argv[1]
+
+if len(sys.argv)<3:
+ address = "amq.topic"
+else:
+ address = sys.argv[2]
+
+connection = Connection(broker)
+
+try:
+ connection.open()
+ session = connection.session()
+
+ sender = session.sender(address)
+ receiver = session.receiver(address)
+
+ sender.send(Message("Hello world!"));
+
+ message = receiver.fetch()
+ print message.content
+ session.acknowledge()
+
+except MessagingError,m:
+ print m
+
+connection.close()
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/e970301e/content/releases/qpid-python-1.37.0/messaging-api/examples/hello.html
----------------------------------------------------------------------
diff --git a/content/releases/qpid-python-1.37.0/messaging-api/examples/hello.html b/content/releases/qpid-python-1.37.0/messaging-api/examples/hello.html
new file mode 100644
index 0000000..b23b02e
--- /dev/null
+++ b/content/releases/qpid-python-1.37.0/messaging-api/examples/hello.html
@@ -0,0 +1,181 @@
+<!DOCTYPE html>
+<!--
+ -
+ - 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.
+ -
+-->
+<html xmlns="http://www.w3.org/1999/xhtml" xml:lang="en">
+ <head>
+ <title>hello - Apache Qpid™</title>
+ <meta http-equiv="X-UA-Compatible" content="IE=edge"/>
+ <meta name="viewport" content="width=device-width, initial-scale=1.0"/>
+ <link rel="stylesheet" href="/site.css" type="text/css" async="async"/>
+ <link rel="stylesheet" href="/deferred.css" type="text/css" defer="defer"/>
+ <script type="text/javascript">var _deferredFunctions = [];</script>
+ <script type="text/javascript" src="/deferred.js" defer="defer"></script>
+ <!--[if lte IE 8]>
+ <link rel="stylesheet" href="/ie.css" type="text/css"/>
+ <script type="text/javascript" src="/html5shiv.js"></script>
+ <![endif]-->
+
+ <!-- Redirects for `go get` and godoc.org -->
+ <meta name="go-import"
+ content="qpid.apache.org git https://git-wip-us.apache.org/repos/asf/qpid-proton.git"/>
+ <meta name="go-source"
+ content="qpid.apache.org
+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}"/>
+ </head>
+ <body>
+ <div id="-content">
+ <div id="-top" class="panel">
+ <a id="-menu-link"><img width="16" height="16" src="" alt="Menu"/></a>
+
+ <a id="-search-link"><img width="22" height="16" src="" alt="Search"/></a>
+
+ <ul id="-global-navigation">
+ <li><a id="-logotype" href="/index.html">Apache Qpid<sup>™</sup></a></li>
+ <li><a href="/documentation.html">Documentation</a></li>
+ <li><a href="/download.html">Download</a></li>
+ <li><a href="/discussion.html">Discussion</a></li>
+ </ul>
+ </div>
+
+ <div id="-menu" class="panel" style="display: none;">
+ <div class="flex">
+ <section>
+ <h3>Project</h3>
+
+ <ul>
+ <li><a href="/overview.html">Overview</a></li>
+ <li><a href="/components/index.html">Components</a></li>
+ <li><a href="/releases/index.html">Releases</a></li>
+ </ul>
+ </section>
+
+ <section>
+ <h3>Messaging APIs</h3>
+
+ <ul>
+ <li><a href="/proton/index.html">Qpid Proton</a></li>
+ <li><a href="/components/jms/index.html">Qpid JMS</a></li>
+ <li><a href="/components/messaging-api/index.html">Qpid Messaging API</a></li>
+ </ul>
+ </section>
+
+ <section>
+ <h3>Servers and tools</h3>
+
+ <ul>
+ <li><a href="/components/broker-j/index.html">Broker-J</a></li>
+ <li><a href="/components/cpp-broker/index.html">C++ broker</a></li>
+ <li><a href="/components/dispatch-router/index.html">Dispatch router</a></li>
+ </ul>
+ </section>
+
+ <section>
+ <h3>Resources</h3>
+
+ <ul>
+ <li><a href="/dashboard.html">Dashboard</a></li>
+ <li><a href="https://cwiki.apache.org/confluence/display/qpid/Index">Wiki</a></li>
+ <li><a href="/resources.html">More resources</a></li>
+ </ul>
+ </section>
+ </div>
+ </div>
+
+ <div id="-search" class="panel" style="display: none;">
+ <form action="http://www.google.com/search" method="get">
+ <input type="hidden" name="sitesearch" value="qpid.apache.org"/>
+ <input type="text" name="q" maxlength="255" autofocus="autofocus" tabindex="1"/>
+ <button type="submit">Search</button>
+ <a href="/search.html">More ways to search</a>
+ </form>
+ </div>
+
+ <div id="-middle" class="panel">
+ <ul id="-path-navigation"><li><a href="/index.html">Home</a></li><li><a href="/releases/index.html">Releases</a></li><li><a href="/releases/qpid-python-1.37.0/index.html">Qpid Python 1.37.0</a></li><li><a href="/releases/qpid-python-1.37.0/messaging-api/examples/index.html">Python Messaging API Examples</a></li><li>hello</li></ul>
+
+ <div id="-middle-content">
+
+<h1>hello</h1>
+<div class="highlight"><pre><span></span><span class="kn">import</span> <span class="nn">sys</span>
+<span class="kn">from</span> <span class="nn">qpid.messaging</span> <span class="kn">import</span> <span class="o">*</span>
+
+<span class="k">if</span> <span class="nb">len</span><span class="p">(</span><span class="n">sys</span><span class="o">.</span><span class="n">argv</span><span class="p">)</span><span class="o"><</span><span class="mi">2</span><span class="p">:</span>
+ <span class="n">broker</span> <span class="o">=</span> <span class="s2">"localhost:5672"</span>
+<span class="k">else</span><span class="p">:</span>
+ <span class="n">broker</span> <span class="o">=</span> <span class="n">sys</span><span class="o">.</span><span class="n">argv</span><span class="p">[</span><span class="mi">1</span><span class="p">]</span>
+
+<span class="k">if</span> <span class="nb">len</span><span class="p">(</span><span class="n">sys</span><span class="o">.</span><span class="n">argv</span><span class="p">)</span><span class="o"><</span><span class="mi">3</span><span class="p">:</span>
+ <span class="n">address</span> <span class="o">=</span> <span class="s2">"amq.topic"</span>
+<span class="k">else</span><span class="p">:</span>
+ <span class="n">address</span> <span class="o">=</span> <span class="n">sys</span><span class="o">.</span><span class="n">argv</span><span class="p">[</span><span class="mi">2</span><span class="p">]</span>
+
+<span class="n">connection</span> <span class="o">=</span> <span class="n">Connection</span><span class="p">(</span><span class="n">broker</span><span class="p">)</span>
+
+<span class="k">try</span><span class="p">:</span>
+ <span class="n">connection</span><span class="o">.</span><span class="n">open</span><span class="p">()</span>
+ <span class="n">session</span> <span class="o">=</span> <span class="n">connection</span><span class="o">.</span><span class="n">session</span><span class="p">()</span>
+
+ <span class="n">sender</span> <span class="o">=</span> <span class="n">session</span><span class="o">.</span><span class="n">sender</span><span class="p">(</span><span class="n">address</span><span class="p">)</span>
+ <span class="n">receiver</span> <span class="o">=</span> <span class="n">session</span><span class="o">.</span><span class="n">receiver</span><span class="p">(</span><span class="n">address</span><span class="p">)</span>
+
+ <span class="n">sender</span><span class="o">.</span><span class="n">send</span><span class="p">(</span><span class="n">Message</span><span class="p">(</span><span class="s2">"Hello world!"</span><span class="p">));</span>
+
+ <span class="n">message</span> <span class="o">=</span> <span class="n">receiver</span><span class="o">.</span><span class="n">fetch</span><span class="p">()</span>
+ <span class="k">print</span> <span class="n">message</span><span class="o">.</span><span class="n">content</span>
+ <span class="n">session</span><span class="o">.</span><span class="n">acknowledge</span><span class="p">()</span>
+
+<span class="k">except</span> <span class="n">MessagingError</span><span class="p">,</span><span class="n">m</span><span class="p">:</span>
+ <span class="k">print</span> <span class="n">m</span>
+
+<span class="n">connection</span><span class="o">.</span><span class="n">close</span><span class="p">()</span>
+</pre></div>
+
+<p><a href="hello">Download this file</a></p>
+
+
+ <hr/>
+
+ <ul id="-apache-navigation">
+ <li><a href="http://www.apache.org/">Apache</a></li>
+ <li><a href="http://www.apache.org/licenses/">License</a></li>
+ <li><a href="http://www.apache.org/foundation/sponsorship.html">Sponsorship</a></li>
+ <li><a href="http://www.apache.org/foundation/thanks.html">Thanks!</a></li>
+ <li><a href="/security.html">Security</a></li>
+ <li><a href="http://www.apache.org/"><img id="-apache-feather" width="48" height="14" src="" alt="Apache"/></a></li>
+ </ul>
+
+ <p id="-legal">
+ Apache Qpid, Messaging built on AMQP; Copyright © 2015
+ The Apache Software Foundation; Licensed under
+ the <a href="http://www.apache.org/licenses/LICENSE-2.0">Apache
+ License, Version 2.0</a>; 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
+ </p>
+ </div>
+ </div>
+ </div>
+ </body>
+</html>
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/e970301e/content/releases/qpid-python-1.37.0/messaging-api/examples/hello_xml
----------------------------------------------------------------------
diff --git a/content/releases/qpid-python-1.37.0/messaging-api/examples/hello_xml b/content/releases/qpid-python-1.37.0/messaging-api/examples/hello_xml
new file mode 100755
index 0000000..ab567ec
--- /dev/null
+++ b/content/releases/qpid-python-1.37.0/messaging-api/examples/hello_xml
@@ -0,0 +1,77 @@
+#!/usr/bin/env 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 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.
+#
+
+import sys
+from qpid.messaging import *
+
+broker = "localhost:5672"
+connection = Connection(broker)
+
+try:
+ connection.open()
+ session = connection.session()
+
+# Set up the receiver
+ query = """
+ let $w := ./weather
+ return $w/station = 'Raleigh-Durham International Airport (KRDU)'
+ and $w/temperature_f > 50
+ and $w/temperature_f - $w/dewpoint > 5
+ and $w/wind_speed_mph > 7
+ and $w/wind_speed_mph < 20 """
+
+# query="./weather"
+
+ address = """
+ xml; {
+ create: always,
+ node:{ type: queue },
+ link: {
+ x-bindings: [{ exchange: xml, key: weather, arguments: { xquery: %r} }]
+ }
+ }
+ """ % query
+
+ receiver = session.receiver(address)
+
+# Send an observation
+
+ observations = """
+ <weather>
+ <station>Raleigh-Durham International Airport (KRDU)</station>
+ <wind_speed_mph>16</wind_speed_mph>
+ <temperature_f>70</temperature_f>
+ <dewpoint>35</dewpoint>
+ </weather> """
+
+ message = Message(subject="weather", content=observations)
+ sender = session.sender("xml")
+ sender.send(message)
+
+# Retrieve matching message from the receiver and print it
+
+ message = receiver.fetch(timeout=1)
+ print message.content
+ session.acknowledge()
+
+except MessagingError,m:
+ print m
+
+connection.close()
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/e970301e/content/releases/qpid-python-1.37.0/messaging-api/examples/hello_xml.html
----------------------------------------------------------------------
diff --git a/content/releases/qpid-python-1.37.0/messaging-api/examples/hello_xml.html b/content/releases/qpid-python-1.37.0/messaging-api/examples/hello_xml.html
new file mode 100644
index 0000000..6ed4b57
--- /dev/null
+++ b/content/releases/qpid-python-1.37.0/messaging-api/examples/hello_xml.html
@@ -0,0 +1,206 @@
+<!DOCTYPE html>
+<!--
+ -
+ - 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.
+ -
+-->
+<html xmlns="http://www.w3.org/1999/xhtml" xml:lang="en">
+ <head>
+ <title>hello_xml - Apache Qpid™</title>
+ <meta http-equiv="X-UA-Compatible" content="IE=edge"/>
+ <meta name="viewport" content="width=device-width, initial-scale=1.0"/>
+ <link rel="stylesheet" href="/site.css" type="text/css" async="async"/>
+ <link rel="stylesheet" href="/deferred.css" type="text/css" defer="defer"/>
+ <script type="text/javascript">var _deferredFunctions = [];</script>
+ <script type="text/javascript" src="/deferred.js" defer="defer"></script>
+ <!--[if lte IE 8]>
+ <link rel="stylesheet" href="/ie.css" type="text/css"/>
+ <script type="text/javascript" src="/html5shiv.js"></script>
+ <![endif]-->
+
+ <!-- Redirects for `go get` and godoc.org -->
+ <meta name="go-import"
+ content="qpid.apache.org git https://git-wip-us.apache.org/repos/asf/qpid-proton.git"/>
+ <meta name="go-source"
+ content="qpid.apache.org
+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}"/>
+ </head>
+ <body>
+ <div id="-content">
+ <div id="-top" class="panel">
+ <a id="-menu-link"><img width="16" height="16" src="" alt="Menu"/></a>
+
+ <a id="-search-link"><img width="22" height="16" src="" alt="Search"/></a>
+
+ <ul id="-global-navigation">
+ <li><a id="-logotype" href="/index.html">Apache Qpid<sup>™</sup></a></li>
+ <li><a href="/documentation.html">Documentation</a></li>
+ <li><a href="/download.html">Download</a></li>
+ <li><a href="/discussion.html">Discussion</a></li>
+ </ul>
+ </div>
+
+ <div id="-menu" class="panel" style="display: none;">
+ <div class="flex">
+ <section>
+ <h3>Project</h3>
+
+ <ul>
+ <li><a href="/overview.html">Overview</a></li>
+ <li><a href="/components/index.html">Components</a></li>
+ <li><a href="/releases/index.html">Releases</a></li>
+ </ul>
+ </section>
+
+ <section>
+ <h3>Messaging APIs</h3>
+
+ <ul>
+ <li><a href="/proton/index.html">Qpid Proton</a></li>
+ <li><a href="/components/jms/index.html">Qpid JMS</a></li>
+ <li><a href="/components/messaging-api/index.html">Qpid Messaging API</a></li>
+ </ul>
+ </section>
+
+ <section>
+ <h3>Servers and tools</h3>
+
+ <ul>
+ <li><a href="/components/broker-j/index.html">Broker-J</a></li>
+ <li><a href="/components/cpp-broker/index.html">C++ broker</a></li>
+ <li><a href="/components/dispatch-router/index.html">Dispatch router</a></li>
+ </ul>
+ </section>
+
+ <section>
+ <h3>Resources</h3>
+
+ <ul>
+ <li><a href="/dashboard.html">Dashboard</a></li>
+ <li><a href="https://cwiki.apache.org/confluence/display/qpid/Index">Wiki</a></li>
+ <li><a href="/resources.html">More resources</a></li>
+ </ul>
+ </section>
+ </div>
+ </div>
+
+ <div id="-search" class="panel" style="display: none;">
+ <form action="http://www.google.com/search" method="get">
+ <input type="hidden" name="sitesearch" value="qpid.apache.org"/>
+ <input type="text" name="q" maxlength="255" autofocus="autofocus" tabindex="1"/>
+ <button type="submit">Search</button>
+ <a href="/search.html">More ways to search</a>
+ </form>
+ </div>
+
+ <div id="-middle" class="panel">
+ <ul id="-path-navigation"><li><a href="/index.html">Home</a></li><li><a href="/releases/index.html">Releases</a></li><li><a href="/releases/qpid-python-1.37.0/index.html">Qpid Python 1.37.0</a></li><li><a href="/releases/qpid-python-1.37.0/messaging-api/examples/index.html">Python Messaging API Examples</a></li><li>hello_xml</li></ul>
+
+ <div id="-middle-content">
+
+<h1>hello_xml</h1>
+<div class="highlight"><pre><span></span><span class="kn">import</span> <span class="nn">sys</span>
+<span class="kn">from</span> <span class="nn">qpid.messaging</span> <span class="kn">import</span> <span class="o">*</span>
+
+<span class="n">broker</span> <span class="o">=</span> <span class="s2">"localhost:5672"</span>
+<span class="n">connection</span> <span class="o">=</span> <span class="n">Connection</span><span class="p">(</span><span class="n">broker</span><span class="p">)</span>
+
+<span class="k">try</span><span class="p">:</span>
+ <span class="n">connection</span><span class="o">.</span><span class="n">open</span><span class="p">()</span>
+ <span class="n">session</span> <span class="o">=</span> <span class="n">connection</span><span class="o">.</span><span class="n">session</span><span class="p">()</span>
+
+<span class="c1"># Set up the receiver</span>
+ <span class="n">query</span> <span class="o">=</span> <span class="s2">"""</span>
+<span class="s2"> let $w := ./weather</span>
+<span class="s2"> return $w/station = 'Raleigh-Durham International Airport (KRDU)'</span>
+<span class="s2"> and $w/temperature_f > 50</span>
+<span class="s2"> and $w/temperature_f - $w/dewpoint > 5</span>
+<span class="s2"> and $w/wind_speed_mph > 7</span>
+<span class="s2"> and $w/wind_speed_mph < 20 """</span>
+
+<span class="c1"># query="./weather"</span>
+
+ <span class="n">address</span> <span class="o">=</span> <span class="s2">"""</span>
+<span class="s2"> xml; {</span>
+<span class="s2"> create: always, </span>
+<span class="s2"> node:{ type: queue }, </span>
+<span class="s2"> link: { </span>
+<span class="s2"> x-bindings: [{ exchange: xml, key: weather, arguments: { xquery: </span><span class="si">%r</span><span class="s2">} }] </span>
+<span class="s2"> } </span>
+<span class="s2"> }</span>
+<span class="s2"> """</span> <span class="o">%</span> <span class="n">query</span>
+
+ <span class="n">receiver</span> <span class="o">=</span> <span class="n">session</span><span class="o">.</span><span class="n">receiver</span><span class="p">(</span><span class="n">address</span><span class="p">)</span>
+
+<span class="c1"># Send an observation</span>
+
+ <span class="n">observations</span> <span class="o">=</span> <span class="s2">"""</span>
+<span class="s2"> <weather></span>
+<span class="s2"> <station>Raleigh-Durham International Airport (KRDU)</station></span>
+<span class="s2"> <wind_speed_mph>16</wind_speed_mph></span>
+<span class="s2"> <temperature_f>70</temperature_f></span>
+<span class="s2"> <dewpoint>35</dewpoint></span>
+<span class="s2"> </weather> """</span>
+
+ <span class="n">message</span> <span class="o">=</span> <span class="n">Message</span><span class="p">(</span><span class="n">subject</span><span class="o">=</span><span class="s2">"weather"</span><span class="p">,</span> <span class="n">content</span><span class="o">=</span><span class="n">observations</span><span class="p">)</span>
+ <span class="n">sender</span> <span class="o">=</span> <span class="n">session</span><span class="o">.</span><span class="n">sender</span><span class="p">(</span><span class="s2">"xml"</span><span class="p">)</span>
+ <span class="n">sender</span><span class="o">.</span><span class="n">send</span><span class="p">(</span><span class="n">message</span><span class="p">)</span>
+
+<span class="c1"># Retrieve matching message from the receiver and print it</span>
+
+ <span class="n">message</span> <span class="o">=</span> <span class="n">receiver</span><span class="o">.</span><span class="n">fetch</span><span class="p">(</span><span class="n">timeout</span><span class="o">=</span><span class="mi">1</span><span class="p">)</span>
+ <span class="k">print</span> <span class="n">message</span><span class="o">.</span><span class="n">content</span>
+ <span class="n">session</span><span class="o">.</span><span class="n">acknowledge</span><span class="p">()</span>
+
+<span class="k">except</span> <span class="n">MessagingError</span><span class="p">,</span><span class="n">m</span><span class="p">:</span>
+ <span class="k">print</span> <span class="n">m</span>
+
+<span class="n">connection</span><span class="o">.</span><span class="n">close</span><span class="p">()</span>
+</pre></div>
+
+<p><a href="hello_xml">Download this file</a></p>
+
+
+ <hr/>
+
+ <ul id="-apache-navigation">
+ <li><a href="http://www.apache.org/">Apache</a></li>
+ <li><a href="http://www.apache.org/licenses/">License</a></li>
+ <li><a href="http://www.apache.org/foundation/sponsorship.html">Sponsorship</a></li>
+ <li><a href="http://www.apache.org/foundation/thanks.html">Thanks!</a></li>
+ <li><a href="/security.html">Security</a></li>
+ <li><a href="http://www.apache.org/"><img id="-apache-feather" width="48" height="14" src="" alt="Apache"/></a></li>
+ </ul>
+
+ <p id="-legal">
+ Apache Qpid, Messaging built on AMQP; Copyright © 2015
+ The Apache Software Foundation; Licensed under
+ the <a href="http://www.apache.org/licenses/LICENSE-2.0">Apache
+ License, Version 2.0</a>; 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
+ </p>
+ </div>
+ </div>
+ </div>
+ </body>
+</html>
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/e970301e/content/releases/qpid-python-1.37.0/messaging-api/examples/index.html
----------------------------------------------------------------------
diff --git a/content/releases/qpid-python-1.37.0/messaging-api/examples/index.html b/content/releases/qpid-python-1.37.0/messaging-api/examples/index.html
new file mode 100644
index 0000000..6634426
--- /dev/null
+++ b/content/releases/qpid-python-1.37.0/messaging-api/examples/index.html
@@ -0,0 +1,163 @@
+<!DOCTYPE html>
+<!--
+ -
+ - 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.
+ -
+-->
+<html xmlns="http://www.w3.org/1999/xhtml" xml:lang="en">
+ <head>
+ <title>Python Messaging API Examples - Apache Qpid™</title>
+ <meta http-equiv="X-UA-Compatible" content="IE=edge"/>
+ <meta name="viewport" content="width=device-width, initial-scale=1.0"/>
+ <link rel="stylesheet" href="/site.css" type="text/css" async="async"/>
+ <link rel="stylesheet" href="/deferred.css" type="text/css" defer="defer"/>
+ <script type="text/javascript">var _deferredFunctions = [];</script>
+ <script type="text/javascript" src="/deferred.js" defer="defer"></script>
+ <!--[if lte IE 8]>
+ <link rel="stylesheet" href="/ie.css" type="text/css"/>
+ <script type="text/javascript" src="/html5shiv.js"></script>
+ <![endif]-->
+
+ <!-- Redirects for `go get` and godoc.org -->
+ <meta name="go-import"
+ content="qpid.apache.org git https://git-wip-us.apache.org/repos/asf/qpid-proton.git"/>
+ <meta name="go-source"
+ content="qpid.apache.org
+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}"/>
+ </head>
+ <body>
+ <div id="-content">
+ <div id="-top" class="panel">
+ <a id="-menu-link"><img width="16" height="16" src="" alt="Menu"/></a>
+
+ <a id="-search-link"><img width="22" height="16" src="" alt="Search"/></a>
+
+ <ul id="-global-navigation">
+ <li><a id="-logotype" href="/index.html">Apache Qpid<sup>™</sup></a></li>
+ <li><a href="/documentation.html">Documentation</a></li>
+ <li><a href="/download.html">Download</a></li>
+ <li><a href="/discussion.html">Discussion</a></li>
+ </ul>
+ </div>
+
+ <div id="-menu" class="panel" style="display: none;">
+ <div class="flex">
+ <section>
+ <h3>Project</h3>
+
+ <ul>
+ <li><a href="/overview.html">Overview</a></li>
+ <li><a href="/components/index.html">Components</a></li>
+ <li><a href="/releases/index.html">Releases</a></li>
+ </ul>
+ </section>
+
+ <section>
+ <h3>Messaging APIs</h3>
+
+ <ul>
+ <li><a href="/proton/index.html">Qpid Proton</a></li>
+ <li><a href="/components/jms/index.html">Qpid JMS</a></li>
+ <li><a href="/components/messaging-api/index.html">Qpid Messaging API</a></li>
+ </ul>
+ </section>
+
+ <section>
+ <h3>Servers and tools</h3>
+
+ <ul>
+ <li><a href="/components/broker-j/index.html">Broker-J</a></li>
+ <li><a href="/components/cpp-broker/index.html">C++ broker</a></li>
+ <li><a href="/components/dispatch-router/index.html">Dispatch router</a></li>
+ </ul>
+ </section>
+
+ <section>
+ <h3>Resources</h3>
+
+ <ul>
+ <li><a href="/dashboard.html">Dashboard</a></li>
+ <li><a href="https://cwiki.apache.org/confluence/display/qpid/Index">Wiki</a></li>
+ <li><a href="/resources.html">More resources</a></li>
+ </ul>
+ </section>
+ </div>
+ </div>
+
+ <div id="-search" class="panel" style="display: none;">
+ <form action="http://www.google.com/search" method="get">
+ <input type="hidden" name="sitesearch" value="qpid.apache.org"/>
+ <input type="text" name="q" maxlength="255" autofocus="autofocus" tabindex="1"/>
+ <button type="submit">Search</button>
+ <a href="/search.html">More ways to search</a>
+ </form>
+ </div>
+
+ <div id="-middle" class="panel">
+ <ul id="-path-navigation"><li><a href="/index.html">Home</a></li><li><a href="/releases/index.html">Releases</a></li><li><a href="/releases/qpid-python-1.37.0/index.html">Qpid Python 1.37.0</a></li><li>Python Messaging API Examples</li></ul>
+
+ <div id="-middle-content">
+ <h1 id="python-messaging-api-examples">Python Messaging API Examples</h1>
+
+<h2 id="example-files">Example files</h2>
+
+<ul>
+<li><a href="drain.html">drain</a></li>
+<li><a href="hello.html">hello</a></li>
+<li><a href="hello_xml.html">hello_xml</a></li>
+<li><a href="server.html">server</a></li>
+<li><a href="spout.html">spout</a></li>
+<li><a href="statistics.py.html">statistics.py</a></li>
+</ul>
+
+<h2 id="more-information">More information</h2>
+
+<ul>
+<li><a href="https://git-wip-us.apache.org/repos/asf?p=qpid-python.git;a=blob_plain;f=examples/README.txt;hb=1.37.0">README</a></li>
+<li><a href="https://git-wip-us.apache.org/repos/asf?p=qpid-python.git;a=tree;f=examples;hb=1.37.0">Source location</a></li>
+</ul>
+
+
+ <hr/>
+
+ <ul id="-apache-navigation">
+ <li><a href="http://www.apache.org/">Apache</a></li>
+ <li><a href="http://www.apache.org/licenses/">License</a></li>
+ <li><a href="http://www.apache.org/foundation/sponsorship.html">Sponsorship</a></li>
+ <li><a href="http://www.apache.org/foundation/thanks.html">Thanks!</a></li>
+ <li><a href="/security.html">Security</a></li>
+ <li><a href="http://www.apache.org/"><img id="-apache-feather" width="48" height="14" src="" alt="Apache"/></a></li>
+ </ul>
+
+ <p id="-legal">
+ Apache Qpid, Messaging built on AMQP; Copyright © 2015
+ The Apache Software Foundation; Licensed under
+ the <a href="http://www.apache.org/licenses/LICENSE-2.0">Apache
+ License, Version 2.0</a>; 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
+ </p>
+ </div>
+ </div>
+ </div>
+ </body>
+</html>
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/e970301e/content/releases/qpid-python-1.37.0/messaging-api/examples/server
----------------------------------------------------------------------
diff --git a/content/releases/qpid-python-1.37.0/messaging-api/examples/server b/content/releases/qpid-python-1.37.0/messaging-api/examples/server
new file mode 100755
index 0000000..78d812b
--- /dev/null
+++ b/content/releases/qpid-python-1.37.0/messaging-api/examples/server
@@ -0,0 +1,95 @@
+#!/usr/bin/env 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 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.
+#
+
+import optparse, sys, traceback
+from qpid.messaging import *
+from qpid.util import URL
+from subprocess import Popen, STDOUT, PIPE
+from qpid.log import enable, DEBUG, WARN
+
+parser = optparse.OptionParser(usage="usage: %prog [options] ADDRESS ...",
+ description="handle requests from the supplied address.")
+parser.add_option("-b", "--broker", default="localhost",
+ help="connect to specified BROKER (default %default)")
+parser.add_option("-r", "--reconnect", action="store_true",
+ help="enable auto reconnect")
+parser.add_option("-i", "--reconnect-interval", type="float", default=3,
+ help="interval between reconnect attempts")
+parser.add_option("-l", "--reconnect-limit", type="int",
+ help="maximum number of reconnect attempts")
+parser.add_option("-v", dest="verbose", action="store_true",
+ help="enable logging")
+
+opts, args = parser.parse_args()
+
+if opts.verbose:
+ enable("qpid", DEBUG)
+else:
+ enable("qpid", WARN)
+
+if args:
+ addr = args.pop(0)
+else:
+ parser.error("address is required")
+
+conn = Connection(opts.broker,
+ reconnect=opts.reconnect,
+ reconnect_interval=opts.reconnect_interval,
+ reconnect_limit=opts.reconnect_limit)
+def dispatch(msg):
+ msg_type = msg.properties.get("type")
+ if msg_type == "shell":
+ proc = Popen(msg.content, shell=True, stderr=STDOUT, stdin=PIPE, stdout=PIPE)
+ output, _ = proc.communicate()
+ result = Message(output)
+ result.properties["exit"] = proc.returncode
+ elif msg_type == "eval":
+ try:
+ content = eval(msg.content)
+ except:
+ content = traceback.format_exc()
+ result = Message(content)
+ else:
+ result = Message("unrecognized message type: %s" % msg_type)
+ return result
+
+try:
+ conn.open()
+ ssn = conn.session()
+ rcv = ssn.receiver(addr)
+
+ while True:
+ msg = rcv.fetch()
+ response = dispatch(msg)
+ snd = None
+ try:
+ snd = ssn.sender(msg.reply_to)
+ snd.send(response)
+ except SendError, e:
+ print e
+ if snd is not None:
+ snd.close()
+ ssn.acknowledge()
+except ReceiverError, e:
+ print e
+except KeyboardInterrupt:
+ pass
+
+conn.close()
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org