diff --git a/src/reactive/dragent_handlers.py b/src/reactive/dragent_handlers.py
index 595cf3f..ae68451 100644
--- a/src/reactive/dragent_handlers.py
+++ b/src/reactive/dragent_handlers.py
@@ -52,7 +52,7 @@ def setup_amqp_req(amqp):
     """Use the amqp interface to request access to the amqp broker using our
     local configuration.
     """
-    amqp.request_access(username='dragent',
+    amqp.request_access(username='neutron',
                         vhost='openstack')
     dragent.assess_status()
 
diff --git a/unit_tests/test_dragent_handlers.py b/unit_tests/test_dragent_handlers.py
index 2604488..6d867da 100644
--- a/unit_tests/test_dragent_handlers.py
+++ b/unit_tests/test_dragent_handlers.py
@@ -150,7 +150,7 @@ class TestDRAgentHandlers(unittest.TestCase):
         amqp = mock.MagicMock()
         handlers.setup_amqp_req(amqp)
         amqp.request_access.assert_called_once_with(
-            username='dragent', vhost='openstack')
+            username='neutron', vhost='openstack')
 
     def test_render_configs(self):
         self.patch(handlers.dragent, 'render_configs')