@Before
public void setUp() {
    initializer = SeContainerInitializer.newInstance();

    initializer.addBeanClasses(MediatorFactory.class,
            MediatorManager.class,
            WorkerPoolRegistry.class,
            ExecutionHolder.class,
            InternalChannelRegistry.class,
            ChannelProducer.class,
            ConfiguredChannelFactory.class,
            LegacyConfiguredChannelFactory.class,
            MetricDecorator.class,

            // In memory connector
            InMemoryConnector.class,

            // SmallRye config
            io.smallrye.config.inject.ConfigProducer.class);

    List<Class<?>> beans = getBeans();
    initializer.addBeanClasses(beans.toArray(new Class<?>[0]));
    initializer.disableDiscovery();
    initializer.addExtensions(new ReactiveMessagingExtension());
}
 

@Before
public void setUp() {
    initializer = SeContainerInitializer.newInstance();

    initializer.addBeanClasses(MediatorFactory.class,
            ExecutionHolder.class,
            MediatorManager.class,
            WorkerPoolRegistry.class,
            InternalChannelRegistry.class,
            ChannelProducer.class,
            ConfiguredChannelFactory.class,
            LegacyConfiguredChannelFactory.class,
            MetricDecorator.class,
            // Messaging provider
            MyDummyConnector.class,

            // SmallRye config
            io.smallrye.config.inject.ConfigProducer.class);

    List<Class<?>> beans = getBeans();
    initializer.addBeanClasses(beans.toArray(new Class<?>[0]));
    initializer.disableDiscovery();
    initializer.addExtensions(new ReactiveMessagingExtension());
}
 

public static void main(String[] args) {
    SeContainerInitializer containerInit = SeContainerInitializer.newInstance();
    SeContainer container = containerInit.initialize();

    TestService testService = container.select(TestService.class).get();

    testService.test();

    System.out.println(testService.hello(-1));
    System.out.println(testService.hello(1));

    System.out.println(testService.helloAnother("bad"));

    try {
        System.out.println(testService.helloAnother("foo"));
    } catch (IllegalStateException e) {
        System.err.println(e.getMessage());
    }

    System.out.println(testService.helloAnother("weld"));

    container.close();
    System.exit(0);
}
 

public static void main(String... args) {
    try (SeContainer container = SeContainerInitializer
            .newInstance().initialize()) {
        Task appInstance = container
                .select(Task.class)
                .get();
        //Test normal CDI
        appInstance.useInjected();
        
        //Test programmatic approach using RequestContextController
        //For each of below requests a new LoginBean is injected
        appInstance.doWorkInRequest("programmatic");            
        appInstance.doWorkInRequest("programmatic");
        
        //Test annotation approach using @ActivateRequestContext
        //For each of below requests a new LoginBean is injected
        appInstance.doWorkInRequest();
        appInstance.doWorkInRequest();
    }
}
 

public static void main(String[] args) {
    try (SeContainer container = SeContainerInitializer
            .newInstance().initialize()) {
        Test appInstance = container
                .select(Test.class)
                .get();

        appInstance.doWork();
    }
}
 

public static void main(String[] args) {
    try (SeContainer container = SeContainerInitializer
            .newInstance().initialize()) {
        Test appInstance = container
                .select(Test.class)
                .get();

        appInstance.doWork();
    }
}
 

public static void main(String... args) {
    //Use try-with-resources for closing the SeContainer instance
    try (SeContainer container = SeContainerInitializer
            .newInstance().initialize()) {
        //Lookup the BootCDI instance by its type.
        BootCDI appInstance = container
                .select(BootCDI.class)
                .get();
        //Once BootCDI instance is obtained we can invoke its methods
        appInstance.doSomething();
    }
}
 

public static void main(String... args) {
    try (SeContainer container = SeContainerInitializer
            .newInstance().initialize()) {
        Test appInstance = container
                .select(Test.class)
                .get();
        //Invoke action which raises an event that an observer listens to
        appInstance.doSomething();
    }
}
 

public static void main(String[] args) {
    try (SeContainer container = SeContainerInitializer
            .newInstance().initialize()) {
        AccountService appInstance = container
                .select(AccountService.class)
                .get();
        
        appInstance.login(1,"AG007");
        appInstance.login(2,"AG007");
        //3rd event should lock account and then send SMS
        appInstance.login(3,"AG007");
    }
}
 

@Test
public void injection_test() {
    try (SeContainer container = SeContainerInitializer.newInstance().initialize()) {
        CdiTest appInstance = container.select(CdiTest.class).get();
        String msg = appInstance.doSomething();

        assertNotNull(msg);
    }
}
 

public static void main(String[] args) {
    try (SeContainer container = SeContainerInitializer
            .newInstance().initialize()) {
        App appInstance = container
                .select(App.class)
                .get();
        appInstance.doCRUD();
    }
}
 

public static void main(final String[] args) {
    SeContainerInitializer initializer = SeContainerInitializer.newInstance();

    try (SeContainer container = initializer.initialize()) {
        container.select(AccountApplication.class).get().run();
    }
}
 

@Test
public void bootBasicContainer() {
    SeContainerInitializer initializer = SeContainerInitializer.newInstance();
    try (SeContainer container = initializer.initialize()) {
        assertTrue(container.isRunning());
        Set<Bean<?>> greeters = container.getBeanManager().getBeans("greeter");
        assertTrue(greeters.size() == 1);
    }
}
 

@Test
public void run() {
    try (final SeContainer container = SeContainerInitializer.newInstance()
            .addProperty("httpPort", new Meecrowave.Builder().randomHttpPort().getHttpPort())
            .disableDiscovery()
            .addBeanClasses(Configured.class)
            .initialize()) {
        final Client client = ClientBuilder.newClient();
        assertNotNull(container.select(Meecrowave.class).get());
        assertEquals("configured", client
                .target(String.format("http://localhost:%d/configured", container.select(Meecrowave.Builder.class).get().getHttpPort()))
                .request(TEXT_PLAIN_TYPE)
                .get(String.class));
    }
}
 

public static void main(String[] args) {
    SeContainerInitializer.newInstance().initialize();
}
 

public static void main(String[] args) throws InterruptedException {
    SeContainerInitializer instance = SeContainerInitializer.newInstance();
    instance.initialize();

    Thread.sleep(10000);
}
 

public static void main(String[] args) {
    SeContainerInitializer.newInstance().initialize();
}
 

public static void main(String[] args) {
    SeContainer container = SeContainerInitializer.newInstance().initialize();

    container.getBeanManager().createInstance().select(BeanUsingAnEmitter.class).get().periodicallySendMqttMessage();
}
 

public static void main(String[] args) {
    SeContainer container = SeContainerInitializer.newInstance().initialize();

    container.getBeanManager().createInstance().select(BeanUsingAnEmitter.class).get().periodicallySendMessageToKafka();
}
 

public static void main(String[] args) {
    SeContainer container = SeContainerInitializer.newInstance().initialize();

    container.getBeanManager().createInstance().select(BeanUsingAnEmitter.class).get().periodicallySendMessage();
}
 

public static void main(String[] args) {
    SeContainer container = SeContainerInitializer.newInstance().initialize();
    container.getBeanManager().createInstance().select(BeanUsingAnEmitter.class).get().periodicallySendMessage();
}
 

public static void main(String[] args) {
    SeContainer container = SeContainerInitializer.newInstance().initialize();

    container.getBeanManager().createInstance().select(BeanUsingAnEmitter.class).get().periodicallySendMessage();
}
 

public static void main(String[] args) {
    SeContainer container = SeContainerInitializer.newInstance().initialize();
    container.getBeanManager().createInstance().select(BeanUsingAnEmitter.class).get().periodicallySendMessage();
}
 

@BeforeClass
public static void init() {
    SeContainerInitializer containerInit = SeContainerInitializer.newInstance();
    container = containerInit.initialize();
}
 

public static void main(String[] args) {
    SeContainer container = SeContainerInitializer.newInstance().initialize();
    container.getBeanManager().fireEvent(new MyEvent("event -> " + System.currentTimeMillis()));
}
 

@Override
public SeContainerInitializer find() {
    return new MeecrowaveSeContainerInitializer();
}
 

@Override
public SeContainerInitializer find() {
    return new HammockInitializer();
}
 

public OWBBootstrapper() {
    seContainerInitializer = SeContainerInitializer.newInstance();
}
 

public Weld3Bootstrapper() {
    seContainerInitializer = SeContainerInitializer.newInstance();
    config = ConfigProvider.getConfig();
}
 

public SeContainerInitializer getSeContainerInitializer() {
    return seContainerInitializer;
}