### Question:
ConsumerGroupServiceImpl extends AbstractBaseService<ConsumerGroupEntity> implements CacheUpdateService, ConsumerGroupService, TimerService { @Override public void notifyRb(long id) { updateRbVersion(Arrays.asList(id)); List<NotifyMessageEntity> notifyMessageEntities = new ArrayList<>(); NotifyMessageEntity notifyMessageEntity = new NotifyMessageEntity(); notifyMessageEntity.setConsumerGroupId(id); notifyMessageEntity.setMessageType(MessageType.Rb); notifyMessageEntities.add(notifyMessageEntity); notifyMessageEntity = new NotifyMessageEntity(); notifyMessageEntity.setConsumerGroupId(id); notifyMessageEntity.setMessageType(MessageType.Meta); notifyMessageEntities.add(notifyMessageEntity); notifyMessageService.insertBatch(notifyMessageEntities); }  @Override void start(); @Override void updateCache(); @Override void forceUpdateCache(); @Override List<ConsumerGroupEntity> getLastMetaConsumerGroup(long minMessageId, long maxMessageId); @Override List<ConsumerGroupEntity> getLastRbConsumerGroup(long minMessageId, long maxMessageId); @Override // @Transactional(rollbackFor = Exception.class) void rb(List<QueueOffsetEntity> queueOffsetEntities); @Override void notifyRb(long id); @Override void notifyRb(List<Long> ids); @Override void notifyMeta(long id); @Override void notifyMeta(List<Long> ids); @Override Map<String, ConsumerGroupEntity> getByNames(List<String> names); @Override Map<String, ConsumerGroupEntity> getCache(); @Override Map<Long, ConsumerGroupEntity> getIdCache(); @Override List<String> getSubEnvList(); @Override void notifyOffset(long id); @Override List<ConsumerGroupTopicEntity> getGroupTopic(); @Override ConsumerGroupTopicEntity getTopic(String consumerGroupName, String topicName); @PreDestroy @Override void stop(); @Override List<ConsumerGroupEntity> getByOwnerNames(Map<String, Object> parameterMap); @Override long countByOwnerNames(Map<String, Object> parameterMap); @Override String info(); @Override void notifyRbByNames(List<String> consumerGroupNames); @Override String getCacheJson(); @Override ConsumerGroupCreateResponse createConsumerGroup(ConsumerGroupCreateRequest consumerGroupCreateRequest); @Override ConsumerGroupEditResponse editConsumerGroup(ConsumerGroupEntity consumerGroupEntity); @Override ConsumerGroupDeleteResponse deleteConsumerGroup(long consumerGroupId, boolean checkOnline); @Override BaseUiResponse<Void> addTopicNameToConsumerGroup(ConsumerGroupTopicEntity consumerGroupTopicEntity); @Override BaseUiResponse<Void> deleteTopicNameFromConsumerGroup(ConsumerGroupTopicEntity consumerGroupTopicEntity); @Override @Transactional(rollbackFor = Exception.class, propagation= Propagation.NESTED) void copyAndNewConsumerGroup(ConsumerGroupEntity consumerGroupEntityOld,
			ConsumerGroupEntity consumerGroupEntityNew); @Override Map<String, ConsumerGroupEntity> getData();  }### Answer:
@Test public void notifyRbTest() { consumerGroupServiceImpl.notifyRb(null); verify(consumerGroupRepository,times(0)).updateMetaVersion(anyListOf(Long.class)); consumerGroupServiceImpl.notifyRb(1L); verify(consumerGroupRepository).updateRbVersion(anyListOf(Long.class)); verify(notifyMessageService).insertBatch(anyListOf(NotifyMessageEntity.class)); }