5 files changed, 0 insertions, 444 deletions
diff --git a/python/examples/api/drain b/python/examples/api/drain
deleted file mode 100755
index 5e30153bc2..0000000000
--- a/python/examples/api/drain
+++ /dev/null
@@ -1,97 +0,0 @@
-#!/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()
diff --git a/python/examples/api/hello b/python/examples/api/hello
deleted file mode 100755
index ad314da19e..0000000000
--- a/python/examples/api/hello
+++ /dev/null
@@ -1,52 +0,0 @@
-#!/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()
diff --git a/python/examples/api/hello_xml b/python/examples/api/hello_xml
deleted file mode 100755
index ab567ec5dd..0000000000
--- a/python/examples/api/hello_xml
+++ /dev/null
@@ -1,77 +0,0 @@
-#!/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()
diff --git a/python/examples/api/server b/python/examples/api/server
deleted file mode 100755
index 3b9a3560da..0000000000
--- a/python/examples/api/server
+++ /dev/null
@@ -1,95 +0,0 @@
-#!/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 ReceiveError, e:
-  print e
-except KeyboardInterrupt:
-  pass
-
-conn.close()
diff --git a/python/examples/api/spout b/python/examples/api/spout
deleted file mode 100755
index c2dc4db380..0000000000
--- a/python/examples/api/spout
+++ /dev/null
@@ -1,123 +0,0 @@
-#!/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("-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
-
-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
-
-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)
-    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()