B4X

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. B4X

Dim success As Boolean = False

'  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.
Dim rest As ChilkatRest
rest.Initialize("rest")
Dim bAutoReconnect As Boolean = True
success = rest.Connect("<yournamespace>.servicebus.windows.net", 443, True, bAutoReconnect)
If success <> True Then
    Log(rest.LastErrorText)
    Return
End If


'  ----------------------------------------------------------------------------------------------
'  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.
Dim sbToken As ChilkatStringBuilder
sbToken.Initialize
sbToken.LoadFile("qa_data/tokens/serviceBusSas.txt", "utf-8")

'  Tell the REST object to use the Azure Shared Access Signature for authorization.
sbToken.Prepend("SharedAccessSignature ")
rest.AddHeader("Authorization", sbToken.GetAsString)

'  ----------------------------------------------------------------------------------------------

'  Send to a topic (or queue) named "gilaMonster";
Dim topicOrQueueName As String = "gilaMonster"

'  The HTTP request body contains JSON that contains multiple messages.
Dim json As ChilkatJsonObject
json.Initialize
json.I = 0
json.UpdateString("messages[i].Body", "This is the first message")
json.UpdateString("messages[i].BrokerProperties.Label", "M1")
json.UpdateString("messages[i].BrokerProperties.TimeToLiveTimeSpan", "0.00:00:40")

json.I = 1
json.UpdateString("messages[i].Body", "This is the second message")
json.UpdateString("messages[i].BrokerProperties.Label", "M2")
json.UpdateString("messages[i].UserProperties.Priority", "Low")

json.I = 2
json.UpdateString("messages[i].Body", "This is the third message")
json.UpdateString("messages[i].BrokerProperties.Label", "M3")
json.UpdateString("messages[i].UserProperties.Priority", "Medium")
json.UpdateString("messages[i].UserProperties.Customer", "ABC")

Dim jsonA As ChilkatJsonArray = json.ArrayOf("messages")
jsonA.EmitCompact = False
Log(jsonA.Emit)

'  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"
'  	    }
'  	  }
'  	]

Dim sbRequestBody As ChilkatStringBuilder
sbRequestBody.Initialize
jsonA.EmitCompact = True
jsonA.EmitSb(sbRequestBody)


'  Build the path..
Dim sbPath As ChilkatStringBuilder
sbPath.Initialize
sbPath.Append("/")
sbPath.Append(topicOrQueueName)
sbPath.Append("/messages")

'  Add timeout and api-version query parameters.
rest.AddQueryParam("timeout", "20")

'  The Content-Type should be "application/vnd.microsoft.servicebus.json"
rest.AddHeader("Content-Type", "application/vnd.microsoft.servicebus.json")

Dim sbResponseBody As ChilkatStringBuilder
sbResponseBody.Initialize
success = rest.FullRequestSb("POST", sbPath.GetAsString, sbRequestBody, sbResponseBody)
If success <> True Then
    Log(rest.LastErrorText)
    Return
End If


Log("Response Status Code = " & rest.ResponseStatusCode)

'  Check for a success response.
If rest.ResponseStatusCode <> 201 Then
    Log(rest.LastRequestStartLine)
    Log(rest.LastRequestHeader)
    Log(sbResponseBody.GetAsString)
    Log("Failed.")
    Return
End If


'  If successful, the 201 response will have no response body.

Log("Success.")