override fun receiveMessage()

in pubsub/src/main/kotlin/PubSub.kt [152:155]

• 4 lines of code
• 1 McCabe index (conditional complexity)

        override fun receiveMessage(message: PubsubMessage, consumer: AckReplyConsumer) {
            messages.offer(message)
            consumer.ack()
        }