Lua Requires Chilkat v9.5.0.65+
Lua
Azure Service Bus - Create Topic
See more Azure Service Bus Examples
Creates an Azure Service Bus Topic.Chilkat Lua Downloads
local chilkat = require("chilkat")
-- 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.
local rest = chilkat.Rest.new()
local bAutoReconnect = true
local success = rest:connect("<yournamespace>.servicebus.windows.net", 443, true, bAutoReconnect)
if not success then
print(rest.last_error_text)
return
end
-- ----------------------------------------------------------------------------------------------
-- 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.
local sbToken = chilkat.StringBuilder.new()
sbToken:load_file("qa_data/tokens/serviceBusSas.txt", "utf-8")
-- Tell the REST object to use the Azure Shared Access Signature for authorization.
sbToken:prepend("SharedAccessSignature ")
rest:add_header("Authorization", sbToken:get_as_string())
-- ----------------------------------------------------------------------------------------------
-- Create a new topic named "gilaMonster";
local topicName = "gilaMonster"
-- Create the XML body of the PUT request.
local xml = chilkat.Xml.new()
xml.tag = "entry"
xml:add_attribute("xmlns", "http://www.w3.org/2005/Atom")
xml:update_attr_at("title", true, "type", "text")
xml:update_child_content("title", topicName)
xml:update_attr_at("content", true, "type", "application/xml")
xml:update_attr_at("content|TopicDescription", true, "xmlns:i", "http://www.w3.org/2001/XMLSchema-instance")
xml:update_attr_at("content|TopicDescription", true, "xmlns", "http://schemas.microsoft.com/netservices/2010/10/servicebus/connect")
xml.emit_xml_decl = false
print(xml:get_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>
local sbRequestBody = chilkat.StringBuilder.new()
xml:get_xml_sb(sbRequestBody)
-- The path should be set to the to-be-created queue name.
local sbPath = chilkat.StringBuilder.new()
sbPath:append("/")
sbPath:append(topicName)
local sbResponseBody = chilkat.StringBuilder.new()
success = rest:full_request_sb("PUT", sbPath:get_as_string(), sbRequestBody, sbResponseBody)
if not success then
print(rest.last_error_text)
return
end
print("Response Status Code = " .. rest.response_status_code)
-- Check for a success response.
if rest.response_status_code ~= 201 then
print(rest.last_request_start_line)
print(rest.last_request_header)
print(sbResponseBody:get_as_string())
print("Failed.")
return
end
-- The response is XML. (See a sample response below..)
xml:load_sb(sbResponseBody, true)
print(xml:get_xml())
print("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>