- new Thread(new Connection(source) {
-
- @Override
- protected int bufferSize() {
- return sourceMetadata.channels() * sourceMetadata.frequency() * 2;
- }
-
- @Override
- protected void feed(byte[] buffer) {
- sourceDataLine.write(buffer, 0, buffer.length);
- logger.finest(String.format("AudioSink: Wrote %d Bytes.", buffer.length));
- }
-
- @Override
- protected void finish() {
- sourceDataLine.stop();
- }
- }).start();
- metadataUpdated();
- } catch (LineUnavailableException lue1) {
- throw new ConnectException(lue1);