Method SetNotifier

mockbroker.go:113–117

SetNotifier set a function that will get invoked whenever a request has been processed successfully and will provide the number of bytes read and written

(notifier RequestNotifierFunc)

// SetNotifier set a function that will get invoked whenever a request has been
// processed successfully and will provide the number of bytes read and written
func (b *MockBroker) SetNotifier(notifier RequestNotifierFunc) {
	b.lock.Lock()
	b.notifier = notifier
	b.lock.Unlock()
}

// BrokerID returns broker ID assigned to the broker.
func (b *MockBroker) BrokerID() int32 {