Method
xclaim
(
self: SyncClientProtocol,
name: KeyT,
groupname: GroupT,
consumername: ConsumerT,
min_idle_time: int,
message_ids: Union[List[StreamIdT], Tuple[StreamIdT]],
idle: int | None = None,
time: int | None = None,
retrycount: int | None = None,
force: bool = False,
justid: bool = False,
)
Source from the content-addressed store, hash-verified
| 6999 | |
| 7000 | @overload |
| 7001 | def xclaim( |
| 7002 | self: SyncClientProtocol, |
| 7003 | name: KeyT, |
| 7004 | groupname: GroupT, |
| 7005 | consumername: ConsumerT, |
| 7006 | min_idle_time: int, |
| 7007 | message_ids: Union[List[StreamIdT], Tuple[StreamIdT]], |
| 7008 | idle: int | None = None, |
| 7009 | time: int | None = None, |
| 7010 | retrycount: int | None = None, |
| 7011 | force: bool = False, |
| 7012 | justid: bool = False, |
| 7013 | ) -> XClaimResponse: ... |
| 7014 | |
| 7015 | @overload |
| 7016 | def xclaim( |