From 030005a8f9f0342c8821e4bf77d2f2103ec8c13b Mon Sep 17 00:00:00 2001
From: Eric D Helms <ericdhelms@gmail.com>
Date: Fri, 24 Mar 2017 10:56:18 -0400
Subject: [PATCH] Switch to using qpid bind

---
 manifests/params.pp | 1 +
 manifests/qpid.pp   | 8 +++++---
 2 files changed, 6 insertions(+), 3 deletions(-)

diff --git a/manifests/params.pp b/manifests/params.pp
index 12df03be..00feb410 100644
--- a/manifests/params.pp
+++ b/manifests/params.pp
@@ -63,5 +63,6 @@
 
   $qpid_url = 'amqp:ssl:localhost:5671'
   $candlepin_event_queue = 'katello_event_queue'
+  $candlepin_qpid_exchange = 'event'
   $enable_ostree = false
 }
diff --git a/manifests/qpid.pp b/manifests/qpid.pp
index f3d0c850..7af86f57 100644
--- a/manifests/qpid.pp
+++ b/manifests/qpid.pp
@@ -2,8 +2,9 @@
 class katello::qpid (
   $client_cert,
   $client_key,
-  $katello_user          = $::katello::user,
-  $candlepin_event_queue = $::katello::candlepin_event_queue,
+  $katello_user            = $::katello::user,
+  $candlepin_event_queue   = $::katello::candlepin_event_queue,
+  $candlepin_qpid_exchange = $::katello::candlepin_qpid_exchange,
 ){
   if $katello_user == undef {
     fail('katello_user not defined')
@@ -25,8 +26,9 @@
     require   => Service['qpidd'],
     logoutput => true,
   } ~>
-  qpid::bind_event { ['entitlement.created', 'entitlement.deleted', 'pool.created', 'pool.deleted', 'compliance.created']:
+  qpid::config::bind { ['entitlement.created', 'entitlement.deleted', 'pool.created', 'pool.deleted', 'compliance.created']:
     ssl_cert => $client_cert,
     queue    => $candlepin_event_queue,
+    exchange => $candlepin_qpid_exchange,
   }
 }