public class StreamrConsumer extends I2PTunnelUDPClientBase
_clientId, _context, lopen, tunnel| Constructor and Description |
|---|
StreamrConsumer(InetAddress host,
int port,
String destination,
Logging l,
EventDispatcher notifyThis,
I2PTunnel tunnel)Creates a Streamr consumer that receives data from I2P and forwards it to a UDP destination. |
| Modifier and Type | Method and Description |
|---|---|
boolean | close(boolean forced)Stops the consumer and releases resources. |
void | startRunning()Starts the consumer and begins receiving data. |
send, setSink, startconnected, destroy, disconnected, errorOccurred, getBooleanOption, getId, getSocketManager, getTunnel, isOpen, optionsUpdated, reportAbuse, routerDisconnected, setId, setName, setTunnel, toStringattachEventDispatcher, detachEventDispatcher, getEventDispatcher, getEvents, getEventValue, ignoreEvents, notifyEvent, unIgnoreEvents, waitEventValuepublic StreamrConsumer(InetAddress host, int port, String destination, Logging l, EventDispatcher notifyThis, I2PTunnel tunnel)
host - UDP destination hostnameport - UDP destination portdestination - I2P destination to subscribe tol - logging facilitynotifyThis - event dispatcher for notificationstunnel - the tunnelpublic boolean close(boolean forced)
close in class I2PTunnelUDPClientBaseforced - if true, forces immediate closepublic final void startRunning()
startRunning in class I2PTunnelUDPClientBase