public class PublishedSource
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
private static class |
PublishedSource.Listener |
Modifier and Type | Field and Description |
---|---|
protected java.io.DataInputStream |
dis |
protected java.text.DateFormat |
formatter |
protected float |
frequency |
protected java.lang.String |
host |
protected java.lang.String |
ipAddress |
private static PublishedSource.Listener |
listener |
protected static int |
MAX_AGE |
protected static int |
MAX_PACKET_SIZE |
protected static int |
MAX_SAMPLE_MESSAGE_SIZE |
protected java.lang.String |
name |
protected int |
port |
protected static int |
PUBLISH_PORT |
protected float[] |
sample |
protected int |
sampleSize |
protected java.net.Socket |
socket |
protected static int |
SOCKET_TIMEOUT |
private static java.util.Map<java.lang.String,PublishedSource> |
sources |
protected long |
timeStamp |
Constructor and Description |
---|
PublishedSource(java.lang.String ipAddress,
byte[] message) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
SubscribedProvider |
connect() |
float |
getFrequency() |
java.lang.String |
getHost() |
java.lang.String |
getIpAddress() |
java.lang.String |
getKey() |
java.lang.String |
getName() |
int |
getPort() |
static java.util.Collection<PublishedSource> |
getSources() |
java.lang.String |
getTime() |
long |
getTimeStamp() |
int |
sampleSize() |
protected static final int MAX_PACKET_SIZE
protected static final int PUBLISH_PORT
protected static final int SOCKET_TIMEOUT
protected static final int MAX_AGE
protected static final int MAX_SAMPLE_MESSAGE_SIZE
private static PublishedSource.Listener listener
protected java.lang.String name
protected int sampleSize
protected float[] sample
protected float frequency
protected java.lang.String host
protected int port
protected long timeStamp
protected java.text.DateFormat formatter
protected java.lang.String ipAddress
protected java.net.Socket socket
protected java.io.DataInputStream dis
private static java.util.Map<java.lang.String,PublishedSource> sources
public PublishedSource(java.lang.String ipAddress, byte[] message) throws java.io.IOException
java.io.IOException
public SubscribedProvider connect() throws java.io.IOException
java.io.IOException
public int sampleSize()
public java.lang.String getName()
public float getFrequency()
public java.lang.String getHost()
public java.lang.String getTime()
public java.lang.String getKey()
public java.lang.String getIpAddress()
public int getPort()
public long getTimeStamp()
public void close() throws java.io.IOException
java.io.IOException
public static java.util.Collection<PublishedSource> getSources()