title: Kombu/Celery messaging
body: <p>I have a simple application that sends &amp; receives messages, kombu, and uses Celery to task the message. Kombu alon, I can receive the message properly. when I send "Hello", kombu receives "Hello". But when I added the task, what kombu receives is the task ID of the celery.</p>
  
  <p>My purpose for this project is so that I can schedule when to send and receive messages, hence Celery.</p>
  
  <p>What I would like to know is why is kombu receiving the task id instead of the sent message? I have searched and searched and have not found any related results on this matter. I am a beginner in using this applications and I would appreciate some help in fixing this matter.</p>
  
  <p>My codes:</p>
  
  <p>task.py</p>
  
  <pre><code>from celery import Celery
  
  app = Celery('tasks', broker='amqp://xx:xx@localhost/xx', backend='amqp://')
  
  @app.task(name='task.add')
  def add(x, y):
      return x+y
  </code></pre>
  
  <p>send.py</p>
  
  <pre><code>import kombu
  from task import add
  #declare connection with broker connection
  connection = kombu.Connection(hostname='xx',
                                userid='xx',
                                password='xx',
                                virtual_host='xx')
  
  connection.connect()
  if connection.connect() is False:
      print("not connected")
  else:
      print("connected")
  
  #checks if connection is okay
  
  
  #rabbitmq connection
  channel = connection.channel()
  
  #queue &amp; exchange for kombu
  exchange = kombu.Exchange('exchnge', type='direct')
  queue = kombu.Queue('kombu_queue', exchange, routing_key='queue1')
  
  #message here
  
  x = input ("Enter first name: ")
  y = input ("Enter last name: ")
  result= add.delay(x,y)
  print(result)
  
  
  
  #syntax used for sending messages to queue
  producer = kombu.Producer(channel, exchange)
  producer.publish(result,
                   exchange = exchange,
                   routing_key='queue1')
  
  print("Message sent: [x]")
  connection.release()
  </code></pre>
  
  <p>receive.py</p>
  
  <pre><code>import kombu
  
  #receive
  connection = kombu.Connection(hostname='xx',
                                userid='xx',
                                password='xx',
                                virtual_host='xx')
  connection.connect()
  
  channel = connection.channel()
  
  exchange = kombu.Exchange('exchnge', type='direct')
  queue = kombu.Queue('kombu_queue', exchange, routing_key='queue1')
  
  print("Waiting for messages...")
  def callback(body, message):
      print('Got message - %s' % body)
      message.ack()
  
  consumer = kombu.Consumer(channel,
                            queues=queue,
                            callbacks=[callback])
  consumer.consume()
  
  while True:
      connection.drain_events()
  </code></pre>
  
  <p>I am using:</p>
  
  <pre><code>Kombu 3.0.26
  Celery 3.1.18
  RabbitMQ as the broker
  </code></pre>
  
  <p>What I sent:</p>
  
  <pre><code>xxx
  yyy
  </code></pre>
  
  <p>What kombu receives:</p>
  
  <pre><code>Got message - d22880c9-b22c-48d8-bc96-5d839b224f2a
  </code></pre>