mirror of https://github.com/usbharu/Hideout.git
style: fix lint (CI)
This commit is contained in:
parent
1c80911365
commit
f82680236e
|
@ -38,7 +38,6 @@ class SubscriberRunner(
|
||||||
|
|
||||||
logger.debug("{}{}{}", header, value, footer)
|
logger.debug("{}{}{}", header, value, footer)
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
companion object {
|
companion object {
|
||||||
|
|
|
@ -22,7 +22,6 @@ class TimelineRelationshipFollowSubscriber(
|
||||||
domainEventSubscriber.subscribe<RelationshipEventBody>(RelationshipEvent.ACCEPT_FOLLOW.eventName, this)
|
domainEventSubscriber.subscribe<RelationshipEventBody>(RelationshipEvent.ACCEPT_FOLLOW.eventName, this)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
override suspend fun invoke(p1: DomainEvent<RelationshipEventBody>) {
|
override suspend fun invoke(p1: DomainEvent<RelationshipEventBody>) {
|
||||||
val relationship = p1.body.getRelationship()
|
val relationship = p1.body.getRelationship()
|
||||||
val userDetail = userDetailRepository.findByActorId(relationship.actorId.id)
|
val userDetail = userDetailRepository.findByActorId(relationship.actorId.id)
|
||||||
|
|
|
@ -32,7 +32,8 @@ class SpringFrameworkDomainEventPublisher(private val applicationEventPublisher:
|
||||||
|
|
||||||
val requestId: String? = MDC.get(ApplicationRequestLogInterceptor.requestId)
|
val requestId: String? = MDC.get(ApplicationRequestLogInterceptor.requestId)
|
||||||
val springDomainEvent = SpringDomainEvent(
|
val springDomainEvent = SpringDomainEvent(
|
||||||
requestId, domainEvent
|
requestId,
|
||||||
|
domainEvent
|
||||||
)
|
)
|
||||||
|
|
||||||
applicationEventPublisher.publishEvent(springDomainEvent)
|
applicationEventPublisher.publishEvent(springDomainEvent)
|
||||||
|
@ -43,4 +44,4 @@ class SpringFrameworkDomainEventPublisher(private val applicationEventPublisher:
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
data class SpringDomainEvent(val requestId: String?, val domainEvent: DomainEvent<*>)
|
data class SpringDomainEvent(val requestId: String?, val domainEvent: DomainEvent<*>)
|
||||||
|
|
|
@ -28,7 +28,6 @@ class SpringFrameworkDomainEventSubscriber : DomainEventSubscriber {
|
||||||
|
|
||||||
@EventListener
|
@EventListener
|
||||||
suspend fun onDomainEventPublished(domainEvent: SpringDomainEvent) {
|
suspend fun onDomainEventPublished(domainEvent: SpringDomainEvent) {
|
||||||
|
|
||||||
logger.debug(
|
logger.debug(
|
||||||
"Domain Event Published: {} id: {} requestId: {}",
|
"Domain Event Published: {} id: {} requestId: {}",
|
||||||
domainEvent.domainEvent.name,
|
domainEvent.domainEvent.name,
|
||||||
|
@ -36,7 +35,6 @@ class SpringFrameworkDomainEventSubscriber : DomainEventSubscriber {
|
||||||
domainEvent.requestId
|
domainEvent.requestId
|
||||||
)
|
)
|
||||||
coroutineScope {
|
coroutineScope {
|
||||||
|
|
||||||
map[domainEvent.domainEvent.name]?.map {
|
map[domainEvent.domainEvent.name]?.map {
|
||||||
async(MDCContext()) {
|
async(MDCContext()) {
|
||||||
try {
|
try {
|
||||||
|
@ -50,7 +48,6 @@ class SpringFrameworkDomainEventSubscriber : DomainEventSubscriber {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}?.awaitAll()
|
}?.awaitAll()
|
||||||
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue