code: def publish(self, message, key=None, **kws):
          
          return PSPut(self, message, key, **kws)
docs: Put a message in the queue and updates any coroutine wating with
          fetch. *works as a coroutine operation*