final AbstractWrapper wrapper = streamSource.getWrapper ( );
streamSource.getInputStream().getRenamingMapping().remove(streamSource.getAlias());
try {
wrapper.removeListener(streamSource);
} catch (SQLException e) {
<BUG>logger.error(e.getMessage(),e);
logger.error("Release the resources failed !");
</BUG>
}
}

final AbstractWrapper wrapper = streamSource.getWrapper ( );
streamSource.getInputStream().getRenamingMapping().remove(streamSource.getAlias());
try {
wrapper.removeListener(streamSource);
} catch (SQLException e) {
logger.error("Release the resources failed !" + e.getMessage());
}
}
