test.js

var
sys = require("sys"),
flow = require("../vendor/flow"),
redis = require("../vendor/redis-client");

function log(what) {
    sys.log("[ext:test] " + what);
}

exports.init_extension = function (options, context) {
    log("initializing.");

    var func_name = 'on_PUBLISH';

    var handlers = our.dispatch._handlers;

    var n = handlers.length;
    for (var i=0; i<n; ++i) {
        var handler = handlers[i];
        if (handler.hasOwnProperty(func_name) &&
            typeof handler[func_name] == "function") {

            var oldPublish = handler[func_name];

            handler[func_name] = function (client, request, callback) {
                access = false; // or true - do your logic here :)
                if (access) {
                    return oldPublish(client,request,callback);
                } else {
                    client.respond(false);
                    process.nextTick(callback);
                }
            }

        }
    }

};

exports.deinit_extension = function (context, callback) {
    log("deinitializing.");
    process.nextTick(callback);
};