Index
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form
A
- above(double) - Method in class org.acemq.rabbitmq.admin.alerts.Alert
- aboveZero() - Method in class org.acemq.rabbitmq.admin.alerts.Alert
-
Fires when the value is anything but zero.
- Absent is not an error - Search tag in class org.acemq.rabbitmq.admin.RabbitAdmin
- Section
- ackRequired() - Method in class org.acemq.rabbitmq.admin.ConsumerInfo
- active() - Method in class org.acemq.rabbitmq.admin.ConsumerInfo
- active() - Method in class org.acemq.rabbitmq.admin.StreamConsumerInfo
- activityStatus() - Method in class org.acemq.rabbitmq.admin.ConsumerInfo
- A different port, and no credentials - Search tag in class org.acemq.rabbitmq.admin.metrics.PrometheusMetrics
- Section
- AdminException - Exception Class in org.acemq.rabbitmq.admin
-
Something went wrong talking to the management API.
- AdminException(String) - Constructor for exception class org.acemq.rabbitmq.admin.AdminException
- AdminException(String, Throwable) - Constructor for exception class org.acemq.rabbitmq.admin.AdminException
- alarms() - Method in class org.acemq.rabbitmq.admin.Health
- Alert - Class in org.acemq.rabbitmq.admin.alerts
-
Builds an
AlertRule. - AlertEvent - Class in org.acemq.rabbitmq.admin.alerts
-
A rule that breached, and the measurement that breached it.
- AlertRule - Class in org.acemq.rabbitmq.admin.alerts
-
A condition worth waking somebody for, written once and used twice.
- Alerts - Class in org.acemq.rabbitmq.admin.alerts
-
The alerts worth having, ready made.
- Alerts.AlertSet - Class in org.acemq.rabbitmq.admin.alerts
-
Several rules, evaluated and exported together.
- algorithm() - Method in class org.acemq.rabbitmq.admin.PasswordHash
- all(String) - Method in class org.acemq.rabbitmq.admin.metrics.MetricsSnapshot
- and(AlertRule) - Method in class org.acemq.rabbitmq.admin.alerts.Alerts.AlertSet
- applyTo() - Method in class org.acemq.rabbitmq.admin.PolicyInfo
- argument(String) - Method in class org.acemq.rabbitmq.admin.QueueInfo
- arguments() - Method in class org.acemq.rabbitmq.admin.BindingInfo
- arguments() - Method in class org.acemq.rabbitmq.admin.ConsumerInfo
- arguments() - Method in class org.acemq.rabbitmq.admin.ExchangeInfo
- arguments() - Method in class org.acemq.rabbitmq.admin.QueueInfo
-
The arguments the queue was declared with.
- asList() - Method in class org.acemq.rabbitmq.admin.GlobalParameterInfo
- asLong() - Method in class org.acemq.rabbitmq.admin.metrics.MetricSample
- asMap() - Method in class org.acemq.rabbitmq.admin.Definitions
- asMap() - Method in class org.acemq.rabbitmq.admin.GlobalParameterInfo
- asString() - Method in class org.acemq.rabbitmq.admin.GlobalParameterInfo
- at(String) - Static method in class org.acemq.rabbitmq.admin.metrics.PrometheusMetrics
- at(String, Duration) - Static method in class org.acemq.rabbitmq.admin.metrics.PrometheusMetrics
- attempts() - Method in class org.acemq.rabbitmq.admin.AuthAttemptInfo
- AuthAttemptInfo - Class in org.acemq.rabbitmq.admin
-
Login attempts one node has counted, for one protocol and — when the broker tracks sources — one remote address and username.
- AuthAttemptInfo(String, String, String, Long, Long, Long) - Constructor for class org.acemq.rabbitmq.admin.AuthAttemptInfo
- authAttempts(String) - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
-
Login attempts one node has counted, per protocol.
- authAttemptsBySource(String) - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
-
Login attempts one node has counted, per remote address and username.
- autoDelete() - Method in class org.acemq.rabbitmq.admin.ExchangeInfo
- autoDelete() - Method in class org.acemq.rabbitmq.admin.QueueInfo
B
- because() - Method in class org.acemq.rabbitmq.admin.alerts.AlertRule
- because(String) - Method in class org.acemq.rabbitmq.admin.alerts.Alert
-
Why this matters, in a sentence somebody woken at three in the morning can act on.
- beingDrained() - Method in class org.acemq.rabbitmq.admin.NodeInfo
- below(double) - Method in class org.acemq.rabbitmq.admin.alerts.Alert
- belowNodeConnectionLimit() - Method in class org.acemq.rabbitmq.admin.Health
- bindExchange(String, String, String, Map<String, Object>) - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
-
Binds an exchange to another exchange.
- BindingInfo - Class in org.acemq.rabbitmq.admin
-
A binding: the rule joining an exchange to a queue or to another exchange.
- BindingInfo(String, String, String, String, String, Map<String, Object>, String) - Constructor for class org.acemq.rabbitmq.admin.BindingInfo
- bindings() - Method in class org.acemq.rabbitmq.admin.Definitions
- bindings() - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
- bindingsForQueue(String) - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
-
What is bound to a queue.
- bindQueue(String, String, String, Map<String, Object>) - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
-
Binds a queue to an exchange.
C
- canAdminister() - Method in class org.acemq.rabbitmq.admin.CurrentUser
- canManage() - Method in class org.acemq.rabbitmq.admin.UserInfo
- canMonitor() - Method in class org.acemq.rabbitmq.admin.CurrentUser
- certificateExpiration(int, String) - Method in class org.acemq.rabbitmq.admin.Health
-
Whether any TLS certificate expires within the given window.
- ChannelInfo - Class in org.acemq.rabbitmq.admin
-
One channel on one connection.
- ChannelInfo(String, String, String, String, Integer, String, Integer, Integer, Integer, Integer, Boolean, Boolean, Map<String, Object>) - Constructor for class org.acemq.rabbitmq.admin.ChannelInfo
- channelName() - Method in class org.acemq.rabbitmq.admin.ConsumerInfo
- channels() - Method in class org.acemq.rabbitmq.admin.ConnectionInfo
- channels() - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
- check() - Method in class org.acemq.rabbitmq.admin.HealthResult
- checkAll() - Method in class org.acemq.rabbitmq.admin.Health
-
Runs the checks that need no arguments and apply to any broker.
- clearUserLimit(String, String) - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
- clearVhostLimit(String) - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
- clientProperties() - Method in class org.acemq.rabbitmq.admin.ConnectionInfo
- clientProvidedName() - Method in class org.acemq.rabbitmq.admin.StreamConnectionInfo
- close() - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
- closeConnection(String, String) - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
-
Closes a client connection.
- clusterName() - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
- companionMetric() - Method in class org.acemq.rabbitmq.admin.alerts.AlertRule
- component() - Method in class org.acemq.rabbitmq.admin.ParameterInfo
- conditionText() - Method in class org.acemq.rabbitmq.admin.alerts.AlertRule
- configure() - Method in class org.acemq.rabbitmq.admin.PermissionInfo
- confirm() - Method in class org.acemq.rabbitmq.admin.ChannelInfo
- confirmed() - Method in class org.acemq.rabbitmq.admin.StreamPublisherInfo
- connect(String, String, String) - Static method in class org.acemq.rabbitmq.admin.RabbitAdmin
- connect(String, String, String, Duration) - Static method in class org.acemq.rabbitmq.admin.RabbitAdmin
- connectedAt() - Method in class org.acemq.rabbitmq.admin.ConnectionInfo
- connectedAt() - Method in class org.acemq.rabbitmq.admin.StreamConnectionInfo
- connection(String) - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
- ConnectionInfo - Class in org.acemq.rabbitmq.admin
-
One client connection, as the broker sees it.
- ConnectionInfo(String, String, String, String, String, String, String, Integer, Integer, Long, Boolean, String, Map<String, Object>) - Constructor for class org.acemq.rabbitmq.admin.ConnectionInfo
- connectionName() - Method in class org.acemq.rabbitmq.admin.ChannelInfo
- connectionName() - Method in class org.acemq.rabbitmq.admin.StreamConsumerInfo
- connectionName() - Method in class org.acemq.rabbitmq.admin.StreamPublisherInfo
- connections() - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
- consumed() - Method in class org.acemq.rabbitmq.admin.StreamConsumerInfo
- consumerCount() - Method in class org.acemq.rabbitmq.admin.ChannelInfo
- ConsumerInfo - Class in org.acemq.rabbitmq.admin
-
One consumer on one queue.
- ConsumerInfo(String, Map<String, Object>, Boolean, Boolean, Boolean, String, Integer, Map<String, Object>, Map<String, Object>) - Constructor for class org.acemq.rabbitmq.admin.ConsumerInfo
- consumers() - Method in class org.acemq.rabbitmq.admin.QueueInfo
- consumers() - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
- consumerTag() - Method in class org.acemq.rabbitmq.admin.ConsumerInfo
- createUser(String, String, String...) - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
-
Creates or updates a user.
- createUser(String, PasswordHash, String...) - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
-
Creates or updates a user from a hash computed elsewhere.
- createVhost(String) - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
-
Creates a virtual host, or does nothing when it is already there.
- credits() - Method in class org.acemq.rabbitmq.admin.StreamConsumerInfo
- CRITICAL - Enum constant in enum org.acemq.rabbitmq.admin.alerts.Severity
-
Wake somebody.
- CurrentUser - Class in org.acemq.rabbitmq.admin
-
Who the broker thinks you are.
- CurrentUser(String, List<String>, Boolean) - Constructor for class org.acemq.rabbitmq.admin.CurrentUser
D
- deadLetters() - Static method in class org.acemq.rabbitmq.admin.alerts.Alerts
-
Anything in a dead-letter queue.
- deadLetters(String) - Static method in class org.acemq.rabbitmq.admin.alerts.Alerts
- declareExchange(String, String, boolean, Map<String, Object>) - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
- declareQueue(String, boolean, Map<String, Object>) - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
-
Declares a queue.
- declareShovel(String, Map<String, Object>) - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
-
Declares a dynamic shovel, or replaces one of the same name.
- DEFAULT_DEAD_LETTER_PATTERN - Static variable in class org.acemq.rabbitmq.admin.alerts.Alerts
-
The queue names
Alerts.deadLetters()treats as dead-letter queues. - DEFAULT_PORT - Static variable in class org.acemq.rabbitmq.admin.metrics.PrometheusMetrics
-
What RabbitMQ's Prometheus plugin listens on.
- DEFAULT_VHOST - Static variable in class org.acemq.rabbitmq.admin.RabbitAdmin
-
The default virtual host, which is literally a forward slash.
- definition() - Method in class org.acemq.rabbitmq.admin.PolicyInfo
- Definitions - Class in org.acemq.rabbitmq.admin
-
Everything the broker is configured to be, as one document.
- deleteExchange(String) - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
- deleteFederationUpstream(String) - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
- deleteOperatorPolicy(String) - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
- deletePolicy(String) - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
- deleteQueue(String) - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
- deleteShovel(String) - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
- deleteUser(String) - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
- deleteUsers(String...) - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
-
Deletes several users in one request.
- deleteVhost(String) - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
-
Deletes a virtual host and everything in it.
- DeprecatedFeatureInfo - Class in org.acemq.rabbitmq.admin
-
A deprecated feature, and how much time is left.
- DeprecatedFeatureInfo(String, String, String, String) - Constructor for class org.acemq.rabbitmq.admin.DeprecatedFeatureInfo
- deprecatedFeaturesInUse() - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
- deprecationPhase() - Method in class org.acemq.rabbitmq.admin.DeprecatedFeatureInfo
- description() - Method in class org.acemq.rabbitmq.admin.DeprecatedFeatureInfo
- description() - Method in class org.acemq.rabbitmq.admin.FeatureFlagInfo
- description() - Method in class org.acemq.rabbitmq.admin.VhostInfo
- destination() - Method in class org.acemq.rabbitmq.admin.BindingInfo
- destinationType() - Method in class org.acemq.rabbitmq.admin.BindingInfo
- details() - Method in class org.acemq.rabbitmq.admin.HealthResult
- diskAlarm() - Static method in class org.acemq.rabbitmq.admin.alerts.Alerts
-
A broker refusing publishes because it is out of disk.
- diskAlarmApproaching() - Static method in class org.acemq.rabbitmq.admin.alerts.Alerts
-
A node running out of disk.
- docUrl() - Method in class org.acemq.rabbitmq.admin.DeprecatedFeatureInfo
- durable() - Method in class org.acemq.rabbitmq.admin.ExchangeInfo
- durable() - Method in class org.acemq.rabbitmq.admin.QueueInfo
E
- equals(Object) - Method in class org.acemq.rabbitmq.admin.PasswordHash
- error() - Method in class org.acemq.rabbitmq.admin.FederationLinkInfo
- errored() - Method in class org.acemq.rabbitmq.admin.StreamPublisherInfo
- evaluate(MetricsSnapshot) - Method in class org.acemq.rabbitmq.admin.alerts.AlertRule
-
Checks this rule against one scrape.
- evaluate(MetricsSnapshot) - Method in class org.acemq.rabbitmq.admin.alerts.Alerts.AlertSet
- Every call has a timeout - Search tag in class org.acemq.rabbitmq.admin.RabbitAdmin
- Section
- exchange() - Method in class org.acemq.rabbitmq.admin.TopicPermissionInfo
- exchange(String) - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
- ExchangeInfo - Class in org.acemq.rabbitmq.admin
-
An exchange as the broker holds it.
- ExchangeInfo(String, String, String, boolean, boolean, boolean, Map<String, Object>) - Constructor for class org.acemq.rabbitmq.admin.ExchangeInfo
- exchanges() - Method in class org.acemq.rabbitmq.admin.Definitions
- exchanges() - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
- exclusive() - Method in class org.acemq.rabbitmq.admin.ConsumerInfo
- exclusive() - Method in class org.acemq.rabbitmq.admin.QueueInfo
- expires() - Method in class org.acemq.rabbitmq.admin.FederationUpstream
- exportDefinitions() - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
-
Exports everything the broker is configured to be.
- exportVhostDefinitions() - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
- extensions() - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
F
- failed() - Method in class org.acemq.rabbitmq.admin.AuthAttemptInfo
- failures() - Method in class org.acemq.rabbitmq.admin.Health
- FeatureFlagInfo - Class in org.acemq.rabbitmq.admin
-
One feature flag, and whether it is enabled.
- FeatureFlagInfo(String, String, String, String) - Constructor for class org.acemq.rabbitmq.admin.FeatureFlagInfo
- featureFlags() - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
- Federation is not a shovel - Search tag in class org.acemq.rabbitmq.admin.FederationUpstream
- Section
- FederationLinkInfo - Class in org.acemq.rabbitmq.admin
-
A federation link: an upstream and a policy having actually met.
- FederationLinkInfo(String, String, String, String, String) - Constructor for class org.acemq.rabbitmq.admin.FederationLinkInfo
- federationLinks() - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
-
The links that actually exist.
- FederationUpstream - Class in org.acemq.rabbitmq.admin
-
Another broker this one may federate from.
- federationUpstreams() - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
- forQueue(String) - Method in class org.acemq.rabbitmq.admin.metrics.MetricsSnapshot
-
Narrows to one queue.
- forVhost(String) - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
G
- GlobalParameterInfo - Class in org.acemq.rabbitmq.admin
-
A cluster-wide parameter, which is not scoped to a virtual host.
- GlobalParameterInfo(String, Object) - Constructor for class org.acemq.rabbitmq.admin.GlobalParameterInfo
- globalParameters() - Method in class org.acemq.rabbitmq.admin.Definitions
- globalParameters() - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
- grant(String, String, String, String) - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
-
Grants a user access to this client's virtual host.
- grantTopic(String, String, String, String) - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
- groupedBy(String...) - Method in class org.acemq.rabbitmq.admin.alerts.Alert
H
- hasCritical(MetricsSnapshot) - Method in class org.acemq.rabbitmq.admin.alerts.Alerts.AlertSet
- hash() - Method in class org.acemq.rabbitmq.admin.PasswordHash
- hashCode() - Method in class org.acemq.rabbitmq.admin.PasswordHash
- health() - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
-
The broker's own health checks.
- Health - Class in org.acemq.rabbitmq.admin
-
The broker's own health checks.
- HealthResult - Class in org.acemq.rabbitmq.admin
-
The answer to one of the broker's own health checks.
- helpFor(String) - Method in class org.acemq.rabbitmq.admin.metrics.MetricsSnapshot
I
- importDefinitions(String) - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
-
Applies a definitions document to this broker.
- INFO - Enum constant in enum org.acemq.rabbitmq.admin.alerts.Severity
-
Worth knowing when you are already looking.
- internal() - Method in class org.acemq.rabbitmq.admin.ExchangeInfo
- isAtPrefetchLimit() - Method in class org.acemq.rabbitmq.admin.ChannelInfo
- isBlocked() - Method in class org.acemq.rabbitmq.admin.ConnectionInfo
- isDefaultExchangeBinding() - Method in class org.acemq.rabbitmq.admin.BindingInfo
- isDeniedByDefault() - Method in class org.acemq.rabbitmq.admin.DeprecatedFeatureInfo
- isEmpty() - Method in class org.acemq.rabbitmq.admin.metrics.MetricsSnapshot
- isEnabled() - Method in class org.acemq.rabbitmq.admin.FeatureFlagInfo
- isFiring(MetricsSnapshot) - Method in class org.acemq.rabbitmq.admin.alerts.AlertRule
- isHealthy() - Method in class org.acemq.rabbitmq.admin.Health
- isInService() - Method in class org.acemq.rabbitmq.admin.Health
- isInternal() - Method in class org.acemq.rabbitmq.admin.CurrentUser
- isOk() - Method in class org.acemq.rabbitmq.admin.HealthResult
- isRequired() - Method in class org.acemq.rabbitmq.admin.FeatureFlagInfo
- isRunning() - Method in class org.acemq.rabbitmq.admin.FederationLinkInfo
- isRunning() - Method in class org.acemq.rabbitmq.admin.ShovelInfo
- isUnrestricted() - Method in class org.acemq.rabbitmq.admin.PermissionInfo
- isZero() - Method in class org.acemq.rabbitmq.admin.alerts.Alert
J
- json() - Method in class org.acemq.rabbitmq.admin.Definitions
L
- label(String) - Method in class org.acemq.rabbitmq.admin.metrics.MetricSample
- labels() - Method in class org.acemq.rabbitmq.admin.alerts.AlertEvent
- labels() - Method in class org.acemq.rabbitmq.admin.metrics.MetricSample
- lasting() - Method in class org.acemq.rabbitmq.admin.alerts.AlertRule
- lasting(Duration) - Method in class org.acemq.rabbitmq.admin.alerts.Alert
-
How long the condition must hold before it counts.
- limit(String) - Method in class org.acemq.rabbitmq.admin.LimitInfo
- LimitInfo - Class in org.acemq.rabbitmq.admin
-
A limit on a virtual host or a user.
- LimitInfo(String, String, Map<String, Object>) - Constructor for class org.acemq.rabbitmq.admin.LimitInfo
- localAlarms() - Method in class org.acemq.rabbitmq.admin.Health
M
- matches(String) - Method in class org.acemq.rabbitmq.admin.PasswordHash
- MAX_CONNECTIONS - Static variable in class org.acemq.rabbitmq.admin.LimitInfo
-
Limits the number of concurrent connections.
- MAX_QUEUES - Static variable in class org.acemq.rabbitmq.admin.LimitInfo
-
Limits the number of queues that may exist.
- memoryAlarm() - Static method in class org.acemq.rabbitmq.admin.alerts.Alerts
-
A broker refusing publishes because memory is exhausted.
- message() - Method in class org.acemq.rabbitmq.admin.alerts.AlertEvent
- messages() - Method in class org.acemq.rabbitmq.admin.QueueInfo
- messagesReady() - Method in class org.acemq.rabbitmq.admin.QueueInfo
- messagesUnacknowledged() - Method in class org.acemq.rabbitmq.admin.ChannelInfo
- messagesUnacknowledged() - Method in class org.acemq.rabbitmq.admin.QueueInfo
- messagesUnconfirmed() - Method in class org.acemq.rabbitmq.admin.ChannelInfo
- metric() - Method in class org.acemq.rabbitmq.admin.alerts.AlertRule
- metric(String) - Method in class org.acemq.rabbitmq.admin.metrics.MetricsSnapshot
- MetricSample - Class in org.acemq.rabbitmq.admin.metrics
-
One measurement: a metric name, its labels, and a number.
- MetricSample(String, Map<String, String>, double) - Constructor for class org.acemq.rabbitmq.admin.metrics.MetricSample
- MetricsSnapshot - Class in org.acemq.rabbitmq.admin.metrics
-
Everything one scrape returned, queryable.
N
- name() - Method in class org.acemq.rabbitmq.admin.alerts.AlertRule
- name() - Method in class org.acemq.rabbitmq.admin.ChannelInfo
- name() - Method in class org.acemq.rabbitmq.admin.ConnectionInfo
- name() - Method in class org.acemq.rabbitmq.admin.CurrentUser
- name() - Method in class org.acemq.rabbitmq.admin.DeprecatedFeatureInfo
- name() - Method in class org.acemq.rabbitmq.admin.ExchangeInfo
- name() - Method in class org.acemq.rabbitmq.admin.FeatureFlagInfo
- name() - Method in class org.acemq.rabbitmq.admin.FederationUpstream
- name() - Method in class org.acemq.rabbitmq.admin.GlobalParameterInfo
- name() - Method in class org.acemq.rabbitmq.admin.metrics.MetricSample
- name() - Method in class org.acemq.rabbitmq.admin.NodeInfo
- name() - Method in class org.acemq.rabbitmq.admin.ParameterInfo
- name() - Method in class org.acemq.rabbitmq.admin.PolicyInfo
- name() - Method in class org.acemq.rabbitmq.admin.QueueInfo
- name() - Method in class org.acemq.rabbitmq.admin.ShovelInfo
- name() - Method in class org.acemq.rabbitmq.admin.StreamConnectionInfo
- name() - Method in class org.acemq.rabbitmq.admin.StreamConsumerInfo
- name() - Method in class org.acemq.rabbitmq.admin.UserInfo
- name() - Method in class org.acemq.rabbitmq.admin.VhostInfo
- named(String) - Static method in class org.acemq.rabbitmq.admin.alerts.Alert
- node() - Method in class org.acemq.rabbitmq.admin.ChannelInfo
- node() - Method in class org.acemq.rabbitmq.admin.ConnectionInfo
- node() - Method in class org.acemq.rabbitmq.admin.StreamConnectionInfo
- NodeInfo - Class in org.acemq.rabbitmq.admin
-
One node of the cluster.
- NodeInfo(String, String, Boolean, Boolean) - Constructor for class org.acemq.rabbitmq.admin.NodeInfo
- nodes() - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
- Not for a load balancer's readiness probe - Search tag in class org.acemq.rabbitmq.admin.Health
- Section
- number() - Method in class org.acemq.rabbitmq.admin.ChannelInfo
O
- observedAt() - Method in class org.acemq.rabbitmq.admin.alerts.AlertEvent
- of(String, String) - Static method in class org.acemq.rabbitmq.admin.PasswordHash
-
A hash computed elsewhere — read from a secrets store, or out of a definitions export.
- of(AlertRule...) - Static method in class org.acemq.rabbitmq.admin.alerts.Alerts.AlertSet
- offset() - Method in class org.acemq.rabbitmq.admin.StreamConsumerInfo
- offsetLag() - Method in class org.acemq.rabbitmq.admin.StreamConsumerInfo
- on(String) - Method in class org.acemq.rabbitmq.admin.alerts.Alert
- operatorPolicies() - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
-
Policies an operator sets and a user cannot override.
- org.acemq.rabbitmq.admin - package org.acemq.rabbitmq.admin
- org.acemq.rabbitmq.admin.alerts - package org.acemq.rabbitmq.admin.alerts
- org.acemq.rabbitmq.admin.metrics - package org.acemq.rabbitmq.admin.metrics
- orThrow() - Method in class org.acemq.rabbitmq.admin.HealthResult
P
- ParameterInfo - Class in org.acemq.rabbitmq.admin
-
A runtime parameter: how the broker stores a plugin's configuration.
- ParameterInfo(String, String, String, Map<String, Object>) - Constructor for class org.acemq.rabbitmq.admin.ParameterInfo
- parameters() - Method in class org.acemq.rabbitmq.admin.Definitions
- parameters(String) - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
-
Runtime parameters of one component.
- parse(String) - Static method in class org.acemq.rabbitmq.admin.metrics.PrometheusMetrics
-
Parses the Prometheus text exposition format.
- PasswordHash - Class in org.acemq.rabbitmq.admin
-
A password hashed the way RabbitMQ's internal user database stores it.
- pattern() - Method in class org.acemq.rabbitmq.admin.PolicyInfo
- peerHost() - Method in class org.acemq.rabbitmq.admin.ConnectionInfo
- peerHost() - Method in class org.acemq.rabbitmq.admin.StreamConnectionInfo
- peerPort() - Method in class org.acemq.rabbitmq.admin.ConnectionInfo
- peerPort() - Method in class org.acemq.rabbitmq.admin.StreamConnectionInfo
- PermissionInfo - Class in org.acemq.rabbitmq.admin
-
What a user may do in a virtual host.
- PermissionInfo(String, String, String, String, String) - Constructor for class org.acemq.rabbitmq.admin.PermissionInfo
- permissions() - Method in class org.acemq.rabbitmq.admin.Definitions
- permissions() - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
- policies() - Method in class org.acemq.rabbitmq.admin.Definitions
- policies() - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
- PolicyInfo - Class in org.acemq.rabbitmq.admin
-
A policy: settings applied to whatever matches a pattern.
- PolicyInfo(String, String, String, String, Integer, Map<String, Object>) - Constructor for class org.acemq.rabbitmq.admin.PolicyInfo
- portListener(int) - Method in class org.acemq.rabbitmq.admin.Health
- prefetchCount() - Method in class org.acemq.rabbitmq.admin.ChannelInfo
- prefetchCount() - Method in class org.acemq.rabbitmq.admin.ConsumerInfo
- priority() - Method in class org.acemq.rabbitmq.admin.PolicyInfo
- PrometheusMetrics - Class in org.acemq.rabbitmq.admin.metrics
-
Reads RabbitMQ's Prometheus endpoint.
- propertiesKey() - Method in class org.acemq.rabbitmq.admin.BindingInfo
-
The broker's identifier for this binding, needed to delete it.
- protocol() - Method in class org.acemq.rabbitmq.admin.AuthAttemptInfo
- protocol() - Method in class org.acemq.rabbitmq.admin.ConnectionInfo
- protocolListener(String) - Method in class org.acemq.rabbitmq.admin.Health
- published() - Method in class org.acemq.rabbitmq.admin.StreamPublisherInfo
- publisherId() - Method in class org.acemq.rabbitmq.admin.StreamPublisherInfo
- purgeQueue(String) - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
-
Discards every message in a queue, keeping the queue.
- putFederationUpstream(String, String, Map<String, Object>) - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
-
Declares an upstream, or replaces one of the same name.
- putOperatorPolicy(String, String, Map<String, Object>, int) - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
- putPolicy(String, String, Map<String, Object>, int) - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
-
Creates or replaces a policy.
Q
- queue() - Method in class org.acemq.rabbitmq.admin.alerts.AlertEvent
- queue() - Method in class org.acemq.rabbitmq.admin.ConsumerInfo
- queue() - Method in class org.acemq.rabbitmq.admin.metrics.MetricSample
- queue(String) - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
-
Looks a queue up, with the arguments the broker actually holds.
- QueueInfo - Class in org.acemq.rabbitmq.admin
-
A queue as the broker actually holds it.
- QueueInfo(String, String, String, boolean, boolean, boolean, Map<String, Object>, Long, Long, Long, Integer, String) - Constructor for class org.acemq.rabbitmq.admin.QueueInfo
- queueNotDraining() - Static method in class org.acemq.rabbitmq.admin.alerts.Alerts
-
A backlog with nobody reading it.
- queues() - Method in class org.acemq.rabbitmq.admin.Definitions
- queues() - Method in class org.acemq.rabbitmq.admin.metrics.MetricsSnapshot
- queues() - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
- quorumCritical() - Method in class org.acemq.rabbitmq.admin.Health
-
Whether any quorum queue would lose its majority if one more node went down.
R
- RabbitAdmin - Class in org.acemq.rabbitmq.admin
-
RabbitMQ's HTTP management API.
- rabbitVersion() - Method in class org.acemq.rabbitmq.admin.Definitions
- read() - Method in class org.acemq.rabbitmq.admin.PermissionInfo
- read() - Method in class org.acemq.rabbitmq.admin.TopicPermissionInfo
- readyToServeClients() - Method in class org.acemq.rabbitmq.admin.Health
- reason() - Method in class org.acemq.rabbitmq.admin.HealthResult
- rebalanceQueues() - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
-
Moves queue leaders so each node leads a fair share.
- recommended() - Static method in class org.acemq.rabbitmq.admin.alerts.Alerts
- redactedUri() - Method in class org.acemq.rabbitmq.admin.FederationUpstream
- reference() - Method in class org.acemq.rabbitmq.admin.StreamPublisherInfo
- remoteAddress() - Method in class org.acemq.rabbitmq.admin.AuthAttemptInfo
- resetAuthAttempts(String) - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
-
Zeroes one node's login counters, the per-protocol totals and the per-source entries alike — after a misconfigured client is fixed, say, so a failure that follows is a new one.
- revoke(String) - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
- revokeTopic(String) - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
- routingKey() - Method in class org.acemq.rabbitmq.admin.BindingInfo
- rule() - Method in class org.acemq.rabbitmq.admin.alerts.AlertEvent
- rules() - Method in class org.acemq.rabbitmq.admin.alerts.Alerts.AlertSet
- running() - Method in class org.acemq.rabbitmq.admin.NodeInfo
S
- sample() - Method in class org.acemq.rabbitmq.admin.alerts.AlertEvent
- samples() - Method in class org.acemq.rabbitmq.admin.metrics.MetricsSnapshot
- scrape() - Method in class org.acemq.rabbitmq.admin.metrics.PrometheusMetrics
- scrapeDetailed() - Method in class org.acemq.rabbitmq.admin.metrics.PrometheusMetrics
- scrapeDetailed(String...) - Method in class org.acemq.rabbitmq.admin.metrics.PrometheusMetrics
- settings() - Method in class org.acemq.rabbitmq.admin.FederationUpstream
- setUserLimit(String, String, long) - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
- setVhostLimit(String, long) - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
- severity() - Method in class org.acemq.rabbitmq.admin.alerts.AlertRule
- severity(Severity) - Method in class org.acemq.rabbitmq.admin.alerts.Alert
- Severity - Enum in org.acemq.rabbitmq.admin.alerts
-
How much this matters.
- sha256(String) - Static method in class org.acemq.rabbitmq.admin.PasswordHash
- SHA256 - Static variable in class org.acemq.rabbitmq.admin.PasswordHash
-
RabbitMQ's default since 3.6.
- sha512(String) - Static method in class org.acemq.rabbitmq.admin.PasswordHash
- SHA512 - Static variable in class org.acemq.rabbitmq.admin.PasswordHash
-
Accepted by every broker that accepts
PasswordHash.SHA256. - ShovelInfo - Class in org.acemq.rabbitmq.admin
-
A shovel: the broker moving messages from one place to another, on its own.
- ShovelInfo(String, String, String, String) - Constructor for class org.acemq.rabbitmq.admin.ShovelInfo
- shovels() - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
- source() - Method in class org.acemq.rabbitmq.admin.BindingInfo
- ssl() - Method in class org.acemq.rabbitmq.admin.ConnectionInfo
- stability() - Method in class org.acemq.rabbitmq.admin.FeatureFlagInfo
- state() - Method in class org.acemq.rabbitmq.admin.ChannelInfo
- state() - Method in class org.acemq.rabbitmq.admin.ConnectionInfo
- state() - Method in class org.acemq.rabbitmq.admin.FeatureFlagInfo
- state() - Method in class org.acemq.rabbitmq.admin.QueueInfo
- state() - Method in class org.acemq.rabbitmq.admin.ShovelInfo
- state() - Method in class org.acemq.rabbitmq.admin.StreamConnectionInfo
- status() - Method in class org.acemq.rabbitmq.admin.FederationLinkInfo
- stream() - Method in class org.acemq.rabbitmq.admin.StreamConsumerInfo
- stream() - Method in class org.acemq.rabbitmq.admin.StreamPublisherInfo
- StreamConnectionInfo - Class in org.acemq.rabbitmq.admin
-
One connection over RabbitMQ's stream protocol, on port 5552.
- StreamConnectionInfo(String, String, String, String, String, String, Integer, String, Long) - Constructor for class org.acemq.rabbitmq.admin.StreamConnectionInfo
- streamConnections() - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
-
Connections over the stream protocol, across all virtual hosts.
- StreamConsumerInfo - Class in org.acemq.rabbitmq.admin
-
One subscription on a stream protocol connection.
- StreamConsumerInfo(Integer, Object, Map<String, Object>, Object, Boolean, Long, Long, Long, Long) - Constructor for class org.acemq.rabbitmq.admin.StreamConsumerInfo
- streamConsumers() - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
-
There is no per-stream form of this, unlike
RabbitAdmin.streamPublishers(String):/api/stream/consumers/{vhost}/{stream}answers 400 on 3.13 and 4.x alike. - StreamPublisherInfo - Class in org.acemq.rabbitmq.admin
-
One publisher on a stream protocol connection.
- StreamPublisherInfo(String, Integer, Map<String, Object>, Object, Long, Long, Long) - Constructor for class org.acemq.rabbitmq.admin.StreamPublisherInfo
- streamPublishers() - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
- streamPublishers(String) - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
- subscriptionId() - Method in class org.acemq.rabbitmq.admin.StreamConsumerInfo
- succeeded() - Method in class org.acemq.rabbitmq.admin.AuthAttemptInfo
- sum(String) - Method in class org.acemq.rabbitmq.admin.metrics.MetricsSnapshot
- summary() - Method in class org.acemq.rabbitmq.admin.Definitions
T
- tags() - Method in class org.acemq.rabbitmq.admin.CurrentUser
- tags() - Method in class org.acemq.rabbitmq.admin.UserInfo
- takenAt() - Method in class org.acemq.rabbitmq.admin.metrics.MetricsSnapshot
- The URI carries credentials - Search tag in class org.acemq.rabbitmq.admin.FederationUpstream
- Section
- toAlertName() - Method in class org.acemq.rabbitmq.admin.alerts.AlertRule
- TopicPermissionInfo - Class in org.acemq.rabbitmq.admin
-
Authorisation for routing keys on a topic exchange.
- TopicPermissionInfo(String, String, String, String, String) - Constructor for class org.acemq.rabbitmq.admin.TopicPermissionInfo
- topicPermissions() - Method in class org.acemq.rabbitmq.admin.Definitions
- topicPermissions() - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
-
Routing-key authorisation on topic exchanges.
- toPrometheusRule() - Method in class org.acemq.rabbitmq.admin.alerts.AlertRule
-
Renders this rule as Prometheus alerting-rule YAML.
- toPrometheusRules() - Method in class org.acemq.rabbitmq.admin.alerts.Alerts.AlertSet
- toString() - Method in class org.acemq.rabbitmq.admin.alerts.AlertEvent
- toString() - Method in class org.acemq.rabbitmq.admin.alerts.AlertRule
- toString() - Method in class org.acemq.rabbitmq.admin.AuthAttemptInfo
- toString() - Method in class org.acemq.rabbitmq.admin.BindingInfo
- toString() - Method in class org.acemq.rabbitmq.admin.ChannelInfo
- toString() - Method in class org.acemq.rabbitmq.admin.ConnectionInfo
- toString() - Method in class org.acemq.rabbitmq.admin.ConsumerInfo
- toString() - Method in class org.acemq.rabbitmq.admin.CurrentUser
- toString() - Method in class org.acemq.rabbitmq.admin.Definitions
- toString() - Method in class org.acemq.rabbitmq.admin.DeprecatedFeatureInfo
- toString() - Method in class org.acemq.rabbitmq.admin.ExchangeInfo
- toString() - Method in class org.acemq.rabbitmq.admin.FeatureFlagInfo
- toString() - Method in class org.acemq.rabbitmq.admin.FederationLinkInfo
- toString() - Method in class org.acemq.rabbitmq.admin.FederationUpstream
- toString() - Method in class org.acemq.rabbitmq.admin.GlobalParameterInfo
- toString() - Method in class org.acemq.rabbitmq.admin.HealthResult
- toString() - Method in class org.acemq.rabbitmq.admin.LimitInfo
- toString() - Method in class org.acemq.rabbitmq.admin.metrics.MetricSample
- toString() - Method in class org.acemq.rabbitmq.admin.metrics.MetricsSnapshot
- toString() - Method in class org.acemq.rabbitmq.admin.metrics.PrometheusMetrics
- toString() - Method in class org.acemq.rabbitmq.admin.NodeInfo
- toString() - Method in class org.acemq.rabbitmq.admin.ParameterInfo
- toString() - Method in class org.acemq.rabbitmq.admin.PasswordHash
- toString() - Method in class org.acemq.rabbitmq.admin.PermissionInfo
- toString() - Method in class org.acemq.rabbitmq.admin.PolicyInfo
- toString() - Method in class org.acemq.rabbitmq.admin.QueueInfo
- toString() - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
- toString() - Method in class org.acemq.rabbitmq.admin.ShovelInfo
- toString() - Method in class org.acemq.rabbitmq.admin.StreamConnectionInfo
- toString() - Method in class org.acemq.rabbitmq.admin.StreamConsumerInfo
- toString() - Method in class org.acemq.rabbitmq.admin.StreamPublisherInfo
- toString() - Method in class org.acemq.rabbitmq.admin.TopicPermissionInfo
- toString() - Method in class org.acemq.rabbitmq.admin.UserInfo
- toString() - Method in class org.acemq.rabbitmq.admin.VhostInfo
- tracing() - Method in class org.acemq.rabbitmq.admin.VhostInfo
- transactional() - Method in class org.acemq.rabbitmq.admin.ChannelInfo
- Two endpoints, and the difference matters - Search tag in class org.acemq.rabbitmq.admin.metrics.PrometheusMetrics
- Section
- type() - Method in class org.acemq.rabbitmq.admin.ExchangeInfo
- type() - Method in class org.acemq.rabbitmq.admin.FederationLinkInfo
- type() - Method in class org.acemq.rabbitmq.admin.NodeInfo
- type() - Method in class org.acemq.rabbitmq.admin.QueueInfo
- type() - Method in class org.acemq.rabbitmq.admin.ShovelInfo
U
- unbind(BindingInfo) - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
-
Removes a binding.
- upstream() - Method in class org.acemq.rabbitmq.admin.FederationLinkInfo
- uri() - Method in class org.acemq.rabbitmq.admin.FederationUpstream
- user() - Method in class org.acemq.rabbitmq.admin.ChannelInfo
- user() - Method in class org.acemq.rabbitmq.admin.ConnectionInfo
- user() - Method in class org.acemq.rabbitmq.admin.LimitInfo
- user() - Method in class org.acemq.rabbitmq.admin.PermissionInfo
- user() - Method in class org.acemq.rabbitmq.admin.StreamConnectionInfo
- user() - Method in class org.acemq.rabbitmq.admin.TopicPermissionInfo
- UserInfo - Class in org.acemq.rabbitmq.admin
-
A broker user.
- UserInfo(String, Object) - Constructor for class org.acemq.rabbitmq.admin.UserInfo
- userLimits() - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
- username() - Method in class org.acemq.rabbitmq.admin.AuthAttemptInfo
- userProvidedName() - Method in class org.acemq.rabbitmq.admin.ConnectionInfo
- users() - Method in class org.acemq.rabbitmq.admin.Definitions
- users() - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
- usersWithoutPermissions() - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
-
Users that cannot reach any virtual host.
V
- value() - Method in class org.acemq.rabbitmq.admin.alerts.AlertEvent
- value() - Method in class org.acemq.rabbitmq.admin.GlobalParameterInfo
- value() - Method in class org.acemq.rabbitmq.admin.LimitInfo
- value() - Method in class org.acemq.rabbitmq.admin.metrics.MetricSample
- value() - Method in class org.acemq.rabbitmq.admin.ParameterInfo
- valueOf(String) - Static method in enum org.acemq.rabbitmq.admin.alerts.Severity
-
Returns the enum constant of this type with the specified name.
- values() - Static method in enum org.acemq.rabbitmq.admin.alerts.Severity
-
Returns an array containing the constants of this enum type, in the order they are declared.
- version() - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
-
Checks the broker is reachable and the credentials work.
- vhost() - Method in class org.acemq.rabbitmq.admin.BindingInfo
- vhost() - Method in class org.acemq.rabbitmq.admin.ChannelInfo
- vhost() - Method in class org.acemq.rabbitmq.admin.ConnectionInfo
- vhost() - Method in class org.acemq.rabbitmq.admin.ConsumerInfo
- vhost() - Method in class org.acemq.rabbitmq.admin.ExchangeInfo
- vhost() - Method in class org.acemq.rabbitmq.admin.FederationLinkInfo
- vhost() - Method in class org.acemq.rabbitmq.admin.FederationUpstream
- vhost() - Method in class org.acemq.rabbitmq.admin.LimitInfo
- vhost() - Method in class org.acemq.rabbitmq.admin.ParameterInfo
- vhost() - Method in class org.acemq.rabbitmq.admin.PermissionInfo
- vhost() - Method in class org.acemq.rabbitmq.admin.PolicyInfo
- vhost() - Method in class org.acemq.rabbitmq.admin.QueueInfo
- vhost() - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
- vhost() - Method in class org.acemq.rabbitmq.admin.ShovelInfo
- vhost() - Method in class org.acemq.rabbitmq.admin.StreamConnectionInfo
- vhost() - Method in class org.acemq.rabbitmq.admin.StreamConsumerInfo
- vhost() - Method in class org.acemq.rabbitmq.admin.StreamPublisherInfo
- vhost() - Method in class org.acemq.rabbitmq.admin.TopicPermissionInfo
- VhostInfo - Class in org.acemq.rabbitmq.admin
-
A virtual host: the broker's unit of isolation, and the cheapest boundary it offers.
- VhostInfo(String, String, boolean) - Constructor for class org.acemq.rabbitmq.admin.VhostInfo
- vhostLimits() - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
- vhosts() - Method in class org.acemq.rabbitmq.admin.Definitions
- vhosts() - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
- virtualHosts() - Method in class org.acemq.rabbitmq.admin.Health
W
- WARNING - Enum constant in enum org.acemq.rabbitmq.admin.alerts.Severity
-
Look at it today.
- What is deliberately not here - Search tag in class org.acemq.rabbitmq.admin.alerts.Alerts
- Section
- What it does not contain - Search tag in class org.acemq.rabbitmq.admin.Definitions
- Section
- What this is not - Search tag in class org.acemq.rabbitmq.admin.alerts.AlertRule
- Section
- where(String, String) - Method in class org.acemq.rabbitmq.admin.alerts.Alert
-
Narrows the rule to the samples whose label matches.
- where(Predicate<MetricSample>) - Method in class org.acemq.rabbitmq.admin.metrics.MetricsSnapshot
- whileZero(String) - Method in class org.acemq.rabbitmq.admin.alerts.Alert
-
Requires a second metric on the same object to be zero at the same time.
- whoami() - Method in class org.acemq.rabbitmq.admin.RabbitAdmin
- Why both - Search tag in class org.acemq.rabbitmq.admin.alerts.AlertRule
- Section
- Why these rather than metrics - Search tag in class org.acemq.rabbitmq.admin.Health
- Section
- Why this beats walking the topology - Search tag in class org.acemq.rabbitmq.admin.Definitions
- Section
- withLabel(String, String) - Method in class org.acemq.rabbitmq.admin.metrics.MetricsSnapshot
- write() - Method in class org.acemq.rabbitmq.admin.PermissionInfo
- write() - Method in class org.acemq.rabbitmq.admin.TopicPermissionInfo
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form