Skip to content

Commit

Permalink
Add effective_policy_definition to QueueInfo
Browse files Browse the repository at this point in the history
References rabbitmq#460
  • Loading branch information
ifyun committed Jun 12, 2024
1 parent 630a688 commit 83f8ca2
Showing 1 changed file with 24 additions and 0 deletions.
24 changes: 24 additions & 0 deletions src/main/java/com/rabbitmq/http/client/domain/QueueInfo.java
Original file line number Diff line number Diff line change
Expand Up @@ -80,6 +80,9 @@
// "name": "langohr.tests2.queues.non-auto-deleted1",
// "node": "rabbit@mercurio",
// "policy": "",
// "effective_policy_definition": {
// "overflow": "reject-publish"
// }
// "recoverable_slaves": "",
// "state": "running",
// "vhost": "/"
Expand All @@ -100,6 +103,10 @@ public class QueueInfo {
private String exclusiveConsumerTag;
private String state;
private String policy;
@JsonIgnore
private PolicyInfo policyInfo;
@JsonProperty("effective_policy_definition")
private Map<String, Object> effectivePolicyDefinition;
@JsonProperty("idle_since")
private String idleSince;

Expand Down Expand Up @@ -270,6 +277,22 @@ public void setPolicy(String policy) {
this.policy = policy;
}

public PolicyInfo getPolicyInfo() {
return policyInfo;
}

public void setPolicyInfo(PolicyInfo policyInfo) {
this.policyInfo = policyInfo;
}

public Map<String, Object> getEffectivePolicyDefinition() {
return effectivePolicyDefinition;
}

public void setEffectivePolicyDefinition(Map<String, Object> effectivePolicyDefinition) {
this.effectivePolicyDefinition = effectivePolicyDefinition;
}

public String getIdleSince() {
return idleSince;
}
Expand Down Expand Up @@ -511,6 +534,7 @@ public String toString() {
", exclusiveConsumerTag='" + exclusiveConsumerTag + '\'' +
", state='" + state + '\'' +
", policy='" + policy + '\'' +
", effective_policy_definition='" + effectivePolicyDefinition + '\'' +
", idleSince='" + idleSince + '\'' +
", diskReads=" + diskReads +
", diskWrites=" + diskWrites +
Expand Down

0 comments on commit 83f8ca2

Please sign in to comment.