eckit::distributed::Consumer class

#include <eckit/distributed/Consumer.h>

Base classes

class Actor

Public types

enum MessageTags { READY, WORK, SHUTDOWN, OPEN, WRITE, CLOSE, STATISTICS, BYE }

Public static functions

static auto tagName(int) -> const char*

Constructors, destructors, conversion operators

Consumer(Transport& transport)

Public functions

void consume(Message& message) pure virtual

void failure(Message& message) virtual

void shutdown(Message& message) virtual

void finalise() pure virtual

void messageFromWorker(Message& message, int worker) const virtual

void messageFromWriter(Message& message, int worker) const virtual

void sendStatisticsToProducer(const Message& message) const virtual

void sendMessageToNextWorker(const Message& message) const virtual

void getNextWorkMessage(Message& message) const virtual

void getNextWriteMessage(Message& message) const virtual

void sendToWriter(int writer, const Message& message) const virtual

void sendShutDownMessage() const virtual

Private functions

void run() virtual

void getNextMessage(Message& message) const pure virtual

Enum documentation

Function documentation