org.mobicents.media.server.impl
Class AbstractSink

java.lang.Object
  org.mobicents.media.server.impl.BaseComponent
      org.mobicents.media.server.impl.AbstractSink

All Implemented Interfaces:

java.io.Serializable, org.mobicents.media.Component, org.mobicents.media.MediaSink

Direct Known Subclasses:

AbstractSinkSet, DtmfBuffer, EchoSink, MeanderDetector, MixerInputStream, MultiFreqToneDetectorImpl, PhoneSignalDetector, PlayerImpl, RecorderImpl, SendStream, SpectraAnalyzer, TestSink

public abstract class AbstractSink
extends BaseComponent
implements org.mobicents.media.MediaSink

The base implementation of the media sink. AbstractSource and AbstractSink are implement general wirring contruct. All media components have to extend one of these classes.

Author:

Oleg Kulikov

See Also:

Serialized Form

Field Summary

protected org.mobicents.media.MediaSource

otherParty

Constructor Summary

AbstractSink(java.lang.String name)
Creates new instance of sink with specified name.

Method Summary

void	connect(org.mobicents.media.MediaSource otherParty) (Non Java-doc).
void	connect(org.mobicents.media.Outlet outlet)
void	disconnect(org.mobicents.media.MediaSource otherParty) (Non Java-doc).
void	disconnect(org.mobicents.media.Outlet outlet)
protected void	failed(int eventID, java.lang.Exception e) Sends failure notification.
long	getBytesReceived() (Non Java-doc).
long	getPacketsReceived() (Non Java-doc).
boolean	isConnected() (Non Java-doc).
boolean	isMultipleConnectionsAllowed()
boolean	isStarted() (Non Java-doc).
abstract void	onMediaTransfer(org.mobicents.media.Buffer buffer) This methos is called when new portion of media arrives.
void	receive(org.mobicents.media.Buffer buffer) (Non Java-doc).
void	resetStats()
void	start() (Non Java-doc).
protected void	started() Sends notification that media processing has been started.
void	stop() (Non Java-doc).
protected void	stopped() Sends notification that detection is terminated.

Methods inherited from class org.mobicents.media.server.impl.BaseComponent

addListener, getConnection, getEndpoint, getId, getName, getResourceType, removeListener, sendEvent, setConnection, setEndpoint, setResourceType, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.mobicents.media.MediaSink

getFormats, isAcceptable

Methods inherited from interface org.mobicents.media.Component

addListener, getConnection, getEndpoint, getId, getName, removeListener, setConnection, setEndpoint

Field Detail

otherParty

protected transient org.mobicents.media.MediaSource otherParty

Constructor Detail

AbstractSink

public AbstractSink(java.lang.String name)

Creates new instance of sink with specified name.

Parameters:

name - the name of the sink to be created.

Method Detail

isMultipleConnectionsAllowed

public boolean isMultipleConnectionsAllowed()

Specified by:

isMultipleConnectionsAllowed in interface org.mobicents.media.MediaSink

connect

public void connect(org.mobicents.media.MediaSource otherParty)

(Non Java-doc).

Specified by:

connect in interface org.mobicents.media.MediaSink

See Also:

org.mobicents.media.MediaSink#connect(MediaStream).

disconnect

public void disconnect(org.mobicents.media.MediaSource otherParty)

(Non Java-doc).

Specified by:

disconnect in interface org.mobicents.media.MediaSink

See Also:

org.mobicents.media.MediaSink#disconnect(MediaStream).

connect

public void connect(org.mobicents.media.Outlet outlet)

Specified by:

connect in interface org.mobicents.media.MediaSink

disconnect

public void disconnect(org.mobicents.media.Outlet outlet)

Specified by:

disconnect in interface org.mobicents.media.MediaSink

isConnected

public boolean isConnected()

(Non Java-doc).

Specified by:

isConnected in interface org.mobicents.media.MediaSink

See Also:

MediaSink.isConnected().

isStarted

public boolean isStarted()

(Non Java-doc).

Specified by:

isStarted in interface org.mobicents.media.MediaSink

See Also:

MediaSink.isStarted().

onMediaTransfer

public abstract void onMediaTransfer(org.mobicents.media.Buffer buffer)
                              throws java.io.IOException

This methos is called when new portion of media arrives.

Parameters:

buffer - the new portion of media data.

Throws:

java.io.IOException

start

public void start()

(Non Java-doc).

Specified by:

start in interface org.mobicents.media.Component

See Also:

Component.start().

stop

public void stop()

(Non Java-doc).

Specified by:

stop in interface org.mobicents.media.Component

See Also:

Component.stop().

receive

public void receive(org.mobicents.media.Buffer buffer)
             throws java.io.IOException

(Non Java-doc).

Specified by:

receive in interface org.mobicents.media.MediaSink

Throws:

java.io.IOException

See Also:

org.mobicents.media.MediaSink#receive().

failed

protected void failed(int eventID,
                      java.lang.Exception e)

Sends failure notification.

Parameters:

eventID - failure event identifier.

e - the exception caused failure.

getPacketsReceived

public long getPacketsReceived()

(Non Java-doc).

Specified by:

getPacketsReceived in interface org.mobicents.media.MediaSink

See Also:

MediaSink.getPacketsReceived().

getBytesReceived

public long getBytesReceived()

(Non Java-doc).

Specified by:

getBytesReceived in interface org.mobicents.media.MediaSink

See Also:

MediaSink.getBytesReceived()

resetStats

public void resetStats()

Specified by:

resetStats in interface org.mobicents.media.Component

Overrides:

resetStats in class BaseComponent

started

protected void started()

Sends notification that media processing has been started.

stopped

protected void stopped()

Sends notification that detection is terminated.