The RdKafka\Queue class

(PECL rdkafka >= 0.9.1)

Introduction

Class synopsis

class RdKafka\Queue {
/* Methods */
public consume(int $timeout_ms): RdKafka\Message
}

Table of Contents