Intitial mod_event_zmq code
This commit is contained in:
parent
e4e879affb
commit
4d55406717
|
@ -0,0 +1,27 @@
|
|||
BASE=../../../..
|
||||
|
||||
ZMQ=zeromq-2.1.3
|
||||
|
||||
ZMQ_BASEURL=http://download.zeromq.org
|
||||
|
||||
ZMQ_DIR=$(switch_srcdir)/libs/$(ZMQ)
|
||||
ZMQ_BUILDDIR=$(switch_builddir)/libs/$(ZMQ)
|
||||
LOCAL_CFLAGS=-I$(ZMQ_DIR)/include
|
||||
ZMQ_LA=$(ZMQ_BUILDDIR)/src/libzmq.la
|
||||
LOCAL_LIBADD=$(ZMQ_LA)
|
||||
|
||||
include $(BASE)/build/modmake.rules
|
||||
|
||||
$(ZMQ_DIR):
|
||||
$(GETLIB) $(ZMQ_BASEURL) $(ZMQ).tar.gz
|
||||
cd $(ZMQ_DIR) && ./autogen.sh
|
||||
|
||||
$(ZMQ_BUILDDIR)/Makefile: $(ZMQ_DIR)
|
||||
mkdir -p $(ZMQ_DIR)
|
||||
cd $(ZMQ_BUILDDIR) && $(DEFAULT_VARS) $(ZMQ_DIR)/configure $(DEFAULT_ARGS) --srcdir=$(ZMQ_DIR)
|
||||
$(TOUCH_TARGET)
|
||||
|
||||
$(ZMQ_LA): $(ZMQ_BUILDDIR)/Makefile
|
||||
cd $(ZMQ_BUILDDIR) && $(MAKE)
|
||||
$(TOUCH_TARGET)
|
||||
|
|
@ -0,0 +1,124 @@
|
|||
#include <switch.h>
|
||||
#include <zmq.hpp>
|
||||
#include <string>
|
||||
#include <exception>
|
||||
#include <stdexcept>
|
||||
#include <memory>
|
||||
|
||||
namespace mod_event_zmq {
|
||||
|
||||
SWITCH_MODULE_LOAD_FUNCTION(load);
|
||||
SWITCH_MODULE_SHUTDOWN_FUNCTION(shutdown);
|
||||
SWITCH_MODULE_RUNTIME_FUNCTION(runtime);
|
||||
|
||||
extern "C" {
|
||||
SWITCH_MODULE_DEFINITION(mod_event_zmq, load, shutdown, runtime);
|
||||
};
|
||||
|
||||
class ZmqStringMessage : public zmq::message_t {
|
||||
public:
|
||||
ZmqStringMessage(const std::string &msg) {
|
||||
|
||||
}
|
||||
};
|
||||
|
||||
// Handles publishing events out to clients
|
||||
class ZmqEventPublisher {
|
||||
public:
|
||||
ZmqEventPublisher() :
|
||||
context(1),
|
||||
event_publisher(context, ZMQ_PUB)
|
||||
{
|
||||
event_publisher.bind("tcp://*.5556");
|
||||
}
|
||||
|
||||
void PublishEvent(const switch_event_t *event) {
|
||||
char* pjson;
|
||||
switch_event_serialize_json(const_cast<switch_event_t*>(event), &pjson);
|
||||
std::auto_ptr<char> json(pjson);
|
||||
|
||||
ZmqStringMessage msg(json.get());
|
||||
event_publisher.send(msg);
|
||||
}
|
||||
|
||||
private:
|
||||
zmq::context_t context;
|
||||
zmq::socket_t event_publisher;
|
||||
};
|
||||
|
||||
// Handles global inititalization and teardown of the module
|
||||
class ZmqModule {
|
||||
public:
|
||||
ZmqModule(switch_loadable_module_interface_t **module_interface, switch_memory_pool_t *pool) {
|
||||
// Subscribe to all switch events of any subclass
|
||||
// Store a pointer to ourself in the user data
|
||||
if (switch_event_bind_removable(modname, SWITCH_EVENT_ALL, SWITCH_EVENT_SUBCLASS_ANY, event_handler, (void*)this, &_node)
|
||||
!= SWITCH_STATUS_SUCCESS) {
|
||||
throw std::runtime_error("Couldn't bind to switch events.");
|
||||
}
|
||||
|
||||
// Create our module interface registration
|
||||
*module_interface = switch_loadable_module_create_module_interface(pool, modname);
|
||||
}
|
||||
|
||||
void Listen() {
|
||||
_publisher.reset(new ZmqEventPublisher());
|
||||
}
|
||||
|
||||
~ZmqModule() {
|
||||
// Unsubscribe from the switch events
|
||||
switch_event_unbind(&_node);
|
||||
}
|
||||
|
||||
private:
|
||||
// Dispatches events to the publisher
|
||||
static void event_handler(switch_event_t *event) {
|
||||
try {
|
||||
ZmqModule *module = (ZmqModule*)event->bind_user_data;
|
||||
if(module->_publisher.get())
|
||||
module->_publisher->PublishEvent(event);
|
||||
} catch(std::exception ex) {
|
||||
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_WARNING, "Error publishing event via 0MQ: %s\n", ex.what());
|
||||
}
|
||||
}
|
||||
|
||||
switch_event_node_t *_node;
|
||||
std::auto_ptr<ZmqEventPublisher> _publisher;
|
||||
};
|
||||
|
||||
//*****************************//
|
||||
// GLOBALS //
|
||||
//*****************************//
|
||||
std::auto_ptr<ZmqModule> module;
|
||||
|
||||
|
||||
//*****************************//
|
||||
// Module interface funtions //
|
||||
//*****************************//
|
||||
SWITCH_MODULE_LOAD_FUNCTION(load) {
|
||||
try {
|
||||
module.reset(new ZmqModule(module_interface, pool));
|
||||
return SWITCH_STATUS_SUCCESS;
|
||||
} catch(const std::exception &ex) {
|
||||
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Error loading 0MQ module: %s\n", ex.what());
|
||||
return SWITCH_STATUS_GENERR;
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
SWITCH_MODULE_RUNTIME_FUNCTION(runtime) {
|
||||
try {
|
||||
// Begin listening for clients
|
||||
module->Listen();
|
||||
} catch(...) { }
|
||||
|
||||
// Tell the switch to stop calling this runtime loop
|
||||
return SWITCH_STATUS_FALSE;
|
||||
}
|
||||
|
||||
SWITCH_MODULE_SHUTDOWN_FUNCTION(shutdown) {
|
||||
// Free the module object
|
||||
module.reset();
|
||||
}
|
||||
|
||||
}
|
Loading…
Reference in New Issue