diff --git a/deployment/logging/rsyslog-container-puppet.yaml b/deployment/logging/rsyslog-container-puppet.yaml
index baf554073d..f3c41e01c8 100644
--- a/deployment/logging/rsyslog-container-puppet.yaml
+++ b/deployment/logging/rsyslog-container-puppet.yaml
@@ -58,6 +58,10 @@ parameters:
     type: string
     default: 'regionOne'
     description: Keystone region for endpoint
+  RsyslogAmqp1Setting:
+    default: {}
+    description: Configuration for rsyslog-omamqp1 plugin
+    type: json
 
 resources:
   ContainersCommon:
@@ -67,9 +71,17 @@ conditions:
   use_tls:
     not:
       and:
+        - equals: [{get_param: RsyslogElasticsearchSetting}, {}]
         - equals: [{get_param: RsyslogElasticsearchTlsCACert}, '']
         - equals: [{get_param: RsyslogElasticsearchTlsClientCert}, '']
         - equals: [{get_param: RsyslogElasticsearchTlsClientKey}, '']
+  use_elasticsearch:
+    not:
+      equals: [{get_param: RsyslogElasticsearchSetting}, {}]
+  use_amqp1:
+    not:
+      equals: [{get_param: RsyslogAmqp1Setting}, {}]
+
 
 outputs:
   role_data:
@@ -113,6 +125,7 @@ outputs:
             rsyslog::server::modules:
               imfile: {}
               omelasticsearch: {}
+              omamqp1: {}
             # output setting
             rsyslog::server::templates:
               rsyslog-node-index:
@@ -179,14 +192,23 @@ outputs:
                     outname: region
                     value: {get_param: KeystoneRegion}
                     format: jsonf
-
-            tripleo::profile::base::logging::rsyslog::elasticsearch:
-              map_merge:
-                - {get_param: RsyslogElasticsearchSetting}
-                - template: rsyslog-record
-                  searchIndex: rsyslog-node-index
-                  dynSearchIndex: "on"
-                  errorfile: '/var/log/rsyslog/omelasticsearch.log'
+          - if:
+            - use_elasticsearch
+            - tripleo::profile::base::logging::rsyslog::elasticsearch:
+                map_merge:
+                  - {get_param: RsyslogElasticsearchSetting}
+                  - template: rsyslog-record
+                    searchIndex: rsyslog-node-index
+                    dynSearchIndex: "on"
+                    errorfile: '/var/log/rsyslog/omelasticsearch.log'
+            - {}
+          - if:
+            - use_amqp1
+            - tripleo::profile::base::logging::rsyslog::amqp1:
+                map_merge:
+                  - {get_param: RsyslogAmqp1Setting}
+                  - template: rsyslog-record
+            - {}
           - if:
             - use_tls
             - tripleo::profile::base::logging::rsyslog::elasticsearch_tls_ca_cert: {get_param: RsyslogElasticsearchTlsCACert}