org.mondemand.transport

Class LWESTransport

Implemented Interfaces:
Transport

public class LWESTransport
extends java.lang.Object
implements Transport

Constructor Summary

LWESTransport(InetAddress address, int port, InetAddress networkInterface)
Creates an initializes a LWES transport.
LWESTransport(InetAddress address, int port, InetAddress networkInterface, int ttl)
Creates and initializes a LWES transport.

Method Summary

void
sendLogs(String programId, LogMessage[] messages, Context[] contexts)
void
sendStats(String programId, StatsMessage[] messages, Context[] contexts)
void
shutdown()

Constructor Details

LWESTransport

public LWESTransport(InetAddress address,
                     int port,
                     InetAddress networkInterface)
            throws TransportException
Creates an initializes a LWES transport.
Parameters:
address - the address to send events to, can be a multicast or unicast address
port - the port to send events to
networkInterface - the network interface to use, or null to specify the default

LWESTransport

public LWESTransport(InetAddress address,
                     int port,
                     InetAddress networkInterface,
                     int ttl)
            throws TransportException
Creates and initializes a LWES transport.
Parameters:
address - the address to send events to, can be a multicast or unicast address
port - the port to send events to
networkInterface - the network interface to use, or null to specify the default
ttl - for multicast addresses, the TTL value to use

Method Details

sendLogs

public void sendLogs(String programId,
                     LogMessage[] messages,
                     Context[] contexts)
            throws TransportException
Specified by:
sendLogs in interface Transport

sendStats

public void sendStats(String programId,
                      StatsMessage[] messages,
                      Context[] contexts)
            throws TransportException
Specified by:
sendStats in interface Transport

shutdown

public void shutdown()
            throws TransportException
Specified by:
shutdown in interface Transport