taraqueue

• taraqueue package
  • Subpackages
    • taraqueue.testing package
      • Submodules
      • taraqueue.testing.compose module
      • taraqueue.testing.queue module
      • taraqueue.testing.services module
      • Module contents
  • Submodules
  • taraqueue.memory module
    • MemoryQueue
      • MemoryQueue.from_url()
      • MemoryQueue.publish()
      • MemoryQueue.queues
      • MemoryQueue.receive()
      • MemoryQueue.subscribe()
      • MemoryQueue.topics
      • MemoryQueue.unsubscribe()
  • taraqueue.redis module
    • RedisQueue
      • RedisQueue.client
      • RedisQueue.from_env()
      • RedisQueue.from_host()
      • RedisQueue.from_url()
      • RedisQueue.publish()
      • RedisQueue.pubsub
      • RedisQueue.receive()
      • RedisQueue.subscribe()
      • RedisQueue.unsubscribe()
  • taraqueue.registry module
    • get_entry_points()
    • registry_add()
    • registry_get()
    • registry_load()
    • registry_remove()
  • Module contents
    • Queue
      • Queue.connect()
      • Queue.from_url()
      • Queue.publish()
      • Queue.receive()
      • Queue.subscribe()
      • Queue.unsubscribe()
    • QueueEmpty