org.apache.reef.wake.remote.transport.netty

Class LoggingLinkListener<T>

java.lang.Object

org.apache.reef.wake.remote.transport.netty.LoggingLinkListener<T>

Type Parameters:

T - type

All Implemented Interfaces:

LinkListener<T>

public class LoggingLinkListener<T>
extends Object
implements LinkListener<T>

Link listener that logs whether the message is sent successfully

Constructor Summary

Constructors

Constructor and Description
LoggingLinkListener()

Method Summary

Methods

Modifier and Type	Method and Description
void	onException(Throwable cause, SocketAddress remoteAddress, T message) Called when the sent message to remoteAddress is failed to be transferred.
void	onSuccess(T message) Called when the sent message is transferred successfully

Methods inherited from class java.lang.Object

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

Constructor Detail

LoggingLinkListener

public LoggingLinkListener()

Method Detail

onSuccess

public void onSuccess(T message)

Called when the sent message is transferred successfully

Specified by:

onSuccess in interface LinkListener<T>

Parameters:

message - the sent message

onException

public void onException(Throwable cause,
               SocketAddress remoteAddress,
               T message)

Called when the sent message to remoteAddress is failed to be transferred.

Specified by:

onException in interface LinkListener<T>

Parameters:

cause - the cause of exception

remoteAddress - the exception occurred remote address

message - the send message