11#include " logger.h"
2- #include < slick_socket /multicast_sender.h>
3- #include < slick_socket /multicast_receiver.h>
2+ #include < slick/socket /multicast_sender.h>
3+ #include < slick/socket /multicast_receiver.h>
44#include < iostream>
55#include < string>
66#include < thread>
77#include < chrono>
88#include < atomic>
99
10- class MulticastReceiver : public slick_socket ::MulticastReceiverBase<MulticastReceiver>
10+ class MulticastReceiver : public slick ::socket ::MulticastReceiverBase<MulticastReceiver>
1111{
1212public:
13- MulticastReceiver (const slick_socket ::MulticastReceiverConfig& config)
14- : slick_socket ::MulticastReceiverBase<MulticastReceiver>(" IntegrationReceiver" , config)
13+ MulticastReceiver (const slick::socket ::MulticastReceiverConfig& config)
14+ : slick::socket ::MulticastReceiverBase<MulticastReceiver>(" IntegrationReceiver" , config)
1515 {
1616 }
1717
@@ -25,11 +25,11 @@ class MulticastReceiver : public slick_socket::MulticastReceiverBase<MulticastRe
2525 std::atomic<int > messages_received_{0 };
2626};
2727
28- class MulticastSender : public slick_socket ::MulticastSenderBase<MulticastSender>
28+ class MulticastSender : public slick ::socket ::MulticastSenderBase<MulticastSender>
2929{
3030public:
31- MulticastSender (const slick_socket ::MulticastSenderConfig& config)
32- : slick_socket ::MulticastSenderBase<MulticastSender>(" IntegrationSender" , config)
31+ MulticastSender (const slick::socket ::MulticastSenderConfig& config)
32+ : slick::socket ::MulticastSenderBase<MulticastSender>(" IntegrationSender" , config)
3333 {
3434 }
3535};
@@ -44,14 +44,14 @@ int main()
4444 const uint16_t port = 12347 ;
4545
4646 // Setup receiver
47- slick_socket ::MulticastReceiverConfig receiver_config;
47+ slick::socket ::MulticastReceiverConfig receiver_config;
4848 receiver_config.multicast_address = multicast_address;
4949 receiver_config.port = port;
5050 receiver_config.reuse_address = true ;
5151 receiver_config.receive_timeout = std::chrono::milliseconds (1000 );
5252
5353 // Setup sender
54- slick_socket ::MulticastSenderConfig sender_config;
54+ slick::socket ::MulticastSenderConfig sender_config;
5555 sender_config.multicast_address = multicast_address;
5656 sender_config.port = port;
5757 sender_config.ttl = 1 ; // Local network only
0 commit comments