Revision 809b6d11 snf-astakos-app/astakos/im/models.py
b/snf-astakos-app/astakos/im/models.py | ||
---|---|---|
171 | 171 |
eventType = 'create' if not user.id else 'modify' |
172 | 172 |
body = UserEvent(QUEUE_CLIENT_ID, user, eventType, {}).format() |
173 | 173 |
conn = exchange_connect(QUEUE_CONNECTION) |
174 |
routing_key = QUEUE_CONNECTION.replace('*', 'user')
|
|
174 |
routing_key = '%s.user' % QUEUE_CONNECTION
|
|
175 | 175 |
exchange_send(conn, routing_key, body) |
176 | 176 |
exchange_close(conn) |
Also available in: Unified diff