diff --git a/README.md b/README.md index bd42476..b8f9ba4 100644 --- a/README.md +++ b/README.md @@ -56,7 +56,7 @@ The client supports two codecs to store the messages to the server: By default you should use `AMQP 1.0` codec: ```python amqp_message = AMQPMessage( - body="hello: {}".format(i), + body=bytes("hello: {}".format(i), "utf-8"), ) ``` @@ -287,7 +287,7 @@ This one: ```python for i in range(1_000_000): amqp_message = AMQPMessage( - body="hello: {}".format(i), + body=bytes("hello: {}".format(i), "utf-8"), ) # send is asynchronous await producer.send(stream=STREAM, message=amqp_message) diff --git a/pyproject.toml b/pyproject.toml index 6cf8b86..c94b4e8 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -1,6 +1,6 @@ [tool.poetry] name = "rstream" -version = "0.19.1" +version = "0.20.0" description = "A python client for RabbitMQ Streams" authors = ["George Fortunatov ", "Daniele Palaia "] readme = "README.md" diff --git a/rstream/__init__.py b/rstream/__init__.py index e9fbc5b..c8a221c 100644 --- a/rstream/__init__.py +++ b/rstream/__init__.py @@ -20,7 +20,6 @@ from .amqp import AMQPMessage, amqp_decoder # noqa: E402 from ._pyamqp.message import Properties # noqa: E402 -from ._pyamqp.message import Header # noqa: E402 from .compression import CompressionType # noqa: E402 from .constants import ( # noqa: E402 ConsumerOffsetSpecification, @@ -59,7 +58,6 @@ "RawMessage", "Producer", "Properties", - "Header", "OffsetType", "ConsumerOffsetSpecification", "ConfirmationStatus",