@Override public synchronized boolean canUnsubscribe(Consumer consumer){
  return (consumers.size() == 1) && Objects.equals(consumer,activeConsumer.get());
}

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