mirror of
https://github.com/scm-manager/scm-manager.git
synced 2025-11-15 17:56:17 +01:00
register every injectable object to event bus
This commit is contained in:
@@ -185,7 +185,7 @@ public class ScmContextListener extends GuiceServletContextListener
|
|||||||
List<Module> moduleList = Lists.newArrayList();
|
List<Module> moduleList = Lists.newArrayList();
|
||||||
|
|
||||||
moduleList.add(new ScmInitializerModule());
|
moduleList.add(new ScmInitializerModule());
|
||||||
moduleList.add(new ScmSubscriberModule());
|
moduleList.add(new ScmEventBusModule());
|
||||||
moduleList.add(new EagerSingletonModule());
|
moduleList.add(new EagerSingletonModule());
|
||||||
moduleList.add(ShiroWebModule.guiceFilterModule());
|
moduleList.add(ShiroWebModule.guiceFilterModule());
|
||||||
moduleList.add(main);
|
moduleList.add(main);
|
||||||
|
|||||||
@@ -30,14 +30,14 @@
|
|||||||
*/
|
*/
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
package sonia.scm;
|
package sonia.scm;
|
||||||
|
|
||||||
//~--- non-JDK imports --------------------------------------------------------
|
//~--- non-JDK imports --------------------------------------------------------
|
||||||
|
|
||||||
import com.google.inject.AbstractModule;
|
import com.google.inject.AbstractModule;
|
||||||
import com.google.inject.TypeLiteral;
|
import com.google.inject.TypeLiteral;
|
||||||
import com.google.inject.matcher.AbstractMatcher;
|
import com.google.inject.matcher.Matchers;
|
||||||
import com.google.inject.matcher.Matcher;
|
|
||||||
import com.google.inject.spi.InjectionListener;
|
import com.google.inject.spi.InjectionListener;
|
||||||
import com.google.inject.spi.TypeEncounter;
|
import com.google.inject.spi.TypeEncounter;
|
||||||
import com.google.inject.spi.TypeListener;
|
import com.google.inject.spi.TypeListener;
|
||||||
@@ -46,24 +46,19 @@ import org.slf4j.Logger;
|
|||||||
import org.slf4j.LoggerFactory;
|
import org.slf4j.LoggerFactory;
|
||||||
|
|
||||||
import sonia.scm.event.ScmEventBus;
|
import sonia.scm.event.ScmEventBus;
|
||||||
import sonia.scm.event.Subscriber;
|
|
||||||
|
|
||||||
//~--- JDK imports ------------------------------------------------------------
|
|
||||||
|
|
||||||
import java.lang.annotation.Annotation;
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
*
|
*
|
||||||
* @author Sebastian Sdorra
|
* @author Sebastian Sdorra
|
||||||
*/
|
*/
|
||||||
public class ScmSubscriberModule extends AbstractModule
|
public class ScmEventBusModule extends AbstractModule
|
||||||
{
|
{
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* the logger for ScmSubscriberModule
|
* the logger for ScmSubscriberModule
|
||||||
*/
|
*/
|
||||||
private static final Logger logger =
|
private static final Logger logger =
|
||||||
LoggerFactory.getLogger(ScmSubscriberModule.class);
|
LoggerFactory.getLogger(ScmEventBusModule.class);
|
||||||
|
|
||||||
//~--- methods --------------------------------------------------------------
|
//~--- methods --------------------------------------------------------------
|
||||||
|
|
||||||
@@ -74,12 +69,11 @@ public class ScmSubscriberModule extends AbstractModule
|
|||||||
@Override
|
@Override
|
||||||
protected void configure()
|
protected void configure()
|
||||||
{
|
{
|
||||||
bindListener(annotatedWith(Subscriber.class), new TypeListener()
|
bindListener(Matchers.any(), new TypeListener()
|
||||||
{
|
{
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public <I> void hear(TypeLiteral<I> type,
|
public <I> void hear(TypeLiteral<I> type, TypeEncounter<I> encounter)
|
||||||
final TypeEncounter<I> encounter)
|
|
||||||
{
|
{
|
||||||
encounter.register(new InjectionListener<I>()
|
encounter.register(new InjectionListener<I>()
|
||||||
{
|
{
|
||||||
@@ -91,83 +85,11 @@ public class ScmSubscriberModule extends AbstractModule
|
|||||||
logger.trace("register subscriber {}", object.getClass());
|
logger.trace("register subscriber {}", object.getClass());
|
||||||
}
|
}
|
||||||
|
|
||||||
Subscriber subscriber =
|
ScmEventBus.getInstance().register(object);
|
||||||
object.getClass().getAnnotation(Subscriber.class);
|
|
||||||
|
|
||||||
|
|
||||||
ScmEventBus.getInstance().register(object, subscriber.async());
|
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
|
||||||
* Method description
|
|
||||||
*
|
|
||||||
*
|
|
||||||
* @param aClass
|
|
||||||
*
|
|
||||||
* @return
|
|
||||||
*/
|
|
||||||
private Matcher<TypeLiteral<?>> annotatedWith(
|
|
||||||
Class<? extends Annotation> aClass)
|
|
||||||
{
|
|
||||||
return new AnnotatedWith(aClass);
|
|
||||||
}
|
|
||||||
|
|
||||||
//~--- inner classes --------------------------------------------------------
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Class description
|
|
||||||
*
|
|
||||||
*
|
|
||||||
* @version Enter version here..., 12/12/07
|
|
||||||
* @author Enter your name here...
|
|
||||||
*/
|
|
||||||
private static class AnnotatedWith extends AbstractMatcher<TypeLiteral<?>>
|
|
||||||
{
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Constructs ...
|
|
||||||
*
|
|
||||||
*
|
|
||||||
* @param baseClass
|
|
||||||
*/
|
|
||||||
private AnnotatedWith(Class<? extends Annotation> baseClass)
|
|
||||||
{
|
|
||||||
this.baseClass = baseClass;
|
|
||||||
}
|
|
||||||
|
|
||||||
//~--- methods ------------------------------------------------------------
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Method description
|
|
||||||
*
|
|
||||||
*
|
|
||||||
* @param t
|
|
||||||
*
|
|
||||||
* @return
|
|
||||||
*/
|
|
||||||
@Override
|
|
||||||
public boolean matches(TypeLiteral<?> t)
|
|
||||||
{
|
|
||||||
try
|
|
||||||
{
|
|
||||||
return t.getRawType().isAnnotationPresent(baseClass);
|
|
||||||
}
|
|
||||||
catch (Exception e)
|
|
||||||
{
|
|
||||||
|
|
||||||
// LOG e
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
//~--- fields -------------------------------------------------------------
|
|
||||||
|
|
||||||
/** Field description */
|
|
||||||
private final Class<? extends Annotation> baseClass;
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
Reference in New Issue
Block a user