Package com.reposilite.journalist.backend

Class PublisherLogger

java.lang.Object

com.reposilite.journalist.backend.DefaultLogger

com.reposilite.journalist.backend.PublisherLogger

All Implemented Interfaces:

Journalist, Logger, panda.std.reactive.Publisher<Integer,Map.Entry<Channel,String>>

public class PublisherLogger
extends DefaultLogger
implements panda.std.reactive.Publisher<Integer,Map.Entry<Channel,String>>

Field Summary

Fields inherited from class com.reposilite.journalist.backend.DefaultLogger

threshold

Constructor Summary

Constructors

Constructor	Description
PublisherLogger(Channel threshold)

Method Summary

Modifier and Type	Method	Description
protected void	internalLog(Channel channel, String message)	Internal method used by DefaultLogger to send processed message to the final implementation.
Integer	subscribe(panda.std.reactive.Subscriber<? super Map.Entry<Channel,String>> subscriber)
boolean	unsubscribe(Integer subscriberId)

Methods inherited from class com.reposilite.journalist.backend.DefaultLogger

exception, getLogger, log, setThreshold, toPrintStream

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.reposilite.journalist.Logger

debug, error, exception, fatal, info, trace, warn

Constructor Details

PublisherLogger

public PublisherLogger(Channel threshold)

Method Details

internalLog

protected void internalLog(Channel channel,
 String message)

Description copied from class: DefaultLogger

Internal method used by DefaultLogger to send processed message to the final implementation.

Specified by:

internalLog in class DefaultLogger

Parameters:

channel - the channel to log to

message - the message to log

subscribe

public Integer subscribe(panda.std.reactive.Subscriber<? super Map.Entry<Channel,String>> subscriber)

Specified by:

subscribe in interface panda.std.reactive.Publisher<Integer,Map.Entry<Channel,String>>

unsubscribe

public boolean unsubscribe(Integer subscriberId)