brokers

type NsqBroker struct {
	// contains filtered or unexported fields
}

type StandardBroker interface {
	Publish(message protocol.ProtoMessage) error
	//Receive() (protocol.ProtoMessage, error)
	Processing(protocol.Processor) error
}