From 01b34e23237c43f8946db908827a9daeb9a4ee1d Mon Sep 17 00:00:00 2001 From: Igor Fedorenko Date: Tue, 18 Dec 2012 23:27:49 -0500 Subject: [PATCH] more specific error log message Signed-off-by: Igor Fedorenko --- .../events/IndexerManagerEventInspector.java | 29 ++++++++++--------- 1 file changed, 16 insertions(+), 13 deletions(-) diff --git a/nexus/plugins/indexer/nexus-indexer-lucene-plugin/src/main/java/org/sonatype/nexus/events/IndexerManagerEventInspector.java b/nexus/plugins/indexer/nexus-indexer-lucene-plugin/src/main/java/org/sonatype/nexus/events/IndexerManagerEventInspector.java index f080c87789..03063b9826 100644 --- a/nexus/plugins/indexer/nexus-indexer-lucene-plugin/src/main/java/org/sonatype/nexus/events/IndexerManagerEventInspector.java +++ b/nexus/plugins/indexer/nexus-indexer-lucene-plugin/src/main/java/org/sonatype/nexus/events/IndexerManagerEventInspector.java @@ -22,6 +22,7 @@ import org.sonatype.nexus.proxy.events.RepositoryItemEventCache; import org.sonatype.nexus.proxy.events.RepositoryItemEventDelete; import org.sonatype.nexus.proxy.events.RepositoryItemEventStore; +import org.sonatype.nexus.proxy.repository.Repository; import org.sonatype.nexus.util.SystemPropertiesHelper; import org.sonatype.plexus.appevents.Event; @@ -35,8 +36,8 @@ public class IndexerManagerEventInspector extends AbstractEventInspector implements AsynchronousEventInspector { - private final boolean enabled = SystemPropertiesHelper.getBoolean( - "org.sonatype.nexus.events.IndexerManagerEventInspector.enabled", true ); + private final boolean enabled = + SystemPropertiesHelper.getBoolean( "org.sonatype.nexus.events.IndexerManagerEventInspector.enabled", true ); @Requirement private IndexerManager indexerManager; @@ -63,26 +64,28 @@ public void inspect( Event evt ) private void inspectForIndexerManager( Event evt ) { - try - { - RepositoryItemEvent ievt = (RepositoryItemEvent) evt; + RepositoryItemEvent ievt = (RepositoryItemEvent) evt; + + Repository repository = ievt.getRepository(); - // should we sync at all - if ( ievt.getRepository().isIndexable() ) + // should we sync at all + if ( repository != null && repository.isIndexable() ) + { + try { if ( ievt instanceof RepositoryItemEventCache || ievt instanceof RepositoryItemEventStore ) { - getIndexerManager().addItemToIndex( ievt.getRepository(), ievt.getItem() ); + getIndexerManager().addItemToIndex( repository, ievt.getItem() ); } else if ( ievt instanceof RepositoryItemEventDelete ) { - getIndexerManager().removeItemFromIndex( ievt.getRepository(), ievt.getItem() ); + getIndexerManager().removeItemFromIndex( repository, ievt.getItem() ); } } - } - catch ( Exception e ) // TODO be more specific - { - getLogger().error( "Could not maintain index!", e ); + catch ( Exception e ) // TODO be more specific + { + getLogger().error( "Could not maintain index for repository {}!", repository.getId(), e ); + } } }