net.tomp2p.connection
Class SenderNetty

java.lang.Object
  net.tomp2p.connection.SenderNetty

All Implemented Interfaces:

Sender

public class SenderNetty
extends Object
implements Sender

Handles sending of messages. In order to send messages one needs to provide a channel creator. This can be obtained via the connection reservation, that keeps track how many connections have been opened.

Author:

Thomas Bocek

Constructor Summary

SenderNetty(ConnectionConfiguration configuration, org.jboss.netty.util.Timer timer)
The sender is shared for all master and child peers

Method Summary

void	sendBroadcastUDP(RequestHandlerUDP<? extends BaseFuture> handler, FutureResponse futureResponse, Message message, ChannelCreator channelCreator) Sent the message via UDP broadcast.
void	sendTCP(RequestHandlerTCP<? extends BaseFuture> handler, FutureResponse futureResponse, Message message, ChannelCreator channelCreator, int idleTCPMillis) Sent the message via TCP.
void	sendUDP(RequestHandlerUDP<? extends BaseFuture> handler, FutureResponse futureResponse, Message message, ChannelCreator channelCreator) Sent the message via UDP.
void	shutdown() Shuts down the sender.

Methods inherited from class java.lang.Object

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

Constructor Detail

SenderNetty

public SenderNetty(ConnectionConfiguration configuration,
                   org.jboss.netty.util.Timer timer)

The sender is shared for all master and child peers

Parameters:

configuration - ConnectionConfigurationBean

timer - Timer

Method Detail

sendTCP

public void sendTCP(RequestHandlerTCP<? extends BaseFuture> handler,
                    FutureResponse futureResponse,
                    Message message,
                    ChannelCreator channelCreator,
                    int idleTCPMillis)

Description copied from interface: Sender

Sent the message via TCP. Keep the future state.

Specified by:

sendTCP in interface Sender

Parameters:

handler - RequestHandlerTCP

futureResponse - FutureResponse

message - Message

channelCreator - ChannelCreator

idleTCPMillis - Timeout

sendUDP

public void sendUDP(RequestHandlerUDP<? extends BaseFuture> handler,
                    FutureResponse futureResponse,
                    Message message,
                    ChannelCreator channelCreator)

Description copied from interface: Sender

Sent the message via UDP. Keep the future state.

Specified by:

sendUDP in interface Sender

Parameters:

handler - RequestHandlerUDP

futureResponse - FutureResponse

message - Message

channelCreator - ChannelCreator

sendBroadcastUDP

public void sendBroadcastUDP(RequestHandlerUDP<? extends BaseFuture> handler,
                             FutureResponse futureResponse,
                             Message message,
                             ChannelCreator channelCreator)

Description copied from interface: Sender

Sent the message via UDP broadcast. Keep the future state.

Specified by:

sendBroadcastUDP in interface Sender

Parameters:

handler - RequestHandlerUDP

futureResponse - FutureResponse

message - Message

channelCreator - ChannelCreator

shutdown

public void shutdown()

Description copied from interface: Sender

Shuts down the sender. After this the sender cannot be used again.

Specified by:

shutdown in interface Sender