

class Consumer(object):
    queue = None
    def consume(self, message):
        raise NotImplementedError


class Consumer(object):
    """ A message consumer """
    topic = None

    def consume(self, message):
        raise NotImplementedError

Update our message Consumer api to consume a `topic`, not a `queue`.
Update our message Consumer api to consume a `topic`, not a `queue`.

- 
  
  class Consumer(object):
-     queue = None
+     """ A message consumer """
+     topic = None
+ 
      def consume(self, message):
          raise NotImplementedError
  
Update our message Consumer api to consume a `topic`, not a `queue`.
## Code Before:


class Consumer(object):
    queue = None
    def consume(self, message):
        raise NotImplementedError

## Instruction:
Update our message Consumer api to consume a `topic`, not a `queue`.
## Code After:

class Consumer(object):
    """ A message consumer """
    topic = None

    def consume(self, message):
        raise NotImplementedError
