queue_go/queue_test.go

package queue

import (
	"fmt"
	"loafle.com/overflow/agent_api/observer"
	"testing"
)

func TestNewQueue(t *testing.T) {
	lq := NewQueue(observer.DATA_QUEUE, 5)

	observer.Notify(observer.DATA_QUEUE.String(), "data")

	re := lq.GetItems()

	for it, val := range re {
		fmt.Println(val)
		fmt.Println(it)
	}
}