PubSubの

Question

私はスカラ座やRedisの世界に新しいですし、私はシンプルな何かをしようとしています：

私は、チャネルにサブスクライブする新しいキーが追加されたときに通知するために、（私の考えがありますキーを設定し、そのキーが追加されたチャンネルに公開するだけです）。

私がウェブサイトで読んでいたように、scala-redisが推奨バージョンの中で最もアップデートされているので、私はそれを使用することに決めました。

私が加入する一部といくつかの問題を抱えています。私は、次のコードを持っている：私は、ドキュメントをチェックしていた機能は次のようになり

error: missing arguments for method subscribe in trait PubSub; follow this method with `_' if you want to treat it as a partially applied function

：正直に言うと

def subscribe(channel: String, channels: String*)(fn: PubSubMessage => Any) { 
    if (pubSub == true) { // already pubsub ing 
     subscribeRaw(channel, channels: _*) 
    } else { 
     pubSub = true 
     subscribeRaw(channel, channels: _*) 
     new Consumer(fn).start 
    } 
    } 

私は、次のエラーメッセージを取得しています

import com.redis._ 
val r = new RedisClient("localhost", 6379) 
r.subscribe("modifications","modifications","subscribe") 

を私は何が間違っているのか分かりません。誰かが私にいくつかのアイデアを手伝ってもらえると、それは素晴らしいものになるでしょう。あなたは、受信したメッセージを処理するための機能を提供する必要が

おかげ

Answer 1

：

r.subscribe("modifications","modifications","subscribe"){ m => println(m) } 

残念ながら、ドキュメントのほとんどはコードであるが、それはあなたがPubSubDemoを見てみた場合に役立つかもしれませんまたはPubSubSpec。