Duplicated messages in agent's fanout topic
Affects | Status | Importance | Assigned to | Milestone | |
---|---|---|---|---|---|
neutron |
Fix Released
|
Undecided
|
Ilya Shakhat | ||
Juno |
Fix Released
|
Undecided
|
Unassigned |
Bug Description
Steps to reproduce on devstack:
1. Create the router:
neutron router-create test
2. Set gateway for the router:
neutron router-gateway-set test public
3. Delete the router:
neutron router-delete test
The notification about router deletion arrives into L3 agent twice:
2015-01-21 10:53:48.401 DEBUG neutron.
8 from (pid=8310) router_deleted /opt/stack/
2015-01-21 10:53:48.402 DEBUG neutron.
8 from (pid=8310) router_deleted /opt/stack/
Notifications are processed sequentially, the first successfully removes the router, while the second results in warning:
2015-01-21 10:53:50.957 WARNING neutron.
Changed in neutron: | |
assignee: | nobody → Ilya Shakhat (shakhat) |
Changed in neutron: | |
milestone: | none → kilo-2 |
status: | Fix Committed → Fix Released |
Changed in neutron: | |
milestone: | kilo-2 → 2015.1.0 |
The fanout consumer is registered twice in agent: /github. com/openstack/ neutron/ blob/master/ neutron/ common/ rpc.py# L161-L167) /github. com/openstack/ oslo.messaging/ blob/master/ oslo_messaging/ _drivers/ amqpdriver. py#L428- L435)
1. In neutron/common/rpc (https:/
and
2. In oslo.messaging amqp driver (https:/
List of bindings: ubuntu- ilya:~$ ./rabbitmqadmin -u guest -p <secure> list bindings | grep l3_agent_fanout fanout_ 7e72c061792a443 cb5c83d72c014dc 2f | l3_agent_ fanout_ 7e72c061792a443 cb5c83d72c014dc 2f | fanout_ d03753e6a73e40e 48dc6bd99c5cbfd 75 | l3_agent_ fanout_ d03753e6a73e40e 48dc6bd99c5cbfd 75 | fanout_ 7e72c061792a443 cb5c83d72c014dc 2f | l3_agent | fanout_ d03753e6a73e40e 48dc6bd99c5cbfd 75 | l3_agent |
developer@
| | l3_agent_
| | l3_agent_
| l3_agent_fanout | l3_agent_
| l3_agent_fanout | l3_agent_
Also the initialization creates topic with double node suffix, e.g. l3_agent. ubuntu- ilya.ubuntu- ilya, not harmful, but useless.