Package org.opendaylight.openflowjava.protocol.impl.core.connection

Class MessageListenerWrapper

java.lang.Object

org.opendaylight.openflowjava.protocol.impl.core.connection.MessageListenerWrapper

Direct Known Subclasses:

UdpMessageListenerWrapper

public class MessageListenerWrapper
extends Object

Wraps outgoing message and includes listener attached to this message. This object is sent to OFEncoder. When OFEncoder fails to serialize the message, listener is filled with exception. The exception is then delegated to upper ODL layers.

Author:

michal.polkorab

Constructor Summary

Constructors

Constructor	Description
MessageListenerWrapper(Object msg, io.netty.util.concurrent.GenericFutureListener<io.netty.util.concurrent.Future<Void>> listener)	Constructor.

Method Summary

Modifier and Type	Method	Description
io.netty.util.concurrent.GenericFutureListener<io.netty.util.concurrent.Future<Void>>	getListener()	Returns the listener listening on message sending success / failure.
OfHeader	getMsg()	Returns the outgoing message.

Methods inherited from class java.lang.Object

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

Constructor Details

MessageListenerWrapper

public MessageListenerWrapper(Object msg,
 io.netty.util.concurrent.GenericFutureListener<io.netty.util.concurrent.Future<Void>> listener)

Constructor.

Parameters:

msg - outgoing message

listener - listener attached to channel.write(msg) Future

Method Details

getMsg

public OfHeader getMsg()

Returns the outgoing message.

Returns:

outgoing message (downstream)

getListener

public io.netty.util.concurrent.GenericFutureListener<io.netty.util.concurrent.Future<Void>> getListener()

Returns the listener listening on message sending success / failure.

Returns:

listener listening on message sending success / failure