public class HttpReceiver
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static class |
HttpReceiver.TimeoutTask
The timeout task
|
Modifier and Type | Field and Description |
---|---|
protected jadex.bridge.IExternalAccess |
access
The external access.
|
protected java.lang.String |
address
The current connected server address (if any).
|
protected java.util.logging.Logger |
logger
The logger (set on first access).
|
protected boolean |
shutdown
The shutdown flag.
|
protected HttpRelayTransport |
transport
The transport.
|
Constructor and Description |
---|
HttpReceiver(HttpRelayTransport transport,
jadex.bridge.IExternalAccess access)
Create a new receiver.
|
Modifier and Type | Method and Description |
---|---|
protected jadex.commons.future.IFuture<java.lang.String> |
fetchServerAddresses()
Fetch an up-to-date server list.
|
java.lang.String[] |
getAddresses()
Get the current addresses (if any).
|
protected jadex.commons.future.IFuture<java.lang.Void> |
handleConnection(java.lang.String adr)
Main thread while connected.
|
protected void |
log(java.util.logging.Level level,
java.lang.String msg)
Do some log output.
|
protected void |
postAwarenessInfo(byte[] data,
int type,
java.util.Map<java.lang.Byte,jadex.bridge.service.types.message.ICodec> codecs)
Post a received awareness info to awareness service (if any).
|
protected static byte[] |
readMessage(java.io.InputStream in)
Read a complete message from the stream.
|
protected jadex.commons.future.IFuture<java.lang.String> |
selectServer(java.lang.String curadrs)
Select a server to connect to.
|
void |
start()
(Re-)Start the receiver.
|
void |
stop()
Stop the receiver.
|
protected HttpRelayTransport transport
protected boolean shutdown
protected jadex.bridge.IExternalAccess access
protected java.lang.String address
protected java.util.logging.Logger logger
public HttpReceiver(HttpRelayTransport transport, jadex.bridge.IExternalAccess access)
public void start()
public void stop()
protected static byte[] readMessage(java.io.InputStream in) throws java.io.IOException
java.io.IOException
protected void postAwarenessInfo(byte[] data, int type, java.util.Map<java.lang.Byte,jadex.bridge.service.types.message.ICodec> codecs)
public java.lang.String[] getAddresses()
protected void log(java.util.logging.Level level, java.lang.String msg)
protected jadex.commons.future.IFuture<java.lang.String> fetchServerAddresses()
protected jadex.commons.future.IFuture<java.lang.String> selectServer(java.lang.String curadrs)
protected jadex.commons.future.IFuture<java.lang.Void> handleConnection(java.lang.String adr)