Merge pull request #5 from Humbedooh/master
Merge 7.2 from upstream
diff --git a/CHANGELOG.md b/CHANGELOG.md
index bd0c1a9..666db83 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -1,5 +1,8 @@
+# 0.7.2
+- Addessed an issue with SQS not updating in real-time, only when backlog is requested.
+
# 0.7.1
-- Use asyncio queues for moifying the list of events pending publishing to avoid potential race conditions.
+- Use asyncio queues for modifying the list of events pending publishing to avoid potential race conditions.
- Minor tweak to the handling of backlog size
- Improved type checks
- Updated client examples
diff --git a/README.md b/README.md
index cc6f6f4..bcfd183 100644
--- a/README.md
+++ b/README.md
@@ -33,9 +33,9 @@
## Installing
- Download or clone this repository: `git clone https://github.com/Humbedooh/pypubsub.git`
-- Install dependencies: `pip3 install -r requirements.txt`
+- Install dependencies using [pipenv](https://github.com/pypa/pipenv): `pipenv --three install -r requirements.txt`
- Edit `pypubsub.yaml` and (for ACL) `pypubsub_acl.yaml` to fit your needs
-- Launch the program in the foreground or as a systemd service: `python3 pypubsub.py`
+- Launch the program in the foreground or as a systemd service: `pipenv run python3 pypubsub.py`
- Check that your pubsub service is working: `curl -I http://localhost:2069`
## Topics and publishing/subscribing
diff --git a/plugins/sqs.py b/plugins/sqs.py
index de065e2..c34b9ab 100644
--- a/plugins/sqs.py
+++ b/plugins/sqs.py
@@ -66,7 +66,7 @@
js = json.loads(body)
path = js.get('pubsub_path', '/') # Default to catch-all pubsub topic
payload = pypubsub.Payload(path, js)
- server.pending_events.put(payload)
+ server.pending_events.put_nowait(payload)
backlog_size = server.config.backlog.queue_size
if backlog_size > 0:
server.backlog.append(payload)
diff --git a/pypubsub.py b/pypubsub.py
index 610838f..9f63562 100644
--- a/pypubsub.py
+++ b/pypubsub.py
@@ -34,7 +34,7 @@
import typing
# Some consts
-PUBSUB_VERSION = '0.7.1'
+PUBSUB_VERSION = '0.7.2'
PUBSUB_CONTENT_TYPE = 'application/vnd.pypubsub-stream'
PUBSUB_DEFAULT_PORT = 2069
PUBSUB_DEFAULT_IP = '0.0.0.0'
diff --git a/requirements.txt b/requirements.txt
index ac058bc..8523d31 100644
--- a/requirements.txt
+++ b/requirements.txt
@@ -4,5 +4,5 @@
python-ldap>=3.0.0
PyYAML~=5.1.2
aiobotocore~=1.0.7
-botocore~=1.5.32
+botocore~=1.15.32
aiofile~=1.5.2
