summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker/Router.cpp
diff options
context:
space:
mode:
authorGordon Sim <gsim@apache.org>2006-10-30 19:27:54 +0000
committerGordon Sim <gsim@apache.org>2006-10-30 19:27:54 +0000
commitb0a120b4edfdb49a08bd7c8c2479e7b1cadc5233 (patch)
treed2b4ca0e774100285e116e5442bff9e55b4a3f92 /cpp/src/qpid/broker/Router.cpp
parentf491af49008a2ed219ad4507cd507b4317afa4cb (diff)
downloadqpid-python-b0a120b4edfdb49a08bd7c8c2479e7b1cadc5233.tar.gz
Initial implementation for tx class.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@469242 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/broker/Router.cpp')
-rw-r--r--cpp/src/qpid/broker/Router.cpp32
1 files changed, 0 insertions, 32 deletions
diff --git a/cpp/src/qpid/broker/Router.cpp b/cpp/src/qpid/broker/Router.cpp
deleted file mode 100644
index d5853473af..0000000000
--- a/cpp/src/qpid/broker/Router.cpp
+++ /dev/null
@@ -1,32 +0,0 @@
-/*
- *
- * Copyright (c) 2006 The Apache Software Foundation
- *
- * Licensed 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/broker/Router.h"
-
-using namespace qpid::broker;
-
-Router::Router(ExchangeRegistry& _registry) : registry(_registry){}
-
-void Router::operator()(Message::shared_ptr& msg){
- Exchange* exchange = registry.get(msg->getExchange());
- if(exchange){
- exchange->route(msg, msg->getRoutingKey(), &(msg->getHeaderProperties()->getHeaders()));
- }else{
- std::cout << "WARNING: Could not route message, unknown exchange: " << msg->getExchange() << std::endl;
- }
-
-}