Skip to content
This repository has been archived by the owner on Sep 18, 2021. It is now read-only.

setting up fanout queues in Scala config files #127

Open
kperi opened this issue Aug 4, 2013 · 0 comments
Open

setting up fanout queues in Scala config files #127

kperi opened this issue Aug 4, 2013 · 0 comments

Comments

@kperi
Copy link

kperi commented Aug 4, 2013

Hi,

trying to setup a fanout queue we came across an issue:

The declaration of a fanout queue in the queue definition scala files (production.scala/development.scala), seems to be ignored when kestrel starts.

eg. starting kestrel with a fanout queue declared, when pushing items to the queue the child queue is not created.

if the child queue file is present, kestrel is loading it and works as expected.

I've forked kestrel and I've added a few lines in src/main/scala/net/lag/kestrel/QueueCollection.scala

to actually create the file if it doesn't exist in the queue directory.

I've also changed the following :

-addSbtPlugin("com.twitter" %% "sbt-package-dist" % "1.0.6")
+addSbtPlugin("com.twitter" % "sbt-package-dist" % "1.0.7")

-addSbtPlugin("com.twitter" %% "sbt11-scrooge" % "3.0.0")
+addSbtPlugin("com.twitter" %% "sbt11-scrooge" % "3.0.2")

I will do a pull request soon,

Thanks
Kostas

Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant