def METHOD_NAME(self):
    """This test case checks if the timestamp is adjusted and log atoms are forwarded correctly."""
    match_context = DummyMatchContext(b" pid=")
    fdme = DummyFixedDataModelElement("s1", b" pid=")
    match_element = fdme.get_match_element("match", match_context)
    nmpd = NewMatchPathDetector(self.aminer_config, [self.stream_printer_event_handler], "Default", False, output_logline=False)
    smta = SimpleMonotonicTimestampAdjust([nmpd], False)
    # the atom time should be set automatically if None.
    log_atom = LogAtom(fdme.data, ParserMatch(match_element), None, nmpd)
    self.assertEqual(smta.receive_atom(log_atom), True)
    self.assertEqual(smta.latest_timestamp_seen, 0)
    self.assertNotEqual(log_atom.atom_time, None)
    t = log_atom.atom_time + 100
    log_atom = LogAtom(fdme.data, ParserMatch(match_element), t, nmpd)
    self.assertEqual(smta.receive_atom(log_atom), True)
    self.assertEqual(smta.latest_timestamp_seen, t)
    self.assertEqual(log_atom.atom_time, t)
    log_atom = LogAtom(fdme.data, ParserMatch(match_element), t-1000, nmpd)
    self.assertEqual(smta.receive_atom(log_atom), True)
    self.assertEqual(smta.latest_timestamp_seen, t)
    self.assertEqual(log_atom.atom_time, t)