4242)
4343from ..._wrappers import ResultWrapper
4444from ...pagination import SyncSinglePage , AsyncSinglePage
45+ from .subscriptions import (
46+ SubscriptionsResource ,
47+ AsyncSubscriptionsResource ,
48+ SubscriptionsResourceWithRawResponse ,
49+ AsyncSubscriptionsResourceWithRawResponse ,
50+ SubscriptionsResourceWithStreamingResponse ,
51+ AsyncSubscriptionsResourceWithStreamingResponse ,
52+ )
4553from ..._base_client import AsyncPaginator , make_request_options
4654from ...types .queues import queue_edit_params , queue_create_params , queue_update_params
4755from ...types .queues .queue import Queue
5159
5260
5361class QueuesResource (SyncAPIResource ):
54- @cached_property
55- def consumers (self ) -> ConsumersResource :
56- return ConsumersResource (self ._client )
57-
5862 @cached_property
5963 def messages (self ) -> MessagesResource :
6064 return MessagesResource (self ._client )
@@ -63,6 +67,14 @@ def messages(self) -> MessagesResource:
6367 def purge (self ) -> PurgeResource :
6468 return PurgeResource (self ._client )
6569
70+ @cached_property
71+ def consumers (self ) -> ConsumersResource :
72+ return ConsumersResource (self ._client )
73+
74+ @cached_property
75+ def subscriptions (self ) -> SubscriptionsResource :
76+ return SubscriptionsResource (self ._client )
77+
6678 @cached_property
6779 def with_raw_response (self ) -> QueuesResourceWithRawResponse :
6880 """
@@ -354,10 +366,6 @@ def get(
354366
355367
356368class AsyncQueuesResource (AsyncAPIResource ):
357- @cached_property
358- def consumers (self ) -> AsyncConsumersResource :
359- return AsyncConsumersResource (self ._client )
360-
361369 @cached_property
362370 def messages (self ) -> AsyncMessagesResource :
363371 return AsyncMessagesResource (self ._client )
@@ -366,6 +374,14 @@ def messages(self) -> AsyncMessagesResource:
366374 def purge (self ) -> AsyncPurgeResource :
367375 return AsyncPurgeResource (self ._client )
368376
377+ @cached_property
378+ def consumers (self ) -> AsyncConsumersResource :
379+ return AsyncConsumersResource (self ._client )
380+
381+ @cached_property
382+ def subscriptions (self ) -> AsyncSubscriptionsResource :
383+ return AsyncSubscriptionsResource (self ._client )
384+
369385 @cached_property
370386 def with_raw_response (self ) -> AsyncQueuesResourceWithRawResponse :
371387 """
@@ -679,10 +695,6 @@ def __init__(self, queues: QueuesResource) -> None:
679695 queues .get ,
680696 )
681697
682- @cached_property
683- def consumers (self ) -> ConsumersResourceWithRawResponse :
684- return ConsumersResourceWithRawResponse (self ._queues .consumers )
685-
686698 @cached_property
687699 def messages (self ) -> MessagesResourceWithRawResponse :
688700 return MessagesResourceWithRawResponse (self ._queues .messages )
@@ -691,6 +703,14 @@ def messages(self) -> MessagesResourceWithRawResponse:
691703 def purge (self ) -> PurgeResourceWithRawResponse :
692704 return PurgeResourceWithRawResponse (self ._queues .purge )
693705
706+ @cached_property
707+ def consumers (self ) -> ConsumersResourceWithRawResponse :
708+ return ConsumersResourceWithRawResponse (self ._queues .consumers )
709+
710+ @cached_property
711+ def subscriptions (self ) -> SubscriptionsResourceWithRawResponse :
712+ return SubscriptionsResourceWithRawResponse (self ._queues .subscriptions )
713+
694714
695715class AsyncQueuesResourceWithRawResponse :
696716 def __init__ (self , queues : AsyncQueuesResource ) -> None :
@@ -715,10 +735,6 @@ def __init__(self, queues: AsyncQueuesResource) -> None:
715735 queues .get ,
716736 )
717737
718- @cached_property
719- def consumers (self ) -> AsyncConsumersResourceWithRawResponse :
720- return AsyncConsumersResourceWithRawResponse (self ._queues .consumers )
721-
722738 @cached_property
723739 def messages (self ) -> AsyncMessagesResourceWithRawResponse :
724740 return AsyncMessagesResourceWithRawResponse (self ._queues .messages )
@@ -727,6 +743,14 @@ def messages(self) -> AsyncMessagesResourceWithRawResponse:
727743 def purge (self ) -> AsyncPurgeResourceWithRawResponse :
728744 return AsyncPurgeResourceWithRawResponse (self ._queues .purge )
729745
746+ @cached_property
747+ def consumers (self ) -> AsyncConsumersResourceWithRawResponse :
748+ return AsyncConsumersResourceWithRawResponse (self ._queues .consumers )
749+
750+ @cached_property
751+ def subscriptions (self ) -> AsyncSubscriptionsResourceWithRawResponse :
752+ return AsyncSubscriptionsResourceWithRawResponse (self ._queues .subscriptions )
753+
730754
731755class QueuesResourceWithStreamingResponse :
732756 def __init__ (self , queues : QueuesResource ) -> None :
@@ -751,10 +775,6 @@ def __init__(self, queues: QueuesResource) -> None:
751775 queues .get ,
752776 )
753777
754- @cached_property
755- def consumers (self ) -> ConsumersResourceWithStreamingResponse :
756- return ConsumersResourceWithStreamingResponse (self ._queues .consumers )
757-
758778 @cached_property
759779 def messages (self ) -> MessagesResourceWithStreamingResponse :
760780 return MessagesResourceWithStreamingResponse (self ._queues .messages )
@@ -763,6 +783,14 @@ def messages(self) -> MessagesResourceWithStreamingResponse:
763783 def purge (self ) -> PurgeResourceWithStreamingResponse :
764784 return PurgeResourceWithStreamingResponse (self ._queues .purge )
765785
786+ @cached_property
787+ def consumers (self ) -> ConsumersResourceWithStreamingResponse :
788+ return ConsumersResourceWithStreamingResponse (self ._queues .consumers )
789+
790+ @cached_property
791+ def subscriptions (self ) -> SubscriptionsResourceWithStreamingResponse :
792+ return SubscriptionsResourceWithStreamingResponse (self ._queues .subscriptions )
793+
766794
767795class AsyncQueuesResourceWithStreamingResponse :
768796 def __init__ (self , queues : AsyncQueuesResource ) -> None :
@@ -787,14 +815,18 @@ def __init__(self, queues: AsyncQueuesResource) -> None:
787815 queues .get ,
788816 )
789817
790- @cached_property
791- def consumers (self ) -> AsyncConsumersResourceWithStreamingResponse :
792- return AsyncConsumersResourceWithStreamingResponse (self ._queues .consumers )
793-
794818 @cached_property
795819 def messages (self ) -> AsyncMessagesResourceWithStreamingResponse :
796820 return AsyncMessagesResourceWithStreamingResponse (self ._queues .messages )
797821
798822 @cached_property
799823 def purge (self ) -> AsyncPurgeResourceWithStreamingResponse :
800824 return AsyncPurgeResourceWithStreamingResponse (self ._queues .purge )
825+
826+ @cached_property
827+ def consumers (self ) -> AsyncConsumersResourceWithStreamingResponse :
828+ return AsyncConsumersResourceWithStreamingResponse (self ._queues .consumers )
829+
830+ @cached_property
831+ def subscriptions (self ) -> AsyncSubscriptionsResourceWithStreamingResponse :
832+ return AsyncSubscriptionsResourceWithStreamingResponse (self ._queues .subscriptions )
0 commit comments