4 * This file is part of the Symfony package.
6 * (c) Fabien Potencier <fabien@symfony.com>
8 * For the full copyright and license information, please view the LICENSE
9 * file that was distributed with this source code.
12 namespace Symfony\Component\VarDumper\Caster;
14 use Symfony\Component\VarDumper\Cloner\Stub;
17 * Casts Amqp related classes to array representation.
19 * @author Grégoire Pineau <lyrixx@lyrixx.info>
23 private static $flags = array(
24 AMQP_DURABLE => 'AMQP_DURABLE',
25 AMQP_PASSIVE => 'AMQP_PASSIVE',
26 AMQP_EXCLUSIVE => 'AMQP_EXCLUSIVE',
27 AMQP_AUTODELETE => 'AMQP_AUTODELETE',
28 AMQP_INTERNAL => 'AMQP_INTERNAL',
29 AMQP_NOLOCAL => 'AMQP_NOLOCAL',
30 AMQP_AUTOACK => 'AMQP_AUTOACK',
31 AMQP_IFEMPTY => 'AMQP_IFEMPTY',
32 AMQP_IFUNUSED => 'AMQP_IFUNUSED',
33 AMQP_MANDATORY => 'AMQP_MANDATORY',
34 AMQP_IMMEDIATE => 'AMQP_IMMEDIATE',
35 AMQP_MULTIPLE => 'AMQP_MULTIPLE',
36 AMQP_NOWAIT => 'AMQP_NOWAIT',
37 AMQP_REQUEUE => 'AMQP_REQUEUE',
40 private static $exchangeTypes = array(
41 AMQP_EX_TYPE_DIRECT => 'AMQP_EX_TYPE_DIRECT',
42 AMQP_EX_TYPE_FANOUT => 'AMQP_EX_TYPE_FANOUT',
43 AMQP_EX_TYPE_TOPIC => 'AMQP_EX_TYPE_TOPIC',
44 AMQP_EX_TYPE_HEADERS => 'AMQP_EX_TYPE_HEADERS',
47 public static function castConnection(\AMQPConnection $c, array $a, Stub $stub, $isNested)
49 $prefix = Caster::PREFIX_VIRTUAL;
52 $prefix.'is_connected' => $c->isConnected(),
55 // Recent version of the extension already expose private properties
56 if (isset($a["\x00AMQPConnection\x00login"])) {
60 // BC layer in the amqp lib
61 if (method_exists($c, 'getReadTimeout')) {
62 $timeout = $c->getReadTimeout();
64 $timeout = $c->getTimeout();
68 $prefix.'is_connected' => $c->isConnected(),
69 $prefix.'login' => $c->getLogin(),
70 $prefix.'password' => $c->getPassword(),
71 $prefix.'host' => $c->getHost(),
72 $prefix.'vhost' => $c->getVhost(),
73 $prefix.'port' => $c->getPort(),
74 $prefix.'read_timeout' => $timeout,
80 public static function castChannel(\AMQPChannel $c, array $a, Stub $stub, $isNested)
82 $prefix = Caster::PREFIX_VIRTUAL;
85 $prefix.'is_connected' => $c->isConnected(),
86 $prefix.'channel_id' => $c->getChannelId(),
89 // Recent version of the extension already expose private properties
90 if (isset($a["\x00AMQPChannel\x00connection"])) {
95 $prefix.'connection' => $c->getConnection(),
96 $prefix.'prefetch_size' => $c->getPrefetchSize(),
97 $prefix.'prefetch_count' => $c->getPrefetchCount(),
103 public static function castQueue(\AMQPQueue $c, array $a, Stub $stub, $isNested)
105 $prefix = Caster::PREFIX_VIRTUAL;
108 $prefix.'flags' => self::extractFlags($c->getFlags()),
111 // Recent version of the extension already expose private properties
112 if (isset($a["\x00AMQPQueue\x00name"])) {
117 $prefix.'connection' => $c->getConnection(),
118 $prefix.'channel' => $c->getChannel(),
119 $prefix.'name' => $c->getName(),
120 $prefix.'arguments' => $c->getArguments(),
126 public static function castExchange(\AMQPExchange $c, array $a, Stub $stub, $isNested)
128 $prefix = Caster::PREFIX_VIRTUAL;
131 $prefix.'flags' => self::extractFlags($c->getFlags()),
134 $type = isset(self::$exchangeTypes[$c->getType()]) ? new ConstStub(self::$exchangeTypes[$c->getType()], $c->getType()) : $c->getType();
136 // Recent version of the extension already expose private properties
137 if (isset($a["\x00AMQPExchange\x00name"])) {
138 $a["\x00AMQPExchange\x00type"] = $type;
144 $prefix.'connection' => $c->getConnection(),
145 $prefix.'channel' => $c->getChannel(),
146 $prefix.'name' => $c->getName(),
147 $prefix.'type' => $type,
148 $prefix.'arguments' => $c->getArguments(),
154 public static function castEnvelope(\AMQPEnvelope $c, array $a, Stub $stub, $isNested, $filter = 0)
156 $prefix = Caster::PREFIX_VIRTUAL;
158 $deliveryMode = new ConstStub($c->getDeliveryMode().(2 === $c->getDeliveryMode() ? ' (persistent)' : ' (non-persistent)'), $c->getDeliveryMode());
160 // Recent version of the extension already expose private properties
161 if (isset($a["\x00AMQPEnvelope\x00body"])) {
162 $a["\0AMQPEnvelope\0delivery_mode"] = $deliveryMode;
167 if (!($filter & Caster::EXCLUDE_VERBOSE)) {
168 $a += array($prefix.'body' => $c->getBody());
172 $prefix.'delivery_tag' => $c->getDeliveryTag(),
173 $prefix.'is_redelivery' => $c->isRedelivery(),
174 $prefix.'exchange_name' => $c->getExchangeName(),
175 $prefix.'routing_key' => $c->getRoutingKey(),
176 $prefix.'content_type' => $c->getContentType(),
177 $prefix.'content_encoding' => $c->getContentEncoding(),
178 $prefix.'headers' => $c->getHeaders(),
179 $prefix.'delivery_mode' => $deliveryMode,
180 $prefix.'priority' => $c->getPriority(),
181 $prefix.'correlation_id' => $c->getCorrelationId(),
182 $prefix.'reply_to' => $c->getReplyTo(),
183 $prefix.'expiration' => $c->getExpiration(),
184 $prefix.'message_id' => $c->getMessageId(),
185 $prefix.'timestamp' => $c->getTimeStamp(),
186 $prefix.'type' => $c->getType(),
187 $prefix.'user_id' => $c->getUserId(),
188 $prefix.'app_id' => $c->getAppId(),
194 private static function extractFlags($flags)
196 $flagsArray = array();
198 foreach (self::$flags as $value => $name) {
199 if ($flags & $value) {
200 $flagsArray[] = $name;
205 $flagsArray = array('AMQP_NOPARAM');
208 return new ConstStub(implode('|', $flagsArray), $flags);