MessageBundle

class borneo.changestream.MessageBundle(messages=None)

Bases: object

One or more messages returned from a Change Streams poll operation.

Methods Summary

commit([timeout_ms])	Marks the messages in this bundle as committed.
get_events_remaining()	Returns an estimate of unconsumed events remaining for this consumer.
get_messages()	Returns the messages in this bundle.
is_empty()	Returns True if this bundle has no messages.

Methods Documentation

commit(timeout_ms=None)

Marks the messages in this bundle as committed.

get_events_remaining()

Returns an estimate of unconsumed events remaining for this consumer.

get_messages()

Returns the messages in this bundle.

is_empty()

Returns True if this bundle has no messages.