(subject, queue string, handler func([]byte))
| 246 | } |
| 247 | |
| 248 | func (f *failOnceMessagingClient) QueueSubscribe(subject, queue string, handler func([]byte)) (messaging.Subscription, error) { |
| 249 | return f.inner.QueueSubscribe(subject, queue, handler) |
| 250 | } |
| 251 | |
| 252 | func (f *failOnceMessagingClient) QueueSubscribeReply(subject, queue string, handler func(data []byte, reply func([]byte))) (messaging.Subscription, error) { |
| 253 | return f.inner.QueueSubscribeReply(subject, queue, handler) |
nothing calls this directly
no test coverage detected