moved Pattern into driver

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@911807 13f79535-47bb-0310-9956-ffa450edef68

2 files changed, 15 insertions, 16 deletions

diff --git a/python/qpid/messaging/driver.py b/python/qpid/messaging/driver.py
index 9d58616804..a09686badd 100644
--- a/python/qpid/messaging/driver.py
+++ b/python/qpid/messaging/driver.py
@@ -28,7 +28,6 @@ from qpid.framing import OpEncoder, SegmentEncoder, FrameEncoder, \
     FrameDecoder, SegmentDecoder, OpDecoder
 from qpid.messaging import address
 from qpid.messaging.constants import UNLIMITED
-from qpid.messaging.endpoints import Pattern
 from qpid.messaging.exceptions import ConnectError
 from qpid.messaging.message import get_codec, Message
 from qpid.ops import *
@@ -64,6 +63,21 @@ DURABLE_DEFAULT=True
 
 # XXX
 
+class Pattern:
+  """
+  The pattern filter matches the supplied wildcard pattern against a
+  message subject.
+  """
+
+  def __init__(self, value):
+    self.value = value
+
+  # XXX: this should become part of the driver
+  def _bind(self, sst, exchange, queue):
+    from qpid.ops import ExchangeBind
+    sst.write_cmd(ExchangeBind(exchange=exchange, queue=queue,
+                               binding_key=self.value.replace("*", "#")))
+
 FILTER_DEFAULTS = {
   "topic": Pattern("*"),
   "amq.failover": Pattern("DUMMY")
diff --git a/python/qpid/messaging/endpoints.py b/python/qpid/messaging/endpoints.py
index 2337986ecb..596866de66 100644
--- a/python/qpid/messaging/endpoints.py
+++ b/python/qpid/messaging/endpoints.py
@@ -191,21 +191,6 @@ class Connection:
       ssn.close()
     self.disconnect()
 
-class Pattern:
-  """
-  The pattern filter matches the supplied wildcard pattern against a
-  message subject.
-  """
-
-  def __init__(self, value):
-    self.value = value
-
-  # XXX: this should become part of the driver
-  def _bind(self, sst, exchange, queue):
-    from qpid.ops import ExchangeBind
-    sst.write_cmd(ExchangeBind(exchange=exchange, queue=queue,
-                               binding_key=self.value.replace("*", "#")))
-
 class Session:
 
   """