}
}
+ @SuppressWarnings("deprecation") //IGetUpdates intentionally deprecated
public void _unlisten(CommandInterpreter ci) {
if (this.icluster == null) {
ci.println("\nNo Clustering services available");
}
public void _dumper(CommandInterpreter ci) {
- ConcurrentMap c;
+ ConcurrentMap<Object, Object> c;
String containerName = ci.nextArgument();
if (containerName == null) {
ci.println("containerName not supplied");
ci.println("Cache not supplied");
return;
}
- c = (ConcurrentMap) this.icluster.getCache(containerName, cacheName);
+ c = (ConcurrentMap<Object, Object>) this.icluster.getCache(containerName, cacheName);
if (c != null) {
- for (Object e : c.entrySet()) {
- Map.Entry entry = (Map.Entry) e;
+ for (Map.Entry<Object, Object> e : c.entrySet()) {
+ Map.Entry<Object, Object> entry = e;
Object v = entry.getValue();
String res = "<NOT KNOWN>";
if (v != null) {
}
}
+ @SuppressWarnings("deprecation") //TODO: remove call to deprecated amIStandby
public void _getRole(CommandInterpreter ci) {
if (this.icluster == null) {
ci.println("\nNo Clustering services available");
ci.println("My role is: " + role);
}
+ @SuppressWarnings("deprecation") //TODO: remove call to deprecated getActiveAddres
public void _getActive(CommandInterpreter ci) {
if (this.icluster == null) {
ci.println("\nNo Clustering services available");
+ this.icluster.getActiveAddress());
}
+ @SuppressWarnings("deprecation") //TODO: remove use of deprecated listenRoleChange
public void _listenActive(CommandInterpreter ci) {
if (this.icluster == null) {
ci.println("\nNo Clustering services available");
ci.println("Register listenRoleChanges");
}
+ @SuppressWarnings("deprecation") //TODO: remove deprecated call to unlistenRoleChange
public void _unlistenActive(CommandInterpreter ci) {
if (this.icluster == null) {
ci.println("\nNo Clustering services available");