func unSubscribeTo(w http.ResponseWriter, r *http.Request) {
	pipe := context.Get(r, "pipe").(string)
	channel := context.Get(r, "channel").(string)
	session := context.Get(r, "session").(*core.UserSession)
	core.StopListen(pipe, channel, session)
	EasyResponse(w, core.NebErrorNone, "unSubscribed from "+channel)
}
User connected, form value: pipe, channel
package handlers
import (
	"fmt"
	"github.com/Nebuleuse/Nebuleuse/core"
	"github.com/gorilla/context"
	"net/http"
	"time"
)
func subscribeTo(w http.ResponseWriter, r *http.Request) {
	pipe := context.Get(r, "pipe").(string)
	channel := context.Get(r, "channel").(string)
	session := context.Get(r, "session").(*core.UserSession)
		core.Listen(pipe, channel, session)
	EasyResponse(w, core.NebErrorNone, "subscribed to "+channel)
}