DataFlex
DataFlex
Azure Service Bus - Send Batch of Messages to Topic or Queue
See more Azure Service Bus Examples
Shows how to send a batch of messages to a service bus queue or topic.Chilkat DataFlex Downloads
Use ChilkatAx-win32.pkg
Procedure Test
Boolean iSuccess
Handle hoRest
Boolean iBAutoReconnect
Handle hoSbToken
String sTopicOrQueueName
Handle hoJson
Variant vJsonA
Handle hoJsonA
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
// ----------------------------------------------------------------------------------------------
// Send to a topic (or queue) named "gilaMonster";
Move "gilaMonster" To sTopicOrQueueName
// The HTTP request body contains JSON that contains multiple messages.
Get Create (RefClass(cComChilkatJsonObject)) To hoJson
If (Not(IsComObjectCreated(hoJson))) Begin
Send CreateComObject of hoJson
End
Set ComI Of hoJson To 0
Get ComUpdateString Of hoJson "messages[i].Body" "This is the first message" To iSuccess
Get ComUpdateString Of hoJson "messages[i].BrokerProperties.Label" "M1" To iSuccess
Get ComUpdateString Of hoJson "messages[i].BrokerProperties.TimeToLiveTimeSpan" "0.00:00:40" To iSuccess
Set ComI Of hoJson To 1
Get ComUpdateString Of hoJson "messages[i].Body" "This is the second message" To iSuccess
Get ComUpdateString Of hoJson "messages[i].BrokerProperties.Label" "M2" To iSuccess
Get ComUpdateString Of hoJson "messages[i].UserProperties.Priority" "Low" To iSuccess
Set ComI Of hoJson To 2
Get ComUpdateString Of hoJson "messages[i].Body" "This is the third message" To iSuccess
Get ComUpdateString Of hoJson "messages[i].BrokerProperties.Label" "M3" To iSuccess
Get ComUpdateString Of hoJson "messages[i].UserProperties.Priority" "Medium" To iSuccess
Get ComUpdateString Of hoJson "messages[i].UserProperties.Customer" "ABC" To iSuccess
Get ComArrayOf Of hoJson "messages" To vJsonA
If (IsComObject(vJsonA)) Begin
Get Create (RefClass(cComChilkatJsonArray)) To hoJsonA
Set pvComObject Of hoJsonA To vJsonA
End
Set ComEmitCompact Of hoJsonA To False
Get ComEmit Of hoJsonA To sTemp1
Showln sTemp1
// The following JSON array is produced by the above code:
// [
// {
// "Body": "This is the first message",
// "BrokerProperties": {
// "Label": "M1",
// "TimeToLiveTimeSpan": "0.00:00:40"
// }
// },
// {
// "Body": "This is the second message",
// "BrokerProperties": {
// "Label": "M2"
// },
// "UserProperties": {
// "Priority": "Low"
// }
// },
// {
// "Body": "This is the third message",
// "BrokerProperties": {
// "Label": "M3"
// },
// "UserProperties": {
// "Priority": "Medium",
// "Customer": "ABC"
// }
// }
// ]
Get Create (RefClass(cComChilkatStringBuilder)) To hoSbRequestBody
If (Not(IsComObjectCreated(hoSbRequestBody))) Begin
Send CreateComObject of hoSbRequestBody
End
Set ComEmitCompact Of hoJsonA To True
Get pvComObject of hoSbRequestBody to vSbRequestBody
Get ComEmitSb Of hoJsonA vSbRequestBody To iSuccess
Send Destroy of hoJsonA
// Build the path..
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 sTopicOrQueueName To iSuccess
Get ComAppend Of hoSbPath "/messages" To iSuccess
// Add timeout and api-version query parameters.
Get ComAddQueryParam Of hoRest "timeout" "20" To iSuccess
// The Content-Type should be "application/vnd.microsoft.servicebus.json"
Get ComAddHeader Of hoRest "Content-Type" "application/vnd.microsoft.servicebus.json" 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 "POST" 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
// If successful, the 201 response will have no response body.
Showln "Success."
End_Procedure