diff --git a/Model/Datasource/BeanstalkdSource.php b/Model/Datasource/BeanstalkdSource.php index adf3033..3387751 100644 --- a/Model/Datasource/BeanstalkdSource.php +++ b/Model/Datasource/BeanstalkdSource.php @@ -95,8 +95,8 @@ function disconnect() { function isConnected() { return $this->connected; } - - function put(&$Model, $data, $options = array()) { + + function put(&$Model, $data, $tube = null, $options = array()) { unset($Model->data[$Model->alias]); $Model->set($data); $body = $Model->data[$Model->alias]; @@ -104,7 +104,9 @@ function put(&$Model, $data, $options = array()) { $priority = 0; $delay = 0; $ttr = $this->config['ttr']; - $tube = 'default'; + if($tube === null) { + $tube = 'default'; + } extract($options, EXTR_OVERWRITE); if (!$this->choose($Model, $tube)) {