public class RelayConnectionManager
extends jadex.commons.HttpConnectionManager
Constructor and Description |
---|
RelayConnectionManager() |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
doGetPeerServers(java.lang.String peeraddress,
java.lang.String ownaddress,
java.lang.String ownid,
int dbstate,
boolean initial)
Get known servers from a peer server.
|
java.net.HttpURLConnection |
doOpenReceiverConnection(java.lang.String address,
jadex.bridge.IComponentIdentifier receiver)
Open a receiving connection.
|
protected void |
doPing(java.lang.String address)
Ping a relay server.
|
byte[] |
getDBEntries(java.lang.String peeraddress,
java.lang.String peerid,
int startid,
int cnt) |
java.lang.String |
getPeerServers(java.lang.String peeraddress,
java.lang.String ownaddress,
java.lang.String ownid,
int dbstate,
boolean initial)
Get known servers from a peer server.
|
java.lang.String |
getServers(java.lang.String address)
Get known servers from a server.
|
static java.lang.String |
httpAddress(java.lang.String address)
Convert a potential 'relay-' address to normal http(s) address.
|
static boolean |
isSameServer(java.lang.String address1,
java.lang.String address2)
Test if two addresses refer to the same server.
|
java.net.HttpURLConnection |
openReceiverConnection(java.lang.String address,
jadex.bridge.IComponentIdentifier receiver)
Open a receiving connection.
|
void |
ping(java.lang.String address)
Ping a relay server.
|
void |
postMessage(java.lang.String address,
jadex.bridge.IComponentIdentifier targetid,
byte[][] data)
Post a message.
|
static java.lang.String |
relayAddress(java.lang.String address)
Convert a potential non 'relay-' address to relay address.
|
static java.lang.String |
secureAddress(java.lang.String address)
Convert a potential non-https address to an https address.
|
public void ping(java.lang.String address) throws java.io.IOException
java.io.IOException
- on connection failuresprotected void doPing(java.lang.String address) throws java.io.IOException
java.io.IOException
- on connection failurespublic java.net.HttpURLConnection openReceiverConnection(java.lang.String address, jadex.bridge.IComponentIdentifier receiver) throws java.io.IOException
java.io.IOException
- on connection failurespublic java.net.HttpURLConnection doOpenReceiverConnection(java.lang.String address, jadex.bridge.IComponentIdentifier receiver) throws java.io.IOException
java.io.IOException
- on connection failurespublic java.lang.String getServers(java.lang.String address) throws java.io.IOException
address
- The remote server address.java.io.IOException
- on connection failurespublic java.lang.String getPeerServers(java.lang.String peeraddress, java.lang.String ownaddress, java.lang.String ownid, int dbstate, boolean initial) throws java.io.IOException
peeraddress
- The remote server address.ownaddress
- The local server address supplied for mutual connection (set to null if not connecting to peer).ownid
- The local peer id supplied for history db synchronization (not used if not connecting to peer).peerstate
- Contains id of the latest history entry of that peer to enable synchronization (not used if not connecting to peer).initial
- True, when peer connects initially (not used if not connecting to peer).java.io.IOException
- on connection failurespublic java.lang.String doGetPeerServers(java.lang.String peeraddress, java.lang.String ownaddress, java.lang.String ownid, int dbstate, boolean initial) throws java.io.IOException
peeraddress
- The remote server address.ownaddress
- The local server address supplied for mutual connection (set to null if not connecting to peer).ownid
- The local peer id supplied for history db synchronization (not used if not connecting to peer).peerstate
- Contains id of the latest history entry of that peer to enable synchronization (not used if not connecting to peer).initial
- True, when peer connects initially (not used if not connecting to peer).java.io.IOException
- on connection failurespublic void postMessage(java.lang.String address, jadex.bridge.IComponentIdentifier targetid, byte[][] data) throws java.io.IOException
java.io.IOException
- on connection failurespublic byte[] getDBEntries(java.lang.String peeraddress, java.lang.String peerid, int startid, int cnt) throws java.io.IOException
java.io.IOException
public static java.lang.String httpAddress(java.lang.String address)
public static java.lang.String relayAddress(java.lang.String address)
public static java.lang.String secureAddress(java.lang.String address)
public static boolean isSameServer(java.lang.String address1, java.lang.String address2)