你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站,请访问 https://docs.azure.cn。
ServiceBusRuleManagerClient 类
- java.
lang. Object - com.
azure. messaging. servicebus. ServiceBusRuleManagerClient
- com.
实现
public class ServiceBusRuleManagerClient
implements AutoCloseable
负责管理特定主题订阅的规则的 同步 规则管理器。 规则管理器只需要侦听声明,而 ServiceBusAdministrationAsyncClient 需要管理声明。
为服务总线订阅创建规则
TokenCredential credential = new DefaultAzureCredentialBuilder().build();
// 'fullyQualifiedNamespace' will look similar to "{your-namespace}.servicebus.windows.net"
ServiceBusRuleManagerClient ruleManager = new ServiceBusClientBuilder()
.credential(fullyQualifiedNamespace, credential)
.ruleManager()
.topicName(topicName)
.subscriptionName(subscriptionName)
.buildClient();
RuleFilter trueRuleFilter = new TrueRuleFilter();
CreateRuleOptions options = new CreateRuleOptions(trueRuleFilter);
ruleManager.createRule("new-rule", options);
// Dispose of the ruleManager when finished using it.
ruleManager.close();
方法摘要
修饰符和类型 | 方法和描述 |
---|---|
void | close() |
void |
createRule(String ruleName, CreateRuleOptions options)
为当前订阅创建一个规则,以筛选从主题到订阅到达的消息。 |
void |
deleteRule(String ruleName)
删除由 |
String |
getEntityPath()
获取服务总线资源的名称。 |
String |
getFullyQualifiedNamespace()
获取完全限定的命名空间。 |
Iterable |
listRules()
提取与主题和订阅关联的所有规则。 |
方法继承自 java.lang.Object
方法详细信息
close
public void close()
释放 。ServiceBusRuleManagerClient 如果客户端具有专用连接,则基础连接也会关闭。
createRule
public void createRule(String ruleName, CreateRuleOptions options)
为当前订阅创建一个规则,以筛选从主题到订阅到达的消息。
Parameters:
deleteRule
public void deleteRule(String ruleName)
删除由 ruleName
标识的订阅上的规则。
Parameters:
getEntityPath
public String getEntityPath()
获取服务总线资源的名称。
Returns:
getFullyQualifiedNamespace
public String getFullyQualifiedNamespace()
获取完全限定的命名空间。
Returns:
listRules
public IterableStream
提取与主题和订阅关联的所有规则。
Returns: