old_contents: #!/usr/bin/env python
  import pika
  import sys
  
  connection = pika.BlockingConnection(pika.ConnectionParameters(
          host='localhost'))
  channel = connection.channel()
  
  channel.exchange_declare(exchange='direct_logs',
                           exchange_type='direct')
  
  severity = sys.argv[1] if len(sys.argv) > 1 else 'info'
  message = ' '.join(sys.argv[2:]) or 'Hello World!'
  channel.basic_publish(exchange='direct_logs',
                        routing_key=severity,
                        body=message)
  print(" [x] Sent %r:%r" % (severity, message))
  connection.close()
  
new_contents: #!/usr/bin/env python
  import pika
  import sys
  
  connection = pika.BlockingConnection(pika.ConnectionParameters(
          host='localhost'))
  channel = connection.channel()
  
  channel.exchange_declare(exchange='direct_logs',
                           exchange_type='direct')
  
  severity = sys.argv[1] if len(sys.argv) > 2 else 'info'
  message = ' '.join(sys.argv[2:]) or 'Hello World!'
  channel.basic_publish(exchange='direct_logs',
                        routing_key=severity,
                        body=message)
  print(" [x] Sent %r:%r" % (severity, message))
  connection.close()
  
subject: Correct Emit Log Direct