Package org.nocrala.tools.texttablefmt

Examples of org.nocrala.tools.texttablefmt.Table.render()

1010
1011
1012
1013
1014
1015
1016
1017
1018
1019
1020
                for(ExchangeFarm.ExchangeInfo info: exchanges) {
                    tab.addCell(info.name);
                    tab.addCell(info.host);
                    tab.addCell(String.valueOf(info.refCount), numberStyle);
                }
                myConsole.logResponseNL(tab.render());
            }

            try {
                Table tab = new Table(3);
                tab.addCell("Exchange");
View Full Code Here
1059
1060
1061
1062
1063
1064
1065
1066
1067
1068
1069
                    tab.addCell(String.format("%d messages to %s", alertConfig.getCount(), alertConfig.getReceiver()));
                }

                myConsole.logResponse("%d configured exchanges%n", fixed_ex.size() + drop_ex.size() + limit_ex.size());
                if(fixed_ex.size() + drop_ex.size() + limit_ex.size() > 0)
                    myConsole.logResponseNL(tab.render());
            }
            catch(Exception e) {
                myConsole.logResponseNL(e.getMessage());
            }
        }
View Full Code Here
391
392
393
394
395
396
397
398
399
400
401
                tab.addCell(String.valueOf(b.getReserved()), new CellStyle(HorizontalAlign.center));
                tab.addCell(new SimpleDateFormat("HH:mm:ss").format(loading.get(b.getHost()).getLastUpdate()), new CellStyle(HorizontalAlign.center));
                if(b.getReserved())
                    reserved.add(b.getHost());
            }
            myConsole.logResponseNL(tab.render());

            HashMap<String, List<String>> allFixed = new HashMap<String, List<String>>();
            try {
                ZNode fixNode = new ZNode(ExchangeCommand.ZNODE_FIXED);
                List<String> nodes = fixNode.getChildren();
View Full Code Here
91
92
93
94
95
96
97
98
99
100
101
                    }
                }
            }
            catch(Exception e) {
            }
            strOut.write(tab.render() + "\n");
        }

        strOut.write(String.format("%d connections%n", Daemon.connectionPool.size()));
        if(Daemon.connectionPool.size() > 0) {
            Table tab = new Table(6);
View Full Code Here
111
112
113
114
115
116
117
118
119
120
121
                tab.addCell(conn.getType());
                tab.addCell(conn.getConfig().getUsername() + ":*");
                tab.addCell(conn.getConnectionString());
                tab.addCell(String.valueOf(conn.getReferenceCount()), new CellStyle(HorizontalAlign.right));
            }
            strOut.write(tab.render() + "\n");
        }

        return strOut.toString();
    }
}
View Full Code Here
227
228
229
230
231
232
233
234
235
236
237
            tab.addCell("Status");
            for(ServiceProvider s : services) {
                tab.addCell(String.valueOf(s.getId()));
                tab.addCell(s.isReady() ? "idle": "busy");
            }
            strOut.write(tab.render() + "\n");
        }
        strOut.write(String.format("%d brokers available%n", brokerFarm.getBrokerCount()));
        if(brokerFarm.getBrokerCount() > 0) {
            Table tab = new Table(2);
            tab.addCell("Host");
View Full Code Here
238
239
240
241
242
243
244
245
246
247
248
            tab.addCell("Status");
            for(Entry<String, ZooKeeperInfo.Broker> ent : brokerFarm.getAllBrokers().entrySet()) {
                tab.addCell(ent.getValue().getHost() + ":" + ent.getValue().getPort());
                tab.addCell(ent.getValue().getStatus().toString());
            }
            strOut.write(tab.render() + "\n");
        }
        strOut.write(String.format("%d exchanges transmitted%n", ExchangeMetric.exchangeStat.size()));
        if(ExchangeMetric.exchangeStat.size() > 0) {
            Table tab = new Table(5);
            tab.addCell("Exchange");
View Full Code Here
256
257
258
259
260
261
262
263
264
265
266
                tab.addCell(String.valueOf(info.getMessageInCount()), numberStyle);
                tab.addCell(String.valueOf(info.getMessageInBytes()), numberStyle);
                tab.addCell(String.valueOf(info.getMessageOutCount()), numberStyle);
                tab.addCell(String.valueOf(info.getMessageOutBytes()), numberStyle);
            }
            strOut.write(tab.render() + "\n");
        }
        return strOut.toString();
    }

    public static boolean isShutdownRequested() {
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.