QPID-664: changed connect() back to open(),removed detach(),defined new exception hierarchy, added ability to re-use reconnect/replay logic for resource-limit-exceeded errors

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@932451 13f79535-47bb-0310-9956-ffa450edef68

10 files changed, 10 insertions, 10 deletions

diff --git a/cpp/examples/messaging/client.cpp b/cpp/examples/messaging/client.cpp
index c1a8d74237..a3855807c8 100644
--- a/cpp/examples/messaging/client.cpp
+++ b/cpp/examples/messaging/client.cpp
@@ -41,7 +41,7 @@ int main(int argc, char** argv) {
 
     Connection connection(url);
     try {
-        connection.connect();
+        connection.open();
         Session session = connection.createSession();
 
         Sender sender = session.createSender("service_queue");
diff --git a/cpp/examples/messaging/drain.cpp b/cpp/examples/messaging/drain.cpp
index 41b9503649..ba613ec364 100644
--- a/cpp/examples/messaging/drain.cpp
+++ b/cpp/examples/messaging/drain.cpp
@@ -95,7 +95,7 @@ int main(int argc, char** argv)
     if (options.parse(argc, argv)) {
         Connection connection(options.url, options.connectionOptions);
         try {
-            connection.connect();
+            connection.open();
             Session session = connection.createSession();
             Receiver receiver = session.createReceiver(options.address);
             Duration timeout = options.getTimeout();
diff --git a/cpp/examples/messaging/map_receiver.cpp b/cpp/examples/messaging/map_receiver.cpp
index 55c543b90b..6afc4c9ec9 100644
--- a/cpp/examples/messaging/map_receiver.cpp
+++ b/cpp/examples/messaging/map_receiver.cpp
@@ -40,7 +40,7 @@ int main(int argc, char** argv) {
 
     Connection connection(url);
     try {
-        connection.connect();
+        connection.open();
         Session session = connection.createSession();
         Receiver receiver = session.createReceiver("message_queue");
         Variant::Map content;
diff --git a/cpp/examples/messaging/map_sender.cpp b/cpp/examples/messaging/map_sender.cpp
index 2e63c88aa4..eeea9a53b4 100644
--- a/cpp/examples/messaging/map_sender.cpp
+++ b/cpp/examples/messaging/map_sender.cpp
@@ -39,7 +39,7 @@ int main(int argc, char** argv) {
     const char* url = argc>1 ? argv[1] : "amqp:tcp:127.0.0.1:5672";
     Connection connection(url);
     try {
-        connection.connect();
+        connection.open();
         Session session = connection.createSession();
         Sender sender = session.createSender("message_queue");
 
diff --git a/cpp/examples/messaging/queue_receiver.cpp b/cpp/examples/messaging/queue_receiver.cpp
index 43dffd8baf..377ce11993 100644
--- a/cpp/examples/messaging/queue_receiver.cpp
+++ b/cpp/examples/messaging/queue_receiver.cpp
@@ -33,7 +33,7 @@ int main(int argc, char** argv) {
 
     Connection connection(url);
     try {
-        connection.connect();
+        connection.open();
         Session session = connection.createSession();
         Receiver receiver = session.createReceiver("message_queue");
         while (true) {
diff --git a/cpp/examples/messaging/queue_sender.cpp b/cpp/examples/messaging/queue_sender.cpp
index fa355dbf88..0592c30b60 100644
--- a/cpp/examples/messaging/queue_sender.cpp
+++ b/cpp/examples/messaging/queue_sender.cpp
@@ -36,7 +36,7 @@ int main(int argc, char** argv) {
 
     Connection connection(url);
     try {
-        connection.connect();
+        connection.open();
         Session session = connection.createSession();
         Sender sender = session.createSender("message_queue");
 
diff --git a/cpp/examples/messaging/server.cpp b/cpp/examples/messaging/server.cpp
index 33d28a75c4..ae1fee4b50 100644
--- a/cpp/examples/messaging/server.cpp
+++ b/cpp/examples/messaging/server.cpp
@@ -42,7 +42,7 @@ int main(int argc, char** argv) {
 
     Connection connection(url);
     try {
-        connection.connect();
+        connection.open();
         Session session = connection.createSession();
         Receiver receiver = session.createReceiver("service_queue; {create: always}");
 
diff --git a/cpp/examples/messaging/spout.cpp b/cpp/examples/messaging/spout.cpp
index 9ed8b642c8..2e9e91bfba 100644
--- a/cpp/examples/messaging/spout.cpp
+++ b/cpp/examples/messaging/spout.cpp
@@ -158,7 +158,7 @@ int main(int argc, char** argv)
     if (options.parse(argc, argv)) {        
         Connection connection(options.url, options.connectionOptions);
         try {
-            connection.connect();
+            connection.open();
             Session session = connection.createSession();
             Sender sender = session.createSender(options.address);
 
diff --git a/cpp/examples/messaging/topic_receiver.cpp b/cpp/examples/messaging/topic_receiver.cpp
index 408920f5aa..96f40a539c 100644
--- a/cpp/examples/messaging/topic_receiver.cpp
+++ b/cpp/examples/messaging/topic_receiver.cpp
@@ -35,7 +35,7 @@ int main(int argc, char** argv) {
 
     Connection connection(url);
     try {
-        connection.connect();
+        connection.open();
         Session session = connection.createSession();
         Receiver receiver = session.createReceiver("news_service; {filter:[control, " + pattern + "]}");
         while (true) {
diff --git a/cpp/examples/messaging/topic_sender.cpp b/cpp/examples/messaging/topic_sender.cpp
index 9d4cd582cf..a95c0951f7 100644
--- a/cpp/examples/messaging/topic_sender.cpp
+++ b/cpp/examples/messaging/topic_sender.cpp
@@ -53,7 +53,7 @@ int main(int argc, char** argv) {
 
     Connection connection(url);
     try {
-        connection.connect();
+        connection.open();
         Session session = connection.createSession();
         Sender sender = session.createSender("news_service");