Index

A B C D E F G H I J L M N O P Q R S T U V W 
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
 
A B C D E F G H I J L M N O P Q R S T U V W 
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form