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

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

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