-
Notifications
You must be signed in to change notification settings - Fork 13
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
rename and reorg #16
rename and reorg #16
Conversation
def fromRootConfig(pipelineName: String, config: Config = ConfigFactory.load())(implicit system: ActorSystem) = { | ||
val path = "workPipeline.metrics" | ||
def fromRootConfig(dispatcherName: String, config: Config = ConfigFactory.load())(implicit system: ActorSystem) = { | ||
val path = "reactiveDispatcher.metrics" |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
maybe have this root config namespace as kanaloa
instead of reactiveDispatcher
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
will be addressed in the configuration ticket.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
can be handled in #7
resolves #8 |
import com.iheart.workpipeline.akka.patterns.CommonProtocol.{ ShutdownSuccessfully, QueryStatus } | ||
import com.iheart.workpipeline.collection.FiniteCollection._ | ||
import Worker.Hold | ||
import kanaloa.reactive.dispatcher.queue.queue.{ ResultChecker, WorkerRef, QueueRef } |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
queue.queue
looks weird
import com.iheart.workpipeline.akka.patterns.queue.Queue.{ QueueStatus, WorkEnqueued } | ||
import com.iheart.workpipeline.akka.patterns.queue.QueueProcessor.{ Shutdown } | ||
import Queue.{ QueueStatus, WorkEnqueued } | ||
import QueueProcessor.{ Shutdown } |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
these should already be handled by the import Queue._
and import QueueProcessor._
above? (and the import should probably be the full package name, as mentioned in another comment)
anyway, PR looks ok other than some package naming issues and imports
No description provided.