func (q ConnectionQueryApi) FindAllConnection() error {
	return q.connectionRepository.FindAll()
}
 func (q ConnectionQueryApi) FindConnection(connID string) error {
	return q.connectionRepository.Find(connID)
}

type ConnectionEventListener struct {
	connectionRepository ConnectionRepository
}
 func NewConnectionEventListener(connRepository connRepository) ConnectionEventListener {
	return ConnectionEventListener{
		connectionRepository: connRepository,
	}
}

 func (cel *ConnectionEventListener) HandleConnectionCreatedEvent(event event.ConnectionCreated) error {
	connection := Connection{
		ConnectionID: event.ConnectionID,
		Address:      event.Address,
	}
 	err := cel.connRepository.Save(connection)
	if err != nil {
		return err
	}
	return nil
}
 func (cel *ConnectionEventListener) HandleConnectionClosedEvent(event event.ConnectionClosed) error {
	cel.connRepository.Remove(event.ConnectionID)
	return nil
}