Configure RabbitMQ server

Configure RabbitMQ listener and RUN

Apply some code with input:

• body - message body decoded respectly to properties "content-type" and "content_encoding"
• properties - channel properties as content_type, content_encoding, priority, correlation_id, reply_to, expiration, message_id, timestamp, type, user_id, app_id, cluster_id
• env - environment object
• logger - for logging

logger.info(body)
if body.get('Data') and len(body.get('Data'))>0:
  for r in body.get('Data'):
    p=env['product.product'].search([('default_code','=',r['sku'])])
    if not p:
      env['product.product'].create({
          'name':r['name'],
          'default_code':r['sku'],
          'type':'product',
        })

Feel excited