summaryrefslogtreecommitdiffstats
path: root/documentapi
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2017-09-29 16:36:59 +0200
committerHenning Baldersheim <balder@yahoo-inc.com>2017-09-29 16:44:36 +0200
commitdb0b5402657e33a7737ad7490473a7fd12850de7 (patch)
tree783cb5b9b3d22f32d6b3574be00c0c4356476caf /documentapi
parentf4f8d93f3be2a2b91ba0db4034db2a1811f438fb (diff)
Protocols tells if they require sequencing of messages. If not messages might be reordered for efficiency.
Diffstat (limited to 'documentapi')
-rw-r--r--documentapi/src/vespa/documentapi/messagebus/documentprotocol.h7
1 files changed, 3 insertions, 4 deletions
diff --git a/documentapi/src/vespa/documentapi/messagebus/documentprotocol.h b/documentapi/src/vespa/documentapi/messagebus/documentprotocol.h
index b2d1456fd98..c3417d85197 100644
--- a/documentapi/src/vespa/documentapi/messagebus/documentprotocol.h
+++ b/documentapi/src/vespa/documentapi/messagebus/documentprotocol.h
@@ -24,7 +24,7 @@ class SystemState;
class IRoutingPolicyFactory;
class IRoutableFactory;
-class DocumentProtocol : public mbus::IProtocol {
+class DocumentProtocol final : public mbus::IProtocol {
private:
std::unique_ptr<RoutingPolicyRepository> _routingPolicyRepository;
std::unique_ptr<RoutableRepository> _routableRepository;
@@ -264,8 +264,7 @@ public:
* @param buf A byte buffer that contains a serialized routable.
* @return The deserialized routable.
*/
- mbus::Routable::UP deserialize(uint32_t type,
- document::ByteBuffer &buf) const;
+ mbus::Routable::UP deserialize(uint32_t type, document::ByteBuffer &buf) const;
/**
* This is a convenient entry to the {@link #merge(RoutingContext,std::set)} method by way of a routing
@@ -307,7 +306,7 @@ public:
mbus::IRoutingPolicy::UP createPolicy(const mbus::string &name, const mbus::string &param) const override;
mbus::Blob encode(const vespalib::Version &version, const mbus::Routable &routable) const override;
mbus::Routable::UP decode(const vespalib::Version &version, mbus::BlobRef data) const override;
+ bool requireSequencing() const override { return false; }
};
}
-