summaryrefslogtreecommitdiff
path: root/qpid/cpp/src
diff options
context:
space:
mode:
authorAndrew Stitcher <astitcher@apache.org>2012-12-20 23:42:57 +0000
committerAndrew Stitcher <astitcher@apache.org>2012-12-20 23:42:57 +0000
commit1282f525084cb60f672f8a2e02e01fa0ce6c62ff (patch)
tree63c9e42b68a70d807b871a525500fd2531f35ed9 /qpid/cpp/src
parent62fe39516a1bb45d206ad68aa7e1ec60966367a9 (diff)
downloadqpid-python-1282f525084cb60f672f8a2e02e01fa0ce6c62ff.tar.gz
NO-JIRA: Removed some unused Broker code
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1424761 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/src')
-rw-r--r--qpid/cpp/src/qpid/broker/Broker.cpp15
-rw-r--r--qpid/cpp/src/qpid/broker/Broker.h10
2 files changed, 3 insertions, 22 deletions
diff --git a/qpid/cpp/src/qpid/broker/Broker.cpp b/qpid/cpp/src/qpid/broker/Broker.cpp
index 18618ee005..15382ae80d 100644
--- a/qpid/cpp/src/qpid/broker/Broker.cpp
+++ b/qpid/cpp/src/qpid/broker/Broker.cpp
@@ -1010,24 +1010,13 @@ void Broker::accept() {
void Broker::connect(
const std::string& host, const std::string& port, const std::string& transport,
- boost::function2<void, int, std::string> failed,
- sys::ConnectionCodec::Factory* f)
+ boost::function2<void, int, std::string> failed)
{
boost::shared_ptr<ProtocolFactory> pf = getProtocolFactory(transport);
- if (pf) pf->connect(poller, host, port, f ? f : factory.get(), failed);
+ if (pf) pf->connect(poller, host, port, factory.get(), failed);
else throw NoSuchTransportException(QPID_MSG("Unsupported transport type: " << transport));
}
-void Broker::connect(
- const Url& url,
- boost::function2<void, int, std::string> failed,
- sys::ConnectionCodec::Factory* f)
-{
- url.throwIfEmpty();
- const Address& addr=url[0];
- connect(addr.host, boost::lexical_cast<std::string>(addr.port), addr.protocol, failed, f);
-}
-
uint32_t Broker::queueMoveMessages(
const std::string& srcQueue,
const std::string& destQueue,
diff --git a/qpid/cpp/src/qpid/broker/Broker.h b/qpid/cpp/src/qpid/broker/Broker.h
index d2b946f71b..9a5204dbf6 100644
--- a/qpid/cpp/src/qpid/broker/Broker.h
+++ b/qpid/cpp/src/qpid/broker/Broker.h
@@ -247,12 +247,7 @@ class Broker : public sys::Runnable, public Plugin::Target,
/** Create a connection to another broker. */
void connect(const std::string& host, const std::string& port,
const std::string& transport,
- boost::function2<void, int, std::string> failed,
- sys::ConnectionCodec::Factory* =0);
- /** Create a connection to another broker. */
- void connect(const Url& url,
- boost::function2<void, int, std::string> failed,
- sys::ConnectionCodec::Factory* =0);
+ boost::function2<void, int, std::string> failed);
/** Move messages from one queue to another.
A zero quantity means to move all messages
@@ -269,9 +264,6 @@ class Broker : public sys::Runnable, public Plugin::Target,
/** Expose poller so plugins can register their descriptors. */
QPID_BROKER_EXTERN boost::shared_ptr<sys::Poller> getPoller();
- boost::shared_ptr<sys::ConnectionCodec::Factory> getConnectionFactory() { return factory; }
- void setConnectionFactory(boost::shared_ptr<sys::ConnectionCodec::Factory> f) { factory = f; }
-
/** Timer for local tasks affecting only this broker */
sys::Timer& getTimer() { return timer; }