8
8
from people_detection_ros2_msg .msg import People , BoundingBox
9
9
from rcl_interfaces .msg import ParameterDescriptor , ParameterType
10
10
from rclpy .node import Node
11
+ from rclpy .qos import QoSProfile , ReliabilityPolicy
11
12
from sensor_msgs .msg import Image , CompressedImage
12
13
13
14
from people_detection_ros2 .people_detection_wrapper import PeopleDetectionWrapper
@@ -19,6 +20,9 @@ class PeopleDetectionNode(Node):
19
20
def __init__ (self ):
20
21
super ().__init__ ('people_detection_node' )
21
22
23
+ # QoS Settings
24
+ shigure_qos = QoSProfile (depth = 10 , reliability = ReliabilityPolicy .BEST_EFFORT )
25
+
22
26
# ros params
23
27
is_debug_mode_descriptor = ParameterDescriptor (type = ParameterType .PARAMETER_BOOL ,
24
28
description = 'If true, run debug mode.' )
@@ -55,10 +59,10 @@ def __init__(self):
55
59
56
60
if is_image_compressed :
57
61
self .subscription = self .create_subscription (CompressedImage , image_node ,
58
- self .get_img_compressed_callback , 10 )
62
+ self .get_img_compressed_callback , shigure_qos )
59
63
else :
60
64
self .subscription = self .create_subscription (Image , image_node ,
61
- self .get_img_callback , 10 )
65
+ self .get_img_callback , shigure_qos )
62
66
63
67
# FPS計測
64
68
self .frame_count = 0
0 commit comments