Xbase++

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.

Xbase++

LOCAL nSuccess
LOCAL oRest
LOCAL nBAutoReconnect
LOCAL oSbToken
LOCAL cTopicName
LOCAL oXml
LOCAL oSbRequestBody
LOCAL oSbPath
LOCAL oSbResponseBody

nSuccess := 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.
oRest := CreateObject("Chilkat.Rest")
nBAutoReconnect := 1
nSuccess := oRest:Connect("<yournamespace>.servicebus.windows.net", 443, 1, nBAutoReconnect)
IF (nSuccess != 1)
    ? oRest:LastErrorText
    oRest:destroy()
    RETURN
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.
oSbToken := CreateObject("Chilkat.StringBuilder")
oSbToken:LoadFile("qa_data/tokens/serviceBusSas.txt", "utf-8")

//  Tell the REST object to use the Azure Shared Access Signature for authorization.
oSbToken:Prepend("SharedAccessSignature ")
oRest:AddHeader("Authorization", oSbToken:GetAsString())

//  ----------------------------------------------------------------------------------------------

//  Create a new topic named "gilaMonster";
cTopicName := "gilaMonster"

//  Create the XML body of the PUT request.
oXml := CreateObject("Chilkat.Xml")
oXml:Tag := "entry"
oXml:AddAttribute("xmlns", "http://www.w3.org/2005/Atom")
oXml:UpdateAttrAt("title", 1, "type", "text")
oXml:UpdateChildContent("title", cTopicName)
oXml:UpdateAttrAt("content", 1, "type", "application/xml")
oXml:UpdateAttrAt("content|TopicDescription", 1, "xmlns:i", "http://www.w3.org/2001/XMLSchema-instance")
oXml:UpdateAttrAt("content|TopicDescription", 1, "xmlns", "http://schemas.microsoft.com/netservices/2010/10/servicebus/connect")
oXml:EmitXmlDecl := 0
? oXml:GetXml()

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

oSbRequestBody := CreateObject("Chilkat.StringBuilder")
oXml:GetXmlSb(oSbRequestBody)

//  The path should be set to the to-be-created queue name.
oSbPath := CreateObject("Chilkat.StringBuilder")
oSbPath:Append("/")
oSbPath:Append(cTopicName)

oSbResponseBody := CreateObject("Chilkat.StringBuilder")
nSuccess := oRest:FullRequestSb("PUT", oSbPath:GetAsString(), oSbRequestBody, oSbResponseBody)
IF (nSuccess != 1)
    ? oRest:LastErrorText
    oRest:destroy()
    oSbToken:destroy()
    oXml:destroy()
    oSbRequestBody:destroy()
    oSbPath:destroy()
    oSbResponseBody:destroy()
    RETURN
ENDIF

? "Response Status Code = " + Str(oRest:ResponseStatusCode)

//  Check for a success response.
IF (oRest:ResponseStatusCode != 201)
    ? oRest:LastRequestStartLine
    ? oRest:LastRequestHeader
    ? oSbResponseBody:GetAsString()
    ? "Failed."
    oRest:destroy()
    oSbToken:destroy()
    oXml:destroy()
    oSbRequestBody:destroy()
    oSbPath:destroy()
    oSbResponseBody:destroy()
    RETURN
ENDIF

//  The response is XML.  (See a sample response below..)
oXml:LoadSb(oSbResponseBody, 1)
? oXml:GetXml()

? "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>

oRest:destroy()
oSbToken:destroy()
oXml:destroy()
oSbRequestBody:destroy()
oSbPath:destroy()
oSbResponseBody:destroy()