listener_receiver Class Reference

Convenience class to bring together listener and concurrent_receiver. More...

#include <listener.hh>

Inheritance diagram for listener_receiver:

Public Member Functions
	listener_receiver ()
	listener_receiver (const listener_receiver &)=delete
	listener_receiver (listener_receiver &&a_orig)
listener_receiver &	operator= (const listener_receiver &)=delete
listener_receiver &	operator= (listener_receiver &&a_orig)
Public Member Functions inherited from listener
	listener ()
	listener (const listener &)=delete
	listener (listener &&a_orig)
virtual	~listener ()
listener &	operator= (const listener &)=delete
listener &	operator= (listener &&a_orig)
virtual bool	listen_on_queue ()=0
	snake_case_mv_referrable (amqp_channel_ptr, channel)
	snake_case_mv_referrable (std::string, consumer_tag)
	snake_case_mv_accessible (unsigned, listen_timeout_ms)
	snake_case_mv_referrable (std::thread, listener_thread)
Public Member Functions inherited from concurrent_receiver
	concurrent_receiver ()
	concurrent_receiver (const concurrent_receiver &)=delete
	concurrent_receiver (concurrent_receiver &&a_orig)
virtual	~concurrent_receiver ()
concurrent_receiver &	operator= (const concurrent_receiver &)=delete
concurrent_receiver &	operator= (concurrent_receiver &&a_orig)
virtual void	process_message (message_ptr_t a_message)
	Deposits the message in the concurrent queue (called by the listener) More...
void	execute ()
	Handles messages that appear in the concurrent queue by calling submit_message(). More...
Public Member Functions inherited from receiver
	receiver ()
	receiver (const receiver &a_orig)=delete
	receiver (receiver &&a_orig)
virtual	~receiver ()
receiver &	operator= (const receiver &a_orig)=delete
receiver &	operator= (receiver &&a_orig)
void	handle_message_chunk (amqp_envelope_ptr a_envelope)
void	wait_for_message (incoming_message_pack &a_pack, const std::string &a_message_id)
void	process_message_pack (incoming_message_pack &a_pack, const std::string &a_message_id)
	Converts a message pack into a Dripline message, and then submits the message for processing. More...
	snake_case_mv_referrable (incoming_message_map, incoming_messages)
	Stores the incomplete messages. More...
	snake_case_mv_accessible (unsigned, single_message_wait_ms)
	Wait time for message chunks from a single message. More...
reply_ptr_t	wait_for_reply (const sent_msg_pkg_ptr a_receive_reply, int a_timeout_ms=0)
reply_ptr_t	wait_for_reply (const sent_msg_pkg_ptr a_receive_reply, bool &a_chan_valid, int a_timeout_ms=0)

Additional Inherited Members
Protected Member Functions inherited from concurrent_receiver
virtual void	submit_message (message_ptr_t a_message)=0
	snake_case_mv_referrable (scarab::concurrent_queue< message_ptr_t >, message_queue)
	snake_case_mv_referrable (std::thread, receiver_thread)
Protected Member Functions inherited from receiver
reply_ptr_t	process_received_reply (incoming_message_pack &a_pack, const std::string &a_message_id)

Detailed Description

Convenience class to bring together listener and concurrent_receiver.

Author

N.S. Oblath

Definition at line 75 of file listener.hh.

Constructor & Destructor Documentation

listener_receiver() [1/3]

listener_receiver ( )

inline

Definition at line 78 of file listener.hh.

listener_receiver() [2/3]

listener_receiver ( const listener_receiver &  )

delete

listener_receiver() [3/3]

listener_receiver ( listener_receiver &&  a_orig )

inline

Definition at line 80 of file listener.hh.

Member Function Documentation

operator=() [1/2]

listener_receiver& operator= ( const listener_receiver &  )

delete

operator=() [2/2]

listener_receiver& operator= ( listener_receiver &&  a_orig )

inline

Definition at line 87 of file listener.hh.

---

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

• listener.hh