SqlRuleAction Klasse

Stellt einen Satz von Aktionen dar, die in sql-sprachbasierter Syntax geschrieben wurden, die für einen ServiceBusMessageausgeführt wird.

Beispiel: Erstellen eines SQL-Regelfilters mit SQL-Regelaktion

Im folgenden Codebeispiel wird eine Regel mithilfe eines SQL-Filters und einer SQL-Aktion erstellt. Die Regel vergleicht Nachrichten mit:

• getCorrelationId() gleich "email"
• getApplicationProperties() enthält einen Schlüssel "sender" mit Wert "joseph"
• getApplicationProperties() enthält einen Schlüssel "importance" mit dem Wert * "joseph" ODER der Wert ist NULL.

Wenn der Filter übereinstimmt, wird der "importance" Schlüssel in getApplicationProperties() mit "critical"festgelegt/aktualisiert.

String topicName = "emails";
 String subscriptionName = "important-emails";
 String ruleName = "emails-from-joseph";

 RuleFilter sqlRuleFilter = new SqlRuleFilter(
     "sys.CorrelationId = 'email' AND sender = 'joseph' AND (importance IS NULL OR importance = 'high')");
 RuleAction sqlRuleAction = new SqlRuleAction("SET importance = 'critical';");
 CreateRuleOptions createRuleOptions = new CreateRuleOptions()
     .setFilter(sqlRuleFilter)
     .setAction(sqlRuleAction);

 RuleProperties rule = client.createRule(topicName, ruleName, subscriptionName, createRuleOptions);

 System.out.printf("Rule '%s' created for topic %s, subscription %s. Filter: %s%n", rule.getName(), topicName,
     subscriptionName, rule.getFilter());