PureBasic
PureBasic
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 PureBasic Downloads
IncludeFile "CkStringBuilder.pb"
IncludeFile "CkJsonObject.pb"
IncludeFile "CkRest.pb"
IncludeFile "CkJsonArray.pb"
Procedure ChilkatExample()
success.i = 0
; 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.
rest.i = CkRest::ckCreate()
If rest.i = 0
Debug "Failed to create object."
ProcedureReturn
EndIf
bAutoReconnect.i = 1
success = CkRest::ckConnect(rest,"<yournamespace>.servicebus.windows.net",443,1,bAutoReconnect)
If success <> 1
Debug CkRest::ckLastErrorText(rest)
CkRest::ckDispose(rest)
ProcedureReturn
EndIf
; ----------------------------------------------------------------------------------------------
; 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.
sbToken.i = CkStringBuilder::ckCreate()
If sbToken.i = 0
Debug "Failed to create object."
ProcedureReturn
EndIf
CkStringBuilder::ckLoadFile(sbToken,"qa_data/tokens/serviceBusSas.txt","utf-8")
; Tell the REST object to use the Azure Shared Access Signature for authorization.
CkStringBuilder::ckPrepend(sbToken,"SharedAccessSignature ")
CkRest::ckAddHeader(rest,"Authorization",CkStringBuilder::ckGetAsString(sbToken))
; ----------------------------------------------------------------------------------------------
; Send to a topic (or queue) named "gilaMonster";
topicOrQueueName.s = "gilaMonster"
; The HTTP request body contains JSON that contains multiple messages.
json.i = CkJsonObject::ckCreate()
If json.i = 0
Debug "Failed to create object."
ProcedureReturn
EndIf
CkJsonObject::setCkI(json, 0)
CkJsonObject::ckUpdateString(json,"messages[i].Body","This is the first message")
CkJsonObject::ckUpdateString(json,"messages[i].BrokerProperties.Label","M1")
CkJsonObject::ckUpdateString(json,"messages[i].BrokerProperties.TimeToLiveTimeSpan","0.00:00:40")
CkJsonObject::setCkI(json, 1)
CkJsonObject::ckUpdateString(json,"messages[i].Body","This is the second message")
CkJsonObject::ckUpdateString(json,"messages[i].BrokerProperties.Label","M2")
CkJsonObject::ckUpdateString(json,"messages[i].UserProperties.Priority","Low")
CkJsonObject::setCkI(json, 2)
CkJsonObject::ckUpdateString(json,"messages[i].Body","This is the third message")
CkJsonObject::ckUpdateString(json,"messages[i].BrokerProperties.Label","M3")
CkJsonObject::ckUpdateString(json,"messages[i].UserProperties.Priority","Medium")
CkJsonObject::ckUpdateString(json,"messages[i].UserProperties.Customer","ABC")
jsonA.i = CkJsonObject::ckArrayOf(json,"messages")
CkJsonArray::setCkEmitCompact(jsonA, 0)
Debug CkJsonArray::ckEmit(jsonA)
; 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"
; }
; }
; ]
sbRequestBody.i = CkStringBuilder::ckCreate()
If sbRequestBody.i = 0
Debug "Failed to create object."
ProcedureReturn
EndIf
CkJsonArray::setCkEmitCompact(jsonA, 1)
CkJsonArray::ckEmitSb(jsonA,sbRequestBody)
CkJsonArray::ckDispose(jsonA)
; Build the path..
sbPath.i = CkStringBuilder::ckCreate()
If sbPath.i = 0
Debug "Failed to create object."
ProcedureReturn
EndIf
CkStringBuilder::ckAppend(sbPath,"/")
CkStringBuilder::ckAppend(sbPath,topicOrQueueName)
CkStringBuilder::ckAppend(sbPath,"/messages")
; Add timeout and api-version query parameters.
CkRest::ckAddQueryParam(rest,"timeout","20")
; The Content-Type should be "application/vnd.microsoft.servicebus.json"
CkRest::ckAddHeader(rest,"Content-Type","application/vnd.microsoft.servicebus.json")
sbResponseBody.i = CkStringBuilder::ckCreate()
If sbResponseBody.i = 0
Debug "Failed to create object."
ProcedureReturn
EndIf
success = CkRest::ckFullRequestSb(rest,"POST",CkStringBuilder::ckGetAsString(sbPath),sbRequestBody,sbResponseBody)
If success <> 1
Debug CkRest::ckLastErrorText(rest)
CkRest::ckDispose(rest)
CkStringBuilder::ckDispose(sbToken)
CkJsonObject::ckDispose(json)
CkStringBuilder::ckDispose(sbRequestBody)
CkStringBuilder::ckDispose(sbPath)
CkStringBuilder::ckDispose(sbResponseBody)
ProcedureReturn
EndIf
Debug "Response Status Code = " + Str(CkRest::ckResponseStatusCode(rest))
; Check for a success response.
If CkRest::ckResponseStatusCode(rest) <> 201
Debug CkRest::ckLastRequestStartLine(rest)
Debug CkRest::ckLastRequestHeader(rest)
Debug CkStringBuilder::ckGetAsString(sbResponseBody)
Debug "Failed."
CkRest::ckDispose(rest)
CkStringBuilder::ckDispose(sbToken)
CkJsonObject::ckDispose(json)
CkStringBuilder::ckDispose(sbRequestBody)
CkStringBuilder::ckDispose(sbPath)
CkStringBuilder::ckDispose(sbResponseBody)
ProcedureReturn
EndIf
; If successful, the 201 response will have no response body.
Debug "Success."
CkRest::ckDispose(rest)
CkStringBuilder::ckDispose(sbToken)
CkJsonObject::ckDispose(json)
CkStringBuilder::ckDispose(sbRequestBody)
CkStringBuilder::ckDispose(sbPath)
CkStringBuilder::ckDispose(sbResponseBody)
ProcedureReturn
EndProcedure