33 $this->methodsMap = $methodsMap;
34 parent::__construct($typeProcessor, $methodsMap);
47 foreach (
$configData[QueueConfig::TOPICS] as $topicName => $configDataItem) {
48 $schemaType = $configDataItem[QueueConfig::TOPIC_SCHEMA][QueueConfig::TOPIC_SCHEMA_VALUE];
50 $configDataItem[QueueConfig::TOPIC_RESPONSE_SCHEMA][QueueConfig::TOPIC_SCHEMA_VALUE];
51 $publisherName = $configDataItem[QueueConfig::TOPIC_PUBLISHER];
55 $this->getAvailablePublishers(
$configData, $xmlConfigData),
62 foreach (
$configData[QueueConfig::CONSUMERS] as $consumerName => $configDataItem) {
63 $handlers = isset($configDataItem[QueueConfig::CONSUMER_HANDLERS])
64 ? $configDataItem[QueueConfig::CONSUMER_HANDLERS] : [];
67 $handler[QueueConfig::CONSUMER_CLASS],
68 $handler[QueueConfig::CONSUMER_METHOD],
75 foreach (
$configData[QueueConfig::BINDS] as $configDataItem) {
77 $this->getAvailableTopics(
$configData, $xmlConfigData),
78 $configDataItem[QueueConfig::BIND_TOPIC]
91 private function getAvailablePublishers(
$configData, $xmlConfigData)
93 $envConfigPublishers = isset(
$configData[QueueConfig::PUBLISHERS]) ?
$configData[QueueConfig::PUBLISHERS] : [];
94 $xmlConfigPublishers = isset($xmlConfigData[QueueConfig::PUBLISHERS])
95 ? $xmlConfigData[QueueConfig::PUBLISHERS] : [];
98 array_keys($xmlConfigPublishers),
99 array_keys($envConfigPublishers)
111 private function getAvailableTopics(
$configData, $xmlConfigData)
114 $xmlConfigTopics = isset($xmlConfigData[QueueConfig::TOPICS]) ? $xmlConfigData[QueueConfig::TOPICS] : [];
117 array_keys($xmlConfigTopics),
118 array_keys($envConfigTopics)
validateBindTopic($topics, $topicName)
validateSchemaType($schema, $topicName)
__construct(TypeProcessor $typeProcessor, MethodsMap $methodsMap)
validateResponseSchemaType($responseSchema, $topicName)
validate($configData, array $xmlConfigData=[])
validateTopicPublisher($publishers, $publisherName, $topicName)
catch(\Exception $e) $handler
validateHandlerType($serviceName, $methodName, $consumerName)