diff --git a/stream/rtp/encoder.go b/stream/rtp/encoder.go
index becb9c6e..527d8c6f 100644
--- a/stream/rtp/encoder.go
+++ b/stream/rtp/encoder.go
@@ -114,7 +114,7 @@ type Encoder struct {
 // NewEncoder returns a new Encoder type given an io.Writer - the destination
 // after encoding and the desired fps
 func NewEncoder(dst io.Writer, fps int) *Encoder {
-	q := &Queue{}
+	q, _ := NewQueue(bufferSize, mtsSize)
 	return &Encoder{
 		dst:           dst,
 		ssrc:          rand.Uint32(),