AgentMBeanImpl.java
3.11 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
/*
* Decompiled with CFR 0_118.
*
* Could not load the following classes:
* com.adobe.granite.jmx.annotation.AnnotatedStandardMBean
*/
package com.day.cq.replication.impl;
import com.adobe.granite.jmx.annotation.AnnotatedStandardMBean;
import com.day.cq.replication.Agent;
import com.day.cq.replication.ReplicationQueue;
import com.day.cq.replication.impl.AgentMBean;
import java.util.Date;
import java.util.List;
import javax.management.NotCompliantMBeanException;
public class AgentMBeanImpl
extends AnnotatedStandardMBean
implements AgentMBean {
private final Agent agent;
protected AgentMBeanImpl(Agent agent) throws NotCompliantMBeanException {
super(AgentMBean.class);
this.agent = agent;
}
@Override
public String getId() {
return this.agent.getId();
}
@Override
public boolean isEnabled() {
return this.agent.isEnabled();
}
@Override
public boolean isValid() {
return this.agent.isValid();
}
@Override
public boolean isQueueBlocked() {
ReplicationQueue q = this.agent.getQueue();
ReplicationQueue.Status s = q == null ? null : q.getStatus();
return s != null && s.getNextRetryTime() > 0;
}
@Override
public boolean isQueuePaused() {
ReplicationQueue q = this.agent.getQueue();
return q != null && q.isPaused();
}
@Override
public void setQueuePaused(boolean paused) {
ReplicationQueue q = this.agent.getQueue();
if (q != null) {
q.setPaused(paused);
}
}
@Override
public long getQueueNumEntries() {
ReplicationQueue q = this.agent.getQueue();
return q == null ? 0 : (long)q.entries().size();
}
@Override
public void queueForceRetry() {
ReplicationQueue q = this.agent.getQueue();
if (q != null) {
q.forceRetry();
}
}
@Override
public Date getQueueStatusTime() {
ReplicationQueue q = this.agent.getQueue();
ReplicationQueue.Status s = q == null ? null : q.getStatus();
return s == null ? null : new Date(s.getStatusTime());
}
@Override
public Date getQueueNextRetryTime() {
ReplicationQueue q = this.agent.getQueue();
ReplicationQueue.Status s = q == null ? null : q.getStatus();
return s == null || s.getNextRetryTime() <= 0 ? null : new Date(s.getNextRetryTime());
}
@Override
public Date getQueueProcessingSince() {
ReplicationQueue q = this.agent.getQueue();
ReplicationQueue.Status s = q == null ? null : q.getStatus();
return s == null || s.getProcessingSince() <= 0 ? null : new Date(s.getProcessingSince());
}
@Override
public Date getQueueLastProcessTime() {
ReplicationQueue q = this.agent.getQueue();
ReplicationQueue.Status s = q == null ? null : q.getStatus();
return s == null || s.getLastProcessTime() <= 0 ? null : new Date(s.getLastProcessTime());
}
@Override
public void queueClear() {
ReplicationQueue q = this.agent.getQueue();
if (q != null) {
q.clear();
}
}
}