final SubmissionService submissionService
          = new SubmissionServiceImpl(submissionDao, submissionProducer,
              localIpAddress + ":" + serverPort);

      final DataHandler dataHandler = new CompilationDataHandler(submissionDao);
      final DataWorkerFactory compilationWorkerFactory
          = new DefaultWorkerFactory(dataHandler,
              CompilationSubmissionData.class);

      final DataConsumer compilationDataConsumer
          = new DefaultConsumer(compilationDataTopic, compilationWorkerFactory);
      compilationDataConsumer.run();

      final DataHandler executionDataHandler
          = new ExecutionDataHandler(submissionDao);

      final DataWorkerFactory executionWorkerFactory
          = new DefaultWorkerFactory(executionDataHandler,
              ExecutionSubmissionData.class);

      final DataConsumer executionDataConsumer
          = new DefaultConsumer(executionDataTopic, executionWorkerFactory);
      executionDataConsumer.run();

      final DataHandler monitorDataHandler = new MonitorDataHandler();

      final DataWorkerFactory monitorWorkerFactory
          = new DefaultWorkerFactory(monitorDataHandler,
              MonitorSubmissionData.class);

      final DataConsumer monitorDataConsumer
          = new DefaultConsumer(monitorTopic, monitorWorkerFactory);
      monitorDataConsumer.run();