blob: 8fd64d00c4191c34ec3e6dd5da32c121f8ad2718 [file] [log] [blame]
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* 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
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
* under the License.
#include "proton/io/link_namer.hpp"
#include "proton/container.hpp"
#include "proton/connection.hpp"
#include "proton/connection_options.hpp"
#include "proton/duration.hpp"
#include "proton/messaging_handler.hpp"
#include "proton/sender.hpp"
#include "proton/receiver.hpp"
#include <proton/reactor.h>
#include "reactor.hpp"
#include "proton_handler.hpp"
#include <string>
#include <sstream>
namespace proton {
class dispatch_helper;
class connection;
class connector;
class acceptor;
class container;
class url;
class task;
class listen_handler;
class container_impl : public container {
container_impl(const std::string& id, messaging_handler* = 0);
std::string id() const PN_CPP_OVERRIDE { return id_; }
returned<connection> connect(const std::string&, const connection_options&) PN_CPP_OVERRIDE;
returned<sender> open_sender(
const std::string&, const proton::sender_options &, const connection_options &) PN_CPP_OVERRIDE;
returned<receiver> open_receiver(
const std::string&, const proton::receiver_options &, const connection_options &) PN_CPP_OVERRIDE;
listener listen(const std::string&, listen_handler& lh) PN_CPP_OVERRIDE;
void stop_listening(const std::string&) PN_CPP_OVERRIDE;
void client_connection_options(const connection_options &) PN_CPP_OVERRIDE;
connection_options client_connection_options() const PN_CPP_OVERRIDE { return client_connection_options_; }
void server_connection_options(const connection_options &) PN_CPP_OVERRIDE;
connection_options server_connection_options() const PN_CPP_OVERRIDE { return server_connection_options_; }
void sender_options(const proton::sender_options&) PN_CPP_OVERRIDE;
class sender_options sender_options() const PN_CPP_OVERRIDE { return sender_options_; }
void receiver_options(const proton::receiver_options&) PN_CPP_OVERRIDE;
class receiver_options receiver_options() const PN_CPP_OVERRIDE { return receiver_options_; }
void run() PN_CPP_OVERRIDE;
void stop(const error_condition& err) PN_CPP_OVERRIDE;
void auto_stop(bool set) PN_CPP_OVERRIDE;
// non-interface functions
void configure_server_connection(connection &c);
task schedule(int delay, proton_handler *h);
internal::pn_ptr<pn_handler_t> cpp_handler(proton_handler *h);
std::string next_link_name();
typedef std::map<std::string, acceptor> acceptors;
struct count_link_namer : public io::link_namer {
count_link_namer() : count_(0) {}
std::string link_name() {
// TODO aconway 2016-01-19: more efficient conversion, fixed buffer.
std::ostringstream o;
o << "PN" << std::hex << ++count_;
return o.str();
uint64_t count_;
reactor reactor_;
proton_handler *handler_;
internal::pn_unique_ptr<proton_handler> override_handler_;
internal::pn_unique_ptr<proton_handler> flow_controller_;
std::string id_;
count_link_namer id_gen_;
connection_options client_connection_options_;
connection_options server_connection_options_;
proton::sender_options sender_options_;
proton::receiver_options receiver_options_;
bool auto_stop_;
acceptors acceptors_;
friend class messaging_adapter;