ModernClient Class Reference

Modern client using new API. More...

Collaboration diagram for ModernClient:

Public Member Functions
	ModernClient (const std::string &id)
bool	connect (const std::string &host, uint16_t port)
size_t	send_batch (const std::vector< std::string > &messages)
void	send_async (const std::string &message)
bool	disconnect ()

Private Attributes
std::string	client_id_
std::shared_ptr< core::messaging_client >	client_

Detailed Description

Modern client using new API.

Definition at line 145 of file modern_usage.cpp.

Constructor & Destructor Documentation

ModernClient()

ModernClient::ModernClient ( const std::string & id )

inline

Definition at line 147 of file modern_usage.cpp.

                                      : client_id_(id) {
        client_ = std::make_shared<core::messaging_client>(client_id_);
        std::cout << "[Modern Client] Created with ID: " << client_id_ << std::endl;
    }

References client_, and client_id_.

Member Function Documentation

connect()

bool ModernClient::connect ( const std::string & host, uint16_t port )

inline

Definition at line 152 of file modern_usage.cpp.

                                                       {
        auto result = client_->start_client(host, port);
        if (result.is_err()) {
            std::cerr << "[Modern Client] Failed to connect: " << result.error().message
                      << " (code: " << result.error().code << ")" << std::endl;
            return false;
        }
 
        std::cout << "[Modern Client] Connecting to " << host << ":" << port << std::endl;
        std::this_thread::sleep_for(200ms);  // Give time to connect
        return true;
    }

References client_, and kcenon::network::core::messaging_client::start_client().

Here is the call graph for this function:

disconnect()

bool ModernClient::disconnect ( )

inline

Definition at line 204 of file modern_usage.cpp.

                      {
        auto result = client_->stop_client();
        if (result.is_err()) {
            std::cerr << "[Modern Client] Failed to disconnect: " << result.error().message
                      << " (code: " << result.error().code << ")" << std::endl;
            return false;
        }
 
        std::cout << "[Modern Client] Disconnected" << std::endl;
        return true;
    }

References client_, and kcenon::network::core::messaging_client::stop_client().

Here is the call graph for this function:

send_async()

void ModernClient::send_async ( const std::string & message )

inline

Definition at line 189 of file modern_usage.cpp.

                                              {
        auto& thread_mgr = integration::thread_integration_manager::instance();
        thread_mgr.submit_task([this, message]() {
            std::vector<uint8_t> data(message.begin(), message.end());
            auto result = client_->send_packet(data);
 
            if (result.is_err()) {
                std::cerr << "[Modern Client] Async send failed: " << result.error().message
                          << " (code: " << result.error().code << ")" << std::endl;
            } else {
                std::cout << "[Modern Client] Async sent: " << message << std::endl;
            }
        });
    }

References client_, kcenon::network::integration::thread_integration_manager::instance(), kcenon::network::message, and kcenon::network::core::messaging_client::send_packet().

Here is the call graph for this function:

send_batch()

size_t ModernClient::send_batch ( const std::vector< std::string > & messages )

inline

Definition at line 165 of file modern_usage.cpp.

                                                            {
        std::cout << "[Modern Client] Sending batch of " << messages.size()
                  << " messages" << std::endl;
 
        size_t successful = 0;
        for (const auto& msg : messages) {
            std::vector<uint8_t> data(msg.begin(), msg.end());
            auto result = client_->send_packet(data);
 
            if (result.is_err()) {
                std::cerr << "[Modern Client] Failed to send message: " << result.error().message
                          << " (code: " << result.error().code << ")" << std::endl;
            } else {
                successful++;
            }
 
            std::this_thread::sleep_for(50ms);
        }
 
        std::cout << "[Modern Client] Successfully sent " << successful << "/" << messages.size()
                  << " messages" << std::endl;
        return successful;
    }

References client_, and kcenon::network::core::messaging_client::send_packet().

Here is the call graph for this function:

Member Data Documentation

client_

std::shared_ptr<core::messaging_client> ModernClient::client_

private

Definition at line 218 of file modern_usage.cpp.

Referenced by connect(), disconnect(), ModernClient(), send_async(), and send_batch().

client_id_

std::string ModernClient::client_id_

private

Definition at line 217 of file modern_usage.cpp.

Referenced by ModernClient().

---

The documentation for this class was generated from the following file:

• examples/messaging_system_integration/modern_usage.cpp