public function ZoomAPISystemQueue::createItem in Zoom API 7.2

Override createItem to handle merging instead of inserting.

Overrides SystemQueue::createItem

File

./zoomapi.module, line 33

Main file for the Zoom API module.

Class

ZoomAPISystemQueue

Extend SystemQueue making each item unique.

Code

public function createItem($data) {
  $serial_data = serialize($data);
  $query = db_merge('queue')
    ->key([
    'name' => $this->name,
    'data' => $serial_data,
  ])
    ->fields([
    'name' => $this->name,
    'data' => $serial_data,
    'created' => REQUEST_TIME,
  ]);
  return (bool) $query
    ->execute();
}