Switch to using qpid bind

theforeman · Mar 24, 2017 · 030005a · 030005a
1 parent ba8aae6
commit 030005a
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 3 deletions.
diff --git 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
@@ -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,
   }
 }