messaging-activemq/src/main/java/org/wildfly/extension/messaging/activemq/jms/ConnectionFactoryService.java
public synchronized void start(final StartContext context) throws StartException {
        final JMSServerManager jmsManager = jmsServer.getValue();
        final Runnable task = new Runnable() {
            @Override
            public void run() {
                try {
                    jmsManager.createConnectionFactory(false, configuration, configuration.getBindings());
                    context.complete();
                } catch (Throwable e) {
                    context.failed(MessagingLogger.ROOT_LOGGER.failedToCreate(e, "connection-factory"));
                }
            }
        };
        try {
            executorInjector.getValue().execute(task);
        } catch (RejectedExecutionException e) {
            task.run();
        } finally {
            context.asynchronous();
        }
    }
public synchronized void start(final StartContext context) throws StartException {
        final JMSServerManager jmsManager = jmsServer.getValue();
        final Runnable task = new Runnable() {
            @Override
            public void run() {
                try {
                    jmsManager.createConnectionFactory(false, configuration, configuration.getBindings());
                    context.complete();
                } catch (Throwable e) {
                    context.failed(MessagingLogger.ROOT_LOGGER.failedToCreate(e, "connection-factory"));
                }
            }
        };
        try {
            executorInjector.getValue().execute(task);
        } catch (RejectedExecutionException e) {
            task.run();
        } finally {
            context.asynchronous();
        }
    }
public synchronized void start ( final StartContext context ) throws StartException { final JMSServerManager jmsManager = jmsServer . getValue ( ) ; final Runnable task = new Runnable ( ) { @ Override public void run ( ) { try { jmsManager . createConnectionFactory ( false , configuration , configuration . getBindings ( ) ) ; context . complete ( ) ; } catch ( Throwable e ) { context . failed ( MessagingLogger . ROOT_LOGGER . failedToCreate ( e , "connection-factory" ) ) ; } } } ; try { executorInjector . getValue ( ) . execute ( task ) ; } catch ( RejectedExecutionException e ) { task . run ( ) ; } finally { context . asynchronous ( ) ; } }
{@inheritDoc}
{