DataFlex
DataFlex
Azure Service Bus - Create Queue
See more Azure Service Bus Examples
Creates an Azure Service Bus Queue.Note: This example requires Chilkat v9.5.0.65 or greater.
Chilkat DataFlex Downloads
Use ChilkatAx-win32.pkg
Procedure Test
Boolean iSuccess
Handle hoRest
Boolean iBAutoReconnect
Handle hoSbToken
String sQueueName
Handle hoXml
Variant vSbRequestBody
Handle hoSbRequestBody
Handle hoSbPath
Variant vSbResponseBody
Handle hoSbResponseBody
String sTemp1
Integer iTemp1
Move False To iSuccess
// Note: Requires Chilkat v9.5.0.65 or greater.
// This requires the Chilkat API to have been previously unlocked.
// See Global Unlock Sample for sample code.
// Make the initial connection.
// A single REST object, once connected, can be used for many Azure Service Bus REST API calls.
// The auto-reconnect indicates that if the already-established HTTPS connection is closed,
// then it will be automatically re-established as needed.
Get Create (RefClass(cComChilkatRest)) To hoRest
If (Not(IsComObjectCreated(hoRest))) Begin
Send CreateComObject of hoRest
End
Move True To iBAutoReconnect
Get ComConnect Of hoRest "<yournamespace>.servicebus.windows.net" 443 True iBAutoReconnect To iSuccess
If (iSuccess <> True) Begin
Get ComLastErrorText Of hoRest To sTemp1
Showln sTemp1
Procedure_Return
End
// ----------------------------------------------------------------------------------------------
// The code above this comment could be placed inside a function/subroutine within the application
// because the connection does not need to be made for every request. Once the connection is made
// the app may send many requests..
// ----------------------------------------------------------------------------------------------
// Let's load a previously computed SAS token and use it.
// See Azure Shared Access Signature for an example to genenerate an Azure SAS token.
Get Create (RefClass(cComChilkatStringBuilder)) To hoSbToken
If (Not(IsComObjectCreated(hoSbToken))) Begin
Send CreateComObject of hoSbToken
End
Get ComLoadFile Of hoSbToken "qa_data/tokens/serviceBusSas.txt" "utf-8" To iSuccess
// Tell the REST object to use the Azure Shared Access Signature for authorization.
Get ComPrepend Of hoSbToken "SharedAccessSignature " To iSuccess
Get ComGetAsString Of hoSbToken To sTemp1
Get ComAddHeader Of hoRest "Authorization" sTemp1 To iSuccess
// ----------------------------------------------------------------------------------------------
// Create a new queue named "fox";
Move "fox" To sQueueName
// Create the XML body of the PUT request.
Get Create (RefClass(cComChilkatXml)) To hoXml
If (Not(IsComObjectCreated(hoXml))) Begin
Send CreateComObject of hoXml
End
Set ComTag Of hoXml To "entry"
Get ComAddAttribute Of hoXml "xmlns" "http://www.w3.org/2005/Atom" To iSuccess
Get ComUpdateAttrAt Of hoXml "title" True "type" "text" To iSuccess
Send ComUpdateChildContent To hoXml "title" sQueueName
Get ComUpdateAttrAt Of hoXml "content" True "type" "application/xml" To iSuccess
Get ComUpdateAttrAt Of hoXml "content|QueueDescription" True "xmlns:i" "http://www.w3.org/2001/XMLSchema-instance" To iSuccess
Get ComUpdateAttrAt Of hoXml "content|QueueDescription" True "xmlns" "http://schemas.microsoft.com/netservices/2010/10/servicebus/connect" To iSuccess
Set ComEmitXmlDecl Of hoXml To False
Get ComGetXml Of hoXml To sTemp1
Showln sTemp1
// The XML created by the above code:
// <entry xmlns="http://www.w3.org/2005/Atom">
// <title type="text">fox</title>
// <content type="application/xml">
// <QueueDescription xmlns:i="http://www.w3.org/2001/XMLSchema-instance"
// xmlns="http://schemas.microsoft.com/netservices/2010/10/servicebus/connect" />
// </content>
// </entry>
Get Create (RefClass(cComChilkatStringBuilder)) To hoSbRequestBody
If (Not(IsComObjectCreated(hoSbRequestBody))) Begin
Send CreateComObject of hoSbRequestBody
End
Get pvComObject of hoSbRequestBody to vSbRequestBody
Get ComGetXmlSb Of hoXml vSbRequestBody To iSuccess
// The path should be set to the to-be-created queue name.
Get Create (RefClass(cComChilkatStringBuilder)) To hoSbPath
If (Not(IsComObjectCreated(hoSbPath))) Begin
Send CreateComObject of hoSbPath
End
Get ComAppend Of hoSbPath "/" To iSuccess
Get ComAppend Of hoSbPath sQueueName To iSuccess
Get Create (RefClass(cComChilkatStringBuilder)) To hoSbResponseBody
If (Not(IsComObjectCreated(hoSbResponseBody))) Begin
Send CreateComObject of hoSbResponseBody
End
Get ComGetAsString Of hoSbPath To sTemp1
Get pvComObject of hoSbRequestBody to vSbRequestBody
Get pvComObject of hoSbResponseBody to vSbResponseBody
Get ComFullRequestSb Of hoRest "PUT" sTemp1 vSbRequestBody vSbResponseBody To iSuccess
If (iSuccess <> True) Begin
Get ComLastErrorText Of hoRest To sTemp1
Showln sTemp1
Procedure_Return
End
Get ComResponseStatusCode Of hoRest To iTemp1
Showln "Response Status Code = " iTemp1
// Check for a success response.
Get ComResponseStatusCode Of hoRest To iTemp1
If (iTemp1 <> 201) Begin
Get ComLastRequestStartLine Of hoRest To sTemp1
Showln sTemp1
Get ComLastRequestHeader Of hoRest To sTemp1
Showln sTemp1
Get ComGetAsString Of hoSbResponseBody To sTemp1
Showln sTemp1
Showln "Failed."
Procedure_Return
End
// The response is XML. (See a sample response below..)
Get pvComObject of hoSbResponseBody to vSbResponseBody
Get ComLoadSb Of hoXml vSbResponseBody True To iSuccess
Get ComGetXml Of hoXml To sTemp1
Showln sTemp1
Showln "Success."
// -----------------------------------------------
// A sample successful XML response:
// <entry xmlns="http://www.w3.org/2005/Atom">
// <id>https://chilkat.servicebus.windows.net/fox</id>
// <title type="text">fox</title>
// <published>2016-12-01T00:37:57Z</published>
// <updated>2016-12-01T00:37:57Z</updated>
// <author>
// <name>chilkat</name>
// </author>
// <link rel="self" href="https://chilkat.servicebus.windows.net/fox" />
// <content type="application/xml">
// <QueueDescription xmlns="http://schemas.microsoft.com/netservices/2010/10/servicebus/connect" xmlns:i="http://www.w3.org/2001/XMLSchema-instance">
// <LockDuration>PT1M</LockDuration>
// <MaxSizeInMegabytes>1024</MaxSizeInMegabytes>
// <RequiresDuplicateDetection>false</RequiresDuplicateDetection>
// <RequiresSession>false</RequiresSession>
// <DefaultMessageTimeToLive>P10675199DT2H48M5.4775807S</DefaultMessageTimeToLive>
// <DeadLetteringOnMessageExpiration>false</DeadLetteringOnMessageExpiration>
// <DuplicateDetectionHistoryTimeWindow>PT10M</DuplicateDetectionHistoryTimeWindow>
// <MaxDeliveryCount>10</MaxDeliveryCount>
// <EnableBatchedOperations>true</EnableBatchedOperations>
// <SizeInBytes>0</SizeInBytes>
// <MessageCount>0</MessageCount>
// <CreatedAt>2016-12-01T00:37:57.66</CreatedAt>
// <UpdatedAt>2016-12-01T00:37:57.677</UpdatedAt>
// </QueueDescription>
// </content>
// </entry>
End_Procedure