Skip to content

Commit

Permalink
fixing doc
Browse files Browse the repository at this point in the history
  • Loading branch information
DanielePalaia committed May 28, 2024
1 parent 4be9a95 commit 0490a38
Show file tree
Hide file tree
Showing 3 changed files with 3 additions and 5 deletions.
4 changes: 2 additions & 2 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -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"),
)
```

Expand Down Expand Up @@ -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)
Expand Down
2 changes: 1 addition & 1 deletion pyproject.toml
Original file line number Diff line number Diff line change
@@ -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 <[email protected]>", "Daniele Palaia <[email protected]>"]
readme = "README.md"
Expand Down
2 changes: 0 additions & 2 deletions rstream/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -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,
Expand Down Expand Up @@ -59,7 +58,6 @@
"RawMessage",
"Producer",
"Properties",
"Header",
"OffsetType",
"ConsumerOffsetSpecification",
"ConfirmationStatus",
Expand Down

0 comments on commit 0490a38

Please sign in to comment.