API Documentation
\

\ConsumerStrategies_AbstractConsumer

Provides some base methods for use by a Consumer implementation

Summary

Methods
Properties
Constants
__construct()
getNumThreads()
persist()
No public properties found
No constants found
_log()
_debug()
_encode()
_handleError()
$_options
N/A
No private methods found
$_defaults
N/A

Properties

$_options

$_options : array

An array of options to be used by the Mixpanel library.

Type

array

$_defaults

$_defaults : array

Default options that can be overridden via the $options constructor arg

Type

array

Methods

__construct()

__construct(array  $options = array())

Creates a new AbstractConsumer

Parameters

array $options

getNumThreads()

getNumThreads() : integer

Number of requests/batches that will be processed in parallel.

Returns

integer

persist()

persist(array  $batch) : boolean

Persist a batch of messages in whatever way the implementer sees fit

Parameters

array $batch

an array of messages to consume

Returns

boolean —

success or fail

_log()

_log(  $msg)

Log a message to PHP's error log

Parameters

$msg

_debug()

_debug() : boolean

Returns true if in debug mode, false if in production mode

Returns

boolean

_encode()

_encode(array  $params) : string

Encode an array to be persisted

Parameters

array $params

Returns

string

_handleError()

_handleError(  $code,   $msg)

Handles errors that occur in a consumer

Parameters

$code
$msg