PureBasic
PureBasic
Azure Service Bus - Create Topic
See more Azure Service Bus Examples
Creates an Azure Service Bus Topic.Note: This example requires Chilkat v9.5.0.65 or greater.
Chilkat PureBasic Downloads
IncludeFile "CkXml.pb"
IncludeFile "CkStringBuilder.pb"
IncludeFile "CkRest.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))
; ----------------------------------------------------------------------------------------------
; Create a new topic named "gilaMonster";
topicName.s = "gilaMonster"
; Create the XML body of the PUT request.
xml.i = CkXml::ckCreate()
If xml.i = 0
Debug "Failed to create object."
ProcedureReturn
EndIf
CkXml::setCkTag(xml, "entry")
CkXml::ckAddAttribute(xml,"xmlns","http://www.w3.org/2005/Atom")
CkXml::ckUpdateAttrAt(xml,"title",1,"type","text")
CkXml::ckUpdateChildContent(xml,"title",topicName)
CkXml::ckUpdateAttrAt(xml,"content",1,"type","application/xml")
CkXml::ckUpdateAttrAt(xml,"content|TopicDescription",1,"xmlns:i","http://www.w3.org/2001/XMLSchema-instance")
CkXml::ckUpdateAttrAt(xml,"content|TopicDescription",1,"xmlns","http://schemas.microsoft.com/netservices/2010/10/servicebus/connect")
CkXml::setCkEmitXmlDecl(xml, 0)
Debug CkXml::ckGetXml(xml)
; The XML created by the above code:
; <entry xmlns="http://www.w3.org/2005/Atom">
; <title type="text">gilaMonster</title>
; <content type="application/xml">
; <TopicDescription xmlns:i="http://www.w3.org/2001/XMLSchema-instance"
; xmlns="http://schemas.microsoft.com/netservices/2010/10/servicebus/connect" />
; </content>
; </entry>
sbRequestBody.i = CkStringBuilder::ckCreate()
If sbRequestBody.i = 0
Debug "Failed to create object."
ProcedureReturn
EndIf
CkXml::ckGetXmlSb(xml,sbRequestBody)
; The path should be set to the to-be-created queue name.
sbPath.i = CkStringBuilder::ckCreate()
If sbPath.i = 0
Debug "Failed to create object."
ProcedureReturn
EndIf
CkStringBuilder::ckAppend(sbPath,"/")
CkStringBuilder::ckAppend(sbPath,topicName)
sbResponseBody.i = CkStringBuilder::ckCreate()
If sbResponseBody.i = 0
Debug "Failed to create object."
ProcedureReturn
EndIf
success = CkRest::ckFullRequestSb(rest,"PUT",CkStringBuilder::ckGetAsString(sbPath),sbRequestBody,sbResponseBody)
If success <> 1
Debug CkRest::ckLastErrorText(rest)
CkRest::ckDispose(rest)
CkStringBuilder::ckDispose(sbToken)
CkXml::ckDispose(xml)
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)
CkXml::ckDispose(xml)
CkStringBuilder::ckDispose(sbRequestBody)
CkStringBuilder::ckDispose(sbPath)
CkStringBuilder::ckDispose(sbResponseBody)
ProcedureReturn
EndIf
; The response is XML. (See a sample response below..)
CkXml::ckLoadSb(xml,sbResponseBody,1)
Debug CkXml::ckGetXml(xml)
Debug "Success."
; -----------------------------------------------
; A sample successful XML response:
; <entry xmlns="http://www.w3.org/2005/Atom">
; <id>https://chilkat.servicebus.windows.net/gilaMonster</id>
; <title type="text">gilaMonster</title>
; <published>2016-12-06T23:34:13Z</published>
; <updated>2016-12-06T23:34:13Z</updated>
; <author>
; <name>chilkat</name>
; </author>
; <link rel="self" href="https://chilkat.servicebus.windows.net/gilaMonster" />
; <content type="application/xml">
; <TopicDescription xmlns="http://schemas.microsoft.com/netservices/2010/10/servicebus/connect" xmlns:i="http://www.w3.org/2001/XMLSchema-instance">
; <DefaultMessageTimeToLive>P10675199DT2H48M5.4775807S</DefaultMessageTimeToLive>
; <MaxSizeInMegabytes>1024</MaxSizeInMegabytes>
; <RequiresDuplicateDetection>false</RequiresDuplicateDetection>
; <DuplicateDetectionHistoryTimeWindow>PT10M</DuplicateDetectionHistoryTimeWindow>
; <EnableBatchedOperations>true</EnableBatchedOperations>
; <SizeInBytes>0</SizeInBytes>
; <CreatedAt>2016-12-06T23:34:13.483</CreatedAt>
; <UpdatedAt>2016-12-06T23:34:13.7</UpdatedAt>
; </TopicDescription>
; </content>
; </entry>
CkRest::ckDispose(rest)
CkStringBuilder::ckDispose(sbToken)
CkXml::ckDispose(xml)
CkStringBuilder::ckDispose(sbRequestBody)
CkStringBuilder::ckDispose(sbPath)
CkStringBuilder::ckDispose(sbResponseBody)
ProcedureReturn
EndProcedure