MCPcopy Create free account
hub / github.com/apache/qpid-proton / settle

Method settle

python/proton/_utils.py:196–206  ·  view source on GitHub ↗

Settle the next message previously taken with :meth:`pop`. :param state: :type state:

(self, state: Optional[int] = None)

Source from the content-addressed store, hash-verified

194 return message
195
196 def settle(self, state: Optional[int] = None) -> None:
197 """
198 Settle the next message previously taken with :meth:`pop`.
199
200 :param state:
201 :type state:
202 """
203 delivery = self.unsettled.popleft()
204 if state:
205 delivery.update(state)
206 delivery.settle()
207
208
209class BlockingReceiver(BlockingLink):

Callers 15

sendMethod · 0.45
recvMethod · 0.45
acceptMethod · 0.45
_release_pendingMethod · 0.45
sendMethod · 0.45
settleMethod · 0.45
on_deliveryMethod · 0.45
test_dispositionMethod · 0.45
test_cleanupMethod · 0.45
_testBufferingOnCloseMethod · 0.45
testSettleCurrentMethod · 0.45

Calls 1

updateMethod · 0.45

Tested by 3

test_dispositionMethod · 0.36
test_cleanupMethod · 0.36