Auto register guice services annotated with Subscribe to EvenBus

EventBusAutoRegisterSampleModule.java

import com.google.common.eventbus.EventBus;
import com.google.common.eventbus.Subscribe;
import com.google.inject.AbstractModule;
import com.google.inject.TypeLiteral;
import com.google.inject.matcher.Matchers;
import com.google.inject.spi.InjectionListener;
import com.google.inject.spi.TypeEncounter;
import com.google.inject.spi.TypeListener;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.lang.reflect.Method;

class EventBusAutoRegisterSampleModule extends AbstractModule {

    private static final Logger log = LoggerFactory.getLogger(EventBusAutoRegisterSampleModule.class);

    @Override
    protected void configure() {
        // bind your services which have methods annotated with @Subscribe 

        EventBus eventBus = new EventBus();
        bind(EventBus.class).toInstance(eventBus);

        bindListener(Matchers.any(), new TypeListener() {
            @Override
            public <I> void hear(TypeLiteral<I> type, TypeEncounter<I> encounter) {
                encounter.register((InjectionListener<I>) injectee -> {
                    for (Method m : injectee.getClass().getDeclaredMethods()) {
                        if (m.isAnnotationPresent(Subscribe.class)) {
                            log.debug("registering {} as event listener", injectee.getClass());

                            eventBus.register(injectee);
                            break;
                        }
                    }
                });
            }
        });
    }
}