Package io.antmedia.webrtc.adaptor

Class Adaptor

java.lang.Object

io.antmedia.webrtc.adaptor.Adaptor

All Implemented Interfaces:

PeerConnection.Observer, SdpObserver

Direct Known Subclasses:

RTMPAdaptor

public abstract class Adaptor
extends Object
implements PeerConnection.Observer, SdpObserver

Field Summary

Fields

Modifier and Type	Field	Description
protected static final org.slf4j.Logger	log
protected PeerConnection	peerConnection
protected PeerConnectionFactory	peerConnectionFactory
private MediaConstraints	sdpMediaConstraints
private jakarta.websocket.Session	session
private String	streamId
protected WebSocketCommunityHandler	webSocketCommunityHandler

Constructor Summary

Constructors

Constructor	Description
Adaptor(WebSocketCommunityHandler websocketCommunityHandler)

Method Summary

Modifier and Type	Method	Description
PeerConnection	getPeerConnection()
MediaConstraints	getSdpMediaConstraints()
jakarta.websocket.Session	getSession()
String	getStreamId()
void	onAddStream(MediaStream stream)	Triggered when media is received on a new stream from remote peer.
void	onAddTrack(RtpReceiver receiver, MediaStream[] mediaStreams)	Triggered when a new track is signaled by the remote peer, as a result of setRemoteDescription.
void	onCreateFailure(String error)	Called on error of Create{Offer,Answer}().
void	onCreateSuccess(SessionDescription sdp)	Called on success of Create{Offer,Answer}().
void	onDataChannel(DataChannel dataChannel)	Triggered when a remote peer opens a DataChannel.
void	onIceCandidate(IceCandidate candidate)	Triggered when a new ICE candidate has been found.
void	onIceCandidatesRemoved(IceCandidate[] candidates)	Triggered when some ICE candidates have been removed.
void	onIceConnectionChange(PeerConnection.IceConnectionState newState)	Triggered when the IceConnectionState changes.
void	onIceConnectionReceivingChange(boolean receiving)	Triggered when the ICE connection receiving status changes.
void	onIceGatheringChange(PeerConnection.IceGatheringState newState)	Triggered when the IceGatheringState changes.
void	onRemoveStream(MediaStream stream)	Triggered when a remote peer close a stream.
void	onRenegotiationNeeded()	Triggered when renegotiation is necessary.
void	onSetFailure(String error)	Called on error of Set{Local,Remote}Description().
void	onSetSuccess()	Called on success of Set{Local,Remote}Description().
void	onSignalingChange(PeerConnection.SignalingState newState)	Triggered when the SignalingState changes.
void	setPeerConnection(PeerConnection peerConnection)
void	setPeerConnectionFactory(PeerConnectionFactory peerConnectionFactory)
void	setSdpMediaConstraints(MediaConstraints sdpMediaConstraints)
void	setSession(jakarta.websocket.Session session)
void	setStreamId(String streamId)
abstract void	start()
abstract void	stop()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.webrtc.PeerConnection.Observer

onConnectionChange, onIceCandidateError, onRemoveTrack, onSelectedCandidatePairChanged, onStandardizedIceConnectionChange, onTrack

Field Details

peerConnection

protected PeerConnection peerConnection

sdpMediaConstraints

private MediaConstraints sdpMediaConstraints

peerConnectionFactory

protected PeerConnectionFactory peerConnectionFactory

webSocketCommunityHandler

protected WebSocketCommunityHandler webSocketCommunityHandler

streamId

private String streamId

session

private jakarta.websocket.Session session

log

protected static final org.slf4j.Logger log

Constructor Details

Adaptor

public Adaptor(WebSocketCommunityHandler websocketCommunityHandler)

Method Details

start

public abstract void start()

stop

public abstract void stop()

setPeerConnection

public void setPeerConnection(PeerConnection peerConnection)

getPeerConnection

public PeerConnection getPeerConnection()

onSignalingChange

public void onSignalingChange(PeerConnection.SignalingState newState)

Description copied from interface: PeerConnection.Observer

Triggered when the SignalingState changes.

Specified by:

onSignalingChange in interface PeerConnection.Observer

onIceConnectionChange

public void onIceConnectionChange(PeerConnection.IceConnectionState newState)

Description copied from interface: PeerConnection.Observer

Triggered when the IceConnectionState changes.

Specified by:

onIceConnectionChange in interface PeerConnection.Observer

onIceConnectionReceivingChange

public void onIceConnectionReceivingChange(boolean receiving)

Description copied from interface: PeerConnection.Observer

Triggered when the ICE connection receiving status changes.

Specified by:

onIceConnectionReceivingChange in interface PeerConnection.Observer

onIceGatheringChange

public void onIceGatheringChange(PeerConnection.IceGatheringState newState)

Description copied from interface: PeerConnection.Observer

Triggered when the IceGatheringState changes.

Specified by:

onIceGatheringChange in interface PeerConnection.Observer

onIceCandidate

public void onIceCandidate(IceCandidate candidate)

Description copied from interface: PeerConnection.Observer

Triggered when a new ICE candidate has been found.

Specified by:

onIceCandidate in interface PeerConnection.Observer

onIceCandidatesRemoved

public void onIceCandidatesRemoved(IceCandidate[] candidates)

Description copied from interface: PeerConnection.Observer

Triggered when some ICE candidates have been removed.

Specified by:

onIceCandidatesRemoved in interface PeerConnection.Observer

onAddStream

public void onAddStream(MediaStream stream)

Description copied from interface: PeerConnection.Observer

Triggered when media is received on a new stream from remote peer.

Specified by:

onAddStream in interface PeerConnection.Observer

onRemoveStream

public void onRemoveStream(MediaStream stream)

Description copied from interface: PeerConnection.Observer

Triggered when a remote peer close a stream.

Specified by:

onRemoveStream in interface PeerConnection.Observer

onDataChannel

public void onDataChannel(DataChannel dataChannel)

Description copied from interface: PeerConnection.Observer

Triggered when a remote peer opens a DataChannel.

Specified by:

onDataChannel in interface PeerConnection.Observer

onRenegotiationNeeded

public void onRenegotiationNeeded()

Description copied from interface: PeerConnection.Observer

Triggered when renegotiation is necessary.

Specified by:

onRenegotiationNeeded in interface PeerConnection.Observer

onAddTrack

public void onAddTrack(RtpReceiver receiver,
 MediaStream[] mediaStreams)

Description copied from interface: PeerConnection.Observer

Triggered when a new track is signaled by the remote peer, as a result of setRemoteDescription.

Specified by:

onAddTrack in interface PeerConnection.Observer

onCreateSuccess

public void onCreateSuccess(SessionDescription sdp)

Description copied from interface: SdpObserver

Called on success of Create{Offer,Answer}().

Specified by:

onCreateSuccess in interface SdpObserver

onSetSuccess

public void onSetSuccess()

Description copied from interface: SdpObserver

Called on success of Set{Local,Remote}Description().

Specified by:

onSetSuccess in interface SdpObserver

onCreateFailure

public void onCreateFailure(String error)

Description copied from interface: SdpObserver

Called on error of Create{Offer,Answer}().

Specified by:

onCreateFailure in interface SdpObserver

onSetFailure

public void onSetFailure(String error)

Description copied from interface: SdpObserver

Called on error of Set{Local,Remote}Description().

Specified by:

onSetFailure in interface SdpObserver

getSdpMediaConstraints

public MediaConstraints getSdpMediaConstraints()

setSdpMediaConstraints

public void setSdpMediaConstraints(MediaConstraints sdpMediaConstraints)

setPeerConnectionFactory

public void setPeerConnectionFactory(PeerConnectionFactory peerConnectionFactory)

setSession

public void setSession(jakarta.websocket.Session session)

getSession

public jakarta.websocket.Session getSession()

getStreamId

public String getStreamId()

setStreamId

public void setStreamId(String streamId)