@Test public void singleStatement() throws Exception { AuditEntry expectedAuditEntry = likeGenericRecord().build(); logger.log(expectedAuditEntry); assertThatWireMatchRecord(expectedAuditEntry); }
@Override public void log(AuditEntry logEntry) { AuditRecordWriteMarshallable auditRecordWriteMarshallable = new AuditRecordWriteMarshallable(logEntry, configuredFields); try { writer.put(auditRecordWriteMarshallable); } catch (InterruptedException e) { LOG.warn("Interrupted while sending message to Chronicle writer"); Thread.currentThread().interrupt(); } }
ChronicleAuditLogger implements AuditLogger { @Override public void log(AuditEntry logEntry) { AuditRecordWriteMarshallable auditRecordWriteMarshallable = new AuditRecordWriteMarshallable(logEntry, configuredFields); try { writer.put(auditRecordWriteMarshallable); } catch (InterruptedException e) { LOG.warn("Interrupted while sending message to Chronicle writer"); Thread.currentThread().interrupt(); } } }
ChronicleAuditLogger implements AuditLogger { @Override public void log(AuditEntry logEntry) { AuditRecordWriteMarshallable auditRecordWriteMarshallable = new AuditRecordWriteMarshallable(logEntry, configuredFields); try { writer.put(auditRecordWriteMarshallable); } catch (InterruptedException e) { LOG.warn("Interrupted while sending message to Chronicle writer"); Thread.currentThread().interrupt(); } } ChronicleAuditLogger(Map<String, String> parameters); @VisibleForTesting  ChronicleAuditLogger(ChronicleWriter writer, FieldSelector configuredFields); }
ChronicleAuditLogger implements AuditLogger { @Override public void log(AuditEntry logEntry) { AuditRecordWriteMarshallable auditRecordWriteMarshallable = new AuditRecordWriteMarshallable(logEntry, configuredFields); try { writer.put(auditRecordWriteMarshallable); } catch (InterruptedException e) { LOG.warn("Interrupted while sending message to Chronicle writer"); Thread.currentThread().interrupt(); } } ChronicleAuditLogger(Map<String, String> parameters); @VisibleForTesting  ChronicleAuditLogger(ChronicleWriter writer, FieldSelector configuredFields); @Override void log(AuditEntry logEntry); }
ChronicleAuditLogger implements AuditLogger { @Override public void log(AuditEntry logEntry) { AuditRecordWriteMarshallable auditRecordWriteMarshallable = new AuditRecordWriteMarshallable(logEntry, configuredFields); try { writer.put(auditRecordWriteMarshallable); } catch (InterruptedException e) { LOG.warn("Interrupted while sending message to Chronicle writer"); Thread.currentThread().interrupt(); } } ChronicleAuditLogger(Map<String, String> parameters); @VisibleForTesting  ChronicleAuditLogger(ChronicleWriter writer, FieldSelector configuredFields); @Override void log(AuditEntry logEntry);  }