summaryrefslogtreecommitdiff
path: root/qpid/cpp/src/tests/replaying_sender.cpp
diff options
context:
space:
mode:
authorAndrew Stitcher <astitcher@apache.org>2009-09-09 19:46:56 +0000
committerAndrew Stitcher <astitcher@apache.org>2009-09-09 19:46:56 +0000
commit9259c46ecb8c5f3e98441080a26914bdea59bffe (patch)
tree67c894abe2f15175c1af01c832300250d3243611 /qpid/cpp/src/tests/replaying_sender.cpp
parent52ab3087da04c4faf8908690c3a07b4e99237c32 (diff)
downloadqpid-python-9259c46ecb8c5f3e98441080a26914bdea59bffe.tar.gz
Tidied up namespace usage
Miscelleneous whitespace fixes git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@813094 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/src/tests/replaying_sender.cpp')
-rw-r--r--qpid/cpp/src/tests/replaying_sender.cpp39
1 files changed, 23 insertions, 16 deletions
diff --git a/qpid/cpp/src/tests/replaying_sender.cpp b/qpid/cpp/src/tests/replaying_sender.cpp
index 3ee69eec14..bfb4b042b6 100644
--- a/qpid/cpp/src/tests/replaying_sender.cpp
+++ b/qpid/cpp/src/tests/replaying_sender.cpp
@@ -7,9 +7,9 @@
* 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
@@ -35,12 +35,15 @@ using namespace qpid::framing;
using namespace std;
+namespace qpid {
+namespace tests {
+
class Sender : public FailoverManager::Command
{
public:
Sender(const std::string& queue, uint count, uint reportFreq);
void execute(AsyncSession& session, bool isRetry);
- uint getSent();
+ uint getSent();
void setVerbosity ( int v ) { verbosity = v; }
void setPersistence ( int p ) { persistence = p; }
@@ -51,7 +54,7 @@ class Sender : public FailoverManager::Command
uint sent;
const uint reportFrequency;
Message message;
-
+
int verbosity;
int persistence;
};
@@ -93,7 +96,11 @@ uint Sender::getSent()
return sent;
}
-int main(int argc, char ** argv)
+}} // namespace qpid::tests
+
+using namespace qpid::tests;
+
+int main(int argc, char ** argv)
{
ConnectionSettings settings;
@@ -118,23 +125,23 @@ int main(int argc, char ** argv)
connection.execute ( sender );
if ( verbosity > 0 )
{
- std::cout << "Sender finished. Sent "
- << sender.getSent()
- << " messages."
+ std::cout << "Sender finished. Sent "
+ << sender.getSent()
+ << " messages."
<< endl;
}
connection.close();
- return 0;
- }
- catch(const std::exception& error)
+ return 0;
+ }
+ catch(const std::exception& error)
{
- cerr << "Sender (host: "
- << settings.host
- << " port: "
+ cerr << "Sender (host: "
+ << settings.host
+ << " port: "
<< settings.port
<< " ) "
- << " Failed: "
- << error.what()
+ << " Failed: "
+ << error.what()
<< std::endl;
}
return 1;