Xbase++

Azure Service Bus - Create Subscription

See more Azure Service Bus Examples

Creates an Azure Service Bus Subscription.

Note: This example requires Chilkat v9.5.0.65 or greater.

Xbase++

LOCAL nSuccess
LOCAL oRest
LOCAL nBAutoReconnect
LOCAL oSbToken
LOCAL cTopicName
LOCAL cSubscriptionName
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 subscription named "feedings";
cTopicName := "gilaMonster"
cSubscriptionName := "feedings"

//  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", cSubscriptionName)
oXml:UpdateAttrAt("content", 1, "type", "application/xml")
oXml:UpdateAttrAt("content|SubscriptionDescription", 1, "xmlns:i", "http://www.w3.org/2001/XMLSchema-instance")
oXml:UpdateAttrAt("content|SubscriptionDescription", 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">feedings</title>
//  	    <content type="application/xml">
//  	        <SubscriptionDescription 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)
oSbPath:Append("/Subscriptions/")
oSbPath:Append(cSubscriptionName)

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/Subscriptions/feedings</id>
//  	    <title type="text">feedings</title>
//  	    <published>2016-12-07T16:02:24Z</published>
//  	    <updated>2016-12-07T16:02:24Z</updated>
//  	    <link rel="self" href="https://chilkat.servicebus.windows.net/gilaMonster/Subscriptions/feedings" />
//  	    <content type="application/xml">
//  	        <SubscriptionDescription xmlns="http://schemas.microsoft.com/netservices/2010/10/servicebus/connect" xmlns:i="http://www.w3.org/2001/XMLSchema-instance">
//  	            <LockDuration>PT1M</LockDuration>
//  	            <RequiresSession>false</RequiresSession>
//  	            <DefaultMessageTimeToLive>P10675199DT2H48M5.4775807S</DefaultMessageTimeToLive>
//  	            <DeadLetteringOnMessageExpiration>false</DeadLetteringOnMessageExpiration>
//  	            <DeadLetteringOnFilterEvaluationExceptions>true</DeadLetteringOnFilterEvaluationExceptions>
//  	            <MessageCount>0</MessageCount>
//  	            <MaxDeliveryCount>10</MaxDeliveryCount>
//  	            <EnableBatchedOperations>true</EnableBatchedOperations>
//  	        </SubscriptionDescription>
//  	    </content>
//  	</entry>

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