summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
Diffstat
-rw-r--r--PHPINFO9
-rw-r--r--REFLECTION1609
-rw-r--r--php-pecl-amqp.spec34
3 files changed, 917 insertions, 735 deletions
diff --git a/PHPINFO b/PHPINFO
index 4ac98b4..599dcfd 100644
--- a/PHPINFO
+++ b/PHPINFO
@@ -1,11 +1,10 @@
amqp
-Version => 1.11.0
-Revision => release
-Compiled => Dec 1 2021 @ 00:00:00
+Version => 2.0.0alpha1
+Compiled => Jul 30 2023 @ 00:00:00
AMQP protocol version => 0-9-1
-librabbitmq version => 0.12.0
+librabbitmq version => 0.13.0
Default max channels per connection => 256
Default max frame size => 131072
Default heartbeats interval => 0
@@ -33,4 +32,4 @@ amqp.cacert => no value => no value
amqp.cert => no value => no value
amqp.key => no value => no value
amqp.verify => 1 => 1
-amqp.sasl_method => 0 => 0
+amqp.sasl_method => no value => no value
diff --git a/REFLECTION b/REFLECTION
index bd5f0fc..b7a782d 100644
--- a/REFLECTION
+++ b/REFLECTION
@@ -1,4 +1,4 @@
-Extension [ <persistent> extension #120 amqp version 1.11.0 ] {
+Extension [ <persistent> extension #124 amqp version 2.0.0alpha1 ] {
- INI {
Entry [ amqp.host <ALL> ]
@@ -68,11 +68,17 @@ Extension [ <persistent> extension #120 amqp version 1.11.0 ] {
Current = '1'
}
Entry [ amqp.sasl_method <ALL> ]
- Current = '0'
+ Current = ''
}
}
- - Constants [24] {
+ - Constants [32] {
+ Constant [ string AMQP_EXTENSION_VERSION ] { 2.0.0alpha1 }
+ Constant [ int AMQP_EXTENSION_VERSION_MAJOR ] { 2 }
+ Constant [ int AMQP_EXTENSION_VERSION_MINOR ] { 0 }
+ Constant [ int AMQP_EXTENSION_VERSION_PATCH ] { 0 }
+ Constant [ string AMQP_EXTENSION_VERSION_EXTRA ] { alpha1 }
+ Constant [ int AMQP_EXTENSION_VERSION_ID ] { 20000 }
Constant [ int AMQP_NOPARAM ] { 0 }
Constant [ int AMQP_JUST_CONSUME ] { 1 }
Constant [ int AMQP_DURABLE ] { 2 }
@@ -97,10 +103,12 @@ Extension [ <persistent> extension #120 amqp version 1.11.0 ] {
Constant [ int PHP_AMQP_MAX_CHANNELS ] { 256 }
Constant [ int AMQP_SASL_METHOD_PLAIN ] { 0 }
Constant [ int AMQP_SASL_METHOD_EXTERNAL ] { 1 }
+ Constant [ int AMQP_DELIVERY_MODE_TRANSIENT ] { 1 }
+ Constant [ int AMQP_DELIVERY_MODE_PERSISTENT ] { 2 }
}
- Classes [15] {
- Class [ <internal:amqp> class AMQPConnection ] {
+ Class [ <internal:amqp> class AMQPException extends Exception implements Throwable, Stringable ] {
- Constants [0] {
}
@@ -111,305 +119,364 @@ Extension [ <persistent> extension #120 amqp version 1.11.0 ] {
- Static methods [0] {
}
- - Properties [18] {
- Property [ private $login = NULL ]
- Property [ private $password = NULL ]
- Property [ private $host = NULL ]
- Property [ private $vhost = NULL ]
- Property [ private $port = NULL ]
- Property [ private $read_timeout = NULL ]
- Property [ private $write_timeout = NULL ]
- Property [ private $connect_timeout = NULL ]
- Property [ private $rpc_timeout = NULL ]
- Property [ private $channel_max = NULL ]
- Property [ private $frame_max = NULL ]
- Property [ private $heartbeat = NULL ]
- Property [ private $cacert = NULL ]
- Property [ private $key = NULL ]
- Property [ private $cert = NULL ]
- Property [ private $verify = NULL ]
- Property [ private $sasl_method = NULL ]
- Property [ private $connection_name = NULL ]
- }
-
- - Methods [43] {
- Method [ <internal:amqp, ctor> public method __construct ] {
+ - Properties [4] {
+ Property [ protected $message = '' ]
+ Property [ protected $code = 0 ]
+ Property [ protected string $file = '' ]
+ Property [ protected int $line = 0 ]
+ }
- - Parameters [1] {
- Parameter #0 [ <optional> array $credentials = <default> ]
+ - Methods [10] {
+ Method [ <internal:Core, inherits Exception, ctor> public method __construct ] {
+
+ - Parameters [3] {
+ Parameter #0 [ <optional> string $message = "" ]
+ Parameter #1 [ <optional> int $code = 0 ]
+ Parameter #2 [ <optional> ?Throwable $previous = null ]
}
}
- Method [ <internal:amqp> public method isConnected ] {
+ Method [ <internal:Core, inherits Exception> public method __wakeup ] {
- Parameters [0] {
}
+ - Tentative return [ void ]
}
- Method [ <internal:amqp> public method connect ] {
+ Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getMessage ] {
- Parameters [0] {
}
+ - Return [ string ]
}
- Method [ <internal:amqp> public method pconnect ] {
+ Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getCode ] {
- Parameters [0] {
}
}
- Method [ <internal:amqp> public method pdisconnect ] {
+ Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getFile ] {
- Parameters [0] {
}
+ - Return [ string ]
}
- Method [ <internal:amqp> public method disconnect ] {
+ Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getLine ] {
- Parameters [0] {
}
+ - Return [ int ]
}
- Method [ <internal:amqp> public method reconnect ] {
+ Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getTrace ] {
- Parameters [0] {
}
+ - Return [ array ]
}
- Method [ <internal:amqp> public method preconnect ] {
+ Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getPrevious ] {
- Parameters [0] {
}
+ - Return [ ?Throwable ]
}
- Method [ <internal:amqp> public method getLogin ] {
+ Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getTraceAsString ] {
- Parameters [0] {
}
+ - Return [ string ]
}
- Method [ <internal:amqp> public method setLogin ] {
+ Method [ <internal:Core, inherits Exception, prototype Stringable> public method __toString ] {
- - Parameters [1] {
- Parameter #0 [ <required> $login ]
+ - Parameters [0] {
}
+ - Return [ string ]
}
+ }
+ }
- Method [ <internal:amqp> public method getPassword ] {
+ Class [ <internal:amqp> class AMQPConnectionException extends AMQPException implements Stringable, Throwable ] {
- - Parameters [0] {
- }
- }
+ - Constants [0] {
+ }
- Method [ <internal:amqp> public method setPassword ] {
+ - Static properties [0] {
+ }
- - Parameters [1] {
- Parameter #0 [ <required> $password ]
+ - Static methods [0] {
+ }
+
+ - Properties [4] {
+ Property [ protected $message = '' ]
+ Property [ protected $code = 0 ]
+ Property [ protected string $file = '' ]
+ Property [ protected int $line = 0 ]
+ }
+
+ - Methods [10] {
+ Method [ <internal:Core, inherits Exception, ctor> public method __construct ] {
+
+ - Parameters [3] {
+ Parameter #0 [ <optional> string $message = "" ]
+ Parameter #1 [ <optional> int $code = 0 ]
+ Parameter #2 [ <optional> ?Throwable $previous = null ]
}
}
- Method [ <internal:amqp> public method getHost ] {
+ Method [ <internal:Core, inherits Exception> public method __wakeup ] {
- Parameters [0] {
}
+ - Tentative return [ void ]
}
- Method [ <internal:amqp> public method setHost ] {
+ Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getMessage ] {
- - Parameters [1] {
- Parameter #0 [ <required> $host ]
+ - Parameters [0] {
}
+ - Return [ string ]
}
- Method [ <internal:amqp> public method getPort ] {
+ Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getCode ] {
- Parameters [0] {
}
}
- Method [ <internal:amqp> public method setPort ] {
+ Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getFile ] {
- - Parameters [1] {
- Parameter #0 [ <required> $port ]
+ - Parameters [0] {
}
+ - Return [ string ]
}
- Method [ <internal:amqp> public method getVhost ] {
+ Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getLine ] {
- Parameters [0] {
}
+ - Return [ int ]
}
- Method [ <internal:amqp> public method setVhost ] {
+ Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getTrace ] {
- - Parameters [1] {
- Parameter #0 [ <required> $vhost ]
+ - Parameters [0] {
}
+ - Return [ array ]
}
- Method [ <internal:amqp> public method getTimeout ] {
+ Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getPrevious ] {
- Parameters [0] {
}
+ - Return [ ?Throwable ]
}
- Method [ <internal:amqp> public method setTimeout ] {
+ Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getTraceAsString ] {
- - Parameters [1] {
- Parameter #0 [ <required> $timeout ]
+ - Parameters [0] {
}
+ - Return [ string ]
}
- Method [ <internal:amqp> public method getReadTimeout ] {
+ Method [ <internal:Core, inherits Exception, prototype Stringable> public method __toString ] {
- Parameters [0] {
}
+ - Return [ string ]
}
+ }
+ }
- Method [ <internal:amqp> public method setReadTimeout ] {
+ Class [ <internal:amqp> class AMQPChannelException extends AMQPException implements Stringable, Throwable ] {
- - Parameters [1] {
- Parameter #0 [ <required> $timeout ]
- }
- }
+ - Constants [0] {
+ }
- Method [ <internal:amqp> public method getWriteTimeout ] {
+ - Static properties [0] {
+ }
- - Parameters [0] {
- }
- }
+ - Static methods [0] {
+ }
- Method [ <internal:amqp> public method setWriteTimeout ] {
+ - Properties [4] {
+ Property [ protected $message = '' ]
+ Property [ protected $code = 0 ]
+ Property [ protected string $file = '' ]
+ Property [ protected int $line = 0 ]
+ }
- - Parameters [1] {
- Parameter #0 [ <required> $timeout ]
+ - Methods [10] {
+ Method [ <internal:Core, inherits Exception, ctor> public method __construct ] {
+
+ - Parameters [3] {
+ Parameter #0 [ <optional> string $message = "" ]
+ Parameter #1 [ <optional> int $code = 0 ]
+ Parameter #2 [ <optional> ?Throwable $previous = null ]
}
}
- Method [ <internal:amqp> public method getRpcTimeout ] {
+ Method [ <internal:Core, inherits Exception> public method __wakeup ] {
- Parameters [0] {
}
+ - Tentative return [ void ]
}
- Method [ <internal:amqp> public method setRpcTimeout ] {
+ Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getMessage ] {
- - Parameters [1] {
- Parameter #0 [ <required> $timeout ]
+ - Parameters [0] {
}
+ - Return [ string ]
}
- Method [ <internal:amqp> public method getUsedChannels ] {
+ Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getCode ] {
- Parameters [0] {
}
}
- Method [ <internal:amqp> public method getMaxChannels ] {
+ Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getFile ] {
- Parameters [0] {
}
+ - Return [ string ]
}
- Method [ <internal:amqp> public method isPersistent ] {
+ Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getLine ] {
- Parameters [0] {
}
+ - Return [ int ]
}
- Method [ <internal:amqp> public method getHeartbeatInterval ] {
+ Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getTrace ] {
- Parameters [0] {
}
+ - Return [ array ]
}
- Method [ <internal:amqp> public method getMaxFrameSize ] {
+ Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getPrevious ] {
- Parameters [0] {
}
+ - Return [ ?Throwable ]
}
- Method [ <internal:amqp> public method getCACert ] {
+ Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getTraceAsString ] {
- Parameters [0] {
}
+ - Return [ string ]
}
- Method [ <internal:amqp> public method setCACert ] {
+ Method [ <internal:Core, inherits Exception, prototype Stringable> public method __toString ] {
- - Parameters [1] {
- Parameter #0 [ <required> $cacert ]
+ - Parameters [0] {
}
+ - Return [ string ]
}
+ }
+ }
- Method [ <internal:amqp> public method getCert ] {
+ Class [ <internal:amqp> class AMQPQueueException extends AMQPException implements Stringable, Throwable ] {
- - Parameters [0] {
+ - Constants [0] {
+ }
+
+ - Static properties [0] {
+ }
+
+ - Static methods [0] {
+ }
+
+ - Properties [4] {
+ Property [ protected $message = '' ]
+ Property [ protected $code = 0 ]
+ Property [ protected string $file = '' ]
+ Property [ protected int $line = 0 ]
+ }
+
+ - Methods [10] {
+ Method [ <internal:Core, inherits Exception, ctor> public method __construct ] {
+
+ - Parameters [3] {
+ Parameter #0 [ <optional> string $message = "" ]
+ Parameter #1 [ <optional> int $code = 0 ]
+ Parameter #2 [ <optional> ?Throwable $previous = null ]
}
}
- Method [ <internal:amqp> public method setCert ] {
+ Method [ <internal:Core, inherits Exception> public method __wakeup ] {
- - Parameters [1] {
- Parameter #0 [ <required> $cert ]
+ - Parameters [0] {
}
+ - Tentative return [ void ]
}
- Method [ <internal:amqp> public method getKey ] {
+ Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getMessage ] {
- Parameters [0] {
}
+ - Return [ string ]
}
- Method [ <internal:amqp> public method setKey ] {
+ Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getCode ] {
- - Parameters [1] {
- Parameter #0 [ <required> $key ]
+ - Parameters [0] {
}
}
- Method [ <internal:amqp> public method getVerify ] {
+ Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getFile ] {
- Parameters [0] {
}
+ - Return [ string ]
}
- Method [ <internal:amqp> public method setVerify ] {
+ Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getLine ] {
- - Parameters [1] {
- Parameter #0 [ <required> $verify ]
+ - Parameters [0] {
}
+ - Return [ int ]
}
- Method [ <internal:amqp> public method getSaslMethod ] {
+ Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getTrace ] {
- Parameters [0] {
}
+ - Return [ array ]
}
- Method [ <internal:amqp> public method setSaslMethod ] {
+ Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getPrevious ] {
- - Parameters [1] {
- Parameter #0 [ <required> $sasl_method ]
+ - Parameters [0] {
}
+ - Return [ ?Throwable ]
}
- Method [ <internal:amqp> public method getConnectionName ] {
+ Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getTraceAsString ] {
- Parameters [0] {
}
+ - Return [ string ]
}
- Method [ <internal:amqp> public method setConnectionName ] {
+ Method [ <internal:Core, inherits Exception, prototype Stringable> public method __toString ] {
- - Parameters [1] {
- Parameter #0 [ <required> $connection_name ]
+ - Parameters [0] {
}
+ - Return [ string ]
}
}
}
- Class [ <internal:amqp> class AMQPChannel ] {
+ Class [ <internal:amqp> class AMQPExchangeException extends AMQPException implements Stringable, Throwable ] {
- Constants [0] {
}
@@ -420,177 +487,180 @@ Extension [ <persistent> extension #120 amqp version 1.11.0 ] {
- Static methods [0] {
}
- - Properties [6] {
- Property [ private $connection = NULL ]
- Property [ private $prefetch_count = NULL ]
- Property [ private $prefetch_size = 0 ]
- Property [ private $global_prefetch_count = NULL ]
- Property [ private $global_prefetch_size = NULL ]
- Property [ private $consumers = NULL ]
+ - Properties [4] {
+ Property [ protected $message = '' ]
+ Property [ protected $code = 0 ]
+ Property [ protected string $file = '' ]
+ Property [ protected int $line = 0 ]
}
- - Methods [24] {
- Method [ <internal:amqp, ctor> public method __construct ] {
+ - Methods [10] {
+ Method [ <internal:Core, inherits Exception, ctor> public method __construct ] {
- - Parameters [1] {
- Parameter #0 [ <required> AMQPConnection $amqp_connection ]
+ - Parameters [3] {
+ Parameter #0 [ <optional> string $message = "" ]
+ Parameter #1 [ <optional> int $code = 0 ]
+ Parameter #2 [ <optional> ?Throwable $previous = null ]
}
}
- Method [ <internal:amqp> public method isConnected ] {
+ Method [ <internal:Core, inherits Exception> public method __wakeup ] {
- Parameters [0] {
}
+ - Tentative return [ void ]
}
- Method [ <internal:amqp> public method close ] {
+ Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getMessage ] {
- Parameters [0] {
}
+ - Return [ string ]
}
- Method [ <internal:amqp> public method getChannelId ] {
+ Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getCode ] {
- Parameters [0] {
}
}
- Method [ <internal:amqp> public method setPrefetchSize ] {
+ Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getFile ] {
- - Parameters [1] {
- Parameter #0 [ <required> $size ]
+ - Parameters [0] {
}
+ - Return [ string ]
}
- Method [ <internal:amqp> public method getPrefetchSize ] {
+ Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getLine ] {
- Parameters [0] {
}
+ - Return [ int ]
}
- Method [ <internal:amqp> public method setPrefetchCount ] {
+ Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getTrace ] {
- - Parameters [1] {
- Parameter #0 [ <required> $count ]
+ - Parameters [0] {
}
+ - Return [ array ]
}
- Method [ <internal:amqp> public method getPrefetchCount ] {
+ Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getPrevious ] {
- Parameters [0] {
}
+ - Return [ ?Throwable ]
}
- Method [ <internal:amqp> public method setGlobalPrefetchSize ] {
+ Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getTraceAsString ] {
- - Parameters [1] {
- Parameter #0 [ <required> $size ]
+ - Parameters [0] {
}
+ - Return [ string ]
}
- Method [ <internal:amqp> public method getGlobalPrefetchSize ] {
+ Method [ <internal:Core, inherits Exception, prototype Stringable> public method __toString ] {
- Parameters [0] {
}
+ - Return [ string ]
}
+ }
+ }
- Method [ <internal:amqp> public method setGlobalPrefetchCount ] {
+ Class [ <internal:amqp> class AMQPValueException extends AMQPException implements Stringable, Throwable ] {
- - Parameters [1] {
- Parameter #0 [ <required> $count ]
- }
- }
+ - Constants [0] {
+ }
- Method [ <internal:amqp> public method getGlobalPrefetchCount ] {
+ - Static properties [0] {
+ }
- - Parameters [0] {
- }
- }
+ - Static methods [0] {
+ }
- Method [ <internal:amqp> public method qos ] {
+ - Properties [4] {
+ Property [ protected $message = '' ]
+ Property [ protected $code = 0 ]
+ Property [ protected string $file = '' ]
+ Property [ protected int $line = 0 ]
+ }
+
+ - Methods [10] {
+ Method [ <internal:Core, inherits Exception, ctor> public method __construct ] {
- Parameters [3] {
- Parameter #0 [ <required> $size ]
- Parameter #1 [ <required> $count ]
- Parameter #2 [ <optional> $global = <default> ]
+ Parameter #0 [ <optional> string $message = "" ]
+ Parameter #1 [ <optional> int $code = 0 ]
+ Parameter #2 [ <optional> ?Throwable $previous = null ]
}
}
- Method [ <internal:amqp> public method startTransaction ] {
+ Method [ <internal:Core, inherits Exception> public method __wakeup ] {
- Parameters [0] {
}
+ - Tentative return [ void ]
}
- Method [ <internal:amqp> public method commitTransaction ] {
+ Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getMessage ] {
- Parameters [0] {
}
+ - Return [ string ]
}
- Method [ <internal:amqp> public method rollbackTransaction ] {
+ Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getCode ] {
- Parameters [0] {
}
}
- Method [ <internal:amqp> public method getConnection ] {
+ Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getFile ] {
- Parameters [0] {
}
+ - Return [ string ]
}
- Method [ <internal:amqp> public method basicRecover ] {
-
- - Parameters [1] {
- Parameter #0 [ <optional> $requeue = <default> ]
- }
- }
-
- Method [ <internal:amqp> public method confirmSelect ] {
+ Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getLine ] {
- Parameters [0] {
}
+ - Return [ int ]
}
- Method [ <internal:amqp> public method waitForConfirm ] {
-
- - Parameters [1] {
- Parameter #0 [ <optional> $timeout = <default> ]
- }
- }
-
- Method [ <internal:amqp> public method setConfirmCallback ] {
+ Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getTrace ] {
- - Parameters [2] {
- Parameter #0 [ <required> $ack_callback ]
- Parameter #1 [ <optional> $nack_callback = <default> ]
+ - Parameters [0] {
}
+ - Return [ array ]
}
- Method [ <internal:amqp> public method setReturnCallback ] {
+ Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getPrevious ] {
- - Parameters [1] {
- Parameter #0 [ <required> $return_callback ]
+ - Parameters [0] {
}
+ - Return [ ?Throwable ]
}
- Method [ <internal:amqp> public method waitForBasicReturn ] {
+ Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getTraceAsString ] {
- - Parameters [1] {
- Parameter #0 [ <optional> $timeout = <default> ]
+ - Parameters [0] {
}
+ - Return [ string ]
}
- Method [ <internal:amqp> public method getConsumers ] {
+ Method [ <internal:Core, inherits Exception, prototype Stringable> public method __toString ] {
- Parameters [0] {
}
+ - Return [ string ]
}
}
}
- Class [ <internal:amqp> class AMQPQueue ] {
+ Class [ <internal:amqp> class AMQPConnection ] {
- Constants [0] {
}
@@ -601,365 +671,354 @@ Extension [ <persistent> extension #120 amqp version 1.11.0 ] {
- Static methods [0] {
}
- - Properties [9] {
- Property [ private $connection = NULL ]
- Property [ private $channel = NULL ]
- Property [ private $name = '' ]
- Property [ private $consumer_tag = NULL ]
- Property [ private $passive = false ]
- Property [ private $durable = false ]
- Property [ private $exclusive = false ]
- Property [ private $auto_delete = true ]
- Property [ private $arguments = NULL ]
- }
-
- - Methods [25] {
+ - Properties [18] {
+ Property [ private string $login ]
+ Property [ private string $password ]
+ Property [ private string $host ]
+ Property [ private string $vhost ]
+ Property [ private int $port ]
+ Property [ private float $readTimeout ]
+ Property [ private float $writeTimeout ]
+ Property [ private float $connectTimeout ]
+ Property [ private float $rpcTimeout ]
+ Property [ private int $frameMax ]
+ Property [ private int $channelMax ]
+ Property [ private int $heartbeat ]
+ Property [ private ?string $cacert = NULL ]
+ Property [ private ?string $key = NULL ]
+ Property [ private ?string $cert = NULL ]
+ Property [ private bool $verify = true ]
+ Property [ private int $saslMethod = 0 ]
+ Property [ private ?string $connectionName = NULL ]
+ }
+
+ - Methods [44] {
Method [ <internal:amqp, ctor> public method __construct ] {
- Parameters [1] {
- Parameter #0 [ <required> AMQPChannel $amqp_channel ]
+ Parameter #0 [ <optional> array $credentials = [] ]
}
}
- Method [ <internal:amqp> public method getName ] {
+ Method [ <internal:amqp> public method isConnected ] {
- Parameters [0] {
}
+ - Return [ bool ]
}
- Method [ <internal:amqp> public method setName ] {
+ Method [ <internal:amqp> public method connect ] {
- - Parameters [1] {
- Parameter #0 [ <required> $queue_name ]
+ - Parameters [0] {
}
+ - Return [ void ]
}
- Method [ <internal:amqp> public method getFlags ] {
+ Method [ <internal:amqp> public method pconnect ] {
- Parameters [0] {
}
+ - Return [ void ]
}
- Method [ <internal:amqp> public method setFlags ] {
+ Method [ <internal:amqp> public method pdisconnect ] {
- - Parameters [1] {
- Parameter #0 [ <required> $flags ]
+ - Parameters [0] {
}
+ - Return [ void ]
}
- Method [ <internal:amqp> public method getArgument ] {
+ Method [ <internal:amqp> public method disconnect ] {
- - Parameters [1] {
- Parameter #0 [ <required> $argument ]
+ - Parameters [0] {
}
+ - Return [ void ]
}
- Method [ <internal:amqp> public method getArguments ] {
+ Method [ <internal:amqp> public method reconnect ] {
- Parameters [0] {
}
+ - Return [ void ]
}
- Method [ <internal:amqp> public method setArgument ] {
+ Method [ <internal:amqp> public method preconnect ] {
- - Parameters [2] {
- Parameter #0 [ <required> $key ]
- Parameter #1 [ <required> $value ]
+ - Parameters [0] {
}
+ - Return [ void ]
}
- Method [ <internal:amqp> public method setArguments ] {
+ Method [ <internal:amqp> public method getLogin ] {
- - Parameters [1] {
- Parameter #0 [ <required> array $arguments ]
+ - Parameters [0] {
}
+ - Return [ string ]
}
- Method [ <internal:amqp> public method hasArgument ] {
+ Method [ <internal:amqp> public method setLogin ] {
- Parameters [1] {
- Parameter #0 [ <required> $key ]
+ Parameter #0 [ <required> string $login ]
}
+ - Return [ void ]
}
- Method [ <internal:amqp> public method declareQueue ] {
+ Method [ <internal:amqp> public method getPassword ] {
- Parameters [0] {
}
+ - Return [ string ]
}
- Method [ <internal:amqp> public method bind ] {
-
- - Parameters [3] {
- Parameter #0 [ <required> $exchange_name ]
- Parameter #1 [ <optional> $routing_key = <default> ]
- Parameter #2 [ <optional> $arguments = <default> ]
- }
- }
-
- Method [ <internal:amqp> public method get ] {
+ Method [ <internal:amqp> public method setPassword ] {
- Parameters [1] {
- Parameter #0 [ <optional> $flags = <default> ]
+ Parameter #0 [ <required> string $password ]
}
+ - Return [ void ]
}
- Method [ <internal:amqp> public method consume ] {
+ Method [ <internal:amqp> public method getHost ] {
- - Parameters [3] {
- Parameter #0 [ <required> $callback ]
- Parameter #1 [ <optional> $flags = <default> ]
- Parameter #2 [ <optional> $consumer_tag = <default> ]
+ - Parameters [0] {
}
+ - Return [ string ]
}
- Method [ <internal:amqp> public method ack ] {
+ Method [ <internal:amqp> public method setHost ] {
- - Parameters [2] {
- Parameter #0 [ <required> $delivery_tag ]
- Parameter #1 [ <optional> $flags = <default> ]
+ - Parameters [1] {
+ Parameter #0 [ <required> string $host ]
}
+ - Return [ void ]
}
- Method [ <internal:amqp> public method nack ] {
+ Method [ <internal:amqp> public method getPort ] {
- - Parameters [2] {
- Parameter #0 [ <required> $delivery_tag ]
- Parameter #1 [ <optional> $flags = <default> ]
+ - Parameters [0] {
}
+ - Return [ int ]
}
- Method [ <internal:amqp> public method reject ] {
+ Method [ <internal:amqp> public method setPort ] {
- - Parameters [2] {
- Parameter #0 [ <required> $delivery_tag ]
- Parameter #1 [ <optional> $flags = <default> ]
+ - Parameters [1] {
+ Parameter #0 [ <required> int $port ]
}
+ - Return [ void ]
}
- Method [ <internal:amqp> public method purge ] {
+ Method [ <internal:amqp> public method getVhost ] {
- Parameters [0] {
}
+ - Return [ string ]
}
- Method [ <internal:amqp> public method cancel ] {
+ Method [ <internal:amqp> public method setVhost ] {
- Parameters [1] {
- Parameter #0 [ <optional> $consumer_tag = <default> ]
+ Parameter #0 [ <required> string $vhost ]
}
+ - Return [ void ]
}
- Method [ <internal:amqp> public method delete ] {
+ Method [ <internal:amqp> public method getTimeout ] {
- - Parameters [1] {
- Parameter #0 [ <optional> $flags = <default> ]
+ - Parameters [0] {
}
+ - Return [ float ]
}
- Method [ <internal:amqp> public method unbind ] {
+ Method [ <internal:amqp> public method setTimeout ] {
- - Parameters [3] {
- Parameter #0 [ <required> $exchange_name ]
- Parameter #1 [ <optional> $routing_key = <default> ]
- Parameter #2 [ <optional> $arguments = <default> ]
+ - Parameters [1] {
+ Parameter #0 [ <required> float $timeout ]
}
+ - Return [ void ]
}
- Method [ <internal:amqp> public method getChannel ] {
+ Method [ <internal:amqp> public method getReadTimeout ] {
- Parameters [0] {
}
+ - Return [ float ]
}
- Method [ <internal:amqp> public method getConnection ] {
+ Method [ <internal:amqp> public method setReadTimeout ] {
- - Parameters [0] {
+ - Parameters [1] {
+ Parameter #0 [ <required> float $timeout ]
}
+ - Return [ void ]
}
- Method [ <internal:amqp> public method getConsumerTag ] {
+ Method [ <internal:amqp> public method getWriteTimeout ] {
- Parameters [0] {
}
+ - Return [ float ]
}
- Method [ <internal, deprecated:amqp> public method declare ] {
+ Method [ <internal:amqp> public method setWriteTimeout ] {
- - Parameters [0] {
+ - Parameters [1] {
+ Parameter #0 [ <required> float $timeout ]
}
+ - Return [ void ]
}
- }
- }
- Class [ <internal:amqp> class AMQPExchange ] {
+ Method [ <internal:amqp> public method getConnectTimeout ] {
- - Constants [0] {
- }
-
- - Static properties [0] {
- }
-
- - Static methods [0] {
- }
-
- - Properties [9] {
- Property [ private $connection = NULL ]
- Property [ private $channel = NULL ]
- Property [ private $name = '' ]
- Property [ private $type = NULL ]
- Property [ private $passive = false ]
- Property [ private $durable = false ]
- Property [ private $auto_delete = false ]
- Property [ private $internal = false ]
- Property [ private $arguments = NULL ]
- }
-
- - Methods [20] {
- Method [ <internal:amqp, ctor> public method __construct ] {
-
- - Parameters [1] {
- Parameter #0 [ <required> AMQPChannel $amqp_channel ]
+ - Parameters [0] {
}
+ - Return [ float ]
}
- Method [ <internal:amqp> public method getName ] {
+ Method [ <internal:amqp> public method getRpcTimeout ] {
- Parameters [0] {
}
+ - Return [ float ]
}
- Method [ <internal:amqp> public method setName ] {
+ Method [ <internal:amqp> public method setRpcTimeout ] {
- Parameters [1] {
- Parameter #0 [ <required> $exchange_name ]
+ Parameter #0 [ <required> float $timeout ]
}
+ - Return [ void ]
}
- Method [ <internal:amqp> public method getFlags ] {
+ Method [ <internal:amqp> public method getUsedChannels ] {
- Parameters [0] {
}
+ - Return [ int ]
}
- Method [ <internal:amqp> public method setFlags ] {
+ Method [ <internal:amqp> public method getMaxChannels ] {
- - Parameters [1] {
- Parameter #0 [ <required> $flags ]
+ - Parameters [0] {
}
+ - Return [ int ]
}
- Method [ <internal:amqp> public method getType ] {
+ Method [ <internal:amqp> public method isPersistent ] {
- Parameters [0] {
}
+ - Return [ bool ]
}
- Method [ <internal:amqp> public method setType ] {
+ Method [ <internal:amqp> public method getHeartbeatInterval ] {
- - Parameters [1] {
- Parameter #0 [ <required> $exchange_type ]
+ - Parameters [0] {
}
+ - Return [ int ]
}
- Method [ <internal:amqp> public method getArgument ] {
+ Method [ <internal:amqp> public method getMaxFrameSize ] {
- - Parameters [1] {
- Parameter #0 [ <required> $argument ]
+ - Parameters [0] {
}
+ - Return [ int ]
}
- Method [ <internal:amqp> public method getArguments ] {
+ Method [ <internal:amqp> public method getCACert ] {
- Parameters [0] {
}
+ - Return [ ?string ]
}
- Method [ <internal:amqp> public method setArgument ] {
+ Method [ <internal:amqp> public method setCACert ] {
- - Parameters [2] {
- Parameter #0 [ <required> $key ]
- Parameter #1 [ <required> $value ]
+ - Parameters [1] {
+ Parameter #0 [ <required> ?string $cacert ]
}
+ - Return [ void ]
}
- Method [ <internal:amqp> public method setArguments ] {
+ Method [ <internal:amqp> public method getCert ] {
- - Parameters [1] {
- Parameter #0 [ <required> array $arguments ]
+ - Parameters [0] {
}
+ - Return [ ?string ]
}
- Method [ <internal:amqp> public method hasArgument ] {
+ Method [ <internal:amqp> public method setCert ] {
- Parameters [1] {
- Parameter #0 [ <required> $argument ]
+ Parameter #0 [ <required> ?string $cert ]
}
+ - Return [ void ]
}
- Method [ <internal:amqp> public method declareExchange ] {
+ Method [ <internal:amqp> public method getKey ] {
- Parameters [0] {
}
+ - Return [ ?string ]
}
- Method [ <internal:amqp> public method bind ] {
+ Method [ <internal:amqp> public method setKey ] {
- - Parameters [3] {
- Parameter #0 [ <required> $exchange_name ]
- Parameter #1 [ <required> $routing_key ]
- Parameter #2 [ <optional> $flags = <default> ]
+ - Parameters [1] {
+ Parameter #0 [ <required> ?string $key ]
}
+ - Return [ void ]
}
- Method [ <internal:amqp> public method unbind ] {
+ Method [ <internal:amqp> public method getVerify ] {
- - Parameters [3] {
- Parameter #0 [ <required> $exchange_name ]
- Parameter #1 [ <required> $routing_key ]
- Parameter #2 [ <optional> $flags = <default> ]
+ - Parameters [0] {
}
+ - Return [ bool ]
}
- Method [ <internal:amqp> public method delete ] {
+ Method [ <internal:amqp> public method setVerify ] {
- - Parameters [2] {
- Parameter #0 [ <optional> $exchange_name = <default> ]
- Parameter #1 [ <optional> $flags = <default> ]
+ - Parameters [1] {
+ Parameter #0 [ <required> bool $verify ]
}
+ - Return [ void ]
}
- Method [ <internal:amqp> public method publish ] {
+ Method [ <internal:amqp> public method getSaslMethod ] {
- - Parameters [4] {
- Parameter #0 [ <required> $message ]
- Parameter #1 [ <optional> $routing_key = <default> ]
- Parameter #2 [ <optional> $flags = <default> ]
- Parameter #3 [ <optional> array $headers = <default> ]
+ - Parameters [0] {
}
+ - Return [ int ]
}
- Method [ <internal:amqp> public method getChannel ] {
+ Method [ <internal:amqp> public method setSaslMethod ] {
- - Parameters [0] {
+ - Parameters [1] {
+ Parameter #0 [ <required> int $saslMethod ]
}
+ - Return [ void ]
}
- Method [ <internal:amqp> public method getConnection ] {
+ Method [ <internal:amqp> public method getConnectionName ] {
- Parameters [0] {
}
+ - Return [ ?string ]
}
- Method [ <internal, deprecated:amqp> public method declare ] {
+ Method [ <internal:amqp> public method setConnectionName ] {
- - Parameters [0] {
+ - Parameters [1] {
+ Parameter #0 [ <required> ?string $connectionName ]
}
+ - Return [ void ]
}
}
}
- Class [ <internal:amqp> class AMQPBasicProperties ] {
+ Class [ <internal:amqp> class AMQPChannel ] {
- Constants [0] {
}
@@ -970,363 +1029,425 @@ Extension [ <persistent> extension #120 amqp version 1.11.0 ] {
- Static methods [0] {
}
- - Properties [14] {
- Property [ private $content_type = '' ]
- Property [ private $content_encoding = '' ]
- Property [ private $headers = NULL ]
- Property [ private $delivery_mode = 1 ]
- Property [ private $priority = 0 ]
- Property [ private $correlation_id = '' ]
- Property [ private $reply_to = '' ]
- Property [ private $expiration = '' ]
- Property [ private $message_id = '' ]
- Property [ private $timestamp = 0 ]
- Property [ private $type = '' ]
- Property [ private $user_id = '' ]
- Property [ private $app_id = '' ]
- Property [ private $cluster_id = '' ]
+ - Properties [6] {
+ Property [ private AMQPConnection $connection ]
+ Property [ private ?int $prefetchCount = NULL ]
+ Property [ private ?int $prefetchSize = NULL ]
+ Property [ private ?int $globalPrefetchCount = NULL ]
+ Property [ private ?int $globalPrefetchSize = NULL ]
+ Property [ private array $consumers = [] ]
}
- - Methods [15] {
+ - Methods [24] {
Method [ <internal:amqp, ctor> public method __construct ] {
- - Parameters [0] {
+ - Parameters [1] {
+ Parameter #0 [ <required> AMQPConnection $connection ]
}
}
- Method [ <internal:amqp> public method getContentType ] {
+ Method [ <internal:amqp> public method isConnected ] {
- Parameters [0] {
}
+ - Return [ bool ]
}
- Method [ <internal:amqp> public method getContentEncoding ] {
+ Method [ <internal:amqp> public method close ] {
- Parameters [0] {
}
+ - Return [ void ]
}
- Method [ <internal:amqp> public method getHeaders ] {
+ Method [ <internal:amqp> public method getChannelId ] {
- Parameters [0] {
}
+ - Return [ int ]
}
- Method [ <internal:amqp> public method getDeliveryMode ] {
+ Method [ <internal:amqp> public method setPrefetchSize ] {
- - Parameters [0] {
+ - Parameters [1] {
+ Parameter #0 [ <required> int $size ]
}
+ - Return [ void ]
}
- Method [ <internal:amqp> public method getPriority ] {
+ Method [ <internal:amqp> public method getPrefetchSize ] {
- Parameters [0] {
}
+ - Return [ int ]
}
- Method [ <internal:amqp> public method getCorrelationId ] {
+ Method [ <internal:amqp> public method setPrefetchCount ] {
- - Parameters [0] {
+ - Parameters [1] {
+ Parameter #0 [ <required> int $count ]
}
+ - Return [ void ]
}
- Method [ <internal:amqp> public method getReplyTo ] {
+ Method [ <internal:amqp> public method getPrefetchCount ] {
- Parameters [0] {
}
+ - Return [ int ]
}
- Method [ <internal:amqp> public method getExpiration ] {
+ Method [ <internal:amqp> public method setGlobalPrefetchSize ] {
- - Parameters [0] {
+ - Parameters [1] {
+ Parameter #0 [ <required> int $size ]
}
+ - Return [ void ]
}
- Method [ <internal:amqp> public method getMessageId ] {
+ Method [ <internal:amqp> public method getGlobalPrefetchSize ] {
- Parameters [0] {
}
+ - Return [ int ]
}
- Method [ <internal:amqp> public method getTimestamp ] {
+ Method [ <internal:amqp> public method setGlobalPrefetchCount ] {
- - Parameters [0] {
+ - Parameters [1] {
+ Parameter #0 [ <required> int $count ]
}
+ - Return [ void ]
}
- Method [ <internal:amqp> public method getType ] {
+ Method [ <internal:amqp> public method getGlobalPrefetchCount ] {
- Parameters [0] {
}
+ - Return [ int ]
}
- Method [ <internal:amqp> public method getUserId ] {
+ Method [ <internal:amqp> public method qos ] {
- - Parameters [0] {
+ - Parameters [3] {
+ Parameter #0 [ <required> int $size ]
+ Parameter #1 [ <required> int $count ]
+ Parameter #2 [ <optional> bool $global = false ]
}
+ - Return [ void ]
}
- Method [ <internal:amqp> public method getAppId ] {
+ Method [ <internal:amqp> public method startTransaction ] {
- Parameters [0] {
}
+ - Return [ void ]
}
- Method [ <internal:amqp> public method getClusterId ] {
+ Method [ <internal:amqp> public method commitTransaction ] {
- Parameters [0] {
}
+ - Return [ void ]
}
- }
- }
- Class [ <internal:amqp> class AMQPEnvelope extends AMQPBasicProperties ] {
-
- - Constants [0] {
- }
-
- - Static properties [0] {
- }
-
- - Static methods [0] {
- }
-
- - Properties [6] {
- Property [ private $body = NULL ]
- Property [ private $consumer_tag = NULL ]
- Property [ private $delivery_tag = NULL ]
- Property [ private $is_redelivery = NULL ]
- Property [ private $exchange_name = NULL ]
- Property [ private $routing_key = NULL ]
- }
-
- - Methods [23] {
- Method [ <internal:amqp, overwrites AMQPBasicProperties, ctor> public method __construct ] {
+ Method [ <internal:amqp> public method rollbackTransaction ] {
- Parameters [0] {
}
+ - Return [ void ]
}
- Method [ <internal:amqp> public method getBody ] {
+ Method [ <internal:amqp> public method getConnection ] {
- Parameters [0] {
}
+ - Return [ AMQPConnection ]
}
- Method [ <internal:amqp> public method getRoutingKey ] {
+ Method [ <internal:amqp> public method basicRecover ] {
- - Parameters [0] {
+ - Parameters [1] {
+ Parameter #0 [ <optional> bool $requeue = true ]
}
+ - Return [ void ]
}
- Method [ <internal:amqp> public method getConsumerTag ] {
+ Method [ <internal:amqp> public method confirmSelect ] {
- Parameters [0] {
}
+ - Return [ void ]
}
- Method [ <internal:amqp> public method getDeliveryTag ] {
+ Method [ <internal:amqp> public method waitForConfirm ] {
- - Parameters [0] {
+ - Parameters [1] {
+ Parameter #0 [ <optional> float $timeout = 0.0 ]
}
+ - Return [ void ]
}
- Method [ <internal:amqp> public method getExchangeName ] {
+ Method [ <internal:amqp> public method setConfirmCallback ] {
- - Parameters [0] {
+ - Parameters [2] {
+ Parameter #0 [ <required> ?callable $ackCallback ]
+ Parameter #1 [ <optional> ?callable $nackCallback = null ]
}
+ - Return [ void ]
}
- Method [ <internal:amqp> public method isRedelivery ] {
+ Method [ <internal:amqp> public method setReturnCallback ] {
- - Parameters [0] {
+ - Parameters [1] {
+ Parameter #0 [ <required> ?callable $returnCallback ]
}
+ - Return [ void ]
}
- Method [ <internal:amqp> public method getHeader ] {
+ Method [ <internal:amqp> public method waitForBasicReturn ] {
- Parameters [1] {
- Parameter #0 [ <required> $name ]
+ Parameter #0 [ <optional> float $timeout = 0.0 ]
}
+ - Return [ void ]
}
- Method [ <internal:amqp> public method hasHeader ] {
+ Method [ <internal:amqp> public method getConsumers ] {
- - Parameters [1] {
- Parameter #0 [ <required> $name ]
+ - Parameters [0] {
}
+ - Return [ array ]
}
+ }
+ }
- Method [ <internal:amqp, inherits AMQPBasicProperties> public method getContentType ] {
+ Class [ <internal:amqp> class AMQPQueue ] {
- - Parameters [0] {
+ - Constants [0] {
+ }
+
+ - Static properties [0] {
+ }
+
+ - Static methods [0] {
+ }
+
+ - Properties [9] {
+ Property [ private AMQPConnection $connection ]
+ Property [ private AMQPChannel $channel ]
+ Property [ private ?string $name = NULL ]
+ Property [ private ?string $consumerTag = NULL ]
+ Property [ private bool $passive = false ]
+ Property [ private bool $durable = false ]
+ Property [ private bool $exclusive = false ]
+ Property [ private bool $autoDelete = true ]
+ Property [ private array $arguments = [] ]
+ }
+
+ - Methods [25] {
+ Method [ <internal:amqp, ctor> public method __construct ] {
+
+ - Parameters [1] {
+ Parameter #0 [ <required> AMQPChannel $channel ]
}
}
- Method [ <internal:amqp, inherits AMQPBasicProperties> public method getContentEncoding ] {
+ Method [ <internal:amqp> public method getName ] {
- Parameters [0] {
}
+ - Return [ ?string ]
}
- Method [ <internal:amqp, inherits AMQPBasicProperties> public method getHeaders ] {
+ Method [ <internal:amqp> public method setName ] {
- - Parameters [0] {
+ - Parameters [1] {
+ Parameter #0 [ <required> string $name ]
}
+ - Return [ void ]
}
- Method [ <internal:amqp, inherits AMQPBasicProperties> public method getDeliveryMode ] {
+ Method [ <internal:amqp> public method getFlags ] {
- Parameters [0] {
}
+ - Return [ int ]
}
- Method [ <internal:amqp, inherits AMQPBasicProperties> public method getPriority ] {
+ Method [ <internal:amqp> public method setFlags ] {
- - Parameters [0] {
+ - Parameters [1] {
+ Parameter #0 [ <required> int $flags ]
}
+ - Return [ void ]
}
- Method [ <internal:amqp, inherits AMQPBasicProperties> public method getCorrelationId ] {
+ Method [ <internal:amqp> public method getArgument ] {
- - Parameters [0] {
+ - Parameters [1] {
+ Parameter #0 [ <required> string $argumentName ]
}
}
- Method [ <internal:amqp, inherits AMQPBasicProperties> public method getReplyTo ] {
+ Method [ <internal:amqp> public method getArguments ] {
- Parameters [0] {
}
+ - Return [ array ]
}
- Method [ <internal:amqp, inherits AMQPBasicProperties> public method getExpiration ] {
+ Method [ <internal:amqp> public method setArgument ] {
- - Parameters [0] {
+ - Parameters [2] {
+ Parameter #0 [ <required> string $argumentName ]
+ Parameter #1 [ <required> $argumentValue ]
}
+ - Return [ void ]
}
- Method [ <internal:amqp, inherits AMQPBasicProperties> public method getMessageId ] {
+ Method [ <internal:amqp> public method setArguments ] {
- - Parameters [0] {
+ - Parameters [1] {
+ Parameter #0 [ <required> array $arguments ]
}
+ - Return [ void ]
}
- Method [ <internal:amqp, inherits AMQPBasicProperties> public method getTimestamp ] {
+ Method [ <internal:amqp> public method hasArgument ] {
- - Parameters [0] {
+ - Parameters [1] {
+ Parameter #0 [ <required> string $argumentName ]
}
+ - Return [ bool ]
}
- Method [ <internal:amqp, inherits AMQPBasicProperties> public method getType ] {
+ Method [ <internal:amqp> public method declareQueue ] {
- Parameters [0] {
}
+ - Return [ int ]
}
- Method [ <internal:amqp, inherits AMQPBasicProperties> public method getUserId ] {
+ Method [ <internal:amqp> public method declare ] {
- Parameters [0] {
}
+ - Return [ int ]
}
- Method [ <internal:amqp, inherits AMQPBasicProperties> public method getAppId ] {
+ Method [ <internal:amqp> public method bind ] {
- - Parameters [0] {
+ - Parameters [3] {
+ Parameter #0 [ <required> string $exchangeName ]
+ Parameter #1 [ <optional> ?string $routingKey = null ]
+ Parameter #2 [ <optional> array $arguments = [] ]
}
+ - Return [ void ]
}
- Method [ <internal:amqp, inherits AMQPBasicProperties> public method getClusterId ] {
+ Method [ <internal:amqp> public method get ] {
- - Parameters [0] {
+ - Parameters [1] {
+ Parameter #0 [ <optional> int $flags = AMQP_NOPARAM ]
}
+ - Return [ ?AMQPEnvelope ]
}
- }
- }
- Class [ <internal:amqp> final class AMQPTimestamp implements Stringable ] {
-
- - Constants [2] {
- Constant [ public string MAX ] { 18446744073709551616 }
- Constant [ public string MIN ] { 0 }
- }
+ Method [ <internal:amqp> public method consume ] {
- - Static properties [0] {
- }
+ - Parameters [3] {
+ Parameter #0 [ <optional> ?callable $callback = null ]
+ Parameter #1 [ <optional> int $flags = AMQP_NOPARAM ]
+ Parameter #2 [ <optional> ?string $consumerTag = null ]
+ }
+ - Return [ void ]
+ }
- - Static methods [0] {
- }
+ Method [ <internal:amqp> public method ack ] {
- - Properties [1] {
- Property [ private $timestamp = NULL ]
- }
+ - Parameters [2] {
+ Parameter #0 [ <required> int $deliveryTag ]
+ Parameter #1 [ <optional> int $flags = AMQP_NOPARAM ]
+ }
+ - Return [ void ]
+ }
- - Methods [3] {
- Method [ <internal:amqp, ctor> public method __construct ] {
+ Method [ <internal:amqp> public method nack ] {
- - Parameters [1] {
- Parameter #0 [ <optional> $timestamp = <default> ]
+ - Parameters [2] {
+ Parameter #0 [ <required> int $deliveryTag ]
+ Parameter #1 [ <optional> int $flags = AMQP_NOPARAM ]
}
+ - Return [ void ]
}
- Method [ <internal:amqp> public method getTimestamp ] {
+ Method [ <internal:amqp> public method reject ] {
- - Parameters [0] {
+ - Parameters [2] {
+ Parameter #0 [ <required> int $deliveryTag ]
+ Parameter #1 [ <optional> int $flags = AMQP_NOPARAM ]
}
+ - Return [ void ]
}
- Method [ <internal:amqp, prototype Stringable> public method __toString ] {
+ Method [ <internal:amqp> public method purge ] {
- Parameters [0] {
}
- - Return [ string ]
+ - Return [ int ]
}
- }
- }
- Class [ <internal:amqp> final class AMQPDecimal ] {
+ Method [ <internal:amqp> public method cancel ] {
- - Constants [4] {
- Constant [ public int EXPONENT_MIN ] { 0 }
- Constant [ public int EXPONENT_MAX ] { 255 }
- Constant [ public int SIGNIFICAND_MIN ] { 0 }
- Constant [ public int SIGNIFICAND_MAX ] { 4294967295 }
- }
+ - Parameters [1] {
+ Parameter #0 [ <optional> string $consumerTag = "" ]
+ }
+ - Return [ void ]
+ }
- - Static properties [0] {
- }
+ Method [ <internal:amqp> public method delete ] {
- - Static methods [0] {
- }
+ - Parameters [1] {
+ Parameter #0 [ <optional> int $flags = AMQP_NOPARAM ]
+ }
+ - Return [ int ]
+ }
- - Properties [2] {
- Property [ private $exponent = 0 ]
- Property [ private $significand = 0 ]
- }
+ Method [ <internal:amqp> public method unbind ] {
- - Methods [3] {
- Method [ <internal:amqp, ctor> public method __construct ] {
+ - Parameters [3] {
+ Parameter #0 [ <required> string $exchangeName ]
+ Parameter #1 [ <optional> ?string $routingKey = null ]
+ Parameter #2 [ <optional> array $arguments = [] ]
+ }
+ - Return [ void ]
+ }
- - Parameters [2] {
- Parameter #0 [ <required> $exponent ]
- Parameter #1 [ <required> $significand ]
+ Method [ <internal:amqp> public method getChannel ] {
+
+ - Parameters [0] {
}
+ - Return [ AMQPChannel ]
}
- Method [ <internal:amqp> public method getExponent ] {
+ Method [ <internal:amqp> public method getConnection ] {
- Parameters [0] {
}
+ - Return [ AMQPConnection ]
}
- Method [ <internal:amqp> public method getSignificand ] {
+ Method [ <internal:amqp> public method getConsumerTag ] {
- Parameters [0] {
}
+ - Return [ ?string ]
}
}
}
- Class [ <internal:amqp> class AMQPException extends Exception implements Throwable, Stringable ] {
+ Class [ <internal:amqp> class AMQPExchange ] {
- Constants [0] {
}
@@ -1337,180 +1458,181 @@ Extension [ <persistent> extension #120 amqp version 1.11.0 ] {
- Static methods [0] {
}
- - Properties [4] {
- Property [ protected $message = '' ]
- Property [ protected $code = 0 ]
- Property [ protected string $file = '' ]
- Property [ protected int $line = 0 ]
+ - Properties [9] {
+ Property [ private AMQPConnection $connection ]
+ Property [ private AMQPChannel $channel ]
+ Property [ private ?string $name = NULL ]
+ Property [ private ?string $type = NULL ]
+ Property [ private bool $passive = false ]
+ Property [ private bool $durable = false ]
+ Property [ private bool $autoDelete = false ]
+ Property [ private bool $internal = false ]
+ Property [ private array $arguments = [] ]
}
- - Methods [10] {
- Method [ <internal:Core, inherits Exception, ctor> public method __construct ] {
+ - Methods [20] {
+ Method [ <internal:amqp, ctor> public method __construct ] {
- - Parameters [3] {
- Parameter #0 [ <optional> string $message = "" ]
- Parameter #1 [ <optional> int $code = 0 ]
- Parameter #2 [ <optional> ?Throwable $previous = null ]
+ - Parameters [1] {
+ Parameter #0 [ <required> AMQPChannel $channel ]
}
}
- Method [ <internal:Core, inherits Exception> public method __wakeup ] {
+ Method [ <internal:amqp> public method getName ] {
- Parameters [0] {
}
- - Tentative return [ void ]
+ - Return [ ?string ]
}
- Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getMessage ] {
+ Method [ <internal:amqp> public method setName ] {
- - Parameters [0] {
+ - Parameters [1] {
+ Parameter #0 [ <required> ?string $exchangeName ]
}
- - Return [ string ]
+ - Return [ void ]
}
- Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getCode ] {
+ Method [ <internal:amqp> public method getFlags ] {
- Parameters [0] {
}
+ - Return [ int ]
}
- Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getFile ] {
+ Method [ <internal:amqp> public method setFlags ] {
- - Parameters [0] {
+ - Parameters [1] {
+ Parameter #0 [ <required> ?int $flags ]
}
- - Return [ string ]
+ - Return [ void ]
}
- Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getLine ] {
+ Method [ <internal:amqp> public method getType ] {
- Parameters [0] {
}
- - Return [ int ]
+ - Return [ ?string ]
}
- Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getTrace ] {
+ Method [ <internal:amqp> public method setType ] {
- - Parameters [0] {
+ - Parameters [1] {
+ Parameter #0 [ <required> ?string $exchangeType ]
}
- - Return [ array ]
+ - Return [ void ]
}
- Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getPrevious ] {
+ Method [ <internal:amqp> public method getArgument ] {
- - Parameters [0] {
+ - Parameters [1] {
+ Parameter #0 [ <required> string $argumentName ]
}
- - Return [ ?Throwable ]
}
- Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getTraceAsString ] {
+ Method [ <internal:amqp> public method getArguments ] {
- Parameters [0] {
}
- - Return [ string ]
+ - Return [ array ]
}
- Method [ <internal:Core, inherits Exception, prototype Stringable> public method __toString ] {
+ Method [ <internal:amqp> public method setArgument ] {
- - Parameters [0] {
+ - Parameters [2] {
+ Parameter #0 [ <required> string $argumentName ]
+ Parameter #1 [ <required> $argumentValue ]
}
- - Return [ string ]
+ - Return [ void ]
}
- }
- }
-
- Class [ <internal:amqp> class AMQPConnectionException extends AMQPException implements Stringable, Throwable ] {
-
- - Constants [0] {
- }
-
- - Static properties [0] {
- }
-
- - Static methods [0] {
- }
-
- - Properties [4] {
- Property [ protected $message = '' ]
- Property [ protected $code = 0 ]
- Property [ protected string $file = '' ]
- Property [ protected int $line = 0 ]
- }
- - Methods [10] {
- Method [ <internal:Core, inherits Exception, ctor> public method __construct ] {
+ Method [ <internal:amqp> public method setArguments ] {
- - Parameters [3] {
- Parameter #0 [ <optional> string $message = "" ]
- Parameter #1 [ <optional> int $code = 0 ]
- Parameter #2 [ <optional> ?Throwable $previous = null ]
+ - Parameters [1] {
+ Parameter #0 [ <required> array $arguments ]
}
+ - Return [ void ]
}
- Method [ <internal:Core, inherits Exception> public method __wakeup ] {
+ Method [ <internal:amqp> public method hasArgument ] {
- - Parameters [0] {
+ - Parameters [1] {
+ Parameter #0 [ <required> string $argumentName ]
}
- - Tentative return [ void ]
+ - Return [ bool ]
}
- Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getMessage ] {
+ Method [ <internal:amqp> public method declareExchange ] {
- Parameters [0] {
}
- - Return [ string ]
+ - Return [ void ]
}
- Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getCode ] {
+ Method [ <internal:amqp> public method declare ] {
- Parameters [0] {
}
+ - Return [ void ]
}
- Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getFile ] {
+ Method [ <internal:amqp> public method bind ] {
- - Parameters [0] {
+ - Parameters [3] {
+ Parameter #0 [ <required> string $exchangeName ]
+ Parameter #1 [ <optional> ?string $routingKey = null ]
+ Parameter #2 [ <optional> array $arguments = [] ]
}
- - Return [ string ]
+ - Return [ void ]
}
- Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getLine ] {
+ Method [ <internal:amqp> public method unbind ] {
- - Parameters [0] {
+ - Parameters [3] {
+ Parameter #0 [ <required> string $exchangeName ]
+ Parameter #1 [ <optional> ?string $routingKey = null ]
+ Parameter #2 [ <optional> array $arguments = [] ]
}
- - Return [ int ]
+ - Return [ void ]
}
- Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getTrace ] {
+ Method [ <internal:amqp> public method delete ] {
- - Parameters [0] {
+ - Parameters [2] {
+ Parameter #0 [ <optional> ?string $exchangeName = null ]
+ Parameter #1 [ <optional> int $flags = AMQP_NOPARAM ]
}
- - Return [ array ]
+ - Return [ void ]
}
- Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getPrevious ] {
+ Method [ <internal:amqp> public method publish ] {
- - Parameters [0] {
+ - Parameters [4] {
+ Parameter #0 [ <required> string $message ]
+ Parameter #1 [ <optional> ?string $routingKey = null ]
+ Parameter #2 [ <optional> int $flags = AMQP_NOPARAM ]
+ Parameter #3 [ <optional> array $headers = [] ]
}
- - Return [ ?Throwable ]
+ - Return [ void ]
}
- Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getTraceAsString ] {
+ Method [ <internal:amqp> public method getChannel ] {
- Parameters [0] {
}
- - Return [ string ]
+ - Return [ AMQPChannel ]
}
- Method [ <internal:Core, inherits Exception, prototype Stringable> public method __toString ] {
+ Method [ <internal:amqp> public method getConnection ] {
- Parameters [0] {
}
- - Return [ string ]
+ - Return [ AMQPConnection ]
}
}
}
- Class [ <internal:amqp> class AMQPChannelException extends AMQPException implements Stringable, Throwable ] {
+ Class [ <internal:amqp> class AMQPBasicProperties ] {
- Constants [0] {
}
@@ -1521,88 +1643,145 @@ Extension [ <persistent> extension #120 amqp version 1.11.0 ] {
- Static methods [0] {
}
- - Properties [4] {
- Property [ protected $message = '' ]
- Property [ protected $code = 0 ]
- Property [ protected string $file = '' ]
- Property [ protected int $line = 0 ]
+ - Properties [14] {
+ Property [ private ?string $contentType = NULL ]
+ Property [ private ?string $contentEncoding = NULL ]
+ Property [ private array $headers = [] ]
+ Property [ private int $deliveryMode = 1 ]
+ Property [ private int $priority = 0 ]
+ Property [ private ?string $correlationId = NULL ]
+ Property [ private ?string $replyTo = NULL ]
+ Property [ private ?string $expiration = NULL ]
+ Property [ private ?string $messageId = NULL ]
+ Property [ private ?int $timestamp = NULL ]
+ Property [ private ?string $type = NULL ]
+ Property [ private ?string $userId = NULL ]
+ Property [ private ?string $appId = NULL ]
+ Property [ private ?string $clusterId = NULL ]
}
- - Methods [10] {
- Method [ <internal:Core, inherits Exception, ctor> public method __construct ] {
+ - Methods [15] {
+ Method [ <internal:amqp, ctor> public method __construct ] {
- - Parameters [3] {
- Parameter #0 [ <optional> string $message = "" ]
- Parameter #1 [ <optional> int $code = 0 ]
- Parameter #2 [ <optional> ?Throwable $previous = null ]
+ - Parameters [14] {
+ Parameter #0 [ <optional> ?string $contentType = null ]
+ Parameter #1 [ <optional> ?string $contentEncoding = null ]
+ Parameter #2 [ <optional> array $headers = [] ]
+ Parameter #3 [ <optional> int $deliveryMode = AMQP_DELIVERY_MODE_TRANSIENT ]
+ Parameter #4 [ <optional> int $priority = 0 ]
+ Parameter #5 [ <optional> ?string $correlationId = null ]
+ Parameter #6 [ <optional> ?string $replyTo = null ]
+ Parameter #7 [ <optional> ?string $expiration = null ]
+ Parameter #8 [ <optional> ?string $messageId = null ]
+ Parameter #9 [ <optional> ?int $timestamp = null ]
+ Parameter #10 [ <optional> ?string $type = null ]
+ Parameter #11 [ <optional> ?string $userId = null ]
+ Parameter #12 [ <optional> ?string $appId = null ]
+ Parameter #13 [ <optional> ?string $clusterId = null ]
}
}
- Method [ <internal:Core, inherits Exception> public method __wakeup ] {
+ Method [ <internal:amqp> public method getContentType ] {
- Parameters [0] {
}
- - Tentative return [ void ]
+ - Return [ ?string ]
}
- Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getMessage ] {
+ Method [ <internal:amqp> public method getContentEncoding ] {
- Parameters [0] {
}
- - Return [ string ]
+ - Return [ ?string ]
}
- Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getCode ] {
+ Method [ <internal:amqp> public method getHeaders ] {
- Parameters [0] {
}
+ - Return [ array ]
}
- Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getFile ] {
+ Method [ <internal:amqp> public method getDeliveryMode ] {
- Parameters [0] {
}
- - Return [ string ]
+ - Return [ int ]
}
- Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getLine ] {
+ Method [ <internal:amqp> public method getPriority ] {
- Parameters [0] {
}
- Return [ int ]
}
- Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getTrace ] {
+ Method [ <internal:amqp> public method getCorrelationId ] {
- Parameters [0] {
}
- - Return [ array ]
+ - Return [ ?string ]
}
- Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getPrevious ] {
+ Method [ <internal:amqp> public method getReplyTo ] {
- Parameters [0] {
}
- - Return [ ?Throwable ]
+ - Return [ ?string ]
}
- Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getTraceAsString ] {
+ Method [ <internal:amqp> public method getExpiration ] {
- Parameters [0] {
}
- - Return [ string ]
+ - Return [ ?string ]
}
- Method [ <internal:Core, inherits Exception, prototype Stringable> public method __toString ] {
+ Method [ <internal:amqp> public method getMessageId ] {
- Parameters [0] {
}
- - Return [ string ]
+ - Return [ ?string ]
+ }
+
+ Method [ <internal:amqp> public method getTimestamp ] {
+
+ - Parameters [0] {
+ }
+ - Return [ ?int ]
+ }
+
+ Method [ <internal:amqp> public method getType ] {
+
+ - Parameters [0] {
+ }
+ - Return [ ?string ]
+ }
+
+ Method [ <internal:amqp> public method getUserId ] {
+
+ - Parameters [0] {
+ }
+ - Return [ ?string ]
+ }
+
+ Method [ <internal:amqp> public method getAppId ] {
+
+ - Parameters [0] {
+ }
+ - Return [ ?string ]
+ }
+
+ Method [ <internal:amqp> public method getClusterId ] {
+
+ - Parameters [0] {
+ }
+ - Return [ ?string ]
}
}
}
- Class [ <internal:amqp> class AMQPQueueException extends AMQPException implements Stringable, Throwable ] {
+ Class [ <internal:amqp> class AMQPEnvelope extends AMQPBasicProperties ] {
- Constants [0] {
}
@@ -1613,181 +1792,181 @@ Extension [ <persistent> extension #120 amqp version 1.11.0 ] {
- Static methods [0] {
}
- - Properties [4] {
- Property [ protected $message = '' ]
- Property [ protected $code = 0 ]
- Property [ protected string $file = '' ]
- Property [ protected int $line = 0 ]
+ - Properties [6] {
+ Property [ private string $body = '' ]
+ Property [ private ?string $consumerTag = NULL ]
+ Property [ private ?int $deliveryTag = NULL ]
+ Property [ private bool $isRedelivery = false ]
+ Property [ private ?string $exchangeName = NULL ]
+ Property [ private string $routingKey = '' ]
}
- - Methods [10] {
- Method [ <internal:Core, inherits Exception, ctor> public method __construct ] {
+ - Methods [23] {
+ Method [ <internal:amqp, overwrites AMQPBasicProperties, ctor> public method __construct ] {
- - Parameters [3] {
- Parameter #0 [ <optional> string $message = "" ]
- Parameter #1 [ <optional> int $code = 0 ]
- Parameter #2 [ <optional> ?Throwable $previous = null ]
+ - Parameters [0] {
}
}
- Method [ <internal:Core, inherits Exception> public method __wakeup ] {
+ Method [ <internal:amqp> public method getBody ] {
- Parameters [0] {
}
- - Tentative return [ void ]
+ - Return [ string ]
}
- Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getMessage ] {
+ Method [ <internal:amqp> public method getRoutingKey ] {
- Parameters [0] {
}
- Return [ string ]
}
- Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getCode ] {
+ Method [ <internal:amqp> public method getConsumerTag ] {
- Parameters [0] {
}
+ - Return [ ?string ]
}
- Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getFile ] {
+ Method [ <internal:amqp> public method getDeliveryTag ] {
- Parameters [0] {
}
- - Return [ string ]
+ - Return [ ?int ]
}
- Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getLine ] {
+ Method [ <internal:amqp> public method getExchangeName ] {
- Parameters [0] {
}
- - Return [ int ]
+ - Return [ ?string ]
}
- Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getTrace ] {
+ Method [ <internal:amqp> public method isRedelivery ] {
- Parameters [0] {
}
- - Return [ array ]
+ - Return [ bool ]
}
- Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getPrevious ] {
+ Method [ <internal:amqp> public method getHeader ] {
- - Parameters [0] {
+ - Parameters [1] {
+ Parameter #0 [ <required> string $headerName ]
}
- - Return [ ?Throwable ]
+ - Return [ ?string ]
}
- Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getTraceAsString ] {
+ Method [ <internal:amqp> public method hasHeader ] {
- - Parameters [0] {
+ - Parameters [1] {
+ Parameter #0 [ <required> string $headerName ]
}
- - Return [ string ]
+ - Return [ bool ]
}
- Method [ <internal:Core, inherits Exception, prototype Stringable> public method __toString ] {
+ Method [ <internal:amqp, inherits AMQPBasicProperties> public method getContentType ] {
- Parameters [0] {
}
- - Return [ string ]
+ - Return [ ?string ]
}
- }
- }
- Class [ <internal:amqp> class AMQPEnvelopeException extends AMQPException implements Stringable, Throwable ] {
+ Method [ <internal:amqp, inherits AMQPBasicProperties> public method getContentEncoding ] {
- - Constants [0] {
- }
+ - Parameters [0] {
+ }
+ - Return [ ?string ]
+ }
- - Static properties [0] {
- }
+ Method [ <internal:amqp, inherits AMQPBasicProperties> public method getHeaders ] {
- - Static methods [0] {
- }
+ - Parameters [0] {
+ }
+ - Return [ array ]
+ }
- - Properties [5] {
- Property [ protected $message = '' ]
- Property [ protected $code = 0 ]
- Property [ protected string $file = '' ]
- Property [ protected int $line = 0 ]
- Property [ public $envelope = NULL ]
- }
+ Method [ <internal:amqp, inherits AMQPBasicProperties> public method getDeliveryMode ] {
- - Methods [10] {
- Method [ <internal:Core, inherits Exception, ctor> public method __construct ] {
+ - Parameters [0] {
+ }
+ - Return [ int ]
+ }
- - Parameters [3] {
- Parameter #0 [ <optional> string $message = "" ]
- Parameter #1 [ <optional> int $code = 0 ]
- Parameter #2 [ <optional> ?Throwable $previous = null ]
+ Method [ <internal:amqp, inherits AMQPBasicProperties> public method getPriority ] {
+
+ - Parameters [0] {
}
+ - Return [ int ]
}
- Method [ <internal:Core, inherits Exception> public method __wakeup ] {
+ Method [ <internal:amqp, inherits AMQPBasicProperties> public method getCorrelationId ] {
- Parameters [0] {
}
- - Tentative return [ void ]
+ - Return [ ?string ]
}
- Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getMessage ] {
+ Method [ <internal:amqp, inherits AMQPBasicProperties> public method getReplyTo ] {
- Parameters [0] {
}
- - Return [ string ]
+ - Return [ ?string ]
}
- Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getCode ] {
+ Method [ <internal:amqp, inherits AMQPBasicProperties> public method getExpiration ] {
- Parameters [0] {
}
+ - Return [ ?string ]
}
- Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getFile ] {
+ Method [ <internal:amqp, inherits AMQPBasicProperties> public method getMessageId ] {
- Parameters [0] {
}
- - Return [ string ]
+ - Return [ ?string ]
}
- Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getLine ] {
+ Method [ <internal:amqp, inherits AMQPBasicProperties> public method getTimestamp ] {
- Parameters [0] {
}
- - Return [ int ]
+ - Return [ ?int ]
}
- Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getTrace ] {
+ Method [ <internal:amqp, inherits AMQPBasicProperties> public method getType ] {
- Parameters [0] {
}
- - Return [ array ]
+ - Return [ ?string ]
}
- Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getPrevious ] {
+ Method [ <internal:amqp, inherits AMQPBasicProperties> public method getUserId ] {
- Parameters [0] {
}
- - Return [ ?Throwable ]
+ - Return [ ?string ]
}
- Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getTraceAsString ] {
+ Method [ <internal:amqp, inherits AMQPBasicProperties> public method getAppId ] {
- Parameters [0] {
}
- - Return [ string ]
+ - Return [ ?string ]
}
- Method [ <internal:Core, inherits Exception, prototype Stringable> public method __toString ] {
+ Method [ <internal:amqp, inherits AMQPBasicProperties> public method getClusterId ] {
- Parameters [0] {
}
- - Return [ string ]
+ - Return [ ?string ]
}
}
}
- Class [ <internal:amqp> class AMQPExchangeException extends AMQPException implements Stringable, Throwable ] {
+ Class [ <internal:amqp> class AMQPEnvelopeException extends AMQPException implements Stringable, Throwable ] {
- Constants [0] {
}
@@ -1798,14 +1977,22 @@ Extension [ <persistent> extension #120 amqp version 1.11.0 ] {
- Static methods [0] {
}
- - Properties [4] {
+ - Properties [5] {
Property [ protected $message = '' ]
Property [ protected $code = 0 ]
Property [ protected string $file = '' ]
Property [ protected int $line = 0 ]
+ Property [ private AMQPEnvelope $envelope ]
}
- - Methods [10] {
+ - Methods [11] {
+ Method [ <internal:amqp> public method getEnvelope ] {
+
+ - Parameters [0] {
+ }
+ - Return [ AMQPEnvelope ]
+ }
+
Method [ <internal:Core, inherits Exception, ctor> public method __construct ] {
- Parameters [3] {
@@ -1879,9 +2066,11 @@ Extension [ <persistent> extension #120 amqp version 1.11.0 ] {
}
}
- Class [ <internal:amqp> class AMQPValueException extends AMQPException implements Stringable, Throwable ] {
+ Class [ <internal:amqp> final class AMQPTimestamp implements Stringable ] {
- - Constants [0] {
+ - Constants [2] {
+ Constant [ public float MAX ] { 1.844674407371E+19 }
+ Constant [ public float MIN ] { 0 }
}
- Static properties [0] {
@@ -1890,83 +2079,75 @@ Extension [ <persistent> extension #120 amqp version 1.11.0 ] {
- Static methods [0] {
}
- - Properties [4] {
- Property [ protected $message = '' ]
- Property [ protected $code = 0 ]
- Property [ protected string $file = '' ]
- Property [ protected int $line = 0 ]
+ - Properties [1] {
+ Property [ private float $timestamp ]
}
- - Methods [10] {
- Method [ <internal:Core, inherits Exception, ctor> public method __construct ] {
+ - Methods [3] {
+ Method [ <internal:amqp, ctor> public method __construct ] {
- - Parameters [3] {
- Parameter #0 [ <optional> string $message = "" ]
- Parameter #1 [ <optional> int $code = 0 ]
- Parameter #2 [ <optional> ?Throwable $previous = null ]
+ - Parameters [1] {
+ Parameter #0 [ <required> float $timestamp ]
}
}
- Method [ <internal:Core, inherits Exception> public method __wakeup ] {
+ Method [ <internal:amqp> public method getTimestamp ] {
- Parameters [0] {
}
- - Tentative return [ void ]
+ - Return [ float ]
}
- Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getMessage ] {
+ Method [ <internal:amqp, prototype Stringable> public method __toString ] {
- Parameters [0] {
}
- Return [ string ]
}
+ }
+ }
- Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getCode ] {
-
- - Parameters [0] {
- }
- }
-
- Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getFile ] {
-
- - Parameters [0] {
- }
- - Return [ string ]
- }
+ Class [ <internal:amqp> final class AMQPDecimal ] {
- Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getLine ] {
+ - Constants [4] {
+ Constant [ public int EXPONENT_MIN ] { 0 }
+ Constant [ public int EXPONENT_MAX ] { 255 }
+ Constant [ public int SIGNIFICAND_MIN ] { 0 }
+ Constant [ public int SIGNIFICAND_MAX ] { 4294967295 }
+ }
- - Parameters [0] {
- }
- - Return [ int ]
- }
+ - Static properties [0] {
+ }
- Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getTrace ] {
+ - Static methods [0] {
+ }
- - Parameters [0] {
- }
- - Return [ array ]
- }
+ - Properties [2] {
+ Property [ private int $exponent ]
+ Property [ private int $significand ]
+ }
- Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getPrevious ] {
+ - Methods [3] {
+ Method [ <internal:amqp, ctor> public method __construct ] {
- - Parameters [0] {
+ - Parameters [2] {
+ Parameter #0 [ <required> int $exponent ]
+ Parameter #1 [ <required> int $significand ]
}
- - Return [ ?Throwable ]
}
- Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getTraceAsString ] {
+ Method [ <internal:amqp> public method getExponent ] {
- Parameters [0] {
}
- - Return [ string ]
+ - Return [ int ]
}
- Method [ <internal:Core, inherits Exception, prototype Stringable> public method __toString ] {
+ Method [ <internal:amqp> public method getSignificand ] {
- Parameters [0] {
}
- - Return [ string ]
+ - Return [ int ]
}
}
}
diff --git a/php-pecl-amqp.spec b/php-pecl-amqp.spec
index 2d8a915..af30aeb 100644
--- a/php-pecl-amqp.spec
+++ b/php-pecl-amqp.spec
@@ -17,9 +17,9 @@
%global with_zts 0%{!?_without_zts:%{?__ztsphp:1}}
%global pecl_name amqp
%global ini_name 40-%{pecl_name}.ini
-%global upstream_version 1.11.0
-#global upstream_prever RC1
-#global upstream_lower rc1
+%global upstream_version 2.0.0
+%global upstream_prever alpha1
+%global upstream_lower %(echo %{upstream_prever} | tr '[:upper:]' '[:lower:]')
%global sources %{pecl_name}-%{upstream_version}%{?upstream_prever}
%global _configure ../%{sources}/configure
@@ -28,19 +28,16 @@
Summary: Communicate with any AMQP compliant server
Name: %{?scl_prefix}php-pecl-amqp
Version: %{upstream_version}%{?upstream_prever:~%{upstream_lower}}
-Release: 3%{?dist}%{!?scl:%{!?nophptag:%(%{__php} -r 'echo ".".PHP_MAJOR_VERSION.".".PHP_MINOR_VERSION;')}}
+Release: 1%{?dist}%{!?scl:%{!?nophptag:%(%{__php} -r 'echo ".".PHP_MAJOR_VERSION.".".PHP_MINOR_VERSION;')}}
License: PHP-3.01
URL: https://pecl.php.net/package/amqp
Source0: https://pecl.php.net/get/%{pecl_name}-%{upstream_version}%{?upstream_prever}.tgz
-Patch0: https://patch-diff.githubusercontent.com/raw/php-amqp/php-amqp/pull/418.patch
-
BuildRequires: make
BuildRequires: %{?dtsprefix}gcc
-BuildRequires: %{?scl_prefix}php-devel >= 5.6
+BuildRequires: %{?scl_prefix}php-devel >= 7.4
BuildRequires: %{?scl_prefix}php-pear
-# Upstream requires 0.7.1, set 0.8.0 to ensure "last" is used.
-BuildRequires: librabbitmq-devel >= 0.8.0
+BuildRequires: librabbitmq-devel
Requires: librabbitmq%{?_isa} >= %{buildver}
%if %{with tests}
BuildRequires: rabbitmq-server
@@ -48,7 +45,6 @@ BuildRequires: rabbitmq-server
Requires: %{?scl_prefix}php(zend-abi) = %{php_zend_api}
Requires: %{?scl_prefix}php(api) = %{php_core_api}
-%{?_sclreq:Requires: %{?scl_prefix}runtime%{?_sclreq}%{?_isa}}
Provides: %{?scl_prefix}php-%{pecl_name} = %{version}
Provides: %{?scl_prefix}php-%{pecl_name}%{?_isa} = %{version}
@@ -97,12 +93,12 @@ sed -e 's/role="test"/role="src"/' \
-i package.xml
cd %{sources}
-%patch -P0 -p1 -b .php82
-
-sed -e 's/CFLAGS="-I/CFLAGS="-fPIC -I/' -i config.m4
+# lower minimal version
+# https://github.com/php-amqp/php-amqp/issues/439
+sed -e '/librabbitmq/s/0.10.0/0.8.0/' -i config.m4
# Upstream often forget to change this
-extver=$(sed -n '/#define PHP_AMQP_VERSION/{s/.* "//;s/".*$//;p}' php_amqp.h)
+extver=$(sed -n '/#define PHP_AMQP_VERSION /{s/.* "//;s/".*$//;p}' php_amqp_version.h)
if test "x${extver}" != "x%{upstream_version}%{?upstream_prever}"; then
: Error: Upstream extension version is ${extver}, expecting %{upstream_version}%{?upstream_prever}.
exit 1
@@ -156,8 +152,8 @@ extension = %{pecl_name}.so
;amqp.cacert = ''
;amqp.cert = ''
;amqp.key = ''
-;amqp.verify = ''
-;amqp.sasl_method = 0
+;amqp.verify = 1
+;amqp.sasl_method = ''
EOF
mkdir NTS
@@ -282,6 +278,12 @@ fi
%changelog
+* Sun Jul 30 2023 Remi Collet <remi@remirepo.net> - 2.0.0~alpha1-1
+- update to 2.0.0alpha1
+- drop patch merged upstream
+- raise dependency on PHP 7.4
+- open https://github.com/php-amqp/php-amqp/issues/439 librabbitmq min version
+
* Wed Jul 12 2023 Remi Collet <remi@remirepo.net> - 1.11.0-3
- build out of sources tree
generated by cgit (git 2.34.1) at 2024-12-28 16:01:58 +0000