StreamUtils.writeString(output, b);
output.flush();
}</BUG>
public void broadcastMessage(final byte[] message, final long checksum) throws IOException {
final StringBuilder b = new StringBuilder();
<BUG>b.append(Command.BROADCAST_BYTES).append('\0');
StreamUtils.writeString(output, b);</BUG>
output.write(message.length);
output.write(message);
StreamUtils.writeLong(output, checksum);

StreamUtils.writeString(output, b);
output.flush();
}
}
public void broadcastMessage(final byte[] message, final long checksum) throws IOException {
final StringBuilder b = new StringBuilder();
b.append(Command.BROADCAST_BYTES).append('\0');
synchronized (output) {
StreamUtils.writeString(output, b);
output.write(message.length);
output.write(message);
StreamUtils.writeLong(output, checksum);
