def incoming_logs_validations(self, mock_message=False):
        """
        Validate that there is incoming traffic of the stream type
        :param mock_message: Tells if to generate mock messages
        :return: True if successfully captured events of the relevant stream.
        """
        tcpdump_time_restriction = 10
        start_seconds = int(round(time.time()))
        end_seconds = int(round(time.time()))
        mock_message_counter = 0
        command_name = "listen_to_incoming_events"
        command_to_run = "sudo tcpdump -A -l -ni any port 514 -vv"
        result_keywords_array = [STREAM_SCENARIO.upper()]
        command_object = CommandVerification(command_name, command_to_run, result_keywords_array)
        print("Attempting to capture events using tcpdump. This could take up to " + str(
            tcpdump_time_restriction) + " seconds.")
        tcp_dump = subprocess.Popen(command_object.command_to_run, shell=True, stdout=subprocess.PIPE,
                                    stderr=subprocess.STDOUT)
        line = str(tcp_dump.stdout.readline().decode('utf-8').strip("\n"))
        # Handle command not found
        if "command not found" in line:
            print(self.TCPDUMP_NOT_INSTALLED_ERROR_MESSAGE)
            command_object.command_result = line
            command_object.run_full_verification()
            return False
        poll_obj = select.poll()
        poll_obj.register(tcp_dump.stdout, select.POLLIN)
        while (end_seconds - start_seconds) < tcpdump_time_restriction:
            if mock_message and mock_message_counter < 10:
                # Sending mock messages
                mock_message_counter += 1
                self.send_message_local(514, 1)
            poll_result = poll_obj.poll(0)
            if poll_result:
                line = tcp_dump.stdout.readline().decode('utf-8').strip("\n")
                if self.check_stream_in_line(line, STREAM_SCENARIO.upper()):
                    command_object.command_result = line
                    command_object.run_full_verification()
                    print_ok("Found {0} in stream. Please verify {0} events arrived at your workspace".format(
                        STREAM_SCENARIO.upper()))
                    return True
            end_seconds = int(round(time.time()))
        print_error("Could not locate {0} message in tcpdump. Please verify {0} events can be sent to the machine and"
                    " there is not firewall blocking incoming traffic".format(STREAM_SCENARIO.upper()))
        if mock_message:
            print_warning("In case hardening is in place please refer to this documentation in order to verify it's configured correctly- "
                       "{}".format(self.LINUX_HARDENING_DOC))
        command_object.command_result = str(line)
        command_object.run_full_verification()
        return False

        Validate that there is incoming traffic of the stream type
        :param mock_message: Tells if to generate mock messages
        :return: True if successfully captured events of the relevant stream.
        
DataConnectors/Syslog/Sentinel_AMA_troubleshoot.py