Revision 9e19989d

b/snf-astakos-app/astakos/im/models.py
182 182 
        eventType = 'create' if not user.id else 'modify'
183 183 
        body = UserEvent(QUEUE_CLIENT_ID, user, eventType, {}).format()
184 184 
        conn = exchange_connect(QUEUE_CONNECTION)
185 
        parts = urlparse(exchange)
185 
        parts = urlparse(QUEUE_CONNECTION)
186 186 
        exchange = parts.path[1:]
187 187 
        routing_key = '%s.user' % exchange
188 188 
        exchange_send(conn, routing_key, body)

Also available in: Unified diff