protected ConnectionPool createConnectionPool(Connection connection) throws JMSException {
if (!(connection instanceof XAConnection)) {
throw new JMSException("Require an instance of javax.jms.XAConnection for creating the ConnectionPool");
}
return new RecoverableConnectionPool((XAConnection)connection, getPoolFactory(), getTransactionManager(), getName());
}