Messsage reader. More...

#include <tkrzw_message_queue.h>

Public Member Functions
	~Reader ()
	Destructor. More...

Status	Read (int64_t timestamp, std::string message, double wait_time=0)
	Reads a message from the queue. More...

Status	Wait (double wait_time=0)
	Waits until the reader is ready to read tne next message. More...

int64_t	GetTimestamp ()
	Gets the latest timestamp. More...

Detailed Description

Messsage reader.

Constructor & Destructor Documentation

tkrzw::MessageQueue::Reader::~Reader ( )

Destructor.

Status tkrzw::MessageQueue::Reader::Read	(	int64_t *	timestamp,
		std::string *	message,
		double	wait_time = `0`
	)

Reads a message from the queue.

Parameters

timestamp	The pointer to a variable to store the timestamp in milliseconds of the message. This is set if the result is SUCCESS or INFEASIBLE_ERROR.
message	The pointer to a string object to store the msssage data.
wait_time	The time in seconds to wait for the next log. Zero means no wait. Negative means unlimited.

Returns: The result status. If the queue is in the read-only mode and there's no record to read, NOT_FOUND_ERROR is returned. If the time wait time passes, INFEASIBLE_ERROR is returned. If the writer closes the file while waiting, CANCELED_ERROR is returned.

Status tkrzw::MessageQueue::Reader::Wait ( double wait_time = 0 )

Waits until the reader is ready to read tne next message.

Parameters

wait_time The time in seconds to wait for the next log. Zero means no wait. Negative means unlimited.

Returns: The result status. If the queue is in the read-only mode and there's no record to read, NOT_FOUND_ERROR is returned. If the time wait time passes, INFEASIBLE_ERROR is returned. If the writer closes the file while waiting, CANCELED_ERROR is returned.

int64_t tkrzw::MessageQueue::Reader::GetTimestamp ( )

Gets the latest timestamp.