PHP Zend_Queue_Adapter_AdapterAbstract类代码示例

OGeek|极客世界-中国程序员成长平台 › 门户 › 编程› PHP›PHP编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了PHP中Zend_Queue_Adapter_AdapterAbstract类的典型用法代码示例。如果您正苦于以下问题：PHP Zend_Queue_Adapter_AdapterAbstract类的具体用法？PHP Zend_Queue_Adapter_AdapterAbstract怎么用？PHP Zend_Queue_Adapter_AdapterAbstract使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

在下文中一共展示了Zend_Queue_Adapter_AdapterAbstract类的11个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的PHP代码示例。

示例1: __construct

 /**
  * Constructor
  *
  * @param  array|Zend_Config $options
  * @param  Zend_Queue|null   $queue
  *
  * @return self
  *
  * @throws Zend_Queue_Exception
  */
 public function __construct($options, Zend_Queue $queue = null)
 {
     Zend_Queue_Adapter_AdapterAbstract::__construct($options, $queue);
     if (!isset($this->_options['options'][Zend_Db_Select::FOR_UPDATE])) {
         // turn off auto update by default
         $this->_options['options'][Zend_Db_Select::FOR_UPDATE] = false;
     }
     if (!is_bool($this->_options['options'][Zend_Db_Select::FOR_UPDATE])) {
         throw new Zend_Queue_Exception('Options array item: Zend_Db_Select::FOR_UPDATE must be boolean');
     }
     if (!isset($this->_options['dbAdapter']) || !$this->_options['dbAdapter'] instanceof Zend_Db_Adapter_Abstract) {
         throw new Zend_Queue_Exception('dbAdapter must be set');
     }
     if (!isset($this->_options['dbQueueTable']) || empty($this->_options['dbQueueTable'])) {
         throw new Zend_Queue_Exception('dbQueueTable must be set');
     }
     if (!isset($this->_options['dbMessageTable']) || empty($this->_options['dbMessageTable'])) {
         throw new Zend_Queue_Exception('dbMessageTable must be set');
     }
     $db = $this->_options['dbAdapter'];
     $queueTable = $this->_options['dbQueueTable'];
     $messageTable = $this->_options['dbMessageTable'];
     $this->_queueTable = new Zend_Db_Table(array('db' => $db, 'name' => $queueTable, 'primary' => 'queue_id'));
     $this->_messageTable = new Zend_Db_Table(array('db' => $db, 'name' => $messageTable, 'primary' => 'message_id'));
 }

开发者ID:robbieaverill，项目名称:Aoe_Queue，代码行数:35，代码来源:Db.php

示例2: __construct

 /**
  * Constructor
  *
  * @param  array|Zend_Config $options
  * @param  Zend_Queue|null $queue
  * @return void
  */
 public function __construct($options, Zend_Queue $queue = null)
 {
     parent::__construct($options, $queue);
     if (!extension_loaded("jobqueue_client")) {
         require_once PHP_LIBRARY_PATH . 'Zend/Queue/Exception.php';
         throw new Zend_Queue_Exception('Platform Job Queue extension does not appear to be loaded');
     }
     if (!isset($this->_options['daemonOptions'])) {
         require_once PHP_LIBRARY_PATH . 'Zend/Queue/Exception.php';
         throw new Zend_Queue_Exception('Job Queue host and password should be provided');
     }
     $options = $this->_options['daemonOptions'];
     if (!array_key_exists('host', $options)) {
         require_once PHP_LIBRARY_PATH . 'Zend/Queue/Exception.php';
         throw new Zend_Queue_Exception('Platform Job Queue host should be provided');
     }
     if (!array_key_exists('password', $options)) {
         require_once PHP_LIBRARY_PATH . 'Zend/Queue/Exception.php';
         throw new Zend_Queue_Exception('Platform Job Queue password should be provided');
     }
     $this->_zendQueue = new ZendApi_Queue($options['host']);
     if (!$this->_zendQueue) {
         require_once PHP_LIBRARY_PATH . 'Zend/Queue/Exception.php';
         throw new Zend_Queue_Exception('Platform Job Queue connection failed');
     }
     if (!$this->_zendQueue->login($options['password'])) {
         require_once PHP_LIBRARY_PATH . 'Zend/Queue/Exception.php';
         throw new Zend_Queue_Exception('Job Queue login failed');
     }
     if ($this->_queue) {
         $this->_queue->setMessageClass('Zend_Queue_Message_PlatformJob');
     }
 }

开发者ID:netixx，项目名称:Stock，代码行数:40，代码来源:PlatformJobQueue.php

示例3: __construct

 /**
  * Constructor
  *
  * @param  array|Zend_Config $options
  * @param  null|Zend_Queue $queue
  * @return void
  */
 public function __construct($options, Zend_Queue $queue = null)
 {
     if (!extension_loaded('mongo')) {
         require_once 'Zend/Queue/Exception.php';
         throw new Zend_Queue_Exception('Mongo extension does not appear to be loaded');
     }
     parent::__construct($options, $queue);
     $options =& $this->_options['driverOptions'];
     if (!array_key_exists('host', $this->_options)) {
         $this->_options['host'] = self::DEFAULT_HOST;
     }
     if (!array_key_exists('port', $this->_options)) {
         $this->_options['port'] = self::DEFAULT_PORT;
     }
     if (!array_key_exists('persistent', $this->_options)) {
         $this->_options['persistent'] = self::DEFAULT_PERSISTENT;
     }
     if (!array_key_exists('dbname', $this->_options)) {
         $this->_options['dbname'] = self::DEFAULT_DBNAME;
     }
     if (!array_key_exists('collection', $this->_options)) {
         $this->_options['collection'] = self::DEFAULT_COLLECTION;
     }
     $options = $this->_options;
     $this->_conn = new Mongo($this->_options['host'], $this->_options['port'], $this->_options['persistent']);
     $this->_db = $this->_conn->selectDB($this->_options['dbname']);
     $result = $this->_collection = $this->_db->selectCollection($this->_options['collection']);
     if ($result === false) {
         require_once 'Zend/Queue/Exception.php';
         throw new Zend_Queue_Exception('Could not connect to Mongo');
     }
     $this->_host = $options['host'];
     $this->_port = (int) $options['port'];
 }

开发者ID:stunti，项目名称:Stunti_Cache_Backend_Mongo，代码行数:41，代码来源:Mongo.php

示例4: __construct

 /**
  * Constructor
  *
  * @param  array|Zend_Config $config An array having configuration data
  * @param  Zend_Queue The Zend_Queue object that created this class
  * @return void
  */
 public function __construct($options, Zend_Queue $queue = null)
 {
     parent::__construct($options);
     $options =& $this->_options['driverOptions'];
     if (!array_key_exists('scheme', $options)) {
         $options['scheme'] = self::DEFAULT_SCHEME;
     }
     if (!array_key_exists('host', $options)) {
         $options['host'] = self::DEFAULT_HOST;
     }
     if (!array_key_exists('port', $options)) {
         $options['port'] = self::DEFAULT_PORT;
     }
     if (array_key_exists('stompClient', $options)) {
         $this->_client = $options['stompClient'];
     } else {
         $this->_client = new Zend_Queue_Stomp_Client($options['scheme'], $options['host'], $options['port']);
     }
     $connect = $this->_client->createFrame();
     // Username and password are optional on some messaging servers
     // such as Apache's ActiveMQ
     $connect->setCommand('CONNECT');
     if (isset($options['username'])) {
         $connect->setHeader('login', $options['username']);
         $connect->setHeader('passcode', $options['password']);
     }
     $response = $this->_client->send($connect)->receive();
     if (false !== $response && $response->getCommand() != 'CONNECTED') {
         //require_once 'Zend/Queue/Exception.php';
         throw new Zend_Queue_Exception("Unable to authenticate to '" . $options['scheme'] . '://' . $options['host'] . ':' . $options['port'] . "'");
     }
 }

开发者ID:siite，项目名称:choose-sa-cloud，代码行数:39，代码来源:Activemq.php

示例5: __construct

    /**
     * Constructor
     *
     * @param  array|Zend_Config $options
     * @param  null|Zend_Queue $queue
     * @return void
     */
    public function __construct($options, Zend_Queue $queue = null)
    {
        if (!extension_loaded('memcache')) {
            require_once 'Zend/Queue/Exception.php';
            throw new Zend_Queue_Exception('Memcache extension does not appear to be loaded');
        }

        parent::__construct($options, $queue);

        $options = &$this->_options['driverOptions'];

        if (!array_key_exists('host', $options)) {
            $options['host'] = self::DEFAULT_HOST;
        }
        if (!array_key_exists('port', $options)) {
            $options['port'] = self::DEFAULT_PORT;
        }

        $this->_cache = new Memcache();

        $result = $this->_cache->connect($options['host'], $options['port']);

        if ($result === false) {
            require_once 'Zend/Queue/Exception.php';
            throw new Zend_Queue_Exception('Could not connect to MemcacheQ');
        }

        $this->_host = $options['host'];
        $this->_port = (int)$options['port'];
    }

开发者ID:nhp，项目名称:shopware-4，代码行数:37，代码来源:Memcacheq.php

示例6: __construct

    /**
     * Constructor
     *
     * @param  array|Zend_Config $options
     * @param  Zend_Queue|null $queue
     * @return void
     */
    public function __construct($options, Zend_Queue $queue = null)
    {
        parent::__construct($options, $queue);

        if (!isset($this->_options['options'][Zend_Db_Select::FOR_UPDATE])) {
            // turn off auto update by default
            $this->_options['options'][Zend_Db_Select::FOR_UPDATE] = false;
        }

        if (!is_bool($this->_options['options'][Zend_Db_Select::FOR_UPDATE])) {
            require_once 'Zend/Queue/Exception.php';
            throw new Zend_Queue_Exception('Options array item: Zend_Db_Select::FOR_UPDATE must be boolean');
        }

        if (isset($this->_options['dbAdapter'])
            && $this->_options['dbAdapter'] instanceof Zend_Db_Adapter_Abstract) {
            $db = $this->_options['dbAdapter'];
        } else {
            $db = $this->_initDbAdapter();
        }

        $this->_queueTable = new Zend_Queue_Adapter_Db_Queue(array(
            'db' => $db,
        ));

        $this->_messageTable = new Zend_Queue_Adapter_Db_Message(array(
            'db' => $db,
        ));

    }

开发者ID:nhp，项目名称:shopware-4，代码行数:37，代码来源:Db.php

示例7: __construct

 /**
  * Constructor
  *
  * @param  array|Zend_Config $options
  * @param  null|Zend_Queue $queue
  * @return void
  */
 public function __construct($options, Zend_Queue $queue = null)
 {
     parent::__construct($options, $queue);
     if (!empty($this->_options['driverOptions'])) {
         $this->_rediska = $options['driverOptions'];
     }
     $this->_rediska = Rediska_Options_RediskaInstance::getRediskaInstance($this->_rediska, 'Zend_Queue_Exception', 'driverOptions');
     $this->_queues = new Rediska_Key_Set($this->_getKeyName('queues'), array('rediska' => $this->_rediska));
 }

开发者ID:tanya61612，项目名称:Pastexen，代码行数:16，代码来源:Redis.php

示例8: __construct

 /**
  * Constructor
  *
  * @param  array|Zend_Config $options
  * @param  null|Zend_Queue $queue
  * @return void
  */
 public function __construct($options, Zend_Queue $queue = null)
 {
     parent::__construct($options, $queue);
     $defaultInstance = Rediska::getDefaultInstance();
     if (empty($this->_options['driverOptions']) && $defaultInstance) {
         $this->_rediska = $defaultInstance;
     } else {
         $this->_rediska = new Rediska($this->_options['driverOptions']);
     }
     $this->_queues = new Rediska_Key_Set($this->_getKeyName('queues'));
     $this->_queues->setRediska($this->_rediska);
 }

开发者ID:jahanzaibbahadur，项目名称:twich，代码行数:19，代码来源:Redis.php

示例9: __construct

 public function __construct($options, Zend_Queue $queue = null)
 {
     $this->_queueModel = isset($options['queue_model']) ? $options['queue_model'] : Mage::getModel('enterprise_queue/queue');
     unset($options['queue_model']);
     $this->_queueTaskModel = isset($options['task_model']) ? $options['task_model'] : Mage::getModel('enterprise_queue/queue_task');
     unset($options['task_model']);
     $this->_queueCollection = isset($options['queue_collection']) ? $options['queue_collection'] : Mage::getResourceModel('enterprise_queue/queue_collection');
     unset($options['queue_collection']);
     $this->_queueTaskCollection = isset($options['queue_task_collection']) ? $options['queue_task_collection'] : Mage::getResourceModel('enterprise_queue/queue_task_collection');
     unset($options['queue_task_collection']);
     $this->_logger = isset($options['logger']) ? $options['logger'] : Mage::getModel('core/logger');
     unset($options['logger']);
     parent::__construct($options, $queue);
 }

开发者ID:xiaoguizhidao，项目名称:autotech_design，代码行数:14，代码来源:Db.php

示例10: __construct

 /**
  * Constructor
  *
  * @param  array|Zend_Config $options
  * @param  Zend_Queue|null $queue
  * @return void
  */
 public function __construct($options, Zend_Queue $queue = null)
 {
     parent::__construct($options, $queue);
     if (!isset($this->_options['options'][Zend_Db_Select::FOR_UPDATE])) {
         // turn off auto update by default
         $this->_options['options'][Zend_Db_Select::FOR_UPDATE] = false;
     }
     if (!is_bool($this->_options['options'][Zend_Db_Select::FOR_UPDATE])) {
         require_once 'Zend/Queue/Exception.php';
         throw new Zend_Queue_Exception('Options array item: Zend_Db_Select::FOR_UPDATE must be boolean');
     }
     $options =& $this->_options['driverOptions'];
     if (!array_key_exists('type', $options)) {
         require_once 'Zend/Queue/Exception.php';
         throw new Zend_Queue_Exception("Configuration array must have a key for 'type' for the database type to use");
     }
     if (!array_key_exists('host', $options)) {
         require_once 'Zend/Queue/Exception.php';
         throw new Zend_Queue_Exception("Configuration array must have a key for 'host' for the host to use");
     }
     if (!array_key_exists('username', $options)) {
         require_once 'Zend/Queue/Exception.php';
         throw new Zend_Queue_Exception("Configuration array must have a key for 'username' for the username to use");
     }
     if (!array_key_exists('password', $options)) {
         require_once 'Zend/Queue/Exception.php';
         throw new Zend_Queue_Exception("Configuration array must have a key for 'password' for the password to use");
     }
     if (!array_key_exists('dbname', $options)) {
         require_once 'Zend/Queue/Exception.php';
         throw new Zend_Queue_Exception("Configuration array must have a key for 'dbname' for the database to use");
     }
     try {
         $db = Zend_Db::factory($options['type'], $options);
         $this->_queueTable = new Zend_Queue_Adapter_Db_Queue(array('db' => $db));
         $this->_messageTable = new Zend_Queue_Adapter_Db_Message(array('db' => $db));
     } catch (Zend_Db_Exception $e) {
         require_once 'Zend/Queue/Exception.php';
         throw new Zend_Queue_Exception('Error connecting to database: ' . $e->getMessage(), $e->getCode());
     }
 }

开发者ID:ki8asui，项目名称:isography，代码行数:48，代码来源:Db.php

示例11: __construct

 /**
  * Constructor
  *
  * @param  array|Zend_Config $options
  * @param  null|Zend_Queue $queue
  * @return void
  */
 public function __construct($options, Zend_Queue $queue = null)
 {
     parent::__construct($options, $queue);
 }

开发者ID:Yaoming9，项目名称:Projet-Web-PhP，代码行数:11，代码来源:Null.php

注：本文中的Zend_Queue_Adapter_AdapterAbstract类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

PHP Zend_Reflection_Class类代码示例发布时间：2022-05-23

PHP Zend_Queue类代码示例发布时间：2022-05-23

librespeed/speedtest: Self-hosted Speedt

1 NanoMichael/MicroTeX: A dynamic, cross-p

NanoMichael/MicroTeX: A dynamic, cross-platform, and embeddable LaTeX rendering

阅读：883|2022-08-12

2 bradtraversy/iweather: Ionic 3 mobile we

bradtraversy/iweather: Ionic 3 mobile weather app

阅读：1584|2022-08-30

3 joaomh/curso-de-matlab

joaomh/curso-de-matlab

阅读：1147|2022-08-17

4 断牙刷新位置时间（断牙属性及刷新位置介绍

魔兽世界怀旧服已经开启两个多月了，但作为一个猎人玩家，抓到“断牙”，已经成为了一

阅读：1002|2022-11-06

5 rugk/mastodon-simplified-federation: Sim

rugk/mastodon-simplified-federation: Simplifies following and interacting with r

阅读：1080|2022-08-17

6 CVE-2022-35890

An issue was discovered in Inductive Automation Ignition before 7.9.20 and 8.x b

阅读：916|2022-07-29

7 Tangshitao/Dense-Scene-Matching: Learnin

Tangshitao/Dense-Scene-Matching: Learning Camera Localization via Dense Scene Ma

阅读：759|2022-08-16

8 json4s/json4s: JSON library

json4s/json4s: JSON library

阅读：776|2022-08-15

9 Respring是什么意思?没有越狱设备如何 Resp

相信不少果粉在对自己的设备进行某些操作时，都会碰到Respring，但这个 Respring 到底

阅读：361|2022-11-06

10 lightningtgc/MProgress.js: Material Prog

lightningtgc/MProgress.js: Material Progress —Google Material Design Progress l

阅读：406|2022-08-17

客服电话

电子邮件

PHP Zend_Queue_Adapter_AdapterAbstract类代码示例

示例1: __construct

示例2: __construct

示例3: __construct

示例4: __construct

示例5: __construct

示例6: __construct

示例7: __construct

示例8: __construct

示例9: __construct

示例10: __construct

示例11: __construct

请发表评论

全部评论

上一篇：

下一篇：

dphi-official/Machine_Learning_Bootcamp

tianli/matlab_offscreen: Matlab offscree

win7系统注册表编辑器打开的操作方法

これがマストドンだ！使い方からインスタ

芙蓉王（硬领航）多少钱一包？

librespeed/speedtest: Self-hosted Speedt

avehtari/BDA_m_demos: Bayesian Data Anal

四维彩超怎么看性别？四维看男孩女孩诀窍

TUNER88/iOSSystemSoundsLibrary: List of

medfreeman/markdown-it-toc-and-anchor: m

一些脑电数据处理相关的matlab函数整理

关于我们

产品与服务

解决方案

139-2527-9053

客服电话

电子邮件

PHP Zend_Queue_Adapter_AdapterAbstract类代码示例

示例1: __construct

示例2: __construct

示例3: __construct

示例4: __construct

示例5: __construct

示例6: __construct

示例7: __construct

示例8: __construct

示例9: __construct

示例10: __construct

示例11: __construct

请发表评论

全部评论

上一篇：

下一篇：

dphi-official/Machine_Learning_Bootcamp

tianli/matlab_offscreen: Matlab offscree

win7系统注册表编辑器打开的操作方法

これがマストドンだ！ 使い方からインスタ

芙蓉王（硬领航）多少钱一包？

librespeed/speedtest: Self-hosted Speedt

avehtari/BDA_m_demos: Bayesian Data Anal

四维彩超怎么看性别？四维看男孩女孩诀窍

TUNER88/iOSSystemSoundsLibrary: List of

medfreeman/markdown-it-toc-and-anchor: m

一些脑电数据处理相关的matlab函数整理

关于我们

产品与服务

解决方案

139-2527-9053

これがマストドンだ！使い方からインスタ