public InstrumentedSocketAppender(PreSerializationTransformer<String> preSerializationTransformer, QueueFactory queueFactory, ObjectWriterFactory objectWriterFactory, SocketConnector socketConnector) { super(queueFactory, objectWriterFactory); this.preSerializationTransformer = preSerializationTransformer; this.socketConnector = socketConnector; }
@Override protected PreSerializationTransformer<Serializable> getPST() { return new PreSerializationTransformer<Serializable>() { public Serializable transform(Serializable event) { return event; } }; }
@Override protected PreSerializationTransformer<String> getPST() { return new PreSerializationTransformer<String>() { public Serializable transform(String event) { return event; } }; }
@Override public PreSerializationTransformer<ILoggingEvent> getPST() { if (sendLoggerNameInMessage) { return pst; } else { return super.getPST(); } }
@Override protected PreSerializationTransformer<String> getPST() { return preSerializationTransformer; }
@Override protected PreSerializationTransformer<Object> getPST() { throw new UnsupportedOperationException(); }
public PreSerializationTransformer<ILoggingEvent> getPST() { return pst; }
@Override protected PreSerializationTransformer<ILoggingEvent> getPST() { return pst; }
public PreSerializationTransformer<IAccessEvent> getPST() { return pst; }
@Override protected PreSerializationTransformer<IAccessEvent> getPST() { return pst; }
/** * Get the pre-serialization transformer that will be used to transform * each event into a Serializable object before delivery to the remote * receiver. * @return transformer object */ protected abstract PreSerializationTransformer<E> getPST();
/** * Gets a transformer that will be used to convert a received event * to a {@link Serializable} form. * @return */ protected abstract PreSerializationTransformer<E> getPST();