Uses of Class
org.apache.pulsar.common.policies.data.PublishRate
Package
Description
Implementation of policies.
-
Uses of PublishRate in org.apache.pulsar.client.admin
Modifier and TypeMethodDescriptionNamespaces.getPublishRate
(String namespace) Get message-publish-rate (topics under this namespace can publish this many messages per second).TopicPolicies.getPublishRate
(String topic) Get message-publish-rate (topics can publish this many messages per second).Topics.getPublishRate
(String topic) Deprecated.Modifier and TypeMethodDescriptionNamespaces.getPublishRateAsync
(String namespace) Get message-publish-rate (topics under this namespace can publish this many messages per second) asynchronously.TopicPolicies.getPublishRateAsync
(String topic) Get message-publish-rate (topics can publish this many messages per second) asynchronously.Topics.getPublishRateAsync
(String topic) Deprecated.UseTopicPolicies.getPublishRateAsync(String)
instead.Modifier and TypeMethodDescriptionvoid
Namespaces.setPublishRate
(String namespace, PublishRate publishMsgRate) Set message-publish-rate (topics under this namespace can publish this many messages per second).void
TopicPolicies.setPublishRate
(String topic, PublishRate publishMsgRate) Set message-publish-rate (topics can publish this many messages per second).void
Topics.setPublishRate
(String topic, PublishRate publishMsgRate) Deprecated.UseTopicPolicies.setPublishRate(String, PublishRate)
instead.Namespaces.setPublishRateAsync
(String namespace, PublishRate publishMsgRate) Set message-publish-rate (topics under this namespace can publish this many messages per second) asynchronously.TopicPolicies.setPublishRateAsync
(String topic, PublishRate publishMsgRate) Set message-publish-rate (topics can publish this many messages per second) asynchronously.Topics.setPublishRateAsync
(String topic, PublishRate publishMsgRate) Deprecated. -
Uses of PublishRate in org.apache.pulsar.common.policies.data
Modifier and TypeMethodDescriptionstatic PublishRate
PublishRate.normalize
(PublishRate publishRate) Modifier and TypeMethodDescriptionstatic PublishRate
PublishRate.normalize
(PublishRate publishRate)
TopicPolicies.getPublishRate(String)
instead.