Skip to content

Commit

Permalink
#42: Create software release 1.2.0. Reduced noise to console. Demoted…
Browse files Browse the repository at this point in the history
… some messages from INFO -> FINEST.
simondelabici committed Jul 27, 2018
1 parent 3d320d8 commit b1e45a9
Showing 4 changed files with 8 additions and 8 deletions.
Original file line number Diff line number Diff line change
@@ -141,7 +141,7 @@ public static boolean isRecognised( String name )
*/
public static MonitorNotificationServiceFactory create( String serviceConfiguration )
{
logger.log( Level.INFO, String.format("MonitorNotificationServiceFactoryCreator has been called with serviceImpl specifier: %s", serviceConfiguration ) );
logger.log( Level.FINEST, String.format("MonitorNotificationServiceFactoryCreator has been called with serviceImpl specifier: %s", serviceConfiguration ) );

Validate.notEmpty( serviceConfiguration );

Original file line number Diff line number Diff line change
@@ -52,8 +52,8 @@ public BlockingQueueMonitorNotificationServiceFactory( int numberOfThreads, int
this.numberOfThreads = numberOfThreads;

final int numberOfThreadsBaseline = Thread.getAllStackTraces().keySet().size();
logger.log(Level.INFO, String.format( "The number of baseline threads in the system was: %d", numberOfThreadsBaseline ) );
logger.log(Level.INFO, String.format( "A BlockingQueueMonitorNotificationServiceFactory is being created with %d threads and a buffer size with %d notification entries...", numberOfThreads, bufferSize ) );
logger.log( Level.FINEST, String.format( "The number of baseline threads in the system was: %d", numberOfThreadsBaseline ) );
logger.log( Level.INFO, String.format( "A BlockingQueueMonitorNotificationServiceFactory is being created with %d threads and a buffer size with %d notification entries...", numberOfThreads, bufferSize ) );

final BlockingQueue<Runnable> notificationTaskQueue = new LinkedBlockingQueue<>();
threadPoolExecutor = new ThreadPoolExecutor( numberOfThreads, numberOfThreads, Long.MAX_VALUE, TimeUnit.DAYS, notificationTaskQueue, new MyThreadFactory("BlockingQueueMonitorNotificationServiceThread-" ) );
@@ -86,7 +86,7 @@ public <T> MonitorNotificationService<T> getServiceForConsumer( Consumer<? super
@Override
public void close()
{
logger.log(Level.INFO, String.format( "A BlockingQueueMonitorNotificationServiceFactory is being closed with %d service entries...", getServiceCount() ) );
logger.log( Level.FINEST, String.format( "A BlockingQueueMonitorNotificationServiceFactory is being closed with %d service entries...", getServiceCount() ) );
for ( MonitorNotificationService service : serviceList )
{
service.close();
Original file line number Diff line number Diff line change
@@ -44,7 +44,7 @@ public DisruptorMonitorNotificationServiceFactory( boolean oldImpl )
this.oldImpl = oldImpl;

final int numberOfThreadsBaseline = Thread.getAllStackTraces().keySet().size();
logger.log( Level.INFO, String.format("The number of baseline threads in the system is: %d", numberOfThreadsBaseline));
logger.log( Level.FINEST, String.format("The number of baseline threads in the system is: %d", numberOfThreadsBaseline));

if ( oldImpl )
{
@@ -81,7 +81,7 @@ public <T> MonitorNotificationService<T> getServiceForConsumer( Consumer<? super
@Override
public void close()
{
logger.log(Level.INFO, String.format( "A DisruptorMonitorNotificationServiceFactory is being closed with %d service entries...", getServiceCount() ) );
logger.log(Level.FINEST, String.format( "A DisruptorMonitorNotificationServiceFactory is being closed with %d service entries...", getServiceCount() ) );
for ( MonitorNotificationService service : serviceList )
{
service.close();
Original file line number Diff line number Diff line change
@@ -49,7 +49,7 @@ public StripedExecutorServiceMonitorNotificationServiceFactory( int numberOfThre
this.numberOfThreads = numberOfThreads;

final int numberOfThreadsBaseline = Thread.getAllStackTraces().keySet().size();
logger.log(Level.INFO, String.format("The number of baseline threads in the system is: %d", numberOfThreadsBaseline));
logger.log(Level.FINEST, String.format("The number of baseline threads in the system is: %d", numberOfThreadsBaseline));
logger.log(Level.INFO, String.format( "A StripedExecutorServiceMonitorNotificationServiceFactory is being created with %d threads and an unlimited notification entry buffer size...", numberOfThreads ) );
stripedExecutorService = new StripedExecutorService( numberOfThreads );
}
@@ -78,7 +78,7 @@ public <T> MonitorNotificationService<T> getServiceForConsumer( Consumer<? super
@Override
public void close()
{
logger.log(Level.INFO, String.format( "A StripedExecutorServiceMonitorNotificationServiceFactory is being closed with %d service entries...", getServiceCount() ) );
logger.log(Level.FINEST, String.format( "A StripedExecutorServiceMonitorNotificationServiceFactory is being closed with %d service entries...", getServiceCount() ) );
for ( MonitorNotificationService service : serviceList )
{
service.close();

0 comments on commit b1e45a9

Please sign in to comment.