Uses of Interface
org.apache.pulsar.common.policies.data.DispatchRate
Package
Description
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
Implementation of policies.
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
-
Uses of DispatchRate in org.apache.pulsar.client.admin
Modifier and TypeMethodDescriptionNamespaces.getDispatchRate
(String namespace) Get message-dispatch-rate (topics under this namespace can dispatch this many messages per second).TopicPolicies.getDispatchRate
(String topic) Get message-dispatch-rate (topic can dispatch this many messages per second).TopicPolicies.getDispatchRate
(String topic, boolean applied) Get applied message-dispatch-rate (topic can dispatch this many messages per second).Topics.getDispatchRate
(String topic) Deprecated.Topics.getDispatchRate
(String topic, boolean applied) Deprecated.UseTopicPolicies.getDispatchRate(String, boolean)
instead.Namespaces.getReplicatorDispatchRate
(String namespace) Get replicator-message-dispatch-rate.TopicPolicies.getReplicatorDispatchRate
(String topic) Get replicatorDispatchRate for the topic.TopicPolicies.getReplicatorDispatchRate
(String topic, boolean applied) Get applied replicatorDispatchRate for the topic.Topics.getReplicatorDispatchRate
(String topic) Deprecated.UseTopicPolicies.getReplicatorDispatchRate(String)
instead.Topics.getReplicatorDispatchRate
(String topic, boolean applied) Deprecated.Namespaces.getSubscriptionDispatchRate
(String namespace) Get subscription-message-dispatch-rate.TopicPolicies.getSubscriptionDispatchRate
(String topic) Get subscription-message-dispatch-rate for the topic.TopicPolicies.getSubscriptionDispatchRate
(String topic, boolean applied) Get applied subscription-message-dispatch-rate.TopicPolicies.getSubscriptionDispatchRate
(String topic, String subscriptionName) Get subscription level dispatch rate limiter setting for a specific subscription.TopicPolicies.getSubscriptionDispatchRate
(String topic, String subscriptionName, boolean applied) If applied is true, get dispatch rate limiter for a specific subscription.Topics.getSubscriptionDispatchRate
(String topic) Deprecated.UseTopicPolicies.getSubscriptionDispatchRate(String)
instead.Topics.getSubscriptionDispatchRate
(String namespace, boolean applied) Deprecated.Modifier and TypeMethodDescriptionNamespaces.getDispatchRateAsync
(String namespace) Get message-dispatch-rate asynchronously.TopicPolicies.getDispatchRateAsync
(String topic) Get message-dispatch-rate asynchronously.TopicPolicies.getDispatchRateAsync
(String topic, boolean applied) Get applied message-dispatch-rate asynchronously.Topics.getDispatchRateAsync
(String topic) Deprecated.UseTopicPolicies.getDispatchRateAsync(String)
instead.Topics.getDispatchRateAsync
(String topic, boolean applied) Deprecated.UseTopicPolicies.getDispatchRateAsync(String, boolean)
instead.Namespaces.getReplicatorDispatchRateAsync
(String namespace) Get replicator-message-dispatch-rate asynchronously.TopicPolicies.getReplicatorDispatchRateAsync
(String topic) Get replicatorDispatchRate asynchronously.TopicPolicies.getReplicatorDispatchRateAsync
(String topic, boolean applied) Get applied replicatorDispatchRate asynchronously.Topics.getReplicatorDispatchRateAsync
(String topic) Deprecated.UseTopicPolicies.getReplicatorDispatchRateAsync(String)
instead.Topics.getReplicatorDispatchRateAsync
(String topic, boolean applied) Deprecated.Namespaces.getSubscriptionDispatchRateAsync
(String namespace) Get subscription-message-dispatch-rate asynchronously.TopicPolicies.getSubscriptionDispatchRateAsync
(String topic) Get subscription-message-dispatch-rate asynchronously.TopicPolicies.getSubscriptionDispatchRateAsync
(String topic, boolean applied) Get applied subscription-message-dispatch-rate asynchronously.TopicPolicies.getSubscriptionDispatchRateAsync
(String topic, String subscriptionName) Async version ofTopicPolicies.getSubscriptionDispatchRate(String, String)
.TopicPolicies.getSubscriptionDispatchRateAsync
(String topic, String subscriptionName, boolean applied) Async version ofTopicPolicies.getSubscriptionDispatchRate(String, String, boolean)
.Topics.getSubscriptionDispatchRateAsync
(String topic) Deprecated.Topics.getSubscriptionDispatchRateAsync
(String namespace, boolean applied) Deprecated.Modifier and TypeMethodDescriptionvoid
Namespaces.setDispatchRate
(String namespace, DispatchRate dispatchRate) Set message-dispatch-rate (topics under this namespace can dispatch this many messages per second).void
TopicPolicies.setDispatchRate
(String topic, DispatchRate dispatchRate) Set message-dispatch-rate (topic can dispatch this many messages per second).void
Topics.setDispatchRate
(String topic, DispatchRate dispatchRate) Deprecated.UseTopicPolicies.setDispatchRate(String, DispatchRate)
instead.Namespaces.setDispatchRateAsync
(String namespace, DispatchRate dispatchRate) Set message-dispatch-rate asynchronously.TopicPolicies.setDispatchRateAsync
(String topic, DispatchRate dispatchRate) Set message-dispatch-rate asynchronously.Topics.setDispatchRateAsync
(String topic, DispatchRate dispatchRate) Deprecated.void
Namespaces.setReplicatorDispatchRate
(String namespace, DispatchRate dispatchRate) Set replicator-message-dispatch-rate.void
TopicPolicies.setReplicatorDispatchRate
(String topic, DispatchRate dispatchRate) Set replicatorDispatchRate for the topic.void
Topics.setReplicatorDispatchRate
(String topic, DispatchRate dispatchRate) Deprecated.Namespaces.setReplicatorDispatchRateAsync
(String namespace, DispatchRate dispatchRate) Set replicator-message-dispatch-rate asynchronously.TopicPolicies.setReplicatorDispatchRateAsync
(String topic, DispatchRate dispatchRate) Set replicatorDispatchRate for the topic asynchronously.Topics.setReplicatorDispatchRateAsync
(String topic, DispatchRate dispatchRate) Deprecated.void
Namespaces.setSubscriptionDispatchRate
(String namespace, DispatchRate dispatchRate) Set subscription-message-dispatch-rate.void
TopicPolicies.setSubscriptionDispatchRate
(String topic, String subscriptionName, DispatchRate dispatchRate) Set dispatch rate limiter for a specific subscription.void
TopicPolicies.setSubscriptionDispatchRate
(String topic, DispatchRate dispatchRate) Set subscription-message-dispatch-rate for the topic.void
Topics.setSubscriptionDispatchRate
(String topic, DispatchRate dispatchRate) Deprecated.Namespaces.setSubscriptionDispatchRateAsync
(String namespace, DispatchRate dispatchRate) Set subscription-message-dispatch-rate asynchronously.TopicPolicies.setSubscriptionDispatchRateAsync
(String topic, String subscriptionName, DispatchRate dispatchRate) Async version ofTopicPolicies.setSubscriptionDispatchRate(String, String, DispatchRate)
.TopicPolicies.setSubscriptionDispatchRateAsync
(String topic, DispatchRate dispatchRate) Set subscription-message-dispatch-rate for the topic asynchronously.Topics.setSubscriptionDispatchRateAsync
(String topic, DispatchRate dispatchRate) Deprecated. -
Uses of DispatchRate in org.apache.pulsar.common.policies.data
-
Uses of DispatchRate in org.apache.pulsar.common.policies.data.impl
TopicPolicies.getDispatchRate(String)
instead.