Class Queue

Class \RdKafka\Queue

Methods

__construct()

public __construct ( 
    \FFI\CData $queue
 ): 

Parameters

queue \FFI\CData

__destruct()

public __destruct (  ): 

consume()

public consume ( 
    int $timeout_ms
 ): ?\RdKafka\Message

Parameters

timeout_ms int

Returns

?\RdKafka\Message

fromRdKafka()

public static fromRdKafka ( 
    \RdKafka $kafka
 ): self

Parameters

kafka \RdKafka

Returns

self

getCData()

public getCData (  ): \FFI\CData

Returns

\FFI\CData

poll()

public poll ( 
    int $timeout_ms
 ): ?\RdKafka\Event

Parameters

timeout_ms int

Returns

?\RdKafka\Event

Test Coverage 💛

• 💛 Lines: 76.92% (20 / 26)
• ❤️ Methods: 50% (3 / 6)