The RdKafka\Queue class

(PECL rdkafka >= 0.9.1)

Introduction

Class synopsis

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

Table of Contents