blob: 903f409df81cdf78069831c4ef19c2472f6ad69b (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
|
// Copyright Vespa.ai. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
#pragma once
#include <vespa/messagebus/routing/hop.h>
#include <vespa/messagebus/routing/iroutingpolicy.h>
#include <vespa/documentapi/common.h>
namespace documentapi {
/**
* An AND policy is a routing policy that can be used to write simple routes that split a message between multiple other
* destinations. It can either be configured in a routing config, which will then produce a policy that always selects
* all configured recipients, or it can be configured using the policy parameter (i.e. a string following the name of
* the policy). Note that configured recipients take precedence over recipients configured in the parameter string.
*
* @author Simon Thoresen Hult
* @version $Id$
*/
class ANDPolicy : public mbus::IRoutingPolicy {
public:
/**
* Constructs a new AND policy that requires all recipients to be ok for it to merge their replies to an ok reply.
* I.e. all errors in all child replies are copied into the merged reply.
*
* @param param A string of recipients to select unless recipients have been configured.
*/
ANDPolicy(const string& param);
~ANDPolicy();
void select(mbus::RoutingContext &context) override;
void merge(mbus::RoutingContext &context) override;
private:
ANDPolicy(const ANDPolicy &); // hide
ANDPolicy &operator=(const ANDPolicy &); // hide
private:
std::vector<mbus::Hop> _hops;
};
}
|
