amqp_exchange.c
No OneTemporary
Actions

Authored By

Unknown

Size

32 KB

Referenced Files

None

Subscribers

None

amqp_exchange.c
View Options

	/*
	+----------------------------------------------------------------------+
	\| PHP Version 5 \|
	+----------------------------------------------------------------------+
	\| Copyright (c) 1997-2007 The PHP Group \|
	+----------------------------------------------------------------------+
	\| This source file is subject to version 3.01 of the PHP license, \|
	\| that is bundled with this package in the file LICENSE, and is \|
	\| available through the world-wide-web at the following url: \|
	\| http://www.php.net/license/3_01.txt \|
	\| If you did not receive a copy of the PHP license and are unable to \|
	\| obtain it through the world-wide-web, please send a note to \|
	\| license@php.net so we can mail you a copy immediately. \|
	+----------------------------------------------------------------------+
	\| Author: Alexandre Kalendarev akalend@mail.ru Copyright (c) 2009-2010 \|
	\| Lead: \|
	\| - Pieter de Zwart \|
	\| Maintainers: \|
	\| - Brad Rodriguez \|
	\| - Jonathan Tansavatdi \|
	+----------------------------------------------------------------------+
	*/
	#ifdef HAVE_CONFIG_H
	#include "config.h"
	#endif

	#include "php.h"
	#include "zend_exceptions.h"

	#ifdef PHP_WIN32
	#if PHP_VERSION_ID >= 80000
	#include <stdint.h>
	#else
	#include "win32/php_stdint.h"
	#endif
	#include "win32/signal.h"
	#else
	#include <signal.h>
	#include <stdint.h>
	#endif
	#if HAVE_LIBRABBITMQ_NEW_LAYOUT
	#include <rabbitmq-c/amqp.h>
	#include <rabbitmq-c/framing.h>
	#else
	#include <amqp.h>
	#include <amqp_framing.h>
	#endif

	#ifdef PHP_WIN32
	#include "win32/unistd.h"
	#else
	#include <unistd.h>
	#endif

	#include "php_amqp.h"
	#include "amqp_connection.h"
	#include "amqp_channel.h"
	#include "amqp_exchange.h"
	#include "amqp_type.h"

	zend_class_entry *amqp_exchange_class_entry;
	#define this_ce amqp_exchange_class_entry

	/* {{{ proto AMQPExchange::__construct(AMQPChannel channel);
	create Exchange */
	static PHP_METHOD(amqp_exchange_class, __construct)
	{
	zval rv;

	zval arguments;

	zval *channelObj;
	amqp_channel_resource *channel_resource;

	if (zend_parse_parameters(ZEND_NUM_ARGS(), "O", &channelObj, amqp_channel_class_entry) == FAILURE) {
	RETURN_THROWS();
	}

	ZVAL_UNDEF(&arguments);
	array_init(&arguments);
	zend_update_property(this_ce, PHP_AMQP_COMPAT_OBJ_P(getThis()), ZEND_STRL("arguments"), &arguments);
	zval_ptr_dtor(&arguments);

	channel_resource = PHP_AMQP_GET_CHANNEL_RESOURCE(channelObj);
	PHP_AMQP_VERIFY_CHANNEL_RESOURCE(channel_resource, "Could not create exchange.");

	zend_update_property(this_ce, PHP_AMQP_COMPAT_OBJ_P(getThis()), ZEND_STRL("channel"), channelObj);
	zend_update_property(
	this_ce,
	PHP_AMQP_COMPAT_OBJ_P(getThis()),
	ZEND_STRL("connection"),
	PHP_AMQP_READ_OBJ_PROP(amqp_channel_class_entry, channelObj, "connection")
	);
	}
	/* }}} */


	/* {{{ proto AMQPExchange::getName()
	Get the exchange name */
	static PHP_METHOD(amqp_exchange_class, getName)
	{
	zval rv;

	PHP_AMQP_NOPARAMS()

	if (PHP_AMQP_READ_THIS_PROP_STRLEN("name") > 0) {
	PHP_AMQP_RETURN_THIS_PROP("name");
	} else {
	RETURN_NULL();
	}
	}
	/* }}} */


	/* {{{ proto AMQPExchange::setName(string name)
	Set the exchange name */
	static PHP_METHOD(amqp_exchange_class, setName)
	{
	char *name = NULL;
	size_t name_len = 0;

	if (zend_parse_parameters(ZEND_NUM_ARGS(), "s!", &name, &name_len) == FAILURE) {
	RETURN_THROWS();
	}

	/* Verify that the name is not null and not an empty string */
	if (name_len > 255) {
	zend_throw_exception(
	amqp_exchange_exception_class_entry,
	"Invalid exchange name given, must be less than 255 characters long.",
	0
	);
	return;
	}

	/* Set the exchange name */
	zend_update_property_stringl(this_ce, PHP_AMQP_COMPAT_OBJ_P(getThis()), ZEND_STRL("name"), name, name_len);
	}
	/* }}} */


	/* {{{ proto AMQPExchange::getFlags()
	Get the exchange parameters */
	static PHP_METHOD(amqp_exchange_class, getFlags)
	{
	zval rv;

	zend_long flags = AMQP_NOPARAM;

	PHP_AMQP_NOPARAMS()

	if (PHP_AMQP_READ_THIS_PROP_BOOL("passive")) {
	flags \|= AMQP_PASSIVE;
	}

	if (PHP_AMQP_READ_THIS_PROP_BOOL("durable")) {
	flags \|= AMQP_DURABLE;
	}

	if (PHP_AMQP_READ_THIS_PROP_BOOL("autoDelete")) {
	flags \|= AMQP_AUTODELETE;
	}

	if (PHP_AMQP_READ_THIS_PROP_BOOL("internal")) {
	flags \|= AMQP_INTERNAL;
	}

	RETURN_LONG(flags);
	}
	/* }}} */


	/* {{{ proto AMQPExchange::setFlags(long bitmask)
	Set the exchange parameters */
	static PHP_METHOD(amqp_exchange_class, setFlags)
	{
	zend_long flags = AMQP_NOPARAM;
	bool flags_is_null = 1;

	if (zend_parse_parameters(ZEND_NUM_ARGS(), "l!", &flags, &flags_is_null) == FAILURE) {
	RETURN_THROWS();
	}

	flags = flags & PHP_AMQP_EXCHANGE_FLAGS;

	zend_update_property_bool(this_ce, PHP_AMQP_COMPAT_OBJ_P(getThis()), ZEND_STRL("passive"), IS_PASSIVE(flags));
	zend_update_property_bool(this_ce, PHP_AMQP_COMPAT_OBJ_P(getThis()), ZEND_STRL("durable"), IS_DURABLE(flags));
	zend_update_property_bool(this_ce, PHP_AMQP_COMPAT_OBJ_P(getThis()), ZEND_STRL("autoDelete"), IS_AUTODELETE(flags));
	zend_update_property_bool(this_ce, PHP_AMQP_COMPAT_OBJ_P(getThis()), ZEND_STRL("internal"), IS_INTERNAL(flags));
	}
	/* }}} */


	/* {{{ proto AMQPExchange::getType()
	Get the exchange type */
	static PHP_METHOD(amqp_exchange_class, getType)
	{
	zval rv;

	PHP_AMQP_NOPARAMS()

	if (PHP_AMQP_READ_THIS_PROP_STRLEN("type") > 0) {
	PHP_AMQP_RETURN_THIS_PROP("type");
	} else {
	RETURN_NULL();
	}
	}
	/* }}} */


	/* {{{ proto AMQPExchange::setType(string type)
	Set the exchange type */
	static PHP_METHOD(amqp_exchange_class, setType)
	{
	char *type = NULL;
	size_t type_len = 0;

	if (zend_parse_parameters(ZEND_NUM_ARGS(), "s!", &type, &type_len) == FAILURE) {
	RETURN_THROWS();
	}

	zend_update_property_stringl(this_ce, PHP_AMQP_COMPAT_OBJ_P(getThis()), ZEND_STRL("type"), type, type_len);
	}
	/* }}} */


	/* {{{ proto AMQPExchange::getArgument(string key)
	Get the exchange argument referenced by key */
	static PHP_METHOD(amqp_exchange_class, getArgument)
	{
	zval rv;

	zval *tmp = NULL;

	char *key;
	size_t key_len;

	if (zend_parse_parameters(ZEND_NUM_ARGS(), "s", &key, &key_len) == FAILURE) {
	RETURN_THROWS();
	}

	if ((tmp = zend_hash_str_find(PHP_AMQP_READ_THIS_PROP_ARR("arguments"), key, key_len)) == NULL) {
	zend_throw_exception_ex(amqp_exchange_exception_class_entry, 0, "The argument \"%s\" does not exist", key);
	return;
	}

	RETURN_ZVAL(tmp, 1, 0);
	}
	/* }}} */

	/* {{{ proto AMQPExchange::hasArgument(string key) */
	static PHP_METHOD(amqp_exchange_class, hasArgument)
	{
	zval rv;
	char *key;
	size_t key_len;

	if (zend_parse_parameters(ZEND_NUM_ARGS(), "s", &key, &key_len) == FAILURE) {
	RETURN_THROWS();
	}

	RETURN_BOOL(zend_hash_str_find(PHP_AMQP_READ_THIS_PROP_ARR("arguments"), key, key_len) != NULL);
	}
	/* }}} */

	/* {{{ proto AMQPExchange::getArguments
	Get the exchange arguments */
	static PHP_METHOD(amqp_exchange_class, getArguments)
	{
	zval rv;
	PHP_AMQP_NOPARAMS()
	PHP_AMQP_RETURN_THIS_PROP("arguments");
	}
	/* }}} */


	/* {{{ proto AMQPExchange::setArguments(array args)
	Overwrite all exchange arguments with given args */
	static PHP_METHOD(amqp_exchange_class, setArguments)
	{
	zval *zvalArguments;

	if (zend_parse_parameters(ZEND_NUM_ARGS(), "a/", &zvalArguments) == FAILURE) {
	RETURN_THROWS();
	}

	zend_update_property(this_ce, PHP_AMQP_COMPAT_OBJ_P(getThis()), ZEND_STRL("arguments"), zvalArguments);
	}
	/* }}} */


	/* {{{ proto AMQPExchange::setArgument(key, value) */
	static PHP_METHOD(amqp_exchange_class, setArgument)
	{
	zval rv;

	char *key = NULL;
	size_t key_len = 0;
	zval *value = NULL;

	if (zend_parse_parameters(ZEND_NUM_ARGS(), "sz", &key, &key_len, &value) == FAILURE) {
	RETURN_THROWS();
	}

	switch (Z_TYPE_P(value)) {
	case IS_NULL:
	case IS_TRUE:
	case IS_FALSE:
	case IS_LONG:
	case IS_DOUBLE:
	case IS_STRING:
	zend_hash_str_add(PHP_AMQP_READ_THIS_PROP_ARR("arguments"), key, key_len, value);
	Z_TRY_ADDREF_P(value);
	break;
	default:
	zend_throw_exception(
	amqp_exchange_exception_class_entry,
	"The value parameter must be of type NULL, int, double or string.",
	0
	);
	return;
	}
	}
	/* }}} */


	/* {{{ proto AMQPExchange::removeArgument(key) */
	static PHP_METHOD(amqp_exchange_class, removeArgument)
	{
	zval rv;

	char *key = NULL;
	size_t key_len = 0;

	if (zend_parse_parameters(ZEND_NUM_ARGS(), "s", &key, &key_len) == FAILURE) {
	RETURN_THROWS();
	}

	zend_hash_str_del(PHP_AMQP_READ_THIS_PROP_ARR("arguments"), key, key_len);
	}
	/* }}} */

	/* {{{ proto AMQPExchange::declareExchange();
	declare Exchange
	*/
	static PHP_METHOD(amqp_exchange_class, declareExchange)
	{
	zval rv;

	amqp_channel_resource *channel_resource;
	amqp_table_t *arguments;

	PHP_AMQP_NOPARAMS()

	channel_resource = PHP_AMQP_GET_CHANNEL_RESOURCE(PHP_AMQP_READ_THIS_PROP("channel"));
	PHP_AMQP_VERIFY_CHANNEL_RESOURCE(channel_resource, "Could not declare exchange.");

	/* Check that the exchange has a name */
	if (PHP_AMQP_READ_THIS_PROP_STRLEN("name") < 1) {
	zend_throw_exception(
	amqp_exchange_exception_class_entry,
	"Could not declare exchange. Exchanges must have a name.",
	0
	);
	return;
	}

	/* Check that the exchange has a name */
	if (PHP_AMQP_READ_THIS_PROP_STRLEN("type") < 1) {
	zend_throw_exception(
	amqp_exchange_exception_class_entry,
	"Could not declare exchange. Exchanges must have a type.",
	0
	);
	return;
	}

	arguments = php_amqp_type_convert_zval_to_amqp_table(PHP_AMQP_READ_THIS_PROP("arguments"));

	amqp_exchange_declare(
	channel_resource->connection_resource->connection_state,
	channel_resource->channel_id,
	amqp_cstring_bytes(PHP_AMQP_READ_THIS_PROP_STR("name")),
	amqp_cstring_bytes(PHP_AMQP_READ_THIS_PROP_STR("type")),
	PHP_AMQP_READ_THIS_PROP_BOOL("passive"),
	PHP_AMQP_READ_THIS_PROP_BOOL("durable"),
	PHP_AMQP_READ_THIS_PROP_BOOL("autoDelete"),
	PHP_AMQP_READ_THIS_PROP_BOOL("internal"),
	*arguments
	);

	amqp_rpc_reply_t res = amqp_get_rpc_reply(channel_resource->connection_resource->connection_state);

	php_amqp_type_free_amqp_table(arguments);
	php_amqp_maybe_release_buffers_on_channel(channel_resource->connection_resource, channel_resource);

	if (PHP_AMQP_MAYBE_ERROR(res, channel_resource)) {
	php_amqp_zend_throw_exception_short(res, amqp_exchange_exception_class_entry);
	return;
	}
	}
	/* }}} */


	/* {{{ proto AMQPExchange::delete([string name[, long params]]);
	delete Exchange
	*/
	static PHP_METHOD(amqp_exchange_class, delete)
	{
	zval rv;

	amqp_channel_resource *channel_resource;

	char *name = NULL;
	size_t name_len = 0;
	zend_long flags = AMQP_NOPARAM;
	bool flags_is_null = 1;

	if (zend_parse_parameters(ZEND_NUM_ARGS(), "\|s!l!", &name, &name_len, &flags, &flags_is_null) == FAILURE) {
	RETURN_THROWS();
	}

	channel_resource = PHP_AMQP_GET_CHANNEL_RESOURCE(PHP_AMQP_READ_THIS_PROP("channel"));
	PHP_AMQP_VERIFY_CHANNEL_RESOURCE(channel_resource, "Could not delete exchange.");

	amqp_exchange_delete(
	channel_resource->connection_resource->connection_state,
	channel_resource->channel_id,
	amqp_cstring_bytes(
	name_len ? name
	: PHP_AMQP_READ_THIS_PROP_STRLEN("name") ? PHP_AMQP_READ_THIS_PROP_STR("name")
	: ""
	),
	(AMQP_IFUNUSED & flags) ? 1 : 0
	);

	amqp_rpc_reply_t res = amqp_get_rpc_reply(channel_resource->connection_resource->connection_state);

	if (PHP_AMQP_MAYBE_ERROR(res, channel_resource)) {
	php_amqp_zend_throw_exception_short(res, amqp_exchange_exception_class_entry);
	php_amqp_maybe_release_buffers_on_channel(channel_resource->connection_resource, channel_resource);
	return;
	}

	php_amqp_maybe_release_buffers_on_channel(channel_resource->connection_resource, channel_resource);
	}
	/* }}} */


	/* {{{ proto AMQPExchange::publish(string msg, [string key, [int flags, [array headers]]]);
	publish into Exchange
	*/
	static PHP_METHOD(amqp_exchange_class, publish)
	{
	zval rv;

	zval *ini_arr = NULL;
	zval *tmp = NULL;

	amqp_channel_resource *channel_resource;

	char *key_name = NULL;
	size_t key_len = 0;
	char *msg = NULL;
	size_t msg_len = 0;
	zend_long flags = AMQP_NOPARAM;
	bool flags_is_null = 1;

	#ifndef PHP_WIN32
	/* Storage for previous signal handler during SIGPIPE override */
	void *old_handler;
	#endif

	amqp_basic_properties_t props;

	if (zend_parse_parameters(
	ZEND_NUM_ARGS(),
	"s\|s!l!a/",
	&msg,
	&msg_len,
	&key_name,
	&key_len,
	&flags,
	&flags_is_null,
	&ini_arr
	) == FAILURE) {
	RETURN_THROWS();
	}

	/* By default (and for BC) content type is text/plain (may be skipped at all, then set props._flags to 0) */
	props.content_type = amqp_cstring_bytes("text/plain");
	props._flags = AMQP_BASIC_CONTENT_TYPE_FLAG;

	props.headers.entries = 0;

	{
	if (ini_arr && (tmp = zend_hash_str_find(HASH_OF(ini_arr), ZEND_STRL("content_type"))) != NULL) {
	SEPARATE_ZVAL(tmp);
	convert_to_string(tmp);

	if (Z_STRLEN_P(tmp) > 0) {
	props.content_type = amqp_cstring_bytes(Z_STRVAL_P(tmp));
	props._flags \|= AMQP_BASIC_CONTENT_TYPE_FLAG;
	}
	}

	if (ini_arr && (tmp = zend_hash_str_find(HASH_OF(ini_arr), ZEND_STRL("content_encoding"))) != NULL) {
	SEPARATE_ZVAL(tmp);
	convert_to_string(tmp);

	if (Z_STRLEN_P(tmp) > 0) {
	props.content_encoding = amqp_cstring_bytes(Z_STRVAL_P(tmp));
	props._flags \|= AMQP_BASIC_CONTENT_ENCODING_FLAG;
	}
	}

	if (ini_arr && (tmp = zend_hash_str_find(HASH_OF(ini_arr), ZEND_STRL("message_id"))) != NULL) {
	SEPARATE_ZVAL(tmp);
	convert_to_string(tmp);

	if (Z_STRLEN_P(tmp) > 0) {
	props.message_id = amqp_cstring_bytes(Z_STRVAL_P(tmp));
	props._flags \|= AMQP_BASIC_MESSAGE_ID_FLAG;
	}
	}

	if (ini_arr && (tmp = zend_hash_str_find(HASH_OF(ini_arr), ZEND_STRL("user_id"))) != NULL) {
	SEPARATE_ZVAL(tmp);
	convert_to_string(tmp);

	if (Z_STRLEN_P(tmp) > 0) {
	props.user_id = amqp_cstring_bytes(Z_STRVAL_P(tmp));
	props._flags \|= AMQP_BASIC_USER_ID_FLAG;
	}
	}

	if (ini_arr && (tmp = zend_hash_str_find(HASH_OF(ini_arr), ZEND_STRL("app_id"))) != NULL) {
	SEPARATE_ZVAL(tmp);
	convert_to_string(tmp);

	if (Z_STRLEN_P(tmp) > 0) {
	props.app_id = amqp_cstring_bytes(Z_STRVAL_P(tmp));
	props._flags \|= AMQP_BASIC_APP_ID_FLAG;
	}
	}

	if (ini_arr && (tmp = zend_hash_str_find(HASH_OF(ini_arr), ZEND_STRL("delivery_mode"))) != NULL) {
	SEPARATE_ZVAL(tmp);
	convert_to_long(tmp);

	props.delivery_mode = (uint8_t) Z_LVAL_P(tmp);
	props._flags \|= AMQP_BASIC_DELIVERY_MODE_FLAG;
	}

	if (ini_arr && (tmp = zend_hash_str_find(HASH_OF(ini_arr), ZEND_STRL("priority"))) != NULL) {
	SEPARATE_ZVAL(tmp);
	convert_to_long(tmp);

	props.priority = (uint8_t) Z_LVAL_P(tmp);
	props._flags \|= AMQP_BASIC_PRIORITY_FLAG;
	}

	if (ini_arr && (tmp = zend_hash_str_find(HASH_OF(ini_arr), ZEND_STRL("timestamp"))) != NULL) {
	SEPARATE_ZVAL(tmp);
	convert_to_long(tmp);

	props.timestamp = (uint64_t) Z_LVAL_P(tmp);
	props._flags \|= AMQP_BASIC_TIMESTAMP_FLAG;
	}

	if (ini_arr && (tmp = zend_hash_str_find(HASH_OF(ini_arr), ZEND_STRL("expiration"))) != NULL) {
	SEPARATE_ZVAL(tmp);
	convert_to_string(tmp);

	if (Z_STRLEN_P(tmp) > 0) {
	props.expiration = amqp_cstring_bytes(Z_STRVAL_P(tmp));
	props._flags \|= AMQP_BASIC_EXPIRATION_FLAG;
	}
	}

	if (ini_arr && (tmp = zend_hash_str_find(HASH_OF(ini_arr), ZEND_STRL("type"))) != NULL) {
	SEPARATE_ZVAL(tmp);
	convert_to_string(tmp);

	if (Z_STRLEN_P(tmp) > 0) {
	props.type = amqp_cstring_bytes(Z_STRVAL_P(tmp));
	props._flags \|= AMQP_BASIC_TYPE_FLAG;
	}
	}

	if (ini_arr && (tmp = zend_hash_str_find(HASH_OF(ini_arr), ZEND_STRL("reply_to"))) != NULL) {
	SEPARATE_ZVAL(tmp);
	convert_to_string(tmp);

	if (Z_STRLEN_P(tmp) > 0) {
	props.reply_to = amqp_cstring_bytes(Z_STRVAL_P(tmp));
	props._flags \|= AMQP_BASIC_REPLY_TO_FLAG;
	}
	}
	if (ini_arr && (tmp = zend_hash_str_find(HASH_OF(ini_arr), ZEND_STRL("correlation_id"))) != NULL) {
	SEPARATE_ZVAL(tmp);
	convert_to_string(tmp);

	if (Z_STRLEN_P(tmp) > 0) {
	props.correlation_id = amqp_cstring_bytes(Z_STRVAL_P(tmp));
	props._flags \|= AMQP_BASIC_CORRELATION_ID_FLAG;
	}
	}
	}

	amqp_table_t *headers = NULL;

	if (ini_arr && (tmp = zend_hash_str_find(HASH_OF(ini_arr), ZEND_STRL("headers"))) != NULL) {
	SEPARATE_ZVAL(tmp);
	convert_to_array(tmp);

	headers = php_amqp_type_convert_zval_to_amqp_table(tmp);

	props._flags \|= AMQP_BASIC_HEADERS_FLAG;
	props.headers = *headers;
	}

	channel_resource = PHP_AMQP_GET_CHANNEL_RESOURCE(PHP_AMQP_READ_THIS_PROP("channel"));
	PHP_AMQP_VERIFY_CHANNEL_RESOURCE(channel_resource, "Could not publish to exchange.");

	#ifndef PHP_WIN32
	/* Start ignoring SIGPIPE */
	old_handler = signal(SIGPIPE, SIG_IGN);
	#endif

	zval *exchange_name = PHP_AMQP_READ_THIS_PROP("name");

	/* NOTE: basic.publish is asynchronous and thus will not indicate failure if something goes wrong on the broker */
	int status = amqp_basic_publish(
	channel_resource->connection_resource->connection_state,
	channel_resource->channel_id,
	(Z_TYPE_P(exchange_name) == IS_STRING && Z_STRLEN_P(exchange_name) > 0
	? amqp_cstring_bytes(Z_STRVAL_P(exchange_name))
	: amqp_empty_bytes), /* exchange */
	(key_len > 0 ? amqp_cstring_bytes(key_name) : amqp_empty_bytes), /* routing key */
	(AMQP_MANDATORY & flags) ? 1 : 0, /* mandatory */
	(AMQP_IMMEDIATE & flags) ? 1 : 0, /* immediate */
	&props,
	php_amqp_type_char_to_amqp_long(msg, msg_len) /* message body */
	);

	if (headers) {
	php_amqp_type_free_amqp_table(headers);
	}

	#ifndef PHP_WIN32
	/* End ignoring of SIGPIPEs */
	signal(SIGPIPE, old_handler);
	#endif

	if (status != AMQP_STATUS_OK) {
	/* Emulate library error */
	amqp_rpc_reply_t res;
	res.reply_type = AMQP_RESPONSE_LIBRARY_EXCEPTION;
	res.library_error = status;

	php_amqp_error(res, &PHP_AMQP_G(error_message), channel_resource->connection_resource, channel_resource);

	php_amqp_zend_throw_exception(
	res,
	amqp_exchange_exception_class_entry,
	PHP_AMQP_G(error_message),
	PHP_AMQP_G(error_code)
	);
	php_amqp_maybe_release_buffers_on_channel(channel_resource->connection_resource, channel_resource);
	return;
	}
	}
	/* }}} */


	/* {{{ proto int exchange::bind(string srcExchangeName[, string routingKey, array arguments]);
	bind exchange to exchange by routing key
	*/
	static PHP_METHOD(amqp_exchange_class, bind)
	{
	zval rv;

	zval *zvalArguments = NULL;

	amqp_channel_resource *channel_resource;

	char *src_name;
	size_t src_name_len = 0;
	char *keyname = NULL;
	size_t keyname_len = 0;

	amqp_table_t *arguments = NULL;

	if (zend_parse_parameters(
	ZEND_NUM_ARGS(),
	"s\|s!a",
	&src_name,
	&src_name_len,
	&keyname,
	&keyname_len,
	&zvalArguments
	) == FAILURE) {
	RETURN_THROWS();
	}

	channel_resource = PHP_AMQP_GET_CHANNEL_RESOURCE(PHP_AMQP_READ_THIS_PROP("channel"));
	PHP_AMQP_VERIFY_CHANNEL_RESOURCE(channel_resource, "Could not bind to exchange.");

	if (zvalArguments) {
	arguments = php_amqp_type_convert_zval_to_amqp_table(zvalArguments);
	}

	amqp_exchange_bind(
	channel_resource->connection_resource->connection_state,
	channel_resource->channel_id,
	amqp_cstring_bytes(PHP_AMQP_READ_THIS_PROP_STRLEN("name") ? PHP_AMQP_READ_THIS_PROP_STR("name") : ""),
	(src_name_len > 0 ? amqp_cstring_bytes(src_name) : amqp_empty_bytes),
	(keyname != NULL && keyname_len > 0 ? amqp_cstring_bytes(keyname) : amqp_empty_bytes),
	(arguments ? *arguments : amqp_empty_table)
	);

	if (arguments) {
	php_amqp_type_free_amqp_table(arguments);
	}

	amqp_rpc_reply_t res = amqp_get_rpc_reply(channel_resource->connection_resource->connection_state);

	if (PHP_AMQP_MAYBE_ERROR(res, channel_resource)) {
	php_amqp_zend_throw_exception_short(res, amqp_exchange_exception_class_entry);
	php_amqp_maybe_release_buffers_on_channel(channel_resource->connection_resource, channel_resource);
	return;
	}

	php_amqp_maybe_release_buffers_on_channel(channel_resource->connection_resource, channel_resource);
	}
	/* }}} */

	/* {{{ proto int exchange::unbind(string srcExchangeName[, string routingKey, array arguments]);
	remove exchange to exchange binding by routing key
	*/
	static PHP_METHOD(amqp_exchange_class, unbind)
	{
	zval rv;

	zval *zvalArguments = NULL;

	amqp_channel_resource *channel_resource;

	char *src_name;
	size_t src_name_len = 0;
	char *keyname = NULL;
	size_t keyname_len = 0;

	amqp_table_t *arguments = NULL;

	if (zend_parse_parameters(
	ZEND_NUM_ARGS(),
	"s\|s!a",
	&src_name,
	&src_name_len,
	&keyname,
	&keyname_len,
	&zvalArguments
	) == FAILURE) {
	RETURN_THROWS();
	}

	channel_resource = PHP_AMQP_GET_CHANNEL_RESOURCE(PHP_AMQP_READ_THIS_PROP("channel"));
	PHP_AMQP_VERIFY_CHANNEL_RESOURCE(channel_resource, "Could not unbind from exchange.");

	if (zvalArguments) {
	arguments = php_amqp_type_convert_zval_to_amqp_table(zvalArguments);
	}

	amqp_exchange_unbind(
	channel_resource->connection_resource->connection_state,
	channel_resource->channel_id,
	amqp_cstring_bytes(PHP_AMQP_READ_THIS_PROP_STRLEN("name") ? PHP_AMQP_READ_THIS_PROP_STR("name") : ""),
	(src_name_len > 0 ? amqp_cstring_bytes(src_name) : amqp_empty_bytes),
	(keyname != NULL && keyname_len > 0 ? amqp_cstring_bytes(keyname) : amqp_empty_bytes),
	(arguments ? *arguments : amqp_empty_table)
	);

	if (arguments) {
	php_amqp_type_free_amqp_table(arguments);
	}

	amqp_rpc_reply_t res = amqp_get_rpc_reply(channel_resource->connection_resource->connection_state);

	if (PHP_AMQP_MAYBE_ERROR(res, channel_resource)) {
	php_amqp_zend_throw_exception_short(res, amqp_exchange_exception_class_entry);
	php_amqp_maybe_release_buffers_on_channel(channel_resource->connection_resource, channel_resource);
	return;
	}

	php_amqp_maybe_release_buffers_on_channel(channel_resource->connection_resource, channel_resource);
	}
	/* }}} */

	/* {{{ proto AMQPExchange::getChannel()
	Get the AMQPChannel object in use */
	static PHP_METHOD(amqp_exchange_class, getChannel)
	{
	zval rv;
	PHP_AMQP_NOPARAMS()
	PHP_AMQP_RETURN_THIS_PROP("channel");
	}
	/* }}} */

	/* {{{ proto AMQPExchange::getConnection()
	Get the AMQPConnection object in use */
	static PHP_METHOD(amqp_exchange_class, getConnection)
	{
	zval rv;
	PHP_AMQP_NOPARAMS()
	PHP_AMQP_RETURN_THIS_PROP("connection");
	}
	/* }}} */

	/* amqp_exchange ARG_INFO definition */
	ZEND_BEGIN_ARG_INFO_EX(arginfo_amqp_exchange_class__construct, ZEND_SEND_BY_VAL, ZEND_RETURN_VALUE, 1)
	ZEND_ARG_OBJ_INFO(0, channel, AMQPChannel, 0)
	ZEND_END_ARG_INFO()

	ZEND_BEGIN_ARG_WITH_RETURN_TYPE_INFO_EX(arginfo_amqp_exchange_class_getName, ZEND_SEND_BY_VAL, 0, IS_STRING, 1)
	ZEND_END_ARG_INFO()

	ZEND_BEGIN_ARG_WITH_RETURN_TYPE_INFO_EX(arginfo_amqp_exchange_class_setName, ZEND_SEND_BY_VAL, 1, IS_VOID, 0)
	ZEND_ARG_TYPE_INFO(0, exchangeName, IS_STRING, 1)
	ZEND_END_ARG_INFO()

	ZEND_BEGIN_ARG_WITH_RETURN_TYPE_INFO_EX(arginfo_amqp_exchange_class_getFlags, ZEND_SEND_BY_VAL, 0, IS_LONG, 0)
	ZEND_END_ARG_INFO()

	ZEND_BEGIN_ARG_WITH_RETURN_TYPE_INFO_EX(arginfo_amqp_exchange_class_setFlags, ZEND_SEND_BY_VAL, 1, IS_VOID, 0)
	ZEND_ARG_TYPE_INFO(0, flags, IS_LONG, 1)
	ZEND_END_ARG_INFO()

	ZEND_BEGIN_ARG_WITH_RETURN_TYPE_INFO_EX(arginfo_amqp_exchange_class_getType, ZEND_SEND_BY_VAL, 0, IS_STRING, 1)
	ZEND_END_ARG_INFO()

	ZEND_BEGIN_ARG_WITH_RETURN_TYPE_INFO_EX(arginfo_amqp_exchange_class_setType, ZEND_SEND_BY_VAL, 1, IS_VOID, 0)
	ZEND_ARG_TYPE_INFO(0, exchangeType, IS_STRING, 1)
	ZEND_END_ARG_INFO()

	ZEND_BEGIN_ARG_INFO_EX(arginfo_amqp_exchange_class_getArgument, ZEND_SEND_BY_VAL, ZEND_RETURN_VALUE, 1)
	ZEND_ARG_TYPE_INFO(0, argumentName, IS_STRING, 0)
	ZEND_END_ARG_INFO()

	ZEND_BEGIN_ARG_WITH_RETURN_TYPE_INFO_EX(arginfo_amqp_exchange_class_hasArgument, ZEND_SEND_BY_VAL, 1, _IS_BOOL, 0)
	ZEND_ARG_TYPE_INFO(0, argumentName, IS_STRING, 0)
	ZEND_END_ARG_INFO()

	ZEND_BEGIN_ARG_WITH_RETURN_TYPE_INFO_EX(arginfo_amqp_exchange_class_getArguments, ZEND_SEND_BY_VAL, 0, IS_ARRAY, 0)
	ZEND_END_ARG_INFO()

	ZEND_BEGIN_ARG_WITH_RETURN_TYPE_INFO_EX(arginfo_amqp_exchange_class_setArgument, ZEND_SEND_BY_VAL, 2, IS_VOID, 0)
	ZEND_ARG_TYPE_INFO(0, argumentName, IS_STRING, 0)
	ZEND_ARG_INFO(0, argumentValue)
	ZEND_END_ARG_INFO()

	ZEND_BEGIN_ARG_WITH_RETURN_TYPE_INFO_EX(arginfo_amqp_exchange_class_removeArgument, ZEND_SEND_BY_VAL, 1, IS_VOID, 0)
	ZEND_ARG_TYPE_INFO(0, argumentName, IS_STRING, 0)
	ZEND_END_ARG_INFO()

	ZEND_BEGIN_ARG_WITH_RETURN_TYPE_INFO_EX(arginfo_amqp_exchange_class_setArguments, ZEND_SEND_BY_VAL, 1, IS_VOID, 0)
	ZEND_ARG_ARRAY_INFO(0, arguments, 0)
	ZEND_END_ARG_INFO()

	ZEND_BEGIN_ARG_WITH_RETURN_TYPE_INFO_EX(arginfo_amqp_exchange_class_declareExchange, ZEND_SEND_BY_VAL, 0, IS_VOID, 0)
	ZEND_END_ARG_INFO()

	ZEND_BEGIN_ARG_WITH_RETURN_TYPE_INFO_EX(arginfo_amqp_exchange_class_bind, ZEND_RETURN_VALUE, 1, IS_VOID, 0)
	ZEND_ARG_TYPE_INFO(0, exchangeName, IS_STRING, 0)
	ZEND_ARG_TYPE_INFO_WITH_DEFAULT_VALUE(0, routingKey, IS_STRING, 1, "null")
	ZEND_ARG_TYPE_INFO_WITH_DEFAULT_VALUE(0, arguments, IS_ARRAY, 0, "[]")
	ZEND_END_ARG_INFO()

	ZEND_BEGIN_ARG_WITH_RETURN_TYPE_INFO_EX(arginfo_amqp_exchange_class_unbind, ZEND_RETURN_VALUE, 1, IS_VOID, 0)
	ZEND_ARG_TYPE_INFO(0, exchangeName, IS_STRING, 0)
	ZEND_ARG_TYPE_INFO_WITH_DEFAULT_VALUE(0, routingKey, IS_STRING, 1, "null")
	ZEND_ARG_TYPE_INFO_WITH_DEFAULT_VALUE(0, arguments, IS_ARRAY, 0, "[]")
	ZEND_END_ARG_INFO()

	ZEND_BEGIN_ARG_WITH_RETURN_TYPE_INFO_EX(arginfo_amqp_exchange_class_delete, ZEND_RETURN_VALUE, 0, IS_VOID, 0)
	ZEND_ARG_TYPE_INFO_WITH_DEFAULT_VALUE(0, exchangeName, IS_STRING, 1, "null")
	ZEND_ARG_TYPE_INFO_WITH_DEFAULT_VALUE(0, flags, IS_LONG, 1, "null")
	ZEND_END_ARG_INFO()

	ZEND_BEGIN_ARG_WITH_RETURN_TYPE_INFO_EX(arginfo_amqp_exchange_class_publish, ZEND_RETURN_VALUE, 1, IS_VOID, 0)
	ZEND_ARG_TYPE_INFO(0, message, IS_STRING, 0)
	ZEND_ARG_TYPE_INFO_WITH_DEFAULT_VALUE(0, routingKey, IS_STRING, 1, "null")
	ZEND_ARG_TYPE_INFO_WITH_DEFAULT_VALUE(0, flags, IS_LONG, 1, "null")
	ZEND_ARG_TYPE_INFO_WITH_DEFAULT_VALUE(0, headers, IS_ARRAY, 0, "[]")
	ZEND_END_ARG_INFO()

	ZEND_BEGIN_ARG_WITH_RETURN_OBJ_INFO(arginfo_amqp_exchange_class_getChannel, AMQPChannel, 0)
	ZEND_END_ARG_INFO()

	ZEND_BEGIN_ARG_WITH_RETURN_OBJ_INFO(arginfo_amqp_exchange_class_getConnection, AMQPConnection, 0)
	ZEND_END_ARG_INFO()

	zend_function_entry amqp_exchange_class_functions[] = {
	PHP_ME(amqp_exchange_class, __construct, arginfo_amqp_exchange_class__construct, ZEND_ACC_PUBLIC)

	PHP_ME(amqp_exchange_class, getName, arginfo_amqp_exchange_class_getName, ZEND_ACC_PUBLIC)
	PHP_ME(amqp_exchange_class, setName, arginfo_amqp_exchange_class_setName, ZEND_ACC_PUBLIC)

	PHP_ME(amqp_exchange_class, getFlags, arginfo_amqp_exchange_class_getFlags, ZEND_ACC_PUBLIC)
	PHP_ME(amqp_exchange_class, setFlags, arginfo_amqp_exchange_class_setFlags, ZEND_ACC_PUBLIC)

	PHP_ME(amqp_exchange_class, getType, arginfo_amqp_exchange_class_getType, ZEND_ACC_PUBLIC)
	PHP_ME(amqp_exchange_class, setType, arginfo_amqp_exchange_class_setType, ZEND_ACC_PUBLIC)

	PHP_ME(amqp_exchange_class, getArgument, arginfo_amqp_exchange_class_getArgument, ZEND_ACC_PUBLIC)
	PHP_ME(amqp_exchange_class, getArguments, arginfo_amqp_exchange_class_getArguments, ZEND_ACC_PUBLIC)
	PHP_ME(amqp_exchange_class, setArgument, arginfo_amqp_exchange_class_setArgument, ZEND_ACC_PUBLIC)
	PHP_ME(amqp_exchange_class, removeArgument, arginfo_amqp_exchange_class_removeArgument, ZEND_ACC_PUBLIC)
	PHP_ME(amqp_exchange_class, setArguments, arginfo_amqp_exchange_class_setArguments, ZEND_ACC_PUBLIC)
	PHP_ME(amqp_exchange_class, hasArgument, arginfo_amqp_exchange_class_hasArgument, ZEND_ACC_PUBLIC)

	PHP_ME(amqp_exchange_class, declareExchange, arginfo_amqp_exchange_class_declareExchange, ZEND_ACC_PUBLIC)
	PHP_MALIAS(amqp_exchange_class, declare, declareExchange, arginfo_amqp_exchange_class_declareExchange, ZEND_ACC_PUBLIC)

	PHP_ME(amqp_exchange_class, bind, arginfo_amqp_exchange_class_bind, ZEND_ACC_PUBLIC)
	PHP_ME(amqp_exchange_class, unbind, arginfo_amqp_exchange_class_unbind, ZEND_ACC_PUBLIC)
	PHP_ME(amqp_exchange_class, delete, arginfo_amqp_exchange_class_delete, ZEND_ACC_PUBLIC)
	PHP_ME(amqp_exchange_class, publish, arginfo_amqp_exchange_class_publish, ZEND_ACC_PUBLIC)

	PHP_ME(amqp_exchange_class, getChannel, arginfo_amqp_exchange_class_getChannel, ZEND_ACC_PUBLIC)
	PHP_ME(amqp_exchange_class, getConnection, arginfo_amqp_exchange_class_getConnection, ZEND_ACC_PUBLIC)

	{NULL, NULL, NULL}
	};

	PHP_MINIT_FUNCTION(amqp_exchange)
	{
	zend_class_entry ce;

	INIT_CLASS_ENTRY(ce, "AMQPExchange", amqp_exchange_class_functions);
	this_ce = zend_register_internal_class(&ce);

	PHP_AMQP_DECLARE_TYPED_PROPERTY_OBJ(this_ce, "connection", ZEND_ACC_PRIVATE, AMQPConnection, 0);
	PHP_AMQP_DECLARE_TYPED_PROPERTY_OBJ(this_ce, "channel", ZEND_ACC_PRIVATE, AMQPChannel, 0);
	PHP_AMQP_DECLARE_TYPED_PROPERTY(this_ce, "name", ZEND_ACC_PRIVATE, IS_STRING, 1);
	PHP_AMQP_DECLARE_TYPED_PROPERTY(this_ce, "type", ZEND_ACC_PRIVATE, IS_STRING, 1);
	PHP_AMQP_DECLARE_TYPED_PROPERTY_WITH_DEFAULT(this_ce, "passive", ZEND_ACC_PRIVATE, _IS_BOOL, 0, ZVAL_FALSE);
	PHP_AMQP_DECLARE_TYPED_PROPERTY_WITH_DEFAULT(this_ce, "durable", ZEND_ACC_PRIVATE, _IS_BOOL, 0, ZVAL_FALSE);
	PHP_AMQP_DECLARE_TYPED_PROPERTY_WITH_DEFAULT(this_ce, "autoDelete", ZEND_ACC_PRIVATE, _IS_BOOL, 0, ZVAL_FALSE);
	PHP_AMQP_DECLARE_TYPED_PROPERTY_WITH_DEFAULT(this_ce, "internal", ZEND_ACC_PRIVATE, _IS_BOOL, 0, ZVAL_FALSE);
	#if PHP_VERSION_ID >= 80000
	PHP_AMQP_DECLARE_TYPED_PROPERTY_WITH_DEFAULT(this_ce, "arguments", ZEND_ACC_PRIVATE, IS_ARRAY, 0, ZVAL_EMPTY_ARRAY);
	#else
	PHP_AMQP_DECLARE_TYPED_PROPERTY_WITH_DEFAULT(this_ce, "arguments", ZEND_ACC_PRIVATE, IS_ARRAY, 0, ZVAL_NULL);
	#endif

	return SUCCESS;
	}

File Metadata

Mime Type: text/x-c
Expires: Sun, Nov 15, 6:48 AM (1 d, 23 h)
Storage Engine: blob
Storage Format: Raw Data
Storage Handle: 132232
Default Alt Text: amqp_exchange.c (32 KB)

amqp_exchange.cNo OneTemporaryActions

amqp_exchange.cView Options

File Metadata

Event Timeline

amqp_exchange.c
No OneTemporary
Actions

amqp_exchange.c
View Options