René's URL Explorer Experiment

{"@context":"https://schema.org","@type":"DiscussionForumPosting","headline":"Support Pub/Sub Emulator","articleBody":"It seems right now `google-cloud-pubsub` doesn't support gcloud emulator. At least I'm not able to configure it for Pub/Sub even though I managed to use an emulator with `google-cloud-datastore`. I think it is related to https://github.com/GoogleCloudPlatform/google-cloud-datastore/issues/114.\r\n\r\nAnyways, when I'm trying to create a subscriber using a channel provider with no credentials. Here are some snippets in Kotlin of how I create a `SubscriptionAdminClient`:\r\n\r\n```\r\nval channelProvider = InstantiatingChannelProvider.newBuilder()\r\n        .setEndpoint(\"localhost:$port\")\r\n        .setCredentialsProvider(FixedCredentialsProvider.create(NoCredentials.getInstance()))\r\n        .build()\r\n```\r\n\r\n```\r\nprotected fun getSubscriptionAdminClient(): SubscriptionAdminClient {\r\n  val adminSettings = SubscriptionAdminSettings.defaultBuilder()\r\n    .setChannelProvider(channelProvider)\r\n    .build()\r\n  return SubscriptionAdminClient.create(adminSettings)\r\n}\r\n```\r\n\r\nWhen I'm trying to call `com.google.cloud.pubsub.spi.v1.SubscriptionAdminClient#createSubscription` I'm getting:\r\n\r\n```\r\ncom.google.api.gax.grpc.ApiException: io.grpc.StatusRuntimeException: UNKNOWN\r\n\tat com.google.api.gax.grpc.ExceptionTransformingCallable$ExceptionTransformingFuture.onFailure(ExceptionTransformingCallable.java:109)\r\n\tat com.google.api.gax.core.ApiFutures$1.onFailure(ApiFutures.java:53)\r\n\tat com.google.common.util.concurrent.Futures$4.run(Futures.java:1126)\r\n\tat com.google.common.util.concurrent.MoreExecutors$DirectExecutor.execute(MoreExecutors.java:399)\r\n\tat com.google.common.util.concurrent.AbstractFuture.executeListener(AbstractFuture.java:902)\r\n\tat com.google.common.util.concurrent.AbstractFuture.addListener(AbstractFuture.java:636)\r\n\tat com.google.common.util.concurrent.ForwardingListenableFuture.addListener(ForwardingListenableFuture.java:45)\r\n\tat com.google.api.gax.core.internal.ApiFutureToListenableFuture.addListener(ApiFutureToListenableFuture.java:53)\r\n\tat com.google.common.util.concurrent.Futures.addCallback(Futures.java:1138)\r\n\tat com.google.common.util.concurrent.Futures.addCallback(Futures.java:1076)\r\n\tat com.google.api.gax.core.ApiFutures.addCallback(ApiFutures.java:48)\r\n\tat com.google.api.gax.grpc.ExceptionTransformingCallable.futureCall(ExceptionTransformingCallable.java:65)\r\n\tat com.google.api.gax.grpc.RetryingCallable$GrpcRetryCallable.call(RetryingCallable.java:139)\r\n\tat com.google.api.gax.grpc.RetryingCallable.futureCall(RetryingCallable.java:84)\r\n\tat com.google.api.gax.grpc.UnaryCallable.futureCall(UnaryCallable.java:219)\r\n\tat com.google.api.gax.grpc.UnaryCallable.futureCall(UnaryCallable.java:230)\r\n\tat com.google.api.gax.grpc.UnaryCallable.call(UnaryCallable.java:258)\r\n\tat com.google.cloud.pubsub.spi.v1.SubscriptionAdminClient.createSubscription(SubscriptionAdminClient.java:339)\r\n\tat com.google.cloud.pubsub.spi.v1.SubscriptionAdminClient.createSubscription(SubscriptionAdminClient.java:307)\r\n\tat com.fkorotkov.gcloud.pubsub.PubSubImpl.registerSubscriber(PubSubImpl.kt:72)\r\nCaused by: io.grpc.StatusRuntimeException: UNKNOWN\r\n\tat io.grpc.Status.asRuntimeException(Status.java:540)\r\n\tat io.grpc.stub.ClientCalls$UnaryStreamToFuture.onClose(ClientCalls.java:439)\r\n\tat io.grpc.ClientInterceptors$CheckedForwardingClientCall.start(ClientInterceptors.java:202)\r\n\tat io.grpc.ForwardingClientCall.start(ForwardingClientCall.java:47)\r\n\tat com.google.api.gax.grpc.HeaderInterceptor$1.start(HeaderInterceptor.java:62)\r\n\tat io.grpc.stub.ClientCalls.startCall(ClientCalls.java:270)\r\n\tat io.grpc.stub.ClientCalls.asyncUnaryRequestCall(ClientCalls.java:249)\r\n\tat io.grpc.stub.ClientCalls.futureUnaryCall(ClientCalls.java:186)\r\n\tat com.google.api.gax.grpc.DirectCallable.futureCall(DirectCallable.java:59)\r\n\tat com.google.api.gax.grpc.ExceptionTransformingCallable.futureCall(ExceptionTransformingCallable.java:62)\r\n\t... 55 more\r\nCaused by: java.lang.IllegalStateException: OAuth2Credentials instance does not support refreshing the access token. An instance with a new access token should be used, or a derived type that supports refreshing.\r\n\tat com.google.auth.oauth2.OAuth2Credentials.refreshAccessToken(OAuth2Credentials.java:182)\r\n\tat com.google.auth.oauth2.OAuth2Credentials.refresh(OAuth2Credentials.java:149)\r\n\tat com.google.auth.oauth2.OAuth2Credentials.getRequestMetadata(OAuth2Credentials.java:135)\r\n\tat io.grpc.auth.ClientAuthInterceptor.getRequestMetadata(ClientAuthInterceptor.java:148)\r\n\tat io.grpc.auth.ClientAuthInterceptor.access$100(ClientAuthInterceptor.java:62)\r\n\tat io.grpc.auth.ClientAuthInterceptor$1.checkedStart(ClientAuthInterceptor.java:94)\r\n\tat io.grpc.ClientInterceptors$CheckedForwardingClientCall.start(ClientInterceptors.java:194)\r\n\t... 62 more\r\n```\r\n\r\nAs I mentioned above I'm able to use Datastore emulator when I run it with `--no-legacy` flag and by creating a Datastore service like this:\r\n\r\n```\r\nDatastoreOptions.newBuilder()\r\n      .setProjectId(\"unit-testing\")\r\n      .setHost(\"localhost:$port\")\r\n      .setCredentials(NoCredentials.getInstance())\r\n      .build()\r\n      .getService()\r\n```\r\n\r\nI'm using the latest available version of the libraries at the moment:\r\n\r\n```\r\n{\r\n  \"group\": \"com.google.cloud\",\r\n  \"name\": \"google-cloud-datastore\",\r\n  \"version\": \"0.13.0-beta\"\r\n},\r\n{\r\n  \"group\": \"com.google.cloud\",\r\n  \"name\": \"google-cloud-pubsub\",\r\n  \"version\": \"0.13.0-alpha\"\r\n}\r\n```","author":{"url":"https://github.com/fkorotkov","@type":"Person","name":"fkorotkov"},"datePublished":"2017-04-22T17:22:05.000Z","interactionStatistic":{"@type":"InteractionCounter","interactionType":"https://schema.org/CommentAction","userInteractionCount":26},"url":"https://github.com/1973/google-cloud-java/issues/1973"}