diff --git a/defaults/main.yml b/defaults/main.yml
index 46423126..df4fd167 100644
--- a/defaults/main.yml
+++ b/defaults/main.yml
@@ -79,6 +79,10 @@ ceilometer_oslomsg_notify_userid: ceilometer
 ceilometer_oslomsg_notify_vhost: /ceilometer
 ceilometer_oslomsg_notify_host_group: "{{ oslomsg_notify_host_group | default('rabbitmq_all') }}"
 
+## (Qdrouterd) info
+# TODO(ansmith): Change structure when more backends will be supported
+ceilometer_oslomsg_amqp1_enabled: "{{ ceilometer_oslomsg_rpc_transport == 'amqp' }}"
+
 #Ceilometer services info
 ceilometer_role_name: admin
 
@@ -139,6 +143,9 @@ ceilometer_pip_packages:
   - tooz
   - warlock
 
+ceilometer_optional_oslomsg_amqp1_pip_packages:
+  - oslo.messaging[amqp1]
+
 ceilometer_agent_init_overrides: {}
 ceilometer_polling_init_overrides: {}
 
diff --git a/tasks/ceilometer_install_source.yml b/tasks/ceilometer_install_source.yml
index eda7f688..8b7c9af5 100644
--- a/tasks/ceilometer_install_source.yml
+++ b/tasks/ceilometer_install_source.yml
@@ -105,6 +105,19 @@
   tags:
     - skip_ansible_lint
 
+- name: Install optional pip packages
+  pip:
+    name: "{{ ceilometer_optional_oslomsg_amqp1_pip_packages }}"
+    state: "{{ ceilometer_pip_package_state }}"
+    virtualenv: "{{ ceilometer_bin | dirname }}"
+    virtualenv_site_packages: "no"
+  when: ceilometer_oslomsg_amqp1_enabled
+  register: install_optional_packages
+  until: install_optional_packages is success
+  retries: 5
+  delay: 2
+  notify: Restart ceilometer services
+
 - name: Record the venv tag deployed
   ini_file:
     dest: "/etc/ansible/facts.d/openstack_ansible.fact"