@synchronized(lock)<EOL><INDENT>def send(self, message):<DEDENT>
dest = message.headers.get('<STR_LIT>')<EOL>if not dest:<EOL><INDENT>raise ValueError(<EOL>"<STR_LIT>" % message)<EOL><DEDENT>message.cmd = '<STR_LIT:message>'<EOL>message.headers.setdefault('<STR_LIT>', str(uuid.uuid4()))<EOL>bad_subscribers = set()<EOL>for subscriber in self._topics[dest]:<EOL><INDENT>try:<EOL><INDENT>subscriber.send_frame(message)<EOL><DEDENT>except:<EOL><INDENT>self.log.exception(<EOL>"<STR_LIT>" % subscriber)<EOL>bad_subscribers.add(subscriber)<EOL><DEDENT><DEDENT>for subscriber in bad_subscribers:<EOL><INDENT>self.disconnect(subscriber)<EOL><DEDENT>
Sends a message to all subscribers of destination.

@param message: The message frame.  (The frame will be modified to set command 
                    to MESSAGE and set a message id.)
@type message: L{stompclient.frame.Frame}