diff --git a/manifests/init.pp b/manifests/init.pp
index 79dd319..4062d3a 100644
--- a/manifests/init.pp
+++ b/manifests/init.pp
@@ -35,6 +35,30 @@
 #   the catalogue/control plane data is kept. (boolean value)
 #   Default false
 #
+# [*queue_pipeline*]
+#   Pipeline to use for processing queue operations.
+#   This pipeline will be consumed before calling the storage driver's
+#   controller methods.
+#   Defaults to $::os_service_default.
+#
+# [*message_pipeline*]
+#   Pipeline to use for processing message operations.
+#   This pipeline will be consumed before calling the storage driver's
+#   controller methods.
+#   Defaults to $::os_service_default.
+#
+# [*claim_pipeline*]
+#   Pipeline to use for processing claim operations. This
+#   pipeline will be consumed before calling the storage driver's controller
+#   methods.
+#   Defaults to $::os_service_default.
+#
+# [*subscription_pipeline*]
+#   Pipeline to use for processing subscription
+#   operations. This pipeline will be consumed before calling the storage
+#   driver's controller methods.
+#   Defaults to $::os_service_default.
+#
 # [*unreliable*]
 #   Disable all reliability constraints. (boolean value)
 #   Default false
@@ -49,15 +73,19 @@
 #
 class zaqar(
   $admin_password,
-  $auth_uri          = 'http://localhost:5000/',
-  $identity_uri      = 'http://localhost:35357/',
-  $admin_user        = 'zaqar',
-  $admin_tenant_name = 'services',
-  $auth_strategy     = 'keystone',
-  $admin_mode        = $::os_service_default,
-  $unreliable        = $::os_service_default,
-  $pooling           = $::os_service_default,
-  $package_name      = $::zaqar::params::package_name,
+  $auth_uri                 = 'http://localhost:5000/',
+  $identity_uri             = 'http://localhost:35357/',
+  $admin_user               = 'zaqar',
+  $admin_tenant_name        = 'services',
+  $auth_strategy            = 'keystone',
+  $admin_mode               = $::os_service_default,
+  $unreliable               = $::os_service_default,
+  $pooling                  = $::os_service_default,
+  $queue_pipeline           = $::os_service_default,
+  $message_pipeline         = $::os_service_default,
+  $claim_pipeline           = $::os_service_default,
+  $subscription_pipeline    = $::os_service_default,
+  $package_name             = $::zaqar::params::package_name,
   $package_ensure    = 'present',
 ) inherits zaqar::params {
 
@@ -77,6 +105,10 @@ class zaqar(
     'DEFAULT/admin_mode'                   : value  => $admin_mode;
     'DEFAULT/unreliable'                   : value  => $unreliable;
     'DEFAULT/pooling'                      : value  => $pooling;
+    'storage/queue_pipeline'               : value  => $queue_pipeline;
+    'storage/message_pipeline'             : value  => $message_pipeline;
+    'storage/claim_pipeline'               : value  => $claim_pipeline;
+    'storage/subscription_pipeline'        : value  => $subscription_pipeline;
   }
 
 }
diff --git a/spec/classes/zaqar_init_spec.rb b/spec/classes/zaqar_init_spec.rb
index b1c88fa..107b4dd 100644
--- a/spec/classes/zaqar_init_spec.rb
+++ b/spec/classes/zaqar_init_spec.rb
@@ -48,7 +48,11 @@ describe 'zaqar' do
         req_params.merge!({
           :admin_mode  => true,
           :unreliable  => true,
-          :pooling  => true
+          :pooling  => true,
+          :queue_pipeline => 'zaqar_pipeline1',
+          :message_pipeline => 'zaqar_pipeline2',
+          :claim_pipeline => 'zaqar_pipeline3',
+          :subscription_pipeline => 'zaqar_pipeline4',
         })
       end
 
@@ -56,6 +60,10 @@ describe 'zaqar' do
         is_expected.to contain_zaqar_config('DEFAULT/admin_mode').with_value(true)
         is_expected.to contain_zaqar_config('DEFAULT/unreliable').with_value(true)
         is_expected.to contain_zaqar_config('DEFAULT/pooling').with_value(true)
+        is_expected.to contain_zaqar_config('storage/queue_pipeline').with_value('zaqar_pipeline1')
+        is_expected.to contain_zaqar_config('storage/message_pipeline').with_value('zaqar_pipeline2')
+        is_expected.to contain_zaqar_config('storage/claim_pipeline').with_value('zaqar_pipeline3')
+        is_expected.to contain_zaqar_config('storage/subscription_pipeline').with_value('zaqar_pipeline4')
       end
     end
   end