HBaseNotificationStore implements NotificationStore { @Override public void store(Notification notification) { try { LOG.debug("Storing notification {} in HBase", notification); store(notificationMapper.tableMutations(notification)); } catch (IOException ex) { throw new NotificationStoreException("Error storing notification, id: " + notification.getId(), ex); } }  @Override void init(Map<String, Object> config); @Override void store(Notification notification); @Override Notification getNotification(String notificationId); @Override List<Notification> getNotifications(List<String> notificationIds); @Override StreamlineEvent getEvent(String eventId); @Override List<StreamlineEvent> getEvents(List<String> eventIds); @Override List<T> findEntities(Criteria<T> criteria); @Override void close(); @Override Notification updateNotificationStatus(String notificationId, Notification.Status status);  }
@Test public void testStore() throws Exception { notificationStore.store(notification); new Verifications() { { List<Put> puts; mockHTable.put(puts = withCapture()); times = 8; } }; }