AQMP PECL Autocomplete file.

AMQP.php

<?php
/**
 *
 */
/**
 * Passing in this constant as a flag will forcefully disable all other flags.
 * Use this if you want to temporarily disable the amqp.auto_ack ini setting.
 * @var  integer
 */
define('AMQP_NOPARAM');
/**
 * Durable exchanges and queues will survive a broker restart, complete with all of their data.
 * @var integer
 */
define('AMQP_DURABLE');
/**
 * Passive exchanges are queues will not be redeclared, but the broker will
 * throw an error if the exchange or queue does not exist.
 * @var integer
 */
define('AMQP_PASSIVE');
/**
 * Valid for queues only, this flag indicates that only one client can be
 * listening to and consuming from this queue.
 * @var integer
 */
define('AMQP_EXCLUSIVE');
/**
 * For exchanges, the auto delete flag indicates that the exchange will be
 * deleted as soon as no more queues are bound to it. If no queues were ever
 * bound the exchange, the exchange will never be deleted. For queues, the auto
 * delete flag indicates that the queue will be deleted as soon as there are no
 * more listeners subscribed to it. If no subscription has ever been active, the
 * queue will never be deleted. Note: Exclusive queues will always be
 * automatically deleted with the client disconnects.
 * @var integer
 */
define('AMQP_AUTODELETE');
/**
 * Clients are not allowed to make specific queue bindings to exchanges defined
 * with this flag.
 * @var integer
 */
define('AMQP_INTERNAL');
/**
 * When passed to the consume method for a clustered environment, do not consume
 *  from the local node.
 *  @var integer
 */
define('AMQP_NOLOCAL');
/**
 * When passed to the AMQPQueue::get() and AMQPQueue::get() methods as a flag,
 * the messages will be immediately marked as acknowledged by the server upon delivery.
 * @var integer
 */
define('AMQP_AUTOACK');
/**
 * Passed on queue creation, this flag indicates that the queue should be
 * deleted if it becomes empty.
 * @var integer
 */
define('AMQP_IFEMPTY');
/**
 * Passed on queue or exchange creation, this flag indicates that the queue or
 * exchange should be deleted when no clients are connected to the given queue
 * or exchange.
 * @var integer
 */
define('AMQP_IFUNUSED');
/**
 * When publishing a message, the message must be routed to a valid queue. If
 * it is not, an error will be returned.
 * @var integer
 */
define('AMQP_MANDATORY');
/**
 * When publishing a message, mark this message for immediate processing by the
 * broker. (High priority message.)
 *
 * @var integer
 */
define('AMQP_IMMEDIATE');
/**
 * If set during a call to AMQPQueue::ack(), the delivery tag is treated as "up
 * to and including", so that multiple messages can be acknowledged with a
 * single method. If set to zero, the delivery tag refers to a single message.
 * If the define('AMQP_MULTIPLE flag is set, and the delivery tag is zero, this
 * indicates acknowledgement of all outstanding messages.
 * @var integer
 */
define('AMQP_MULTIPLE');
/**
 * If set during a call to AMQPExchange::bind(), the server will not respond to
 * the method. The client should not wait for a reply method. If the server
 * could not complete the method it will raise a channel or connection exception.
 * @var string
 */
define('AMQP_NOWAIT');
/**
 * A direct exchange type.
 * @var string
 */
define('AMQP_EX_TYPE_DIRECT');
/**
 * A direct exchange type.
 * @var string
 */
define('AMQP_EX_TYPE_FANOUT');
/**
 * A fanout exchange type.
 * @var string
 */
define('AMQP_EX_TYPE_TOPIC');
/**
 * A topic exchange type.
 * @var string
 */
define('AMQP_EX_TYPE_HEADER');

/**
 * Represents a connection to an AMQP broker.
 *
 *
 * @category   PECL
 * @package    AMQP
 * @subpackage Connection
 */
class AMQPConnection {
    /**
     * Create an instance of AMQPConnection
     * @param array $credentials
     */
    public function __construct (array $credentials = array()){}
    /**
     *  Establish a connection with the AMQP broker.
     * @return bool
     */
    public function connect (){}
    /**
     * Closes the connection with the AMQP broker.
     * @return bool
     */
    public function disconnect (){}
    /**
     * Get the configured host
     * @return string
     */
    public function getHost ( ){}
    /**
     * Get the configured login
     * @return string
     */
    public function getLogin ( ){}
    /**
     * Get the configured password
     * @return string
     */
    public function getPassword ( ){}
    /**
     * Get the configured port
     * @return int
     */
    public function getPort ( ){}
    /**
     * Get the configured vhost
     * @return string
     */
    public function getVhost ( ){}
    /**
     * Determine if the AMQPConnection object is connected to the broker.
     * @return bool
     */
    public function isConnected (){}
    /**
     * Closes any open connection and creates a new connection with the AMQP broker.
     * @return bool
     */
    public function reconnect (){}
    /**
     * Set the amqp host
     *
     * @param string $host
     * @return bool
     */
    public function setHost ( $host ){}
    /**
     * Set the login.
     *
     * @param string $login
     * @return bool
     */
    public function setLogin ( $login ){}
    /**
     * Set the password.
     *
     * @param string $password
     * @return bool
     */
    public function setPassword ( $password ){}
    /**
     * Set the port.
     *
     * @param int $port
     * @return bool
     */
    public function setPort ( $port ) {}
    /**
     * Set the amqp virtual host
     *
     * @param string $vhost
     * @return bool
     */
    public function setVhost ( $vhost ){}
}
/**
 * Represents a channel on an connection. Each connection can have multiple channels.
 *
 *
 * @category   PECL
 * @package    AMQP
 * @subpackage Channel
 */
class AMQPChannel {
    /**
     * Create an instance of an AMQPChannel object
     *
     * @param AMQPConnection $amqp_connection
     * @return void
     */
    public function __construct ( AMQPConnection $amqp_connection ){}
    /**
     * Commit a pending transaction
     *
     * @return void
     */
    public function commitTransaction ( ){}
    /**
     * Check the channel connection
     *
     * @return void
     */
    public function isConnected ( ){}
    /**
     * Set the Quality Of Service settings for the given channel
     *
     * @param int $size
     * @param int $count
     * @return void
     */
    public function qos ( int $size , int $count ){}
    /**
     * Rollback a transaction
     *
     * @return void
     */
    public function rollbackTransaction ( ){}
    /**
     * Set the number of messages to prefetch from the broker
     *
     * @param int $count
     * @return void
     */
    public function setPrefetchCount ( int $count ){}
    /**
     * Set the window size to prefetch from the broker
     *
     * @param int $size
     * @return void
     */
    public function setPrefetchSize ( int $size ){}
    /**
     * Start a transaction
     *
     * @return void
     */
    public function startTransaction ( ){}
}
/**
 * Represents an AMQP exchange.
 *
 *
 * @category   Pecl
 * @package    AMQP
 * @subpackage Exchange
 */
class AMQPExchange {
    /**
     * Create an instance of AMQPExchange
     *
     * @param AMQPChannel $amqp_channel
     */
    public function __construct ( AMQPChannel $amqp_channel ){}
    /**
     *  Bind to another exchange
     *
     * @param string $destination_exchange_name
     * @param string $source_exchange_name
     * @param string $routing_key
     * @return bool
     */
    public function bind ( string $destination_exchange_name , string $source_exchange_name , string $routing_key ){}
    /**
     * Declare a new exchange on the broker.
     *
     * @return int
     */
    public function declare (){}
    /**
     * Delete the exchange from the broker.
     *
     * @param int $flags
     * @return bool
     */
    public function delete ($flags = AMQP_NOPARAM){}
    /**
     * Get the argument associated with the given key
     *
     * @param string $key
     * @return mixed
     */
    public function getArgument ( string $key ){}
    /**
     * Get all arguments set on the given exchange
     *
     * @return array
     */
    public function getArguments (){}
    /**
     * Get the flag bitmask
     *
     * return int
     */
    public function getFlags (){}
    /**
     * Get the configured name
     * @return string
     */
    public function getName (){}
    /**
     * Get the configured type
     *
     * @return string
     */
    public function getType (){}
    /**
     * Publish a message to an exchange.
     *
     * @param string $message
     * @param string $routing_key
     * @param int $flags
     * @param array $attributes
     * @return bool
     */
    public function publish ( string $message , string $routing_key, int $flags = AMQP_NOPARAM, array $attributes = array()){}
    /**
     * Set the value for the given key
     *
     * @param string $key
     * @param mixed $value
     * @return boolean
     */
    public function setArgument ( string $key , mixed $value ){}
    /**
     * Set all arguments on the exchange
     *
     * @param array $arguments
     * @return bool
     */
    public function setArguments ( array $arguments ){}
    /**
     * Set the flags on an exchange
     *
     * @param int $flags
     * @return bool
     */
    public function setFlags ( int $flags ){}
    /**
     * Set the name of the exchange
     *
     * @param string $exchange_name
     * @return bool
     */
    public function setName ( string $exchange_name ){}
    /**
     * Set the type of the exchange
     *
     * @param string $exchange_type
     * @return string
     */
    public function setType ( string $exchange_type ){}
}
/**
 * Represents an AMQP queue.
 *
 *
 * @category   PECL
 * @package    AMQP
 * @subpackage Queue
 */
class AMQPQueue {
    /**
     * Create an instance of an AMQPQueue object
     *
     * @param AMQPConnection $amqp_connection
     * @return bool
     */
    public function __construct ( AMQPConnection $amqp_connection ){}
    /**
     * Acknowledge the receipt of a message
     *
     * @param int $delivery_tag
     * @param int $flags
     * @return bool
     */
public function ack ( int $delivery_tag , int $flags = AMQP_NOPARAM  ){}
    /**
     * Bind the given queue to a routing key on an exchange.
     *
     * @param string $exchange_name
     * @param string $routing_key
     * @return bool
     */
    public function bind ( string $exchange_name , string $routing_key ){}
    /**
     * Cancel a queue binding.
     *
     * @param string $consumer_tag
     * @return bool
     */
    public function cancel (string $consumer_tag = ''){}
    /**
     * Consume messages from a queue
     *
     * @param callable $callback
     * @param int $flags
     * @return void
     */
    public function consume ( callable $callback , int $flags = AMQP_NOPARAM ){}
    /**
     * Declare a new queue
     *
     * @return int
     */
    public function declare (){}
    /**
     * Delete a queue and its contents.
     *
     * @return bool
     */
    public function delete (){}
    /**
     * Retrieve the next message from the queue.
     *
     * @param int $flags
     * @return mixed
     */
    public function get (int $flags){}
    /**
     * Get the argument associated with the given key
     *
     * @param string $key
     * @return mixed
     */
    public function getArgument ( string $key ){}
    /**
     * Get all arguments set on the given queue
     *
     * @return array
     */
    public function getArguments (){}
    /**
     * Get the flag bitmask
     *
     * @return int
     */
    public function getFlags (){}
    /**
     * Get the configured name
     *
     * @return string
     */
    public function getName (){}
    /**
     * Mark a message as explicitly not acknowledged.
     *
     * @param string $delivery_tag
     * @param string $flags
     * @return void
     */
    public function nack ( string $delivery_tag , string $flags = AMQP_NOPARAM ){}
    /**
     * Purge the contents of a queue
     *
     * @return bool
     */
    public function purge (){}
    /**
     * Set the value for the given key
     *
     * @param string $key
     * @param mixed $value
     * @return void
     */
    public function setArgument ( string $key , mixed $value ){}
    /**
     * Set all arguments on the queue
     *
     * @param array $arguments
     * @return void
     */
    public function setArguments ( array $arguments ){}
    /**
     * Set the queue flags
     *
     * @param int $flags
     * @return void
     */
    public function setFlags ( int $flags ){}
    /**
     * Set the queue name
     *
     * @param string $queue_name
     * @return void
     */
    public function setName ( string $queue_name ){}
    /**
     * Unbind the queue from a routing key.
     *
     * @param string $exchange_name
     * @param string $routing_key
     * @return bool
     */
    public function unbind ( string $exchange_name , string $routing_key ){}
}
/**
 * Contains a message and all of its attributes.
 *
 *
 * @category   PECL
 * @package    AMQP
 * @subpackage Envelope
 */
class AMQPEnvelope {
    /**
     * Get the message appid
     *
     * @return string
     */
    public function getAppId (){}
    /**
     * Get the message body
     *
     * @return string
     */
    public function getBody (){}
    /**
     * Get the message contentencoding
     *
     * @return string
     */
    public function getContentEncoding (){}
    /**
     * Get the message contenttype
     *
     * @return string
     */
    public function getContentType (){}
    /**
     * Get the message correlation id
     *
     * @return string
     */
    public function getCorrelationId (){}
    /**
     * Get the message delivery tag
     *
     * @return string
     */
    public function getDeliveryTag (){}
    /**
     * Get the message exchange
     *
     * @return string
     */
    public function getExchangeName (){}
    /**
     * Get the message expiration
     *
     * @return string
     */
    public function getExpiration (){}
    /**
     * Get a specific message header
     *
     * @return string
     */
    public function getHeader ( string $header_key ){}
    /**
     * Get the message headers
     *
     * @return array
     */
    public function getHeaders (){}
    /**
     * Get the message id
     *
     * @return string
     */
    public function getMessageId (){}
    /**
     * Get the message priority
     *
     * @return string
     */
    public function getPriority (){}
    /**
     * Get the message replyto
     *
     * @return string
     */
    public function getReplyTo (){}
    /**
     * @return int
     */
    public function getDeliveryMode(){}
    /**
     * Get the message routing key
     *
     * @return string
     */
    public function getRoutingKey (){}
    /**
     * Get the message timestamp
     *
     * @return string
     */
    public function getTimeStamp (){}
    /**
     * Get the message type
     *
     * @return string
     */
    public function getType (){}
    /**
     * Get the message user id
     *
     * @return string
     */
    public function getUserId (){}
    /**
     * Whether this is a redelivery of the message
     *
     * @return bool
     */
    public function isRedelivery (){}
}