this.id = id; this.dispatcher = new MessageDispatcher(this); this.txnManager = new TransactionManager(this);
dispatcher.addListener(listener);
return txnManager.cancelTransaction(type);
AEDiagnosticsLogger diag_logger = AEDiagnostics.getLogger("v3.CMsgr"); diag_logger.log("[" + id + "] " + message); if (Constants.DIAG_TO_STDOUT) { System.out.println("[" + id + "] " + message); }
AEDiagnosticsLogger diag_logger = AEDiagnostics.getLogger("v3.CMsgr"); diag_logger.log("[" + id + "] " + message); diag_logger.log(t); if (Constants.DIAG_TO_STDOUT) { System.err.println("[" + id + "] " + message); t.printStackTrace(); }
return id;
return dispatcher;
return txnManager.getTransaction(type);
return txnManager;
txnManager.registerTransactionType(type, clazz);
dispatcher.removeListener(listener);
dispatcher.removeListener(listenerId);
return txnManager.startTransaction(type);