messaging-activemq/src/main/java/org/wildfly/extension/messaging/activemq/QueueService.java
@Override
    public synchronized void start(StartContext context) throws StartException {
        if (createQueue) {
            try {
                final ActiveMQServer server = this.activeMQServerSupplier.get();
                MessagingLogger.ROOT_LOGGER.debugf("Deploying queue on server %s with address: %s ,  name: %s, filter: %s ands durable: %s, temporary: %s",
                        server.getNodeID(), new SimpleString(queueConfiguration.getAddress()), new SimpleString(queueConfiguration.getName()),
                        SimpleString.toSimpleString(queueConfiguration.getFilterString()), queueConfiguration.isDurable(), temporary);
                final SimpleString resourceName = new SimpleString(queueConfiguration.getName());
                final SimpleString address = new SimpleString(queueConfiguration.getAddress());
                final SimpleString filterString = SimpleString.toSimpleString(queueConfiguration.getFilterString());
                server.createQueue(address,
                        queueConfiguration.getRoutingType(),
                        resourceName,
                        filterString,
                        queueConfiguration.isDurable(),
                        temporary);
            } catch (Exception e) {
                throw new StartException(e);
            }
        }
    }
@Override
    public synchronized void start(StartContext context) throws StartException {
        if (createQueue) {
            try {
                final ActiveMQServer server = this.activeMQServerSupplier.get();
                MessagingLogger.ROOT_LOGGER.debugf("Deploying queue on server %s with address: %s ,  name: %s, filter: %s ands durable: %s, temporary: %s",
                        server.getNodeID(), new SimpleString(queueConfiguration.getAddress()), new SimpleString(queueConfiguration.getName()),
                        SimpleString.toSimpleString(queueConfiguration.getFilterString()), queueConfiguration.isDurable(), temporary);
                final SimpleString resourceName = new SimpleString(queueConfiguration.getName());
                final SimpleString address = new SimpleString(queueConfiguration.getAddress());
                final SimpleString filterString = SimpleString.toSimpleString(queueConfiguration.getFilterString());
                server.createQueue(address,
                        queueConfiguration.getRoutingType(),
                        resourceName,
                        filterString,
                        queueConfiguration.isDurable(),
                        temporary);
            } catch (Exception e) {
                throw new StartException(e);
            }
        }
    }
@ Override public synchronized void start ( StartContext context ) throws StartException { if ( createQueue ) { try { final ActiveMQServer server = this . activeMQServerSupplier . get ( ) ; MessagingLogger . ROOT_LOGGER . debugf ( "Deploying queue on server %s with address: %s ,  name: %s, filter: %s ands durable: %s, temporary: %s" , server . getNodeID ( ) , new SimpleString ( queueConfiguration . getAddress ( ) ) , new SimpleString ( queueConfiguration . getName ( ) ) , SimpleString . toSimpleString ( queueConfiguration . getFilterString ( ) ) , queueConfiguration . isDurable ( ) , temporary ) ; final SimpleString resourceName = new SimpleString ( queueConfiguration . getName ( ) ) ; final SimpleString address = new SimpleString ( queueConfiguration . getAddress ( ) ) ; final SimpleString filterString = SimpleString . toSimpleString ( queueConfiguration . getFilterString ( ) ) ; server . createQueue ( address , queueConfiguration . getRoutingType ( ) , resourceName , filterString , queueConfiguration . isDurable ( ) , temporary ) ; } catch ( Exception e ) { throw new StartException ( e ) ; } } }
{@inheritDoc}
{