René's URL Explorer Experiment

{"@context":"https://schema.org","@type":"DiscussionForumPosting","headline":"Pub/Sub Subscriber.stopAsync() is not asynchronous","articleBody":"The javadocs for `Subscriber.stopAsync()` (really from `AbstractApiService`) read:\r\n\r\n\u003e ... this initiates a service shutdown and returns immediately.\r\n\r\nThis does not seem to be how it is implemented in Pub/Sub.  The `doStop()` calls into the `MessageDispatcher.stop()` then into the `MessageWaiter.waitNoMessages()`, etc..\r\n\r\nMaybe the method name needs to be changed or the functionality updated?  What I've had to do outside is to fork a thread that calls `stopAsync()`, dequeue messages from the receiver queues in other thread(s) so they can be nack'd in a ~spin loop, notice when the `subscriber.state()` gets to TERMINATED, and then join with the stopping thread.\r\n\r\nA simple way to test this is to receive a message, don't ack or nack it reply-consumer, and the call `stopAsync()`.\r\n\r\nMaybe I am missing a configuration option or something?  Thanks.","author":{"url":"https://github.com/j256","@type":"Person","name":"j256"},"datePublished":"2018-04-06T14:54:50.000Z","interactionStatistic":{"@type":"InteractionCounter","interactionType":"https://schema.org/CommentAction","userInteractionCount":0},"url":"https://github.com/3134/google-cloud-java/issues/3134"}