diff --git a/publisher.py b/publisher.py index e5a0d9b..140dc80 100644 --- a/publisher.py +++ b/publisher.py @@ -1 +1,9 @@ #!/usr/bin/env python3 + +import redis +redis_client = redis.Redis(host='localhost', port=6379, db=0) + +for i in range(1000): + message = 'message: {}'.format(i) + redis_client.publish('testing', message) +