(kc)
| 123 | |
| 124 | |
| 125 | def start_flusher(kc): |
| 126 | # Start FlushMessenger |
| 127 | kill_sema = threading.Semaphore() |
| 128 | kill_sema.acquire() |
| 129 | t = FlushingThread(kc, kill_sema) |
| 130 | t.start() |
| 131 | |
| 132 | def end_thread(): |
| 133 | kill_sema.release() |
| 134 | |
| 135 | atexit.register(end_thread) |
| 136 | |
| 137 | |
| 138 | def send_message(message, message_type="message"): |
no test coverage detected