summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/framing/Invoker.h
blob: 4f1cf7c331143c49f221032428fd8cb673e2beb2 (plain)
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
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
#ifndef QPID_FRAMING_INVOKER_H
#define QPID_FRAMING_INVOKER_H

/*
 *
 * Licensed to the Apache Software Foundation (ASF) under one
 * or more contributor license agreements.  See the NOTICE file
 * distributed with this work for additional information
 * regarding copyright ownership.  The ASF licenses this file
 * to you under the Apache License, Version 2.0 (the
 * "License"); you may not use this file except in compliance
 * with the License.  You may obtain a copy of the License at
 * 
 *   http://www.apache.org/licenses/LICENSE-2.0
 * 
 * Unless required by applicable law or agreed to in writing,
 * software distributed under the License is distributed on an
 * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
 * KIND, either express or implied.  See the License for the
 * specific language governing permissions and limitations
 * under the License.
 *
 */
#include "qpid/framing/AMQMethodBody.h"
#include "qpid/framing/MethodBodyDefaultVisitor.h"
#include "qpid/framing/StructHelper.h"

#include <boost/optional.hpp>

namespace qpid {
namespace framing {

class AMQMethodBody;

/**
 * Base class for invoker visitors.
 */ 
class Invoker: public MethodBodyDefaultVisitor, protected StructHelper
{
  public:
    struct Result {
      public:
        Result() : handled(false) {}
        const std::string& getResult() const { return result; }
        bool hasResult() const { return !result.empty(); }
        bool wasHandled() const { return handled; }
        operator bool() const { return handled; }

        std::string result;
        bool handled;
    };

    void defaultVisit(const AMQMethodBody&) {}
    Result getResult() const { return result; }

  protected:
    Result result;
};

/**
 * Invoke an invocable object.
 * Invocable classes must provide a nested type Invoker.
 */
template <class Invocable>
Invoker::Result invoke(Invocable& target, const AMQMethodBody& body) {
    typename Invocable::Invoker invoker(target);
    body.accept(invoker);
    return invoker.getResult();
}

/**
 * Invoke an invocable object.
 * Invocable classes must provide a nested type Invoker.
 */
template <class Invocable>
Invoker::Result invoke(Invocable& target, const AMQBody& body) {
    typename Invocable::Invoker invoker(target);
    const AMQMethodBody* method = body.getMethod();
    if (method)
        method->accept(invoker);
    return invoker.getResult();
}

}} // namespace qpid::framing

#endif  /*!QPID_FRAMING_INVOKER_H*/