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:22 UTC
[02/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/input/releases/qpid-python-1.37.0/messaging-api/api/toc-qpid.messaging.address-module.html
----------------------------------------------------------------------
diff --git a/input/releases/qpid-python-1.37.0/messaging-api/api/toc-qpid.messaging.address-module.html b/input/releases/qpid-python-1.37.0/messaging-api/api/toc-qpid.messaging.address-module.html
new file mode 100644
index 0000000..9a1f5f5
--- /dev/null
+++ b/input/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/input/releases/qpid-python-1.37.0/messaging-api/api/toc-qpid.messaging.constants-module.html
----------------------------------------------------------------------
diff --git a/input/releases/qpid-python-1.37.0/messaging-api/api/toc-qpid.messaging.constants-module.html b/input/releases/qpid-python-1.37.0/messaging-api/api/toc-qpid.messaging.constants-module.html
new file mode 100644
index 0000000..bb47268
--- /dev/null
+++ b/input/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/input/releases/qpid-python-1.37.0/messaging-api/api/toc-qpid.messaging.driver-module.html
----------------------------------------------------------------------
diff --git a/input/releases/qpid-python-1.37.0/messaging-api/api/toc-qpid.messaging.driver-module.html b/input/releases/qpid-python-1.37.0/messaging-api/api/toc-qpid.messaging.driver-module.html
new file mode 100644
index 0000000..b0e2026
--- /dev/null
+++ b/input/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/input/releases/qpid-python-1.37.0/messaging-api/api/toc-qpid.messaging.endpoints-module.html
----------------------------------------------------------------------
diff --git a/input/releases/qpid-python-1.37.0/messaging-api/api/toc-qpid.messaging.endpoints-module.html b/input/releases/qpid-python-1.37.0/messaging-api/api/toc-qpid.messaging.endpoints-module.html
new file mode 100644
index 0000000..51ed570
--- /dev/null
+++ b/input/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/input/releases/qpid-python-1.37.0/messaging-api/api/toc-qpid.messaging.exceptions-module.html
----------------------------------------------------------------------
diff --git a/input/releases/qpid-python-1.37.0/messaging-api/api/toc-qpid.messaging.exceptions-module.html b/input/releases/qpid-python-1.37.0/messaging-api/api/toc-qpid.messaging.exceptions-module.html
new file mode 100644
index 0000000..df5eae0
--- /dev/null
+++ b/input/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/input/releases/qpid-python-1.37.0/messaging-api/api/toc-qpid.messaging.message-module.html
----------------------------------------------------------------------
diff --git a/input/releases/qpid-python-1.37.0/messaging-api/api/toc-qpid.messaging.message-module.html b/input/releases/qpid-python-1.37.0/messaging-api/api/toc-qpid.messaging.message-module.html
new file mode 100644
index 0000000..43565c1
--- /dev/null
+++ b/input/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/input/releases/qpid-python-1.37.0/messaging-api/api/toc-qpid.messaging.transports-module.html
----------------------------------------------------------------------
diff --git a/input/releases/qpid-python-1.37.0/messaging-api/api/toc-qpid.messaging.transports-module.html b/input/releases/qpid-python-1.37.0/messaging-api/api/toc-qpid.messaging.transports-module.html
new file mode 100644
index 0000000..d5f6a60
--- /dev/null
+++ b/input/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/input/releases/qpid-python-1.37.0/messaging-api/api/toc-qpid.messaging.util-module.html
----------------------------------------------------------------------
diff --git a/input/releases/qpid-python-1.37.0/messaging-api/api/toc-qpid.messaging.util-module.html b/input/releases/qpid-python-1.37.0/messaging-api/api/toc-qpid.messaging.util-module.html
new file mode 100644
index 0000000..543b471
--- /dev/null
+++ b/input/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/input/releases/qpid-python-1.37.0/messaging-api/api/toc.html
----------------------------------------------------------------------
diff --git a/input/releases/qpid-python-1.37.0/messaging-api/api/toc.html b/input/releases/qpid-python-1.37.0/messaging-api/api/toc.html
new file mode 100644
index 0000000..4f6f84a
--- /dev/null
+++ b/input/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/input/releases/qpid-python-1.37.0/messaging-api/examples/drain
----------------------------------------------------------------------
diff --git a/input/releases/qpid-python-1.37.0/messaging-api/examples/drain b/input/releases/qpid-python-1.37.0/messaging-api/examples/drain
new file mode 100755
index 0000000..5e30153
--- /dev/null
+++ b/input/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/input/releases/qpid-python-1.37.0/messaging-api/examples/drain.html.in
----------------------------------------------------------------------
diff --git a/input/releases/qpid-python-1.37.0/messaging-api/examples/drain.html.in b/input/releases/qpid-python-1.37.0/messaging-api/examples/drain.html.in
new file mode 100644
index 0000000..30e1e39
--- /dev/null
+++ b/input/releases/qpid-python-1.37.0/messaging-api/examples/drain.html.in
@@ -0,0 +1,82 @@
+
+<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>
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/e970301e/input/releases/qpid-python-1.37.0/messaging-api/examples/hello
----------------------------------------------------------------------
diff --git a/input/releases/qpid-python-1.37.0/messaging-api/examples/hello b/input/releases/qpid-python-1.37.0/messaging-api/examples/hello
new file mode 100755
index 0000000..ad314da
--- /dev/null
+++ b/input/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/input/releases/qpid-python-1.37.0/messaging-api/examples/hello.html.in
----------------------------------------------------------------------
diff --git a/input/releases/qpid-python-1.37.0/messaging-api/examples/hello.html.in b/input/releases/qpid-python-1.37.0/messaging-api/examples/hello.html.in
new file mode 100644
index 0000000..1295ce4
--- /dev/null
+++ b/input/releases/qpid-python-1.37.0/messaging-api/examples/hello.html.in
@@ -0,0 +1,37 @@
+
+<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>
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/e970301e/input/releases/qpid-python-1.37.0/messaging-api/examples/hello_xml
----------------------------------------------------------------------
diff --git a/input/releases/qpid-python-1.37.0/messaging-api/examples/hello_xml b/input/releases/qpid-python-1.37.0/messaging-api/examples/hello_xml
new file mode 100755
index 0000000..ab567ec
--- /dev/null
+++ b/input/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/input/releases/qpid-python-1.37.0/messaging-api/examples/hello_xml.html.in
----------------------------------------------------------------------
diff --git a/input/releases/qpid-python-1.37.0/messaging-api/examples/hello_xml.html.in b/input/releases/qpid-python-1.37.0/messaging-api/examples/hello_xml.html.in
new file mode 100644
index 0000000..16ac907
--- /dev/null
+++ b/input/releases/qpid-python-1.37.0/messaging-api/examples/hello_xml.html.in
@@ -0,0 +1,62 @@
+
+<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>
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/e970301e/input/releases/qpid-python-1.37.0/messaging-api/examples/index.md
----------------------------------------------------------------------
diff --git a/input/releases/qpid-python-1.37.0/messaging-api/examples/index.md b/input/releases/qpid-python-1.37.0/messaging-api/examples/index.md
new file mode 100644
index 0000000..ac13414
--- /dev/null
+++ b/input/releases/qpid-python-1.37.0/messaging-api/examples/index.md
@@ -0,0 +1,16 @@
+
+# Python Messaging API Examples
+
+## Example files
+
+ - [drain](drain.html)
+ - [hello](hello.html)
+ - [hello_xml](hello_xml.html)
+ - [server](server.html)
+ - [spout](spout.html)
+ - [statistics.py](statistics.py.html)
+
+## More information
+
+ - [README](https://git-wip-us.apache.org/repos/asf?p=qpid-python.git;a=blob_plain;f=examples/README.txt;hb=1.37.0)
+ - [Source location](https://git-wip-us.apache.org/repos/asf?p=qpid-python.git;a=tree;f=examples;hb=1.37.0)
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/e970301e/input/releases/qpid-python-1.37.0/messaging-api/examples/server
----------------------------------------------------------------------
diff --git a/input/releases/qpid-python-1.37.0/messaging-api/examples/server b/input/releases/qpid-python-1.37.0/messaging-api/examples/server
new file mode 100755
index 0000000..78d812b
--- /dev/null
+++ b/input/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()
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/e970301e/input/releases/qpid-python-1.37.0/messaging-api/examples/server.html.in
----------------------------------------------------------------------
diff --git a/input/releases/qpid-python-1.37.0/messaging-api/examples/server.html.in b/input/releases/qpid-python-1.37.0/messaging-api/examples/server.html.in
new file mode 100644
index 0000000..b9d9eed
--- /dev/null
+++ b/input/releases/qpid-python-1.37.0/messaging-api/examples/server.html.in
@@ -0,0 +1,80 @@
+
+<h1>server</h1>
+<div class="highlight"><pre><span></span><span class="kn">import</span> <span class="nn">optparse</span><span class="o">,</span> <span class="nn">sys</span><span class="o">,</span> <span class="nn">traceback</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">subprocess</span> <span class="kn">import</span> <span class="n">Popen</span><span class="p">,</span> <span class="n">STDOUT</span><span class="p">,</span> <span class="n">PIPE</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">"handle requests 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">"-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">"-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="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">def</span> <span class="nf">dispatch</span><span class="p">(</span><span class="n">msg</span><span class="p">):</span>
+ <span class="n">msg_type</span> <span class="o">=</span> <span class="n">msg</span><span class="o">.</span><span class="n">properties</span><span class="o">.</span><span class="n">get</span><span class="p">(</span><span class="s2">"type"</span><span class="p">)</span>
+ <span class="k">if</span> <span class="n">msg_type</span> <span class="o">==</span> <span class="s2">"shell"</span><span class="p">:</span>
+ <span class="n">proc</span> <span class="o">=</span> <span class="n">Popen</span><span class="p">(</span><span class="n">msg</span><span class="o">.</span><span class="n">content</span><span class="p">,</span> <span class="n">shell</span><span class="o">=</span><span class="bp">True</span><span class="p">,</span> <span class="n">stderr</span><span class="o">=</span><span class="n">STDOUT</span><span class="p">,</span> <span class="n">stdin</span><span class="o">=</span><span class="n">PIPE</span><span class="p">,</span> <span class="n">stdout</span><span class="o">=</span><span class="n">PIPE</span><span class="p">)</span>
+ <span class="n">output</span><span class="p">,</span> <span class="n">_</span> <span class="o">=</span> <span class="n">proc</span><span class="o">.</span><span class="n">communicate</span><span class="p">()</span>
+ <span class="n">result</span> <span class="o">=</span> <span class="n">Message</span><span class="p">(</span><span class="n">output</span><span class="p">)</span>
+ <span class="n">result</span><span class="o">.</span><span class="n">properties</span><span class="p">[</span><span class="s2">"exit"</span><span class="p">]</span> <span class="o">=</span> <span class="n">proc</span><span class="o">.</span><span class="n">returncode</span>
+ <span class="k">elif</span> <span class="n">msg_type</span> <span class="o">==</span> <span class="s2">"eval"</span><span class="p">:</span>
+ <span class="k">try</span><span class="p">:</span>
+ <span class="n">content</span> <span class="o">=</span> <span class="nb">eval</span><span class="p">(</span><span class="n">msg</span><span class="o">.</span><span class="n">content</span><span class="p">)</span>
+ <span class="k">except</span><span class="p">:</span>
+ <span class="n">content</span> <span class="o">=</span> <span class="n">traceback</span><span class="o">.</span><span class="n">format_exc</span><span class="p">()</span>
+ <span class="n">result</span> <span class="o">=</span> <span class="n">Message</span><span class="p">(</span><span class="n">content</span><span class="p">)</span>
+ <span class="k">else</span><span class="p">:</span>
+ <span class="n">result</span> <span class="o">=</span> <span class="n">Message</span><span class="p">(</span><span class="s2">"unrecognized message type: </span><span class="si">%s</span><span class="s2">"</span> <span class="o">%</span> <span class="n">msg_type</span><span class="p">)</span>
+ <span class="k">return</span> <span class="n">result</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="k">while</span> <span class="bp">True</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">response</span> <span class="o">=</span> <span class="n">dispatch</span><span class="p">(</span><span class="n">msg</span><span class="p">)</span>
+ <span class="n">snd</span> <span class="o">=</span> <span class="bp">None</span>
+ <span class="k">try</span><span class="p">:</span>
+ <span class="n">snd</span> <span class="o">=</span> <span class="n">ssn</span><span class="o">.</span><span class="n">sender</span><span class="p">(</span><span class="n">msg</span><span class="o">.</span><span class="n">reply_to</span><span class="p">)</span>
+ <span class="n">snd</span><span class="o">.</span><span class="n">send</span><span class="p">(</span><span class="n">response</span><span class="p">)</span>
+ <span class="k">except</span> <span class="n">SendError</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">if</span> <span class="n">snd</span> <span class="ow">is</span> <span class="ow">not</span> <span class="bp">None</span><span class="p">:</span>
+ <span class="n">snd</span><span class="o">.</span><span class="n">close</span><span class="p">()</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">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="server">Download this file</a></p>
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/e970301e/input/releases/qpid-python-1.37.0/messaging-api/examples/spout
----------------------------------------------------------------------
diff --git a/input/releases/qpid-python-1.37.0/messaging-api/examples/spout b/input/releases/qpid-python-1.37.0/messaging-api/examples/spout
new file mode 100755
index 0000000..6584b85
--- /dev/null
+++ b/input/releases/qpid-python-1.37.0/messaging-api/examples/spout
@@ -0,0 +1,133 @@
+#!/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, time
+from qpid.messaging import *
+from qpid.util import URL
+from qpid.log import enable, DEBUG, WARN
+
+def nameval(st):
+ idx = st.find("=")
+ if idx >= 0:
+ name = st[0:idx]
+ value = st[idx+1:]
+ else:
+ name = st
+ value = None
+ return name, value
+
+parser = optparse.OptionParser(usage="usage: %prog [options] ADDRESS [ CONTENT ... ]",
+ description="Send messages to 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("-c", "--count", type="int", default=1,
+ help="stop after count messages have been sent, zero disables (default %default)")
+parser.add_option("-d", "--durable", action="store_true",
+ help="make the message persistent")
+parser.add_option("-t", "--timeout", type="float", default=None,
+ help="exit after the specified time")
+parser.add_option("-I", "--id", help="use the supplied id instead of generating one")
+parser.add_option("-S", "--subject", help="specify a subject")
+parser.add_option("-R", "--reply-to", help="specify reply-to address")
+parser.add_option("-P", "--property", dest="properties", action="append", default=[],
+ metavar="NAME=VALUE", help="specify message property")
+parser.add_option("-M", "--map", dest="entries", action="append", default=[],
+ metavar="KEY=VALUE",
+ help="specify map entry for message body")
+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 opts.id is None:
+ spout_id = str(uuid4())
+else:
+ spout_id = opts.id
+if args:
+ addr = args.pop(0)
+else:
+ parser.error("address is required")
+
+content = None
+content_type = None
+
+if args:
+ text = " ".join(args)
+else:
+ text = None
+
+if opts.entries:
+ content = {}
+ if text:
+ content["text"] = text
+ for e in opts.entries:
+ name, val = nameval(e)
+ content[name] = val
+else:
+ content = text
+ # no entries were supplied, so assume text/plain for
+ # compatibility with java (and other) clients
+ content_type = "text/plain"
+
+conn = Connection(opts.broker,
+ reconnect=opts.reconnect,
+ reconnect_interval=opts.reconnect_interval,
+ reconnect_limit=opts.reconnect_limit)
+try:
+ conn.open()
+ ssn = conn.session()
+ snd = ssn.sender(addr)
+
+ count = 0
+ start = time.time()
+ while (opts.count == 0 or count < opts.count) and \
+ (opts.timeout is None or time.time() - start < opts.timeout):
+ msg = Message(subject=opts.subject,
+ reply_to=opts.reply_to,
+ content=content)
+ if opts.durable:
+ msg.durable = True
+ if content_type is not None:
+ msg.content_type = content_type
+ msg.properties["spout-id"] = "%s:%s" % (spout_id, count)
+ for p in opts.properties:
+ name, val = nameval(p)
+ msg.properties[name] = val
+
+ snd.send(msg)
+ count += 1
+ print msg
+except SendError, 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