@@ -4,3 +4,4 @@ dist *.class bin .manager +.DS_Store .gitignore @@ -130,6 +130,8 @@ class KestrelHandler(val session: IoSession, val config: Config) extends Actor { writeResponse("Flushed all queues.\r\n") case "DUMP_CONFIG" => dumpConfig() + case "VERSION" => + version() } } @@ -309,6 +311,10 @@ class KestrelHandler(val session: IoSession, val config: Config) extends Actor { } writeResponse(dump.mkString("", "\r\n", "\r\nEND\r\n")) } + + private def version() = { + writeResponse("VERSION Kestrel 1.1.2\r\n") + } private def shutdown() = { Kestrel.shutdown src/main/scala/net/lag/kestrel/KestrelHandler.scala @@ -39,7 +39,7 @@ case class Response(data: IoBuffer) object Codec { - private val KNOWN_COMMANDS = List("GET", "SET", "STATS", "SHUTDOWN", "RELOAD", "FLUSH", "FLUSH_ALL", "DUMP_CONFIG") + private val KNOWN_COMMANDS = List("GET", "SET", "STATS", "SHUTDOWN", "RELOAD", "FLUSH", "FLUSH_ALL", "DUMP_CONFIG", "VERSION") private val DATA_COMMANDS = List("SET") val encoder = new ProtocolEncoder { src/main/scala/net/lag/kestrel/memcache/Codec.scala a6d2831ef282806f2c68f9a0d73fb5880c1bd4f5 Frederic Jean frederic.jean@sun.com http://github.com/robey/kestrel/commit/4c2417f81ec31ecba5081be22233132be7738c0f 4c2417f81ec31ecba5081be22233132be7738c0f 2009-07-27T23:27:23-07:00 2009-07-27T23:14:54-07:00 Adding support for the VERSION command. This will enable the use of the Whalin Java MemCache client and the JRuby MemCache Client. 7c9b39c602d8a944122988fe6505bb14c38e56a5 Frederic Jean frederic.jean@sun.com