```
public class MessageCaptor<T extends com.google.protobuf.Message>
extends Object
```
Utility class for queueing original messages as they are received from a subscription to Yamcs. This is intended for use in unit tests only.

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`clear()`
`T`	`expectTimely()`
`int`	`getPendingCount()`	Returns the number of unprocessed messages.
`boolean`	`isEmpty()`	Returns true if there are not currently any unprocessed messages.
`static <T extends com.google.protobuf.Message> MessageCaptor<T>`	`of(Subscription<?,T> subscription)`
`T`	`poll()`	Returns the next received message.
`T`	`poll(long timeout)`

poll
```
public T poll()
```
Returns the next received message. Or null, if nothing was received yet.

public T poll(long timeout)
       throws InterruptedException

public T expectTimely()
               throws InterruptedException,
                      TimeoutException

isEmpty
```
public boolean isEmpty()
```
Returns true if there are not currently any unprocessed messages.

getPendingCount
```
public int getPendingCount()
```
Returns the number of unprocessed messages.

public static <T extends com.google.protobuf.Message> MessageCaptor<T> of(Subscription<?,T> subscription)

Class MessageCaptor<T extends com.google.protobuf.Message>