core/src/main/java/flex/messaging/services/messaging/adapters/JMSQueueConsumer.java [44:78]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public void start() throws NamingException, JMSException {
        super.start();

        // Establish queue
        Queue queue = null;
        try {
            queue = (Queue) destination;
        } catch (ClassCastException cce) {
            // JMS queue proxy for JMS destination ''{0}'' has a destination type of ''{1}'' which is not Queue.
            MessageException me = new MessageException();
            me.setMessage(JMSConfigConstants.NON_QUEUE_DESTINATION, new Object[]{destinationJndiName, destination.getClass().getName()});
            throw me;
        }

        // Create connection
        try {
            QueueConnectionFactory queueFactory = (QueueConnectionFactory) connectionFactory;
            if (connectionCredentials != null)
                connection = queueFactory.createQueueConnection(connectionCredentials.getUsername(), connectionCredentials.getPassword());
            else
                connection = queueFactory.createQueueConnection();
        } catch (ClassCastException cce) {
            // JMS queue proxy for JMS destination ''{0}'' has a connection factory type of ''{1}'' which is not QueueConnectionFactory.
            MessageException me = new MessageException();
            me.setMessage(JMSConfigConstants.NON_QUEUE_FACTORY, new Object[]{destinationJndiName, connectionFactory.getClass().getName()});
            throw me;
        }

        QueueConnection queueConnection = (QueueConnection) connection;

        // Create queue session on the connection
        session = queueConnection.createQueueSession(false, getAcknowledgeMode());

        // Create receiver on the queue session
        QueueSession queueSession = (QueueSession) session;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



core/src/main/java/flex/messaging/services/messaging/adapters/JMSQueueProducer.java [45:78]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public void start() throws NamingException, JMSException {
        super.start();

        // Establish queue
        Queue queue = null;
        try {
            queue = (Queue) destination;
        } catch (ClassCastException cce) {
            // JMS queue proxy for JMS destination ''{0}'' has a destination type of ''{1}'' which is not Queue.
            MessageException me = new MessageException();
            me.setMessage(JMSConfigConstants.NON_QUEUE_DESTINATION, new Object[]{destinationJndiName, destination.getClass().getName()});
            throw me;
        }

        // Create connection
        try {
            QueueConnectionFactory queueFactory = (QueueConnectionFactory) connectionFactory;
            if (connectionCredentials != null)
                connection = queueFactory.createQueueConnection(connectionCredentials.getUsername(), connectionCredentials.getPassword());
            else
                connection = queueFactory.createQueueConnection();
        } catch (ClassCastException cce) {
            // JMS queue proxy for JMS destination ''{0}'' has a connection factory type of ''{1}'' which is not QueueConnectionFactory.
            MessageException me = new MessageException();
            me.setMessage(JMSConfigConstants.NON_QUEUE_FACTORY, new Object[]{destinationJndiName, connectionFactory.getClass().getName()});
            throw me;
        }

        // Create queue session on the connection
        QueueConnection queueConnection = (QueueConnection) connection;
        session = queueConnection.createQueueSession(false, getAcknowledgeMode());

        // Create sender on the queue session
        QueueSession queueSession = (QueueSession) session;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -