BrokerMessageReaders.h File Reference

Include dependency graph for BrokerMessageReaders.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Classes
struct	catapult::subscribers::detail::Flusher< TSubscriber, typename >
struct	catapult::subscribers::detail::is_type_expression_t< decltype(reinterpret_cast< TSubscriber * >(0) ->flush())> >
struct	catapult::subscribers::MessageQueueDescriptor
	Describes a message queue. More...

Namespaces
	catapult
	catapult::subscribers
	catapult::subscribers::detail

Functions
template<typename TSubscriber , typename TMessageReader >
void	catapult::subscribers::ReadAll (io::InputStream &inputStream, TSubscriber &subscriber, TMessageReader readNextMessage)
	Reads all messages from inputStream into subscriber using readNextMessage. More...
template<typename TSubscriber , typename TMessageReader >
void	catapult::subscribers::ReadAll (io::FileQueueReader &reader, TSubscriber &subscriber, TMessageReader readNextMessage)
	Reads all messages from reader into subscriber using readNextMessage. More...
template<typename TSubscriber , typename TMessageReader >
void	catapult::subscribers::ReadAll (const MessageQueueDescriptor &descriptor, TSubscriber &subscriber, TMessageReader readNextMessage)
	Reads all messages from queue described by descriptor into subscriber using readNextMessage. More...