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
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
|
/*
*
* 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/console/SessionManager.h"
using namespace std;
using namespace qpid::console;
//==============================================================
// Main program
//==============================================================
int main_int(int /*argc*/, char** /*argv*/)
{
//
// Declare connection settings for the messaging broker. The settings default to
// localhost:5672 with user guest (password guest). Refer to the header file
// <qpid/client/ConnectionSettings.h> for full details.
//
qpid::client::ConnectionSettings connSettings;
//
// Declare the (optional) session manager settings. Override the default timeout
// for methods calls to be 2 seconds.
//
SessionManager::Settings smSettings;
smSettings.methodTimeout = 2;
//
// Declare the console session manager. With a null listener argument, it defaults to
// synchronous-only access mode.
//
SessionManager sm(0, smSettings);
//
// Add a broker connection to the session manager.
//
Broker* broker = sm.addBroker(connSettings);
uint32_t count = 5; // The number of echo requests we will send to the broker.
Object::Vector list; // A container for holding objects retrieved from the broker.
//
// Query for a list of 'broker' objects from the Management Database
//
sm.getObjects(list, "broker");
//
// We expect one object (since we are connected to only one broker)
//
if (list.size() == 1) {
Object& brokerObject = *(list.begin());
for (uint32_t iter = 0; iter < count; iter++) {
//
// Declare a container for arguments to be sent with the "echo" method
// that we will invoke on the remote "broker" object.
//
Object::AttributeMap args;
//
// Declare a container for the result of the method invocation.
//
MethodResponse result;
//
// Set the values of the input arguments.
//
args.addUint("sequence", iter);
args.addString("body", "ABCDEFGHIJKLMNOPQRSTUVWXYZ");
cout << "Ping Broker: " << broker->getUrl() << "... ";
cout.flush();
//
// Invoke the method. This is a synchronous operation that will block until
// the method completes and returns a result.
//
brokerObject.invokeMethod("echo", args, result);
//
// result.code is the return code (0 => Success)
// result.text is the return text
// result.arguments is a container (of type Object::AttributeMap) that holds
// the output arguments (if any) from the method.
//
cout << "Result: code=" << result.code << " text=" << result.text;
if (result.code == 0)
cout << " seq=" << result.arguments["sequence"]->asUint();
cout << endl;
if (result.code == 0 && iter < count - 1)
::sleep(1);
}
}
//
// Disconnect the broker from the session manager.
//
sm.delBroker(broker);
return 0;
}
int main(int argc, char** argv)
{
try {
return main_int(argc, argv);
} catch(std::exception& e) {
cout << "Top Level Exception: " << e.what() << endl;
}
}
|
