def emit(self, tup, tup_id=None, stream=Stream.DEFAULT_STREAM_ID,<EOL>direct_task=None, need_task_ids=None):
<EOL>self.tuples_to_complete += <NUM_LIT:1><EOL>if tup_id is None:<EOL><INDENT>Log.info("<STR_LIT>" % str(tup))<EOL>_tup_id = integ_const.INTEGRATION_TEST_MOCK_MESSAGE_ID<EOL><DEDENT>else:<EOL><INDENT>_tup_id = tup_id<EOL><DEDENT>super(IntegrationTestSpout, self).emit(tup, _tup_id, stream, direct_task, need_task_ids)<EOL>
Emits from this integration test spout

        Overriden method which will be called when user's spout calls emit()