I am trying to get local Pub/Sub emulator to work. Setting $PUBSUB_EMULATOR_HOST alone does not make the library make calls to the local emulator instead of cloud as stated in Pub/Sub documentation.
Procedure stated here does not work either. I get the following error -
---------------OUTBOUND--------------------
[id: 0xdced07d7] GO_AWAY: lastStreamId=0, errorCode=2, length=50, bytes=436f6e6e656374696f6e20726566757365643a206c6f63616c686f73742f303a303a303a303a303a303a303a313a38373232
------------------------------------
17:37:01.001 [grpc-default-worker-ELG-1-12] DEBUG io.netty.handler.codec.http2.Http2ConnectionHandler - [id: 0xdced07d7] Sending GOAWAY failed: lastStreamId '0', errorCode '2', debugData 'Connection refused: localhost/0:0:0:0:0:0:0:1:8722'. Forcing shutdown of the connection.
io.netty.channel.ChannelException: Pending write on removal of SslHandler
at io.netty.handler.ssl.SslHandler.handlerRemoved0(SslHandler.java:547)
at io.netty.handler.codec.ByteToMessageDecoder.handlerRemoved(ByteToMessageDecoder.java:227)
at io.netty.channel.DefaultChannelPipeline.callHandlerRemoved0(DefaultChannelPipeline.java:631)
at io.netty.channel.DefaultChannelPipeline.destroyDown(DefaultChannelPipeline.java:883)
at io.netty.channel.DefaultChannelPipeline.destroyUp(DefaultChannelPipeline.java:849)
at io.netty.channel.DefaultChannelPipeline.destroy(DefaultChannelPipeline.java:841)
at io.netty.channel.DefaultChannelPipeline.access$700(DefaultChannelPipeline.java:44)
at io.netty.channel.DefaultChannelPipeline$HeadContext.channelUnregistered(DefaultChannelPipeline.java:1316)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelUnregistered(AbstractChannelHandlerContext.java:181)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelUnregistered(AbstractChannelHandlerContext.java:167)
at io.netty.channel.DefaultChannelPipeline.fireChannelUnregistered(DefaultChannelPipeline.java:826)
at io.netty.channel.AbstractChannel$AbstractUnsafe$7.run(AbstractChannel.java:752)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:403)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:445)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:858)
at io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:144)
at java.lang.Thread.run(Thread.java:748)
And on the emulator I get -
[pubsub] Jun 14, 2017 5:28:13 PM io.gapi.emulators.grpc.GrpcServer$3 operationComplete
[pubsub] INFO: Adding handler(s) to newly registered Channel.
[pubsub] Jun 14, 2017 5:28:13 PM io.gapi.emulators.netty.HttpVersionRoutingHandler channelRead
[pubsub] INFO: Detected non-HTTP/2 connection.
[pubsub] Jun 14, 2017 5:28:13 PM io.gapi.emulators.netty.NotFoundHandler handleRequest
[pubsub] INFO: Unknown request URI: /bad-request
[pubsub] Jun 14, 2017 5:28:40 PM io.gapi.emulators.grpc.GrpcServer$3 operationComplete
[pubsub] INFO: Adding handler(s) to newly registered Channel.
[pubsub] Jun 14, 2017 5:28:40 PM io.gapi.emulators.netty.HttpVersionRoutingHandler channelRead
[pubsub] INFO: Detected non-HTTP/2 connection.
[pubsub] Jun 14, 2017 5:28:40 PM io.gapi.emulators.netty.NotFoundHandler handleRequest
[pubsub] INFO: Unknown request URI: /bad-request
[pubsub] Jun 14, 2017 5:29:20 PM io.gapi.emulators.grpc.GrpcServer$3 operationComplete
[pubsub] INFO: Adding handler(s) to newly registered Channel.
[pubsub] Jun 14, 2017 5:29:20 PM io.gapi.emulators.netty.HttpVersionRoutingHandler channelRead
[pubsub] INFO: Detected non-HTTP/2 connection.
[pubsub] Jun 14, 2017 5:29:20 PM io.gapi.emulators.netty.NotFoundHandler handleRequest
[pubsub] INFO: Unknown request URI: /bad-request
[pubsub] Jun 14, 2017 5:30:42 PM io.gapi.emulators.grpc.GrpcServer$3 operationComplete
[pubsub] INFO: Adding handler(s) to newly registered Channel.
[pubsub] Jun 14, 2017 5:30:42 PM io.gapi.emulators.netty.HttpVersionRoutingHandler channelRead
[pubsub] INFO: Detected non-HTTP/2 connection.
[pubsub] Jun 14, 2017 5:30:42 PM io.gapi.emulators.netty.NotFoundHandler handleRequest
[pubsub] INFO: Unknown request URI: /bad-request
I am using "com.google.cloud" % "google-cloud-pubsub" % "0.19.0-alpha".
I am trying to get local Pub/Sub emulator to work. Setting
$PUBSUB_EMULATOR_HOSTalone does not make the library make calls to the local emulator instead of cloud as stated in Pub/Sub documentation.Procedure stated here does not work either. I get the following error -
And on the emulator I get -
I am using
"com.google.cloud" % "google-cloud-pubsub" % "0.19.0-alpha".