get_queue_message_latest

lsst.ts.m2com.get_queue_message_latest(queue: Queue, name: str, flush: bool = True) dict

Get the latest message in queue.

This function is used in the unit test only.

Parameters

queueasyncio.Queue

Queue of message.

namestr

Name of message.

flushbool, optional

Flush the queue or not. (the default is True)

Returns

message_latestdict

Latest message.