blob: 500166144dfaa37ab787eb0790c2c5d66d01c382 (
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
|
/*
*
* 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 "shared_ptr.h"
#include <sys/Monitor.h>
#ifndef _ResponseHandler_
#define _ResponseHandler_
namespace qpid {
namespace framing {
class AMQMethodBody;
}
namespace client {
/**
* Holds a response from the broker peer for the client.
*/
class ResponseHandler{
typedef shared_ptr<framing::AMQMethodBody> MethodPtr;
bool waiting;
bool shutdownFlag;
MethodPtr response;
sys::Monitor monitor;
public:
ResponseHandler();
~ResponseHandler();
/** Is a response expected? */
bool isWaiting();
/** Provide a response to the waiting thread */
void signalResponse(MethodPtr response);
/** Indicate a message is expected. */
void expect();
/** Wait for a response. */
MethodPtr receive();
/** Wait for a specific response. */
MethodPtr receive(framing::ClassId, framing::MethodId);
/** Template version of receive returns typed pointer. */
template <class BodyType>
shared_ptr<BodyType> receive() {
return shared_polymorphic_downcast<BodyType>(
receive(BodyType::CLASS_ID, BodyType::METHOD_ID));
}
};
}}
#endif
|
