Skip to content

Commit 52f18ef

Browse files
committed
amqp msg
1 parent 7212809 commit 52f18ef

File tree

1 file changed

+13
-6
lines changed

1 file changed

+13
-6
lines changed

sdk/eventhub/azure-eventhub/azure/eventhub/amqp/_amqp_message.py

+13-6
Original file line numberDiff line numberDiff line change
@@ -170,10 +170,13 @@ def _from_amqp_message(self, message):
170170

171171
@property
172172
def body(self) -> Any:
173-
"""The body of the Message. The format may vary depending on the body type:
174-
For ~azure.eventhub.AmqpMessageBodyType.DATA, the body could be bytes or Iterable[bytes]
175-
For ~azure.eventhub.AmqpMessageBodyType.SEQUENCE, the body could be List or Iterable[List]
176-
For ~azure.eventhub.AmqpMessageBodyType.VALUE, the body could be any type.
173+
"""
174+
The body of the Message. The format may vary depending on the body type:
175+
176+
For AmqpMessageBodyType.DATA, the body could be bytes or Iterable[bytes].
177+
For AmqpMessageBodyType.SEQUENCE, the body could be List or Iterable[List].
178+
For AmqpMessageBodyType.VALUE, the body could be any type.
179+
177180
:rtype: Any
178181
"""
179182
if self._body_type == AmqpMessageBodyType.DATA: # pylint:disable=no-else-return
@@ -186,15 +189,18 @@ def body(self) -> Any:
186189

187190
@property
188191
def body_type(self) -> AmqpMessageBodyType:
189-
"""The body type of the underlying AMQP message.
190-
rtype: ~azure.eventhub.amqp.AmqpMessageBodyType
192+
"""
193+
The body type of the underlying AMQP message.
194+
195+
:rtype: ~azure.eventhub.amqp.AmqpMessageBodyType
191196
"""
192197
return self._body_type
193198

194199
@property
195200
def properties(self) -> Optional[AmqpMessageProperties]:
196201
"""
197202
Properties to add to the message.
203+
198204
:rtype: Optional[~azure.eventhub.amqp.AmqpMessageProperties]
199205
"""
200206
return self._properties
@@ -247,6 +253,7 @@ def delivery_annotations(self, value: Optional[Dict[Union[str, bytes], Any]]) ->
247253
def header(self) -> Optional[AmqpMessageHeader]:
248254
"""
249255
The message header.
256+
250257
:rtype: Optional[~azure.eventhub.amqp.AmqpMessageHeader]
251258
"""
252259
return self._header

0 commit comments

Comments
 (0)