protocol

type Params struct {
	Type  string
	Value interface{}
}

type Processor interface {
	Process(*ProtoMessage) error
}

type ProtoMessage struct {
	UUID       string
	Name       string
	RoutingKey string
	ETA        *time.Time
	Headers    Protocol
	Args       []Params
	// contains filtered or unexported fields
}

type Protocol map[string]interface{}

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