INNER CODE UNIT · Go

NewMockConsumer

owlistic-notes/owlistic · src/backend/broker/consumer_test.go:17

func NewMockConsumer() *MockConsumer {
	topic := "mock_topic"
	return &MockConsumer{
		messages: []*nats.Msg{
			{
				Subject: topic,
				Data: []byte("mock_value"),
			},
		},
	}
}

func (m *MockConsumer) ReadMessage(timeoutMs int) (*nats.Msg, error) {
	if m.closed {
		// Use a standard error code instead of ErrConsumerClosed which doesn't exist
		return nil, nats.ErrConnectionClosed
	}

View source record →