app.library.linkflow.rtmp

Class RtmpClient

java.lang.Object

app.library.linkflow.rtmp.RtmpClient

public class RtmpClient
extends java.lang.Object

Created by faraklit on 01.01.2016.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	RtmpClient.RtmpIOException

Field Summary

Fields

Modifier and Type	Field and Description
static int	RTMP_READ_DONE RTMP read has received an EOF or READ_COMPLETE from the server

Constructor Summary

Constructors

Constructor and Description
RtmpClient()

Method Summary

Modifier and Type	Method and Description
void	close() closes the connection.
boolean	isConnected()
void	open(java.lang.String url, boolean isPublishMode) opens the rtmp url
boolean	pause(boolean pause)
int	read(byte[] data, int offset, int size) read data from rtmp connection
void	setReceiveTimeout(int receiveTimeoutInMs) Sets the socket's receive timeout value
void	setSendTimeout(int sendTimeoutInMs) Sets the socket's send timeout value
int	write(byte[] data) Sends data to server
int	write(byte[] data, int offset, int size) Sends data to server

Methods inherited from class java.lang.Object

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

Field Detail

RTMP_READ_DONE

public static final int RTMP_READ_DONE

RTMP read has received an EOF or READ_COMPLETE from the server

See Also:

Constant Field Values

Constructor Detail

RtmpClient

public RtmpClient()

Method Detail

setSendTimeout

public void setSendTimeout(int sendTimeoutInMs)

Sets the socket's send timeout value

Parameters:

sendTimeoutInMs - The send timeout value for the rtmp socket in milliseconds. Parameter expects a non-zero positive integer and will reset timeout to the default value (10000 ms) if zero or a negative integer is passed.

setReceiveTimeout

public void setReceiveTimeout(int receiveTimeoutInMs)

Sets the socket's receive timeout value

Parameters:

receiveTimeoutInMs - The receive timeout value for the rtmp socket in milliseconds. Parameter expects a non-zero positive integer and will reset timeout to the default value (10000 ms) if zero or a negative integer is passed.

open

public void open(java.lang.String url,
                 boolean isPublishMode)
          throws RtmpClient.RtmpIOException

opens the rtmp url

Parameters:

url - url of the stream

isPublishMode - if this is an publication it is true, if connection is for getting stream it is false

Throws:

RtmpClient.RtmpIOException - if open fails

read

public int read(byte[] data,
                int offset,
                int size)
         throws RtmpClient.RtmpIOException,
                java.lang.IllegalStateException

read data from rtmp connection

Parameters:

data - buffer that will be filled

offset - offset to read data

size - size of the data to be read

Returns:

number of bytes to be read if it returns RTMP_READ_DONE, it means stream is complete and close function can be called.

Throws:

RtmpClient.RtmpIOException - if connection to server is lost

java.lang.IllegalStateException - if call to open(String, boolean) was unsuccessful or missing

write

public int write(byte[] data)
          throws RtmpClient.RtmpIOException,
                 java.lang.IllegalStateException

Sends data to server

Parameters:

data - The data to write to server

Returns:

number of bytes written

Throws:

RtmpClient.RtmpIOException - if connection to server is lost

java.lang.IllegalStateException - if call to open(String, boolean) was unsuccessful or missing

write

public int write(byte[] data,
                 int offset,
                 int size)
          throws RtmpClient.RtmpIOException,
                 java.lang.IllegalStateException

Sends data to server

Parameters:

data - data to write to server

offset - The offset from where data will be accessed to write to server

size - The number of bytes to write to server

Returns:

number of bytes written

Throws:

RtmpClient.RtmpIOException - if connection to server is lost

java.lang.IllegalStateException - if call to open(String, boolean) was unsuccessful or missing

pause

public boolean pause(boolean pause)
              throws RtmpClient.RtmpIOException,
                     java.lang.IllegalStateException

Parameters:

pause - if pause is true then stream is going to be paused If pause is false, it unpauses the stream and it is ready to to play again

Returns:

true if it is successful else returns false

Throws:

RtmpClient.RtmpIOException - if connection is lost

java.lang.IllegalStateException - if call to open(String, boolean) was unsuccessful or missing

isConnected

public boolean isConnected()

Returns:

true if it is connected false if it is not connected

close

public void close()

closes the connection. Don't forget to call