chunk_integrations::ChunkMessageQueue Class Reference

Class for publishing chunks to message queues. More...

#include <chunk_integrations.hpp>

Collaboration diagram for chunk_integrations::ChunkMessageQueue:

Public Member Functions
	ChunkMessageQueue (std::unique_ptr< MessageQueueConnection > connection, const std::string &queue_name)
	Constructor.
template<typename T >
void	publish_chunks_kafka (const std::vector< std::vector< T > > &chunks)
	Publish chunks to Kafka topic.
template<typename T >
void	publish_chunks_rabbitmq (const std::vector< std::vector< T > > &chunks)
	Publish chunks to RabbitMQ queue.

Private Attributes
std::unique_ptr< MessageQueueConnection >	mq_connection
	Message queue connection.
std::string	queue
	Target queue name.

Detailed Description

Class for publishing chunks to message queues.

Definition at line 94 of file chunk_integrations.hpp.

Constructor & Destructor Documentation

ChunkMessageQueue()

chunk_integrations::ChunkMessageQueue::ChunkMessageQueue	(	std::unique_ptr< MessageQueueConnection >	connection,
		const std::string &	queue_name
	)

Constructor.

Parameters

connection	Message queue connection instance
queue_name	Target queue name

Member Function Documentation

publish_chunks_kafka()

template<typename T >

void chunk_integrations::ChunkMessageQueue::publish_chunks_kafka

(

const std::vector< std::vector< T > > &

chunks

)

Publish chunks to Kafka topic.

Template Parameters

T	Data type of chunk elements

Parameters

chunks

Vector of chunks to publish

Exceptions

std::runtime_error

if publishing fails

publish_chunks_rabbitmq()

template<typename T >

void chunk_integrations::ChunkMessageQueue::publish_chunks_rabbitmq

(

const std::vector< std::vector< T > > &

chunks

)

Publish chunks to RabbitMQ queue.

Template Parameters

T	Data type of chunk elements

Parameters

chunks

Vector of chunks to publish

Exceptions

std::runtime_error

if publishing fails

Member Data Documentation

mq_connection

std::unique_ptr<MessageQueueConnection> chunk_integrations::ChunkMessageQueue::mq_connection

private

Message queue connection.

Definition at line 123 of file chunk_integrations.hpp.

queue

std::string chunk_integrations::ChunkMessageQueue::queue

private

Target queue name.

Definition at line 124 of file chunk_integrations.hpp.

---

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

• chunk_integrations.hpp