org.apache.storm.messaging.netty

Class Client

java.lang.Object

org.apache.storm.messaging.ConnectionWithStatus

org.apache.storm.messaging.netty.Client

All Implemented Interfaces:

IConnection, ISaslClient, IStatefulObject

public class Client
extends ConnectionWithStatus
implements IStatefulObject, ISaslClient

A Netty client for sending task messages to a remote destination (Netty server).

Implementation details:

• Sending messages, i.e. writing to the channel, is performed asynchronously.
• Messages are sent in batches to optimize for network throughput at the expense of network latency. The message batch size is configurable.
• Connecting and reconnecting are performed asynchronously.
  • Note: The current implementation drops any messages that are being enqueued for sending if the connection to the remote destination is currently unavailable.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.storm.messaging.ConnectionWithStatus

ConnectionWithStatus.Status

Field Summary

Fields

Modifier and Type	Field and Description
protected String	dstAddressPrefixedName

Method Summary

Modifier and Type	Method and Description
void	channelConnected(org.jboss.netty.channel.Channel channel) ISaslClient interface
void	channelReady()
void	close() Gracefully close this client.
Map	getConfig()
InetSocketAddress	getDstAddress()
Map<Integer,Load>	getLoad(Collection<Integer> tasks) Get the current load for the given tasks
Object	getState()
String	name()
void	notifyInterestChanged(org.jboss.netty.channel.Channel channel) Called by Netty thread on change in channel interest
void	registerRecv(IConnectionCallback cb) Receiving messages is not supported by a client.
String	secretKey()
void	send(int taskId, byte[] payload) send a message with taskId and payload
void	send(Iterator<TaskMessage> msgs) Enqueue task messages to be sent to the remote destination (cf.
void	sendLoadMetrics(Map<Integer,Double> taskToLoad) Send load metrics to all downstream connections.
ConnectionWithStatus.Status	status() Note: Storm will check via this method whether a worker can be activated safely during the initial startup of a topology.
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

dstAddressPrefixedName

protected final String dstAddressPrefixedName

Method Detail

status

public ConnectionWithStatus.Status status()

Note: Storm will check via this method whether a worker can be activated safely during the initial startup of a topology. The worker will only be activated once all of the its connections are ready.

Specified by:

status in class ConnectionWithStatus

registerRecv

public void registerRecv(IConnectionCallback cb)

Receiving messages is not supported by a client.

Specified by:

registerRecv in interface IConnection

Parameters:

cb - the callback to process the messages.

Throws:

UnsupportedOperationException - whenever this method is being called.

sendLoadMetrics

public void sendLoadMetrics(Map<Integer,Double> taskToLoad)

Description copied from interface: IConnection

Send load metrics to all downstream connections.

Specified by:

sendLoadMetrics in interface IConnection

Parameters:

taskToLoad - a map from the task id to the load for that task.

send

public void send(int taskId,
                 byte[] payload)

Description copied from interface: IConnection

send a message with taskId and payload

Specified by:

send in interface IConnection

Parameters:

taskId - task ID

send

public void send(Iterator<TaskMessage> msgs)

Enqueue task messages to be sent to the remote destination (cf. host and port).

Specified by:

send in interface IConnection

getDstAddress

public InetSocketAddress getDstAddress()

close

public void close()

Gracefully close this client.

Specified by:

close in interface IConnection

getLoad

public Map<Integer,Load> getLoad(Collection<Integer> tasks)

Description copied from interface: IConnection

Get the current load for the given tasks

Specified by:

getLoad in interface IConnection

Parameters:

tasks - the tasks to look for.

Returns:

a Load for each of the tasks it knows about.

getState

public Object getState()

Specified by:

getState in interface IStatefulObject

getConfig

public Map getConfig()

channelConnected

public void channelConnected(org.jboss.netty.channel.Channel channel)

ISaslClient interface

Specified by:

channelConnected in interface ISaslClient

channelReady

public void channelReady()

Specified by:

channelReady in interface ISaslClient

name

public String name()

Specified by:

name in interface ISaslClient

secretKey

public String secretKey()

Specified by:

secretKey in interface ISaslClient

toString

public String toString()

Overrides:

toString in class Object

notifyInterestChanged

public void notifyInterestChanged(org.jboss.netty.channel.Channel channel)

Called by Netty thread on change in channel interest

Parameters:

channel -