redis-daemon/dev.ust.zinc.grader.daemon/Job/Companion

Companion

object Companion

Properties

private val lookupTable: Map<String, Pair<Job<out Payload>, KClass<out Payload>>>

val subscriptions: List<String>

private val threadPool: ExecutorService

Functions

fun parse(message: String): Result<Pair<String, Payload>>

Parses from a String representation of JobMessage to a JobMessage type then parse String JobMessage.payload to the Payload of JobMessage.job

parseFromPayload

fun parseFromPayload(jobMessage: JobMessage): Result<Pair<String, Payload>>

Parses from JobMessage to pair of topicName and payload

fun resolveJob(topicName: String): Pair<Job<Payload>, KClass<Payload>>?

Retrieve the Job object and Payload type from lookupTable