public void release() {
subscribedChannelsAmount.release();
}
public void subscribe(final String channelName) {
conn.addListener(new RedisPubSubAdapter() {
@Override
public void subscribed(String channel, long count) {
log.debug("subscribed to '{}' channel", channelName);
}