'Called when a component connection was made.
This enables traffic debugging on incoming streams.'

def onConnectionMade(self, xs):

    xs.serial = self.serial
    self.serial += 1
    def logDataIn(buf):
        log.msg(('RECV    (%d):    %r' % (xs.serial, buf)))
    def logDataOut(buf):
        log.msg(('SEND    (%d):    %r' % (xs.serial, buf)))
    if self.logTraffic:
        xs.rawDataInFn = logDataIn
        xs.rawDataOutFn = logDataOut
    xs.addObserver(xmlstream.STREAM_ERROR_EVENT, self.onError)
