Update
This commit is contained in:
parent
bc7f557a3e
commit
a275514696
@ -1,6 +1,7 @@
|
|||||||
package no.iktdev.mediaprocessing.processer
|
package no.iktdev.mediaprocessing.processer
|
||||||
|
|
||||||
import no.iktdev.mediaprocessing.shared.common.Defaults
|
import no.iktdev.mediaprocessing.shared.common.Defaults
|
||||||
|
import no.iktdev.mediaprocessing.shared.common.socket.SocketImplementation
|
||||||
import no.iktdev.mediaprocessing.shared.kafka.core.CoordinatorProducer
|
import no.iktdev.mediaprocessing.shared.kafka.core.CoordinatorProducer
|
||||||
import no.iktdev.mediaprocessing.shared.kafka.core.DefaultMessageListener
|
import no.iktdev.mediaprocessing.shared.kafka.core.DefaultMessageListener
|
||||||
import no.iktdev.mediaprocessing.shared.kafka.core.KafkaImplementation
|
import no.iktdev.mediaprocessing.shared.kafka.core.KafkaImplementation
|
||||||
@ -9,8 +10,7 @@ import org.springframework.context.annotation.Configuration
|
|||||||
import org.springframework.context.annotation.Import
|
import org.springframework.context.annotation.Import
|
||||||
import org.springframework.web.client.RestTemplate
|
import org.springframework.web.client.RestTemplate
|
||||||
|
|
||||||
//@Configuration
|
|
||||||
//class SocketLocalInit: SocketImplementation()
|
|
||||||
|
|
||||||
@Configuration
|
@Configuration
|
||||||
@Import(CoordinatorProducer::class, DefaultMessageListener::class)
|
@Import(CoordinatorProducer::class, DefaultMessageListener::class)
|
||||||
@ -20,3 +20,7 @@ class KafkaLocalInit: KafkaImplementation() {
|
|||||||
@Configuration
|
@Configuration
|
||||||
public class DefaultProcesserConfiguration: Defaults() {
|
public class DefaultProcesserConfiguration: Defaults() {
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Configuration
|
||||||
|
class SocketImplemented: SocketImplementation() {
|
||||||
|
}
|
||||||
@ -41,9 +41,6 @@ fun main(args: Array<String>) {
|
|||||||
val context = runApplication<ProcesserApplication>(*args)
|
val context = runApplication<ProcesserApplication>(*args)
|
||||||
}
|
}
|
||||||
|
|
||||||
class SocketImplemented: SocketImplementation() {
|
|
||||||
|
|
||||||
}
|
|
||||||
@EnableScheduling
|
@EnableScheduling
|
||||||
class DatabaseReconnect() {
|
class DatabaseReconnect() {
|
||||||
var lostConnectionCount = 0
|
var lostConnectionCount = 0
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user