soa/logger/callback_output.h

/* callback_output.h                                                -*- C++ -*-
   Jeremy Barnes, 29 May 2011
   Copyright (c) 2011 Datacratic.  All rights reserved.

   Output that callbacks on a zeromq socket.
*/

#ifndef __logger__callback_output_h__
#define __logger__callback_output_h__

#include "logger.h"

namespace Datacratic {

/*****************************************************************************/
/* CALLBACK OUTPUT                                                           */
/*****************************************************************************/

struct CallbackOutput : public LogOutput {

    typedef boost::function<void (std::string, std::string)> Callback;

    CallbackOutput(const Callback & callback);

    virtual ~CallbackOutput();

    virtual void logMessage(const std::string & channel,
                            const std::string & message);

    virtual void close();

    Callback callback;
};




} // namespace Datacratic


#endif /* __logger__callback_output_h__ */