org.apache.reef.wake.remote.impl

Class RemoteEvent<T>

java.lang.Object

org.apache.reef.wake.remote.impl.RemoteEvent<T>

Type Parameters:

T - type

public class RemoteEvent<T>
extends Object

Event that are exchanged across process boundaries

Constructor Summary

Constructors

Constructor and Description
RemoteEvent(SocketAddress localAddr, SocketAddress remoteAddr, String src, String sink, long seq, T event) Constructs a remote event

Method Summary

Methods

Modifier and Type	Method and Description
T	getEvent() Gets the actual event
long	getSeq() Gets the sequence number
String	getSink() Gets the sink
String	getSource() Gets the source
SocketAddress	localAddress() Gets the local socket address
SocketAddress	remoteAddress() Gets the remote socket address
void	setLocalAddress(SocketAddress addr) Sets the local socket address
void	setRemoteAddress(SocketAddress addr) Sets the remote socket address
void	setSink(String name) Sets the sink
void	setSource(String name) Sets the source
String	toString() Returns a string representation of this object

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

RemoteEvent

public RemoteEvent(SocketAddress localAddr,
           SocketAddress remoteAddr,
           String src,
           String sink,
           long seq,
           T event)

Constructs a remote event

Parameters:

localAddr - the local socket address

remoteAddr - the remote socket address

src - the source

sink - the remote sink

seq - the sequence number

event - the event

Method Detail

localAddress

public SocketAddress localAddress()

Gets the local socket address

Returns:

the local socket address

remoteAddress

public SocketAddress remoteAddress()

Gets the remote socket address

Returns:

the remote socket address

getSource

public String getSource()

Gets the source

Returns:

the source

setSource

public void setSource(String name)

Sets the source

Parameters:

name - the source name

getSink

public String getSink()

Gets the sink

Returns:

the sink

setSink

public void setSink(String name)

Sets the sink

Parameters:

name - the sink name

getEvent

public T getEvent()

Gets the actual event

Returns:

the event

getSeq

public long getSeq()

Gets the sequence number

Returns:

the sequence number

setLocalAddress

public void setLocalAddress(SocketAddress addr)

Sets the local socket address

Parameters:

addr - the local socket address

setRemoteAddress

public void setRemoteAddress(SocketAddress addr)

Sets the remote socket address

Parameters:

addr - the remote socket address

toString

public String toString()

Returns a string representation of this object

Overrides:

toString in class Object

Returns:

a string representation of this object