Package com.linkedin.databus.monitoring.mbean

Examples of com.linkedin.databus.monitoring.mbean.EventSourceStatistics.addError()

1189
1190
1191
1192
1193
1194
1195
1196
1197
1198
1199
          _rc.incrementEventCount();
          dbUpdatesEventsSize += serializedValue.length;
        }
        catch (IOException io)
        {
          perSourceStats.addError();
          globalStats.addEmptyEventCycle();
          _log.error("Cannot create byte stream payload: " + dbUpdates.get(i).getSourceId());
        }
      }
      long endDbUpdatesMs = System.currentTimeMillis();
View Full Code Here
447
448
449
450
451
452
453
454
455
456
457
              throw new DatabusException("Unable to append DBChangeEntry (" + c + ") to event buffer !!");
            }
            dbUpdatesEventsSize += length;
          } catch (DatabusException e) {
            _log.error("Got databus exception :", e);
            perSourceStats.addError();
            globalStats.addEmptyEventCycle();
            throw e;
          } catch (UnsupportedKeyException e) {
            perSourceStats.addError();
            globalStats.addEmptyEventCycle();
View Full Code Here
451
452
453
454
455
456
457
458
459
460
461
            _log.error("Got databus exception :", e);
            perSourceStats.addError();
            globalStats.addEmptyEventCycle();
            throw e;
          } catch (UnsupportedKeyException e) {
            perSourceStats.addError();
            globalStats.addEmptyEventCycle();
            _log.error("Got UnsupportedKeyException :", e);
            throw e;
          } catch (EventCreationException e) {
            perSourceStats.addError();
View Full Code Here
456
457
458
459
460
461
462
463
464
465
466
            perSourceStats.addError();
            globalStats.addEmptyEventCycle();
            _log.error("Got UnsupportedKeyException :", e);
            throw e;
          } catch (EventCreationException e) {
            perSourceStats.addError();
            globalStats.addEmptyEventCycle();
            _log.error("Got EventCreationException :", e);
            throw e;
          }
          perSourceStats.addEventCycle(1, txn.getTxnReadLatencyNanos(), length, scn);
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.