Package org.red5.client.net.rtmpt

Class RTMPTClientConnector

java.lang.Object

java.lang.Thread

org.red5.client.net.rtmpt.RTMPTClientConnector

All Implemented Interfaces:

Runnable

Direct Known Subclasses:

RTMPTSClientConnector

public class RTMPTClientConnector
extends Thread

Client connector for RTMPT

Author:

Anton Lebedevich (mabrek@gmail.com), Paul Gregoire (mondain@gmail.com)

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field	Description
protected RTMPTClient	client
protected static String	CONTENT_TYPE
protected org.apache.http.client.HttpClient	httpClient
protected long	messageCount
protected static int	SEND_TARGET_SIZE	Size to split messages queue by, borrowed from RTMPTServlet.RESPONSE_TARGET_SIZE
protected String	sessionId
protected boolean	stopRequested
protected org.apache.http.HttpHost	targetHost
protected static org.apache.http.entity.ByteArrayEntity	ZERO_REQUEST_ENTITY

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	RTMPTClientConnector()
	RTMPTClientConnector(String server, int port, RTMPTClient client)

Method Summary

Modifier and Type	Method	Description
protected static void	checkResponseCode(org.apache.http.HttpResponse response)
protected void	finalizeConnection()
protected static org.apache.http.client.methods.HttpPost	getPost(String uri)
String	getSessionId()
protected org.apache.http.client.methods.HttpPost	makePost(String command)
protected String	makeUrl(String command)
void	run()
protected static void	setCommonHeaders(org.apache.http.client.methods.HttpPost post)
void	setStopRequested(boolean stopRequested)

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Field Detail

CONTENT_TYPE

protected static final String CONTENT_TYPE

See Also:

Constant Field Values

ZERO_REQUEST_ENTITY

protected static final org.apache.http.entity.ByteArrayEntity ZERO_REQUEST_ENTITY

SEND_TARGET_SIZE

protected static final int SEND_TARGET_SIZE

Size to split messages queue by, borrowed from RTMPTServlet.RESPONSE_TARGET_SIZE

See Also:

Constant Field Values

httpClient

protected org.apache.http.client.HttpClient httpClient

targetHost

protected org.apache.http.HttpHost targetHost

client

protected RTMPTClient client

sessionId

protected String sessionId

messageCount

protected long messageCount

stopRequested

protected volatile boolean stopRequested

Constructor Detail

RTMPTClientConnector

protected RTMPTClientConnector()

RTMPTClientConnector

public RTMPTClientConnector(String server,
                            int port,
                            RTMPTClient client)

Method Detail

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

getSessionId

public String getSessionId()

Returns:

the sessionId

finalizeConnection

protected void finalizeConnection()
                           throws IOException

Throws:

IOException

getPost

protected static org.apache.http.client.methods.HttpPost getPost(String uri)

makePost

protected org.apache.http.client.methods.HttpPost makePost(String command)

makeUrl

protected String makeUrl(String command)

setCommonHeaders

protected static void setCommonHeaders(org.apache.http.client.methods.HttpPost post)

checkResponseCode

protected static void checkResponseCode(org.apache.http.HttpResponse response)
                                 throws org.apache.http.ParseException,
                                        IOException

Throws:

org.apache.http.ParseException

IOException

setStopRequested

public void setStopRequested(boolean stopRequested)