|
Project JXTA | ||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||
SUMMARY: INNER | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object | +--net.jxta.impl.endpoint.http.HttpTransport
This class implements the HTTP Transport Protocol
Inner Class Summary | |
class |
HttpTransport.ClientConnection
|
class |
HttpTransport.IncomingUnicastThreads
|
class |
HttpTransport.ServerConnection
|
Field Summary | |
static int |
BlockingSend
|
static Cm |
cm
|
static int |
DefaultNbOfUnicastThreads
|
static java.lang.String |
HttpSpool
|
static java.lang.String |
MagicWord
|
static int |
MaxNbOfPendingSockets
|
static int |
MaxNbOfUnicastKeepAliveThreads
|
static int |
MaxNbOfUnicastThreads
|
static int |
PollingSend
|
java.net.ServerSocket |
serverSocket
|
static int |
serverSocketPort
|
Constructor Summary | |
HttpTransport()
|
|
HttpTransport(net.jxta.protocol.EndpointAdvertisement a)
This is a portion of the API which might not be useful when the configuration part of the JXTA platform will be completed. |
Method Summary | |
void |
addPollingHttp(java.lang.String url)
|
void |
close()
closes this TransportProtocol. |
boolean |
doesPropagate()
|
net.jxta.endpoint.EndpointAddress |
getLocalAddress()
Returns an EndpointAddress of the local endpoint manage by the TransportProtocol |
EndpointMessenger |
getMessenger(net.jxta.endpoint.EndpointAddress dst,
java.lang.String peer,
int type)
Creates and return an EndpointMessenger |
int |
getPort()
|
java.lang.String |
getProtocolName()
Returns a String containing the canonical name of this protocol, as it appears in an EndpointAddress. |
java.lang.String |
getProxy()
|
java.util.Vector |
getRouters()
|
java.lang.String |
getServer()
|
void |
init(Endpoint ep)
Initialise this instance of the TransportProtocol. |
boolean |
isConnected()
Returns true if the Transport Protocol can establish connection to the remote host (like TCP). |
boolean |
isFast()
Returns true if the Transport Protocol is fast. |
boolean |
ping(net.jxta.endpoint.EndpointAddress addr)
Returns true if the target address is reachable. |
protected boolean |
pollRemote(java.lang.String addr,
int type)
|
void |
propagate(net.jxta.endpoint.Message message,
java.lang.String pName,
java.lang.String pParams,
java.lang.String prunePeer)
Propagates a TransportMessage on this TransportProtocol |
void |
removePollingHttp(java.lang.String url)
|
void |
run()
|
void |
runReceive(java.net.Socket inputSocket)
|
void |
runServer()
|
void |
sendHttpPUT(java.lang.String url,
java.util.Enumeration buffers,
long size)
|
protected void |
sendMessageToClient(java.lang.String peer,
java.util.Vector buffers)
|
Methods inherited from class java.lang.Object |
clone,
equals,
finalize,
getClass,
hashCode,
notify,
notifyAll,
toString,
wait,
wait,
wait |
Field Detail |
public static final java.lang.String HttpSpool
public static final Cm cm
public static final java.lang.String MagicWord
public static final int DefaultNbOfUnicastThreads
public static final int MaxNbOfUnicastThreads
public static final int MaxNbOfUnicastKeepAliveThreads
public static final int MaxNbOfPendingSockets
public static int serverSocketPort
public java.net.ServerSocket serverSocket
public static final int PollingSend
public static final int BlockingSend
Constructor Detail |
public HttpTransport(net.jxta.protocol.EndpointAdvertisement a)
public HttpTransport()
Method Detail |
public int getPort()
public void init(Endpoint ep)
public void run()
public void runServer()
public void runReceive(java.net.Socket inputSocket)
public void sendHttpPUT(java.lang.String url, java.util.Enumeration buffers, long size) throws java.io.IOException
protected void sendMessageToClient(java.lang.String peer, java.util.Vector buffers)
public EndpointMessenger getMessenger(net.jxta.endpoint.EndpointAddress dst, java.lang.String peer, int type) throws java.io.IOException
dest
- EndpointAddress of the destinationtype
- type of the messenger as defined in the class Endpointpublic void propagate(net.jxta.endpoint.Message message, java.lang.String pName, java.lang.String pParams, java.lang.String prunePeer) throws java.io.IOException
msg
- the TransportMessage to be propagatedpublic java.lang.String getProtocolName()
public void close()
public net.jxta.endpoint.EndpointAddress getLocalAddress()
public void addPollingHttp(java.lang.String url)
public void removePollingHttp(java.lang.String url)
protected boolean pollRemote(java.lang.String addr, int type)
public java.lang.String getProxy()
public java.util.Vector getRouters()
public java.lang.String getServer()
public boolean doesPropagate()
public boolean isFast()
public boolean isConnected()
public boolean ping(net.jxta.endpoint.EndpointAddress addr)
|
Project JXTA | ||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||
SUMMARY: INNER | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |