@synchronized(lock)<EOL><INDENT>def subscribe(self, connection, destination):<DEDENT>
self.log.debug("<STR_LIT>" % (connection, destination))<EOL>self._topics[destination].add(connection)<EOL>
Subscribes a connection to the specified topic destination. 

@param connection: The client connection to subscribe.
@type connection: L{coilmq.server.StompConnection}

@param destination: The topic destination (e.g. '/topic/foo')
@type destination: C{str}