type RMRStatistics struct{}
type RMRClient struct {
- context unsafe.Pointer
- ready int
- wg sync.WaitGroup
- mux sync.Mutex
- stat map[string]Counter
- consumers []MessageConsumer
- readyCb ReadyCB
+ context unsafe.Pointer
+ ready int
+ wg sync.WaitGroup
+ mux sync.Mutex
+ stat map[string]Counter
+ consumers []MessageConsumer
+ readyCb ReadyCB
+ readyCbParams interface{}
}
type MessageConsumer interface {
}
if m.readyCb != nil {
- m.readyCb()
+ m.readyCb(m.readyCbParams)
}
m.Wait()
return m.ready != 0
}
-func (m *RMRClient) SetReadyCB(cb ReadyCB) {
+func (m *RMRClient) SetReadyCB(cb ReadyCB, params interface{}) {
m.readyCb = cb
+ m.readyCbParams = params
}
func (m *RMRClient) GetRicMessageId(name string) (int, bool) {