// Listen starts the pipe's listener
Listen starts the pipe's listener
// Listen starts the pipe ' s listener
func (m *Mongodb) Listen() (err error) {
	defer func() {
		m.pipe.Stop()
	}()
	if m.bulk {
		go m.bulkWriter()
	}
	return m.pipe.Listen(m.writeMessage, m.collectionMatch)
}
func ( m * Mongodb ) Listen ( ) ( err error ) { defer func ( ) { m . pipe . Stop ( ) } ( ) if m . bulk { go m . bulkWriter ( ) } return m . pipe . Listen ( m . writeMessage , m . collectionMatch ) }
Listen starts the pipe's listener
Listen starts the pipe ' s listener