Class for using Stomp to talk to an Stomp compliant server
category | Zend |
---|---|
package | Zend_Queue |
subpackage | Adapter |
copyright | Copyright (c) 2005-2015 Zend Technologies USA Inc. (http://www.zend.com) |
license | New BSD License |
inherited_from | \Zend_Queue_Adapter_AdapterAbstract |
__construct(array|\Zend_Config $options, \Zend_Queue $queue = null
) : void
$options is an array of key/value pairs or an instance of Zend_Config containing configuration options. These options are common to most adapters:
See the Zend_Queue Adapter Notes documentation for example configurations.
Some options are used on a case-by-case basis by adapters:
access_key => (string) Amazon AWS Access Key secret_key => (string) Amazon AWS Secret Key dbname => (string) The name of the database to user username => (string) Connect to the database as this username. password => (string) Password associated with the username. host => (string) What host to connect to, defaults to localhost port => (string) The port of the database
inherited_from | \Zend_Queue_Adapter_AdapterAbstract::__construct() |
---|
__construct(array|\Zend_Config $options, \Zend_Queue $queue = null
) : void
$options is an array of key/value pairs or an instance of Zend_Config containing configuration options. These options are common to most adapters:
See the Zend_Queue Adapter Notes documentation for example configurations.
Some options are used on a case-by-case basis by adapters:
access_key => (string) Amazon AWS Access Key secret_key => (string) Amazon AWS Secret Key dbname => (string) The name of the database to user username => (string) Connect to the database as this username. password => (string) Password associated with the username. host => (string) What host to connect to, defaults to localhost port => (string) The port of the database
inherited_from | \Zend_Queue_Adapter_AdapterInterface::__construct() |
---|
\Zend_Queue_Exception |
---|
__destruct() : void
count(\Zend_Queue $queue = null
) : integer
\Zend_Queue
\Zend_Queue_Exception |
(not supported) |
---|
integer
create(string $name, integer $timeout = null
) : void
string
queue name
integer
default visibility timeout
\Zend_Queue_Exception |
---|
delete(string $name) : void
string
queue name
\Zend_Queue_Exception |
---|
deleteMessage(\Zend_Queue_Message $message) : boolean
Returns true if the message is deleted, false if the deletion is unsuccessful.
\Zend_Queue_Message
boolean
getCapabilities() : array
$array['function name'] = true or false true is supported, false is not supported.
array
getOptions() : array
inherited_from | \Zend_Queue_Adapter_AdapterInterface::getOptions() |
---|
array
getQueue() : \Zend_Queue | null
inherited_from | \Zend_Queue_Adapter_AdapterInterface::getQueue() |
---|
\Zend_Queue
null
getQueues() : void
\Zend_Queue_Exception |
---|
isExists(string $name) : boolean
string
\Zend_Queue_Exception |
(not supported) |
---|
boolean
isSupported(string $name) : boolean
inherited_from | \Zend_Queue_Adapter_AdapterInterface::isSupported() |
---|
string
boolean
receive(integer $maxMessages= null
, integer $timeout= null
, \Zend_Queue $queue= null
) : \Zend_Queue_Message_Iterator
integer
integer
\Zend_Queue
\Zend_Queue_Message_Iterator
send(string $message, \Zend_Queue $queue = null
) : \Zend_Queue_Message
string
message to send to the queue
\Zend_Queue
\Zend_Queue_Message
setQueue(\Zend_Queue $queue) : \Zend_Queue_Adapter_AdapterInterface
inherited_from | \Zend_Queue_Adapter_AdapterInterface::setQueue() |
---|
\Zend_Queue
\Zend_Queue_Adapter_AdapterInterface
_isSubscribed(\Zend_Queue $queue) : boolean
\Zend_Queue
boolean
_subscribe(\Zend_Queue $queue) : void
\Zend_Queue
$_queue : \Zend_Queue_Adapter_Abstract
null
$_queues : array
array()
$_client : \Zend_Queue_Adapter_Stomp_client
null
$_subscribed : array
array()
CREATE_TIMEOUT_DEFAULT = 30
DEFAULT_HOST = '127.0.0.1'
DEFAULT_PORT = 61613
DEFAULT_SCHEME = 'tcp'
RECEIVE_TIMEOUT_DEFAULT = 30