class NotificationManager extends AbstractDataSourcePropertyManager<Client, NotificationClientRepository> implements DataSink {

	@Override
	public void onNewDataItem(DataSource source, ObjectNode data) {
		for (Client client : getAll(source)) {
			senderCache.get(source, client).onNewDataItem(data);
		}
	}

	@Inject  NotificationManager(
			Cache<NotificationClientRepository> repositoryCache,
			RepositoryFactory repositoryFactory,
			SenderCache senderCache);

}