#NEWLINE# def handleCompleteMultiBulkData( self , reply ) : #NEWLINE# #INDENT# '\n        Overrides RedisBase.handleCompleteMultiBulkData to intercept published\n        message events.\n        ' #NEWLINE# if ( reply [ 0 ] == 'message' ) : #NEWLINE# #INDENT# ( channel , message ) = reply [ 1 : ] #NEWLINE# self . messageReceived ( channel , message ) #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# if ( reply [ 0 ] == 'pmessage' ) : #NEWLINE# #INDENT# ( pattern , channel , message ) = reply [ 1 : ] #NEWLINE# self . messageReceived ( channel , message ) #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# if ( reply [ 0 ] == 'subscribe' ) : #NEWLINE# #INDENT# ( channel , numSubscribed ) = reply [ 1 : ] #NEWLINE# self . channelSubscribed ( channel , numSubscribed ) #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# if ( reply [ 0 ] == 'unsubscribe' ) : #NEWLINE# #INDENT# ( channel , numSubscribed ) = reply [ 1 : ] #NEWLINE# self . channelUnsubscribed ( channel , numSubscribed ) #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# if ( reply [ 0 ] == 'psubscribe' ) : #NEWLINE# #INDENT# ( channelPattern , numSubscribed ) = reply [ 1 : ] #NEWLINE# self . channelPatternSubscribed ( channelPattern , numSubscribed ) #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# if ( reply [ 0 ] == 'punsubscribe' ) : #NEWLINE# #INDENT# ( channelPattern , numSubscribed ) = reply [ 1 : ] #NEWLINE# self . channelPatternUnsubscribed ( channelPattern , numSubscribed ) #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# RedisBase . handleCompleteMultiBulkData ( self , reply )