(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 ActiveX Downloads ActiveX for 32-bit and 64-bit Windows

Use ChilkatAx-win32.pkg

Procedure Test
    Handle hoRest
    Boolean iBAutoReconnect
    Boolean iSuccess
    Handle hoSbToken
    String sTopicOrQueueName
    Handle hoJson
    Variant vJsonA
    Handle hoJsonA
    Variant vSbRequestBody
    Handle hoSbRequestBody
    Handle hoSbPath
    Variant vSbResponseBody
    Handle hoSbResponseBody
    String sTemp1
    Integer iTemp1

    // 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