question: @ Override public synchronized boolean canUnsubscribe ( Consumer consumer ) { return ( consumers . size ( ) == 1 ) && Objects . equals ( consumer , activeConsumer . get ( ) ) ; }
target:  Handle unsubscribe command from the client API For failover subscription, if consumer is connected consumer, we can unsubscribe.