Java

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.

Chilkat2 Java

import com.chilkatsoft.chilkat2.ChilkatException;
import com.chilkatsoft.chilkat2.Rest;
import com.chilkatsoft.chilkat2.StringBuilder;
import com.chilkatsoft.chilkat2.Xml;

public class ChilkatExample {

    public static void main(String[] args) {
        // 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 rest = new Rest();
        boolean bAutoReconnect = true;
        try {
            rest.connect("<yournamespace>.servicebus.windows.net", 443, true, bAutoReconnect);
        } catch (ChilkatException e) {
            System.out.println(e.getLastErrorText());
            return;
        }

        // ----------------------------------------------------------------------------------------------
        // 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.
        StringBuilder sbToken = new StringBuilder();
        sbToken.loadFile("qa_data/tokens/serviceBusSas.txt", "utf-8");

        // Tell the REST object to use the Azure Shared Access Signature for authorization.
        sbToken.prepend("SharedAccessSignature ");
        rest.addHeader("Authorization", sbToken.getAsString());

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

        // Create a new subscription named "feedings";
        String topicName = "gilaMonster";
        String subscriptionName = "feedings";

        // Create the XML body of the PUT request.
        Xml xml = new Xml();
        xml.setTag("entry");
        xml.addAttribute("xmlns", "http://www.w3.org/2005/Atom");
        xml.updateAttrAt("title", true, "type", "text");
        xml.updateChildContent("title", subscriptionName);
        xml.updateAttrAt("content", true, "type", "application/xml");
        xml.updateAttrAt("content|SubscriptionDescription", true, "xmlns:i", "http://www.w3.org/2001/XMLSchema-instance");
        xml.updateAttrAt("content|SubscriptionDescription", true, "xmlns", "http://schemas.microsoft.com/netservices/2010/10/servicebus/connect");
        xml.setEmitXmlDecl(false);
        System.out.println(xml.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>

        StringBuilder sbRequestBody = new StringBuilder();
        xml.getXmlSb(sbRequestBody);

        // The path should be set to the to-be-created queue name.
        StringBuilder sbPath = new StringBuilder();
        sbPath.append("/");
        sbPath.append(topicName);
        sbPath.append("/Subscriptions/");
        sbPath.append(subscriptionName);

        StringBuilder sbResponseBody = new StringBuilder();
        try {
            rest.fullRequestSb("PUT", sbPath.getAsString(), sbRequestBody, sbResponseBody);
        } catch (ChilkatException e) {
            System.out.println(e.getLastErrorText());
            return;
        }

        System.out.println("Response Status Code = " + rest.getResponseStatusCode());

        // Check for a success response.
        if (rest.getResponseStatusCode() != 201) {
            System.out.println(rest.getLastRequestStartLine());
            System.out.println(rest.getLastRequestHeader());
            System.out.println(sbResponseBody.getAsString());
            System.out.println("Failed.");
            return;
        }

        // The response is XML.  (See a sample response below..)
        xml.loadSb(sbResponseBody, true);
        System.out.println(xml.getXml());

        System.out.println("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>
    }
}