001// -------------------------------------------------------------------------------- 002// Copyright 2002-2024 Echo Three, LLC 003// 004// Licensed under the Apache License, Version 2.0 (the "License"); 005// you may not use this file except in compliance with the License. 006// You may obtain a copy of the License at 007// 008// http://www.apache.org/licenses/LICENSE-2.0 009// 010// Unless required by applicable law or agreed to in writing, software 011// distributed under the License is distributed on an "AS IS" BASIS, 012// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 013// See the License for the specific language governing permissions and 014// limitations under the License. 015// -------------------------------------------------------------------------------- 016 017package com.echothree.model.control.core.server.eventbus; 018 019import com.google.common.eventbus.EventBus; 020import io.github.classgraph.ClassGraph; 021import java.lang.reflect.InvocationTargetException; 022 023public class SentEventEventBus { 024 025 public static EventBus eventBus; 026 027 static { 028 eventBus = new EventBus(); 029 030 try(var scanResult = new ClassGraph() 031 .enableAnnotationInfo() 032 .scan()) { 033 final var sentEventSubscriberClasses = scanResult 034 .getClassesWithAnnotation(SentEventSubscriber.class.getName()); 035 036 for(var sentEventSubscriberClass : sentEventSubscriberClasses) { 037 var clazz = sentEventSubscriberClass.loadClass(); 038 var constructor = clazz.getDeclaredConstructor(); 039 040 eventBus.register(constructor.newInstance()); 041 } 042 } catch(InvocationTargetException | IllegalAccessException | NoSuchMethodException | InstantiationException e) { 043 throw new RuntimeException(e); 044 } 045 } 046 047}