http://git-wip-us.apache.org/repos/asf/qpid-site/blob/55375a76/input/releases/qpid-python-1.36.0/messaging-api/api/toc-qpid.messaging.address-module.html ---------------------------------------------------------------------- diff --git a/input/releases/qpid-python-1.36.0/messaging-api/api/toc-qpid.messaging.address-module.html b/input/releases/qpid-python-1.36.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.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/input/releases/qpid-python-1.36.0/messaging-api/api/toc-qpid.messaging.constants-module.html ---------------------------------------------------------------------- diff --git a/input/releases/qpid-python-1.36.0/messaging-api/api/toc-qpid.messaging.constants-module.html b/input/releases/qpid-python-1.36.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.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/input/releases/qpid-python-1.36.0/messaging-api/api/toc-qpid.messaging.driver-module.html ---------------------------------------------------------------------- diff --git a/input/releases/qpid-python-1.36.0/messaging-api/api/toc-qpid.messaging.driver-module.html b/input/releases/qpid-python-1.36.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.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/input/releases/qpid-python-1.36.0/messaging-api/api/toc-qpid.messaging.endpoints-module.html ---------------------------------------------------------------------- diff --git a/input/releases/qpid-python-1.36.0/messaging-api/api/toc-qpid.messaging.endpoints-module.html b/input/releases/qpid-python-1.36.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.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/input/releases/qpid-python-1.36.0/messaging-api/api/toc-qpid.messaging.exceptions-module.html ---------------------------------------------------------------------- diff --git a/input/releases/qpid-python-1.36.0/messaging-api/api/toc-qpid.messaging.exceptions-module.html b/input/releases/qpid-python-1.36.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.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/input/releases/qpid-python-1.36.0/messaging-api/api/toc-qpid.messaging.message-module.html ---------------------------------------------------------------------- diff --git a/input/releases/qpid-python-1.36.0/messaging-api/api/toc-qpid.messaging.message-module.html b/input/releases/qpid-python-1.36.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.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/input/releases/qpid-python-1.36.0/messaging-api/api/toc-qpid.messaging.transports-module.html ---------------------------------------------------------------------- diff --git a/input/releases/qpid-python-1.36.0/messaging-api/api/toc-qpid.messaging.transports-module.html b/input/releases/qpid-python-1.36.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.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/input/releases/qpid-python-1.36.0/messaging-api/api/toc-qpid.messaging.util-module.html ---------------------------------------------------------------------- diff --git a/input/releases/qpid-python-1.36.0/messaging-api/api/toc-qpid.messaging.util-module.html b/input/releases/qpid-python-1.36.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.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/input/releases/qpid-python-1.36.0/messaging-api/api/toc.html ---------------------------------------------------------------------- diff --git a/input/releases/qpid-python-1.36.0/messaging-api/api/toc.html b/input/releases/qpid-python-1.36.0/messaging-api/api/toc.html new file mode 100644 index 0000000..4f6f84a --- /dev/null +++ b/input/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/input/releases/qpid-python-1.36.0/messaging-api/examples/drain ---------------------------------------------------------------------- diff --git a/input/releases/qpid-python-1.36.0/messaging-api/examples/drain b/input/releases/qpid-python-1.36.0/messaging-api/examples/drain new file mode 100755 index 0000000..5e30153 --- /dev/null +++ b/input/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/input/releases/qpid-python-1.36.0/messaging-api/examples/drain.html.in ---------------------------------------------------------------------- diff --git a/input/releases/qpid-python-1.36.0/messaging-api/examples/drain.html.in b/input/releases/qpid-python-1.36.0/messaging-api/examples/drain.html.in new file mode 100644 index 0000000..af91fcf --- /dev/null +++ b/input/releases/qpid-python-1.36.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="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> http://git-wip-us.apache.org/repos/asf/qpid-site/blob/55375a76/input/releases/qpid-python-1.36.0/messaging-api/examples/hello ---------------------------------------------------------------------- diff --git a/input/releases/qpid-python-1.36.0/messaging-api/examples/hello b/input/releases/qpid-python-1.36.0/messaging-api/examples/hello new file mode 100755 index 0000000..ad314da --- /dev/null +++ b/input/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/input/releases/qpid-python-1.36.0/messaging-api/examples/hello.html.in ---------------------------------------------------------------------- diff --git a/input/releases/qpid-python-1.36.0/messaging-api/examples/hello.html.in b/input/releases/qpid-python-1.36.0/messaging-api/examples/hello.html.in new file mode 100644 index 0000000..1295ce4 --- /dev/null +++ b/input/releases/qpid-python-1.36.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/55375a76/input/releases/qpid-python-1.36.0/messaging-api/examples/hello_xml ---------------------------------------------------------------------- diff --git a/input/releases/qpid-python-1.36.0/messaging-api/examples/hello_xml b/input/releases/qpid-python-1.36.0/messaging-api/examples/hello_xml new file mode 100755 index 0000000..ab567ec --- /dev/null +++ b/input/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/input/releases/qpid-python-1.36.0/messaging-api/examples/hello_xml.html.in ---------------------------------------------------------------------- diff --git a/input/releases/qpid-python-1.36.0/messaging-api/examples/hello_xml.html.in b/input/releases/qpid-python-1.36.0/messaging-api/examples/hello_xml.html.in new file mode 100644 index 0000000..16ac907 --- /dev/null +++ b/input/releases/qpid-python-1.36.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/55375a76/input/releases/qpid-python-1.36.0/messaging-api/examples/index.md ---------------------------------------------------------------------- diff --git a/input/releases/qpid-python-1.36.0/messaging-api/examples/index.md b/input/releases/qpid-python-1.36.0/messaging-api/examples/index.md new file mode 100644 index 0000000..c3f8639 --- /dev/null +++ b/input/releases/qpid-python-1.36.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.36.0) + - [Source location](https://git-wip-us.apache.org/repos/asf?p=qpid-python.git;a=tree;f=examples;hb=1.36.0) http://git-wip-us.apache.org/repos/asf/qpid-site/blob/55375a76/input/releases/qpid-python-1.36.0/messaging-api/examples/server ---------------------------------------------------------------------- diff --git a/input/releases/qpid-python-1.36.0/messaging-api/examples/server b/input/releases/qpid-python-1.36.0/messaging-api/examples/server new file mode 100755 index 0000000..78d812b --- /dev/null +++ b/input/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() http://git-wip-us.apache.org/repos/asf/qpid-site/blob/55375a76/input/releases/qpid-python-1.36.0/messaging-api/examples/server.html.in ---------------------------------------------------------------------- diff --git a/input/releases/qpid-python-1.36.0/messaging-api/examples/server.html.in b/input/releases/qpid-python-1.36.0/messaging-api/examples/server.html.in new file mode 100644 index 0000000..b9d9eed --- /dev/null +++ b/input/releases/qpid-python-1.36.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/55375a76/input/releases/qpid-python-1.36.0/messaging-api/examples/spout ---------------------------------------------------------------------- diff --git a/input/releases/qpid-python-1.36.0/messaging-api/examples/spout b/input/releases/qpid-python-1.36.0/messaging-api/examples/spout new file mode 100755 index 0000000..6584b85 --- /dev/null +++ b/input/releases/qpid-python-1.36.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-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org