Databases
StackOverflow2013
Postsdbo
PO
 

Note that there are some explanatory texts on larger screens.

plurals
  1. PO
    primarykey
    data
    text
    <p>After obtaining my default management credentials from the Azure portal as describe in <a href="http://www.windowsazure.com/en-us/develop/java/how-to-guides/service-bus-topics/" rel="noreferrer">the documentation</a> my application was able to get a ServiceBusContract object for my Service Bus namespace as follows: </p> <pre><code>public class Service { private Configuration config; public Service() { String namespace = "jasper"; String issuer = "owner"; String key = "BB9BB9BBBbBBBbBbbBBbB99SS9b+Bb9BbB+bbBBbBB9="; String serviceBusRootUri = ".servicebus.windows.net"; String wrapRootUri = "-sb.accesscontrol.windows.net/WRAPv0.9"; this.config = ServiceBusConfiguration.configureWithWrapAuthentication( namespace, issuer, key, serviceBusRootUri, wrapRootUri); } public ServiceBusContract getservice() { ServiceBusContract service = ServiceBusService.create(config); return service; } } </code></pre> <p>The following Java code can then be used to create three subscriptions to the “TestTopic” topic. “TestTopic” must already exist in the “jasper” namespace. The “AllMessages” subscription is the default and receives all the messages sent to the topic. The “LowMessages” and “HighMessages” subscriptions use SqlFilter rules to filter messages based upon the value of the MessageNumber custom property. The original example code omits that it is necessary to provide a rule name and that it necessary to delete the default rule. If you do not delete the default rule, the subscription still receives all messages.</p> <pre><code>public class Make_sub_rule { public static void main(String[] args) throws ServiceException { Service creds = new Service(); ServiceBusContract service = creds.getservice(); SubscriptionInfo subInfo = new SubscriptionInfo("AllMessages"); service.createSubscription("TestTopic", subInfo); System.out.println(subInfo.getName() + " Default Rules"); SubscriptionInfo subInfo1 = new SubscriptionInfo("LowMessages"); CreateSubscriptionResult result1 = service.createSubscription("TestTopic", subInfo1); RuleInfo ruleInfo1 = new RuleInfo("RULENAME1"); ruleInfo1 = ruleInfo1.withSqlExpressionFilter("MessageNumber &lt;= 3"); CreateRuleResult ruleResult1 = service.createRule("TestTopic", "LowMessages", ruleInfo1); service.deleteRule("TestTopic", "LowMessages", "$Default"); System.out.println(subInfo1.getName() + " " + result1.toString()); System.out.println(ruleInfo1.getName() + " " + ruleResult1.toString()); SubscriptionInfo subInfo2 = new SubscriptionInfo("HighMessages"); CreateSubscriptionResult result2 = service.createSubscription("TestTopic", subInfo2); RuleInfo ruleInfo2 = new RuleInfo("RULENAME2"); ruleInfo2 = ruleInfo2.withSqlExpressionFilter("MessageNumber &gt; 3"); CreateRuleResult ruleResult2 = service.createRule("TestTopic", "HighMessages", ruleInfo2); service.deleteRule("TestTopic", "HighMessages", "$Default"); System.out.println(subInfo2.getName() + " " + result2.toString()); System.out.println(ruleInfo2.getName() + " " + ruleResult2.toString()); } } </code></pre> <p>The following sends a batch of brokered messages to “TestTopic” and increments the value of the MessageNumber custom property.</p> <pre><code>public class SendSbMsTopicB { public static void main(String[] args) throws ServiceException { Service creds = new Service(); ServiceBusContract service = creds.getservice(); for (int i=0; i&lt;7; i++) { BrokeredMessage message = new BrokeredMessage("Test message" + i); message.setLabel("Day" + i); message.setProperty("MessageNumber", i); message.setProperty("CustomProperty", "CustomTestValue" + i); service.sendTopicMessage("TestTopic", message); System.out.println("send MessageNumber " + i + " to topic"); } } } </code></pre> <p>Run the following code repeatedly to read the virtual queues of the “AllMessages”, “LowMessages”, or “HighMessages” subscriptions (change the value of subscriptionName). Each message is deleted from the virtual queue when it is read until there are no more messages remaining in that subscription’s queue. Note that more than one subscription can receive the same message and that filtered subscriptions do not receive all messages.</p> <pre><code>public class GetSbMessSub { public static void main(String[] args) throws ServiceException { Service creds = new Service(); ServiceBusContract service = creds.getservice(); String subscriptionName = "LowMessages"; ReceiveMessageOptions opts = ReceiveMessageOptions.DEFAULT; opts.setReceiveMode(ReceiveMode.PEEK_LOCK); ReceiveSubscriptionMessageResult resultQM = service.receiveSubscriptionMessage("TestTopic", subscriptionName, opts); BrokeredMessage message = resultQM.getValue(); if (message != null &amp;&amp; message.getMessageId() != null) { try { System.out.println("Subscription: " + subscriptionName); System.out.println("MessageNumber: " + message.getProperty("MessageNumber")); service.deleteMessage(message);} catch (Exception ex){ System.out.println("Inner exception encountered!"); service.unlockMessage(message);} } else {System.out.println("There are no more messages.");} } } </code></pre>
    singulars
    1. This table or related slice is empty.
    1. POFiltering Subscriptions to Windows Azure Service Bus Topics using Java
      singulars
      1. PTQuestion
    1. PTAnswer
    1. This table or related slice is empty.
    1. USMark Rovetta
    plurals
    1. This table or related slice is empty.
    1. This table or related slice is empty.
    1. This table or related slice is empty.
    1. This table or related slice is empty.
    1. VO
      singulars
      1. PO
      1. This table or related slice is empty.
      1. VTUpMod
    2. VO
      singulars
      1. PO
      1. This table or related slice is empty.
      1. VTUpMod
    3. VO
      singulars
      1. PO
      1. This table or related slice is empty.
      1. VTUpMod
    1. This table or related slice is empty.
 

Querying!

 
Guidance
A row detail

Detail views are divided into sections. All the information in the data section comes from columns in the selected row. The other sections display data from other, related rows.

Related data can be related in a to-one or a to-many fashion. Captions of data related in a to-many fashion link to a list view showing a filtered view of the table.

Try moving around until you find a non-empty to-many entry and click on the label to get to one. You can move back to the root by clicking on the database name in the header.

SQuiL has stopped working due to an internal error.

If you are curious you may find further information in the browser console, which is accessible through the devtools (F12).

Reload