@Test public void testFlushMessages() { assignmentsImpl.flushMessages(); }
@Override public void flushMessages() { for (String name : executors.keySet()) { executors.get(name).flushMessages(); } }
AssignmentsImpl implements Assignments { @Override public void flushMessages() { for (String name : executors.keySet()) { executors.get(name).flushMessages(); } } }
AssignmentsImpl implements Assignments { @Override public void flushMessages() { for (String name : executors.keySet()) { executors.get(name).flushMessages(); } } AssignmentsImpl(AssignmentsRepository assignmentRepository); @Inject  AssignmentsImpl(Map<String, AssignmentIngestionExecutor> executors,
                           final @CassandraRepository ExperimentRepository repository,
                           final AssignmentsRepository assignmentsRepository,
                           final RuleCache ruleCache, final Pages pages,
                           final AssignmentDecorator assignmentDecorator,
                           final @Named(RULECACHE_THREADPOOL)
                                   ThreadPoolExecutor ruleCacheExecutor,
                           final EventLog eventLog,
                           final @Named(ASSIGNMENTS_METADATA_CACHE_ENABLED)
                                   Boolean metadataCacheEnabled,
                           final AssignmentsMetadataCache metadataCache,
                           final Experiments experimentUtil); }
AssignmentsImpl implements Assignments { @Override public void flushMessages() { for (String name : executors.keySet()) { executors.get(name).flushMessages(); } } AssignmentsImpl(AssignmentsRepository assignmentRepository); @Inject  AssignmentsImpl(Map<String, AssignmentIngestionExecutor> executors,
                           final @CassandraRepository ExperimentRepository repository,
                           final AssignmentsRepository assignmentsRepository,
                           final RuleCache ruleCache, final Pages pages,
                           final AssignmentDecorator assignmentDecorator,
                           final @Named(RULECACHE_THREADPOOL)
                                   ThreadPoolExecutor ruleCacheExecutor,
                           final EventLog eventLog,
                           final @Named(ASSIGNMENTS_METADATA_CACHE_ENABLED)
                                   Boolean metadataCacheEnabled,
                           final AssignmentsMetadataCache metadataCache,
                           final Experiments experimentUtil); @Override List<Assignment> doBatchAssignments(User.ID userID, Application.Name applicationName, Context context,
                                               boolean createAssignment, boolean overwrite, HttpHeaders headers,
                                               ExperimentBatch experimentBatch,boolean forceProfileCheck); @Override List<Assignment> doPageAssignments(Application.Name applicationName, Page.Name pageName, User.ID userID,
                                              Context context, boolean createAssignment, boolean ignoreSamplingPercent,
                                              HttpHeaders headers, SegmentationProfile segmentationProfile,boolean forceProfileCheck); @Override Assignment doSingleAssignment(User.ID userID, Application.Name applicationName, Experiment.Label experimentLabel,
                                         Context context, boolean createAssignment, boolean ignoreSamplingPercent,
                                         SegmentationProfile segmentationProfile, HttpHeaders headers, boolean forceProfileCheck); @Override Assignment getExistingAssignment(User.ID userID,
                                            Application.Name appName, Experiment.Label experimentLabel,
                                            Context context); @Override Assignment putAssignment(User.ID userID, Application.Name applicationName, Experiment.Label experimentLabel,
                                    Context context, Bucket.Label desiredBucketLabel, boolean overwrite); @Override StreamingOutput getAssignmentStream(Experiment.ID experimentID, Context context, Parameters parameters, Boolean ignoreNullBucket); @Override boolean doSegmentTest(Application.Name applicationName, Experiment.Label experimentLabel,
                                 Context context, SegmentationProfile segmentationProfile,
                                 HttpHeaders headers); @Override Map<String, Integer> queuesLength(); @Override Map<String, Object> queuesDetails(); @Override void flushMessages(); @Override void clearMetadataCache(); @Override Map<String, String> metadataCacheDetails(); }
AssignmentsImpl implements Assignments { @Override public void flushMessages() { for (String name : executors.keySet()) { executors.get(name).flushMessages(); } } AssignmentsImpl(AssignmentsRepository assignmentRepository); @Inject  AssignmentsImpl(Map<String, AssignmentIngestionExecutor> executors,
                           final @CassandraRepository ExperimentRepository repository,
                           final AssignmentsRepository assignmentsRepository,
                           final RuleCache ruleCache, final Pages pages,
                           final AssignmentDecorator assignmentDecorator,
                           final @Named(RULECACHE_THREADPOOL)
                                   ThreadPoolExecutor ruleCacheExecutor,
                           final EventLog eventLog,
                           final @Named(ASSIGNMENTS_METADATA_CACHE_ENABLED)
                                   Boolean metadataCacheEnabled,
                           final AssignmentsMetadataCache metadataCache,
                           final Experiments experimentUtil); @Override List<Assignment> doBatchAssignments(User.ID userID, Application.Name applicationName, Context context,
                                               boolean createAssignment, boolean overwrite, HttpHeaders headers,
                                               ExperimentBatch experimentBatch,boolean forceProfileCheck); @Override List<Assignment> doPageAssignments(Application.Name applicationName, Page.Name pageName, User.ID userID,
                                              Context context, boolean createAssignment, boolean ignoreSamplingPercent,
                                              HttpHeaders headers, SegmentationProfile segmentationProfile,boolean forceProfileCheck); @Override Assignment doSingleAssignment(User.ID userID, Application.Name applicationName, Experiment.Label experimentLabel,
                                         Context context, boolean createAssignment, boolean ignoreSamplingPercent,
                                         SegmentationProfile segmentationProfile, HttpHeaders headers, boolean forceProfileCheck); @Override Assignment getExistingAssignment(User.ID userID,
                                            Application.Name appName, Experiment.Label experimentLabel,
                                            Context context); @Override Assignment putAssignment(User.ID userID, Application.Name applicationName, Experiment.Label experimentLabel,
                                    Context context, Bucket.Label desiredBucketLabel, boolean overwrite); @Override StreamingOutput getAssignmentStream(Experiment.ID experimentID, Context context, Parameters parameters, Boolean ignoreNullBucket); @Override boolean doSegmentTest(Application.Name applicationName, Experiment.Label experimentLabel,
                                 Context context, SegmentationProfile segmentationProfile,
                                 HttpHeaders headers); @Override Map<String, Integer> queuesLength(); @Override Map<String, Object> queuesDetails(); @Override void flushMessages(); @Override void clearMetadataCache(); @Override Map<String, String> metadataCacheDetails();  }