http://git-wip-us.apache.org/repos/asf/qpid-site/blob/55375a76/content/releases/qpid-python-1.36.0/messaging-api/api/toc-qpid.messaging.address-module.html ---------------------------------------------------------------------- diff --git a/content/releases/qpid-python-1.36.0/messaging-api/api/toc-qpid.messaging.address-module.html b/content/releases/qpid-python-1.36.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.36.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/55375a76/content/releases/qpid-python-1.36.0/messaging-api/api/toc-qpid.messaging.constants-module.html ---------------------------------------------------------------------- diff --git a/content/releases/qpid-python-1.36.0/messaging-api/api/toc-qpid.messaging.constants-module.html b/content/releases/qpid-python-1.36.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.36.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/55375a76/content/releases/qpid-python-1.36.0/messaging-api/api/toc-qpid.messaging.driver-module.html ---------------------------------------------------------------------- diff --git a/content/releases/qpid-python-1.36.0/messaging-api/api/toc-qpid.messaging.driver-module.html b/content/releases/qpid-python-1.36.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.36.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/55375a76/content/releases/qpid-python-1.36.0/messaging-api/api/toc-qpid.messaging.endpoints-module.html ---------------------------------------------------------------------- diff --git a/content/releases/qpid-python-1.36.0/messaging-api/api/toc-qpid.messaging.endpoints-module.html b/content/releases/qpid-python-1.36.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.36.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/55375a76/content/releases/qpid-python-1.36.0/messaging-api/api/toc-qpid.messaging.exceptions-module.html ---------------------------------------------------------------------- diff --git a/content/releases/qpid-python-1.36.0/messaging-api/api/toc-qpid.messaging.exceptions-module.html b/content/releases/qpid-python-1.36.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.36.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/55375a76/content/releases/qpid-python-1.36.0/messaging-api/api/toc-qpid.messaging.message-module.html ---------------------------------------------------------------------- diff --git a/content/releases/qpid-python-1.36.0/messaging-api/api/toc-qpid.messaging.message-module.html b/content/releases/qpid-python-1.36.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.36.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/55375a76/content/releases/qpid-python-1.36.0/messaging-api/api/toc-qpid.messaging.transports-module.html ---------------------------------------------------------------------- diff --git a/content/releases/qpid-python-1.36.0/messaging-api/api/toc-qpid.messaging.transports-module.html b/content/releases/qpid-python-1.36.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.36.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/55375a76/content/releases/qpid-python-1.36.0/messaging-api/api/toc-qpid.messaging.util-module.html ---------------------------------------------------------------------- diff --git a/content/releases/qpid-python-1.36.0/messaging-api/api/toc-qpid.messaging.util-module.html b/content/releases/qpid-python-1.36.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.36.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/55375a76/content/releases/qpid-python-1.36.0/messaging-api/api/toc.html ---------------------------------------------------------------------- diff --git a/content/releases/qpid-python-1.36.0/messaging-api/api/toc.html b/content/releases/qpid-python-1.36.0/messaging-api/api/toc.html new file mode 100755 index 0000000..4f6f84a --- /dev/null +++ b/content/releases/qpid-python-1.36.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/55375a76/content/releases/qpid-python-1.36.0/messaging-api/examples/drain ---------------------------------------------------------------------- diff --git a/content/releases/qpid-python-1.36.0/messaging-api/examples/drain b/content/releases/qpid-python-1.36.0/messaging-api/examples/drain new file mode 100755 index 0000000..5e30153 --- /dev/null +++ b/content/releases/qpid-python-1.36.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/55375a76/content/releases/qpid-python-1.36.0/messaging-api/examples/drain.html ---------------------------------------------------------------------- diff --git a/content/releases/qpid-python-1.36.0/messaging-api/examples/drain.html b/content/releases/qpid-python-1.36.0/messaging-api/examples/drain.html new file mode 100644 index 0000000..0ae7486 --- /dev/null +++ b/content/releases/qpid-python-1.36.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/java-broker/index.html">Broker for Java</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.36.0/index.html">Qpid Python 1.36.0</a></li><li><a href="/releases/qpid-python-1.36.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="nf">__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="nf">__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/55375a76/content/releases/qpid-python-1.36.0/messaging-api/examples/hello ---------------------------------------------------------------------- diff --git a/content/releases/qpid-python-1.36.0/messaging-api/examples/hello b/content/releases/qpid-python-1.36.0/messaging-api/examples/hello new file mode 100755 index 0000000..ad314da --- /dev/null +++ b/content/releases/qpid-python-1.36.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/55375a76/content/releases/qpid-python-1.36.0/messaging-api/examples/hello.html ---------------------------------------------------------------------- diff --git a/content/releases/qpid-python-1.36.0/messaging-api/examples/hello.html b/content/releases/qpid-python-1.36.0/messaging-api/examples/hello.html new file mode 100644 index 0000000..0ae53ea --- /dev/null +++ b/content/releases/qpid-python-1.36.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/java-broker/index.html">Broker for Java</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.36.0/index.html">Qpid Python 1.36.0</a></li><li><a href="/releases/qpid-python-1.36.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/55375a76/content/releases/qpid-python-1.36.0/messaging-api/examples/hello_xml ---------------------------------------------------------------------- diff --git a/content/releases/qpid-python-1.36.0/messaging-api/examples/hello_xml b/content/releases/qpid-python-1.36.0/messaging-api/examples/hello_xml new file mode 100755 index 0000000..ab567ec --- /dev/null +++ b/content/releases/qpid-python-1.36.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/55375a76/content/releases/qpid-python-1.36.0/messaging-api/examples/hello_xml.html ---------------------------------------------------------------------- diff --git a/content/releases/qpid-python-1.36.0/messaging-api/examples/hello_xml.html b/content/releases/qpid-python-1.36.0/messaging-api/examples/hello_xml.html new file mode 100644 index 0000000..0857025 --- /dev/null +++ b/content/releases/qpid-python-1.36.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/java-broker/index.html">Broker for Java</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.36.0/index.html">Qpid Python 1.36.0</a></li><li><a href="/releases/qpid-python-1.36.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/55375a76/content/releases/qpid-python-1.36.0/messaging-api/examples/index.html ---------------------------------------------------------------------- diff --git a/content/releases/qpid-python-1.36.0/messaging-api/examples/index.html b/content/releases/qpid-python-1.36.0/messaging-api/examples/index.html new file mode 100644 index 0000000..0aa3f66 --- /dev/null +++ b/content/releases/qpid-python-1.36.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/java-broker/index.html">Broker for Java</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.36.0/index.html">Qpid Python 1.36.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.36.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.36.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/55375a76/content/releases/qpid-python-1.36.0/messaging-api/examples/server ---------------------------------------------------------------------- diff --git a/content/releases/qpid-python-1.36.0/messaging-api/examples/server b/content/releases/qpid-python-1.36.0/messaging-api/examples/server new file mode 100755 index 0000000..78d812b --- /dev/null +++ b/content/releases/qpid-python-1.36.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: [email protected] For additional commands, e-mail: [email protected]
