func (s *Storage) OnGet(p *GetRequestPacket) {
	msgs := s.queue.Find(p.Since)
	p.Data = msgs
	s.Out <- p.RequestPacket
}
Gets messages from the store and sends the to out
package main
import (
	"github.com/trustmaster/goflow"
	"net/http"
)
const DefaultQueueCapacity int = 50
type Storage struct {
	flow.Component
	MaxLen <-chan int
	Get    <-chan *GetRequestPacket
	Post   <-chan *PostRequestPacket
	Out    chan<- *RequestPacket
	queue *Queue
}
func NewStorage() *Storage {
	s := new(Storage)
	s.queue = NewQueue(DefaultQueueCapacity)
	return s
}
func (s *Storage) OnMaxLen(ml int) {
	s.queue.SetMaxLen(ml)
}