is initialized

is_initialized.go

type MessengerFactory struct {
    factory.MessengerFactory
    isInitialized bool
}

func (m *MessengerFactory) IsInitialized() bool { return m.isInitialized }

func (m *MessengerFactory) Connect(address string) (conn *Connection, err error) {
    return m.ConnectWithConfig(address, nil)
}

func (m *MessengerFactory) ConnectWithConfig(address string, config *ConnConfig) (conn *Connection, err error) {
    if conn, err = m.MessengerFactory.ConnectWithConfig(address, config); err == nil {
        m.isInitialized = true
    }
    return
}

func (m *MessengerFactory) Listen(address string) (err error) {
    if err = m.MessengerFactory.Listen(address); err == nil {
        m.isInitialized = true
    }
    return
}

func (m *MessengerFactory) ForEachConn(fn func(connection *Connection)) {
    if m.isInitialized == false {
        return
    }
    m.MessengerFactory.ForEachConn(fn)
}