src/SAREhub/Client/Amqp/AmqpMessageHeaders.php
<?php
namespace SAREhub\Client\Amqp;
/**
* Enum for all supported AMQP headers sets in Exchange messages.
*/
class AmqpMessageHeaders
{
const CONSUMER_TAG = 'amqp_consumer_tag';
const DELIVERY_TAG = 'amqp_delivery_tag';
const REDELIVERED = 'amqp_redelivered';
const EXCHANGE = 'amqp_exchange';
const ROUTING_KEY = 'amqp_routing_key';
const CONTENT_TYPE = 'amqp_content_type';
const CONTENT_ENCODING = 'amqp_content_encoding';
const REPLY_TO = 'amqp_reply_to';
const CORRELATION_ID = 'amqp_correlation_id';
const PRIORITY = 'amqp_priority';
private static $headers = [
self::CONSUMER_TAG,
self::DELIVERY_TAG,
self::REDELIVERED,
self::EXCHANGE,
self::ROUTING_KEY,
self::CONTENT_TYPE,
self::CONTENT_ENCODING,
self::REPLY_TO,
self::CORRELATION_ID,
self::PRIORITY
];
private static $propertyHeaders = [
self::CONTENT_TYPE,
self::CONTENT_ENCODING,
self::REPLY_TO,
self::CORRELATION_ID,
self::PRIORITY
];
public static function getMessagePropertyName($header)
{
return substr($header, 5);
}
/**
* @return array
*/
public static function getAll()
{
return self::$headers;
}
/**
* @return array
*/
public static function getPropertyHeaders()
{
return self::$propertyHeaders;
}
}