func (w *Workmq) GetProcessor(name string) (Processor, error) {
	if _, ok := w.Processors[name]; !ok {
		return nil, fmt.Errorf("Unable to find processor '%s'", name)
	}
	return w.Processors[name], nil
}
GetProcessor retrieves a processor from its name
package workmq
import "fmt"
type Processor func(worker *Worker, message Message)
func (w *Workmq) AddProcessor(name string, processor Processor) {
	w.Processors[name] = processor
}