Function NewInMemoryMessageQueue

pkg/runtime/message_queue.go:53–55

NewInMemoryMessageQueue creates a MessageQueue backed by a buffered channel with the given capacity.

(capacity int)

// NewInMemoryMessageQueue creates a MessageQueue backed by a buffered channel
// with the given capacity.
func NewInMemoryMessageQueue(capacity int) MessageQueue {
	return &inMemoryMessageQueue{ch: make(chan QueuedMessage, capacity)}
}

func (q *inMemoryMessageQueue) Enqueue(_ context.Context, msg QueuedMessage) bool {
	select {