mock

package

v1.0.0 Latest Latest Go to latest Published: Feb 12, 2026 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation ¶

This section is empty.

This section is empty.

This section is empty.

type MockMessageBus struct {
	Messages []string
	// contains filtered or unexported fields
}

MockMessageBus is a mock that implements the Messagebus interface.

For now, it doesn't do anything with the queue name. All messages sent are appended to the Messages slice.

func NewMockMessageBus() *MockMessageBus

NewMockMessageBus creates a new MockMessageBus instance

func (mb *MockMessageBus) AddQueueMessage(queue string, msg string)

AddQueueMessage adds a message to a specific queue (for test setup)

func (mb *MockMessageBus) Close() error

func (mb *MockMessageBus) GetMessages(queue string) []string

GetMessages returns messages sent to a specific queue

func (mb *MockMessageBus) ReceiveMessage(message chan<- string, queue string) (messagebus.Subscription, error)

func (mb *MockMessageBus) SendMessage(message []byte, queue string) error

func (mb *MockMessageBus) SendMessageWithHeaders(message []byte, queue string, headers map[string]string) error

func (mb *MockMessageBus) SetReplyMessage(msg string)

SetReplyMessage is deprecated - use SetReplyPayload instead

func (mb *MockMessageBus) SetReplyPayload(payload any)

SetReplyPayload sets the payload that will be used to reply to requests

func (mb *MockMessageBus) SetSendError(err error)

SetSendError sets an error to be returned by SendMessage

type MockSubscription struct {
	// contains filtered or unexported fields
}

func (ms MockSubscription) Close() error