// --- cut from here... --- //
// First find a capture device that will capture linear audio
// data at 8bit 8Khz
AudioFormat format= new AudioFormat(AudioFormat.LINEAR,
8000,
8,
1);
Vector devices= CaptureDeviceManager.getDeviceList( format);
CaptureDeviceInfo di= null;
if (devices.size() > 0) {
di = (CaptureDeviceInfo) devices.elementAt( 0);
}
else {
// exit if we could not find the relevant capturedevice.
System.exit(-1);
}
// Now create a processor for this capturedevice & exit if we
// cannot create it
try {
Processor p = Manager.createProcessor(di.getLocator());
} catch (IOException e) {
System.exit(-1);
} catch (NoProcessorException e) {
System.exit(-1);
}
// configure the processor
processor.configure();
// block until it has been configured
processor.setContentDescriptor(
new ContentDescriptor( ContentDescriptor.RAW));
TrackControl track[] = processor.getTrackControls();
boolean encodingOk = false;
// Go through the tracks and try to program one of them to
// output gsm data.
for (int i = 0; i < track.length; i++) {
if (!encodingOk && track[i] instanceof FormatControl) {
if (((FormatControl)track[i]).
setFormat( new AudioFormat(AudioFormat.GSM_RTP,
8000,
8,
1)) == null) {
track[i].setEnabled(false);
}
else {
encodingOk = true;
}
}
else {
// we could not set this track to gsm, so disable it
track[i].setEnabled(false);
}
}
// At this point, we have determined where we can send out
// gsm data or not.
// realize the processor
if (encodingOk) {
processor.realize();
// block until realized.
// get the output datasource of the processor and exit
// if we fail
DataSource origDataSource = null;
try {
origDataSource = processor.getDataOutput();
} catch (NotRealizedError e) {
System.exit(-1);
}
// We want to send the stream of this datasource over two
// RTP sessions.
// So we need to clone the output datasource of the
// processor and hand the clone over to the second
// SessionManager
DataSource cloneableDataSource = null;
DataSource clonedDataSource = null;
cloneableDataSource
= Manager.createCloneableDataSource(origDataSource);
clonedDataSource
= ((SourceCloneable)cloneableDataSource).createClone();
// Now create the first SessionManager and hand over the
// first datasource for SendStream creation.
SessionManager rtpsm1
= new com.sun.media.rtp.RTPSessionMgr();
// rtpsm1.initSession(...);
// rtpsm1.startSession(...);
try {
rtpsm1.createSendStream(cloneableDataSource, // 1st datasource
0);
} catch (IOException e) {
e.printStackTrace();
} catch( UnsupportedFormatException e) {
e.printStackTrace();
}
try {
cloneableDataSource.connect();
cloneableDataSource.start();
} catch (IOException e) {
e.printStackTrace();
}
// create the second RTPSessionMgr and hand over the
// cloned datasource
if (clonedDataSource != null) {
SessionManager rtpsm2
= new com.sun.media.rtp.RTPSessionMgr();
// rtpsm2.initSession(...);
// rtpsm2.startSession(...);
try {
rtpsm2.createSendStream(clonedDataSource,0);
} catch (IOException e) {
e.printStackTrace();
} catch( UnsupportedFormatException e) {
e.printStackTrace();
}
}
}
else {
// we failed to set the encoding to gsm. So deallocate
// and close the processor before we leave.
processor.deallocate();
processor.close();
}
// --- ...until here --- //
