import pika, json

def send_notification(request , channel):
  try:
    data = json.loads(request.data)
    
    subject = data.get('subject')
    email = data.get('email')
    mail_message = data.get('mail_message')
    message = {
        "mail_message": mail_message,
        "email": email,
        "subject": subject
    }
    channel.basic_publish(
      exchange="",
      routing_key="notifications",
      body= json.dumps(message),
      properties=pika.BasicProperties(
        delivery_mode=pika.spec.PERSISTENT_DELIVERY_MODE
      ),
    )
    return "success"
  except Exception as err:
    print(err)
    return f"error in translating this text, {err}"