2017-05-12 1 views
0

は、私は次のように定義された加入者を持っている:subscriber.startAsyncを呼び出すときGoogleのPubSubの加入者startAsync NosuchmethodError

class PubSubMessageReceiver extends MessageReceiver { 
    override def receiveMessage(message: PubsubMessage, consumer: AckReplyConsumer): Unit = { 
    // .. business logic 
     //acknowledge message 
     consumer.ack() 
    } 
    } 

val subscriber = Subscriber.defaultBuilder(subscriptionName, new PubSubMessageReceiver).build() 

は、しかし、私は次のエラーが表示されます

java.lang.NoSuchMethodError: com.google.api.core.AbstractApiService$InnerService.startAsync()Lcom/google/common/util/concurrent/Service; 
    at com.google.api.core.AbstractApiService.startAsync(AbstractApiService.java:121) 
    at com.google.cloud.pubsub.spi.v1.Subscriber.startAsync(Subscriber.java:218) 
+0

サブスクライバをどのような環境で起動していますか? –

答えて

0

私のランタイム環境がインストールされグアバの古いバージョンを持っていました。

関連する問題