1717T = TypeVar ('T' )
1818ClsType = Optional [Callable [[PipelineResponse [HttpRequest , AsyncHttpResponse ], T , Dict [str , Any ]], Any ]]
1919
20- class QueueOperations :
21- """QueueOperations async operations.
20+ class EntityOperations :
21+ """EntityOperations async operations.
2222
2323 You should not instantiate this class directly. Instead, you should create a Client instance that
2424 instantiates it for you and attaches it as an attribute.
@@ -41,17 +41,17 @@ def __init__(self, client, config, serializer, deserializer) -> None:
4141
4242 async def get (
4343 self ,
44- queue_name : str ,
44+ entity_name : str ,
4545 enrich : Optional [bool ] = False ,
4646 api_version : Optional [str ] = "2017_04" ,
4747 ** kwargs
4848 ) -> object :
49- """Get the details about the Queue with the given queueName .
49+ """Get the details about the Queue or Topic with the given entityName .
5050
51- Get Queue.
51+ Get Queue or Topic .
5252
53- :param queue_name : The name of the queue relative to the Service Bus namespace.
54- :type queue_name : str
53+ :param entity_name : The name of the queue or topic relative to the Service Bus namespace.
54+ :type entity_name : str
5555 :param enrich: A query parameter that sets enrich to true or false.
5656 :type enrich: bool
5757 :param api_version: Api Version.
@@ -69,7 +69,7 @@ async def get(
6969 url = self .get .metadata ['url' ] # type: ignore
7070 path_format_arguments = {
7171 'endpoint' : self ._serialize .url ("self._config.endpoint" , self ._config .endpoint , 'str' , skip_quote = True ),
72- 'queueName ' : self ._serialize .url ("queue_name " , queue_name , 'str' , min_length = 1 ),
72+ 'entityName ' : self ._serialize .url ("entity_name " , entity_name , 'str' , min_length = 1 ),
7373 }
7474 url = self ._client .format_url (url , ** path_format_arguments )
7575
@@ -100,21 +100,21 @@ async def get(
100100 return cls (pipeline_response , deserialized , {})
101101
102102 return deserialized
103- get .metadata = {'url' : '/{queueName }' } # type: ignore
103+ get .metadata = {'url' : '/{entityName }' } # type: ignore
104104
105105 async def put (
106106 self ,
107- queue_name : str ,
107+ entity_name : str ,
108108 request_body : object ,
109109 api_version : Optional [str ] = "2017_04" ,
110110 if_match : Optional [str ] = None ,
111111 ** kwargs
112112 ) -> object :
113- """Create or update a queue at the provided queuePath .
113+ """Create or update a queue or topic at the provided entityName .
114114
115- :param queue_name : The name of the queue relative to the Service Bus namespace.
116- :type queue_name : str
117- :param request_body: Parameters required to make or edit a queue.
115+ :param entity_name : The name of the queue or topic relative to the Service Bus namespace.
116+ :type entity_name : str
117+ :param request_body: Parameters required to make or edit a queue or topic .
118118 :type request_body: object
119119 :param api_version: Api Version.
120120 :type api_version: str
@@ -131,13 +131,13 @@ async def put(
131131 cls = kwargs .pop ('cls' , None ) # type: ClsType[object]
132132 error_map = {404 : ResourceNotFoundError , 409 : ResourceExistsError }
133133 error_map .update (kwargs .pop ('error_map' , {}))
134- content_type = kwargs .pop ("content_type" , "application/xml" )
134+ content_type = kwargs .pop ("content_type" , "application/atom+ xml" )
135135
136136 # Construct URL
137137 url = self .put .metadata ['url' ] # type: ignore
138138 path_format_arguments = {
139139 'endpoint' : self ._serialize .url ("self._config.endpoint" , self ._config .endpoint , 'str' , skip_quote = True ),
140- 'queueName ' : self ._serialize .url ("queue_name " , queue_name , 'str' , min_length = 1 ),
140+ 'entityName ' : self ._serialize .url ("entity_name " , entity_name , 'str' , min_length = 1 ),
141141 }
142142 url = self ._client .format_url (url , ** path_format_arguments )
143143
@@ -178,20 +178,20 @@ async def put(
178178 return cls (pipeline_response , deserialized , {})
179179
180180 return deserialized
181- put .metadata = {'url' : '/{queueName }' } # type: ignore
181+ put .metadata = {'url' : '/{entityName }' } # type: ignore
182182
183183 async def delete (
184184 self ,
185- queue_name : str ,
185+ entity_name : str ,
186186 api_version : Optional [str ] = "2017_04" ,
187187 ** kwargs
188188 ) -> object :
189- """Delete the Queue with the given queueName .
189+ """Delete the Queue or Topic with the given entityName .
190190
191- Delete Queue.
191+ Delete Queue or Topic .
192192
193- :param queue_name : The name of the queue relative to the Service Bus namespace.
194- :type queue_name : str
193+ :param entity_name : The name of the queue or topic relative to the Service Bus namespace.
194+ :type entity_name : str
195195 :param api_version: Api Version.
196196 :type api_version: str
197197 :keyword callable cls: A custom type or function that will be passed the direct response
@@ -207,7 +207,7 @@ async def delete(
207207 url = self .delete .metadata ['url' ] # type: ignore
208208 path_format_arguments = {
209209 'endpoint' : self ._serialize .url ("self._config.endpoint" , self ._config .endpoint , 'str' , skip_quote = True ),
210- 'queueName ' : self ._serialize .url ("queue_name " , queue_name , 'str' , min_length = 1 ),
210+ 'entityName ' : self ._serialize .url ("entity_name " , entity_name , 'str' , min_length = 1 ),
211211 }
212212 url = self ._client .format_url (url , ** path_format_arguments )
213213
@@ -236,4 +236,4 @@ async def delete(
236236 return cls (pipeline_response , deserialized , {})
237237
238238 return deserialized
239- delete .metadata = {'url' : '/{queueName }' } # type: ignore
239+ delete .metadata = {'url' : '/{entityName }' } # type: ignore
0 commit comments