From e40e2c0d969e87a693bfd62da2a4f22778b34514 Mon Sep 17 00:00:00 2001 From: usbharu <64310155+usbharu@users.noreply.github.com> Date: Mon, 27 Nov 2023 15:03:26 +0900 Subject: [PATCH] =?UTF-8?q?refactor:=20=E4=B8=8D=E8=A6=81=E3=81=AA?= =?UTF-8?q?=E4=BE=9D=E5=AD=98=E3=82=92=E5=89=8A=E9=99=A4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../activitypub/service/common/ApJobService.kt | 8 -------- .../hideout/application/config/JobQueueRunner.kt | 16 ---------------- 2 files changed, 24 deletions(-) delete mode 100644 src/main/kotlin/dev/usbharu/hideout/activitypub/service/common/ApJobService.kt diff --git a/src/main/kotlin/dev/usbharu/hideout/activitypub/service/common/ApJobService.kt b/src/main/kotlin/dev/usbharu/hideout/activitypub/service/common/ApJobService.kt deleted file mode 100644 index 3b50b777..00000000 --- a/src/main/kotlin/dev/usbharu/hideout/activitypub/service/common/ApJobService.kt +++ /dev/null @@ -1,8 +0,0 @@ -package dev.usbharu.hideout.activitypub.service.common - -import dev.usbharu.hideout.core.external.job.HideoutJob -import kjob.core.dsl.JobContextWithProps - -interface ApJobService { - suspend fun > processActivity(job: JobContextWithProps, hideoutJob: HideoutJob) -} diff --git a/src/main/kotlin/dev/usbharu/hideout/application/config/JobQueueRunner.kt b/src/main/kotlin/dev/usbharu/hideout/application/config/JobQueueRunner.kt index cc1580ea..1667b7ec 100644 --- a/src/main/kotlin/dev/usbharu/hideout/application/config/JobQueueRunner.kt +++ b/src/main/kotlin/dev/usbharu/hideout/application/config/JobQueueRunner.kt @@ -1,6 +1,5 @@ package dev.usbharu.hideout.application.config -import dev.usbharu.hideout.activitypub.service.common.ApJobService import dev.usbharu.hideout.core.external.job.HideoutJob import dev.usbharu.hideout.core.service.job.JobQueueParentService import dev.usbharu.hideout.core.service.job.JobQueueWorkerService @@ -29,24 +28,9 @@ class JobQueueRunner( @Component class JobQueueWorkerRunner( private val jobQueueWorkerService: JobQueueWorkerService, - private val jobs: List>, - private val apJobService: ApJobService ) : ApplicationRunner { override fun run(args: ApplicationArguments?) { LOGGER.info("Init job queue worker.") -// jobQueueWorkerService.init>( -// jobs.map { -// it to { -// execute { -// LOGGER.debug("excute job ${it.name}") -// apJobService.processActivity( -// job = this, -// hideoutJob = it -// ) -// } -// } -// } -// ) jobQueueWorkerService.init>(emptyList()) }