Public Member Functions
	Queue (const google::protobuf::Descriptor desc, QueueManager parent, const protobuf::QueuedMessageEntry &cfg=protobuf::QueuedMessageEntry())

bool	push_message (boost::shared_ptr< google::protobuf::Message > dccl_msg)

bool	push_message (boost::shared_ptr< google::protobuf::Message > dccl_msg, protobuf::QueuedMessageMeta meta)

protobuf::QueuedMessageMeta	meta_from_msg (const google::protobuf::Message &dccl_msg)

boost::any	find_queue_field (const std::string &field_name, const google::protobuf::Message &msg)

goby::acomms::QueuedMessage	give_data (unsigned frame)

bool	pop_message (unsigned frame)

bool	pop_message_ack (unsigned frame, boost::shared_ptr< google::protobuf::Message > &removed_msg)

void	stream_for_pop (const QueuedMessage &queued_msg)

std::vector< boost::shared_ptr< google::protobuf::Message > >	expire ()

bool	get_priority_values (double priority, boost::posix_time::ptime last_send_time, const protobuf::ModemTransmission &request_msg, const std::string &data)

bool	clear_ack_queue (unsigned start_frame)

void	flush ()

size_t	size () const

boost::posix_time::ptime	last_send_time () const

boost::posix_time::ptime	newest_msg_time () const

void	info (std::ostream *os) const

std::string	name () const

void	set_cfg (const protobuf::QueuedMessageEntry &cfg)

void	process_cfg ()

const protobuf::QueuedMessageEntry &	queue_message_options ()

const google::protobuf::Descriptor *	descriptor () const

int	id ()

Detailed Description

Definition at line 60 of file queue.h.

The documentation for this class was generated from the following files:

Public Member Functions