1 files changed, 92 insertions, 0 deletions
diff --git a/cpp/broker/src/Broker.cpp b/cpp/broker/src/Broker.cpp
new file mode 100644
index 0000000000..5d59b63622
--- /dev/null
+++ b/cpp/broker/src/Broker.cpp
@@ -0,0 +1,92 @@
+/*
+ *
+ * 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 <iostream>
+#include <memory>
+#include "apr_signal.h"
+
+#include "Acceptor.h"
+#include "Configuration.h"
+#include "QpidError.h"
+#include "SessionHandlerFactoryImpl.h"
+
+//optional includes:
+#ifdef _USE_APR_IO_
+
+#include "BlockingAPRAcceptor.h"
+#include "LFAcceptor.h"
+
+#endif 
+
+using namespace qpid::broker;
+using namespace qpid::io;
+
+void handle_signal(int signal);
+
+Acceptor* createAcceptor(Configuration& config);
+
+int main(int argc, char** argv)
+{
+    SessionHandlerFactoryImpl factory;
+    Configuration config;
+    try{
+
+        config.parse(argc, argv);
+        if(config.isHelp()){
+            config.usage();
+        }else{
+#ifdef _USE_APR_IO_         
+            apr_signal(SIGINT, handle_signal);
+#endif
+            try{    
+                std::auto_ptr<Acceptor> acceptor(createAcceptor(config));
+                try{             
+                    acceptor->bind(config.getPort(), &factory);
+                }catch(qpid::QpidError error){
+                    std::cout << "Error [" << error.code << "] " << error.msg << " (" << error.file << ":" << error.line << ")" << std::endl;
+                }
+            }catch(qpid::QpidError error){
+                std::cout << "Error [" << error.code << "] " << error.msg << " (" << error.file << ":" << error.line << ")" << std::endl;
+            }
+        }            
+    }catch(Configuration::ParseException error){
+        std::cout << "Error: " << error.error << std::endl;        
+    }
+
+    return 1;
+}
+
+Acceptor* createAcceptor(Configuration& config){
+    const string type(config.getAcceptor());
+#ifdef _USE_APR_IO_         
+    if("blocking" == type){
+        std::cout << "Using blocking acceptor " << std::endl;
+        return new BlockingAPRAcceptor(config.isTrace(), config.getConnectionBacklog());
+    }else if("non-blocking" == type){
+        std::cout << "Using non-blocking acceptor " << std::endl;
+        return new LFAcceptor(config.isTrace(), 
+                              config.getConnectionBacklog(), 
+                              config.getWorkerThreads(),
+                              config.getMaxConnections());
+    }
+#endif
+    throw Configuration::ParseException("Unrecognised acceptor: " + type);
+}
+
+void handle_signal(int signal){
+    std::cout << "Shutting down..." << std::endl;
+}