This repository was archived by the owner on Feb 10, 2025. It is now read-only.
File tree Expand file tree Collapse file tree 1 file changed +6
-0
lines changed
queue/src/test/java/com/bazaarvoice/emodb/queue Expand file tree Collapse file tree 1 file changed +6
-0
lines changed Original file line number Diff line number Diff line change 13
13
import com .bazaarvoice .emodb .job .api .JobService ;
14
14
import com .bazaarvoice .emodb .queue .api .DedupQueueService ;
15
15
import com .bazaarvoice .emodb .queue .api .QueueService ;
16
+ import com .bazaarvoice .emodb .queue .core .kafka .KafkaAdminService ;
16
17
import com .bazaarvoice .emodb .queue .core .kafka .KafkaProducerService ;
18
+ import com .bazaarvoice .emodb .queue .core .stepfn .StepFunctionService ;
17
19
import com .bazaarvoice .ostrich .HostDiscovery ;
18
20
import com .codahale .metrics .MetricRegistry ;
19
21
import com .google .common .collect .ImmutableMap ;
@@ -57,8 +59,12 @@ protected void configure() {
57
59
bind (HostDiscovery .class ).annotatedWith (DedupQueueHostDiscovery .class ).toInstance (mock (HostDiscovery .class ));
58
60
bind (JobHandlerRegistry .class ).toInstance (mock (JobHandlerRegistry .class ));
59
61
bind (JobService .class ).toInstance (mock (JobService .class ));
62
+ bind (KafkaAdminService .class ).asEagerSingleton ();
60
63
bind (KafkaProducerService .class ).asEagerSingleton ();
61
64
65
+ // Bind Step Function Service
66
+ bind (StepFunctionService .class ).asEagerSingleton ();
67
+
62
68
MetricRegistry metricRegistry = new MetricRegistry ();
63
69
bind (MetricRegistry .class ).toInstance (metricRegistry );
64
70
bind (Clock .class ).toInstance (mock (Clock .class ));
You can’t perform that action at this time.
0 commit comments