()
| 66 | } |
| 67 | |
| 68 | func (b *BrokerType) GetClient() Client { |
| 69 | b.Lock.Lock() |
| 70 | defer b.Lock.Unlock() |
| 71 | return b.Client |
| 72 | } |
| 73 | |
| 74 | // if already subscribed, this will *resubscribe* with the new subscription (remove the old one, and replace with this one) |
| 75 | func (b *BrokerType) Subscribe(subRouteId string, sub SubscriptionRequest) { |
no outgoing calls
no test coverage detected