Skip to content
Branch: master
Find file Copy path
Find file Copy path
jbwyme Initial commit 8812955 Jun 19, 2013
0 contributors

Users who have contributed to this file

21 lines (18 sloc) 651 Bytes
require_once(dirname(__FILE__) . "/../../lib/ConsumerStrategies/AbstractConsumer.php");
class ObConsumer extends ConsumerStrategies_AbstractConsumer {
public function persist($batch) {
if (isset($batch[0]['event']) && $batch[0]['event'] == "force_error") {
$this->_handleError(0, "This is the data from a fake error");
return false;
} else {
echo "<pre>";
echo "printing batch:\n";
echo "---------------\n";
echo json_encode($batch) . "\n";
echo "---------------\n\n";
echo "</pre>";
return true;
You can’t perform that action at this time.