|
|
@ -84,6 +84,12 @@ func (m *syncInboundHandlerManager) Close() error {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
func (m *syncInboundHandlerManager) Set(manager InboundHandlerManager) {
|
|
|
|
func (m *syncInboundHandlerManager) Set(manager InboundHandlerManager) {
|
|
|
|
|
|
|
|
if manager == nil {
|
|
|
|
|
|
|
|
return
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
m.Close()
|
|
|
|
|
|
|
|
|
|
|
|
m.Lock()
|
|
|
|
m.Lock()
|
|
|
|
defer m.Unlock()
|
|
|
|
defer m.Unlock()
|
|
|
|
|
|
|
|
|
|
|
@ -161,6 +167,11 @@ func (m *syncOutboundHandlerManager) Close() error {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
func (m *syncOutboundHandlerManager) Set(manager OutboundHandlerManager) {
|
|
|
|
func (m *syncOutboundHandlerManager) Set(manager OutboundHandlerManager) {
|
|
|
|
|
|
|
|
if manager == nil {
|
|
|
|
|
|
|
|
return
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
m.Close()
|
|
|
|
m.Lock()
|
|
|
|
m.Lock()
|
|
|
|
defer m.Unlock()
|
|
|
|
defer m.Unlock()
|
|
|
|
|
|
|
|
|
|
|
|