debug = defined('AMQP_DEBUG') ? AMQP_DEBUG : false; $this->PROTOCOL_CONSTANTS_CLASS = $PROTOCOL_CONSTANTS_CLASS; } /** * @param string $msg */ public function debug_msg($msg) { if ($this->debug) { $this->print_msg($msg); } } /** * @param array $allowed_methods */ public function debug_allowed_methods($allowed_methods) { if ($allowed_methods) { $msg = 'waiting for ' . implode(', ', $allowed_methods); } else { $msg = 'waiting for any method'; } $this->debug_msg($msg); } /** * @param string $method_sig */ public function debug_method_signature1($method_sig) { $this->debug_method_signature('< %s:', $method_sig); } /** * @param string $msg * @param string $method_sig */ public function debug_method_signature($msg, $method_sig) { if ($this->debug) { $protocolClass = $this->PROTOCOL_CONSTANTS_CLASS; $this->debug_msg(sprintf( $msg . ': %s', MiscHelper::methodSig($method_sig), $protocolClass::$GLOBAL_METHOD_NAMES[MiscHelper::methodSig($method_sig)] )); } } /** * @param string $data */ public function debug_hexdump($data) { if ($this->debug) { $this->debug_msg(sprintf( '< [hex]: %s%s', PHP_EOL, MiscHelper::hexdump($data, $htmloutput = false, $uppercase = true, $return = true) )); } } /** * @param int $version_major * @param int $version_minor * @param array $server_properties * @param array $mechanisms * @param array $locales */ public function debug_connection_start($version_major, $version_minor, $server_properties, $mechanisms, $locales) { if ($this->debug) { $this->debug_msg(sprintf( 'Start from server, version: %d.%d, properties: %s, mechanisms: %s, locales: %s', $version_major, $version_minor, MiscHelper::dump_table($server_properties), implode(', ', $mechanisms), implode(', ', $locales) )); } } /** * @param string $s */ protected function print_msg($s) { echo $s . PHP_EOL; } }