manfilter.cc

Go to the documentation of this file.

 
/* LABEL-START */
 
#include  "debug_mq.h"
#include  "LibMqMsgque_cc.hh"
 
/* LABEL-END */
 
#include "LibMqMsgque_cc.hh"
 
using namespace ccmqmsgque;
 
class manfilter : public MqContextC {
  public:
    void fFTR () {
      MqContextC *ftr = SlaveGetFilter();
      MkBufferC temp;
      ftr->SendSTART();
      while (ReadItemExists()) {
        ftr->SendBUF(temp.SetV("<%s>", ReadSTR()));
      }
      ftr->SendEND_AND_WAIT("+FTR");
      return SendRETURN();
    }
};
 
int MK_CDECL main (int argc, MK_STRN argv[])
{
  MqMsgque::CcMqSetup();
  static manfilter filter;
  try {
    filter.ConfigSetName ("manfilter");
    filter.ConfigSetIsServer (true);
    filter.LinkCreate(MkBufferListC {argc, argv});
    filter.ServiceCreate("+FTR", MqContextC::MqServiceICB(&manfilter::fFTR));
    filter.ServiceProxy ("+EOF");
    filter.ProcessEvent (MQ_WAIT_FOREVER);
  } catch (const std::exception& e) {
    filter.ErrorCatch(e);
  }
  return filter.Exit();
}