Versions in this module Expand all Collapse all v0 v0.1.0 Apr 22, 2026 Changes in this version + type MockBroker struct + func NewMockBroker() *MockBroker + func (m *MockBroker) AssertNotPublished(t testing.TB, destination string) + func (m *MockBroker) AssertPublishCount(t testing.TB, destination string, expected int) + func (m *MockBroker) AssertPublished(t testing.TB, destination string) + func (m *MockBroker) Backend() string + func (m *MockBroker) Call(ctx context.Context, destination string, msg *core.Message, ...) (*core.Message, error) + func (m *MockBroker) Close() error + func (m *MockBroker) Connect(ctx context.Context) error + func (m *MockBroker) HasSubscription(destination string) bool + func (m *MockBroker) IsConnected() bool + func (m *MockBroker) IsRecovering() bool + func (m *MockBroker) Publish(ctx context.Context, destination string, msg *core.Message, ...) error + func (m *MockBroker) PublishedMessages() []PublishedMessage + func (m *MockBroker) PublishedTo(destination string) []PublishedMessage + func (m *MockBroker) Reset() + func (m *MockBroker) SetCallError(destination string, err error) + func (m *MockBroker) SetCallResponse(destination string, response *core.Message) + func (m *MockBroker) SimulateMessage(ctx context.Context, destination string, msg *core.Message) error + func (m *MockBroker) Subscribe(ctx context.Context, destination string, handler core.Handler, ...) error + func (m *MockBroker) Subscriptions() []string + type PublishedMessage struct + Destination string + Message *core.Message
Go to main page