search

twitter-archive / kestrel

simple, distributed message queue system (inactive)
http://twitter.github.io/kestrel
Other
2.78k stars 313 forks source link

setting up fanout queues in Scala config files #127

Open kperi opened 11 years ago

kperi commented 11 years ago

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