backtype.storm.messaging

Interface IConnection

All Known Implementing Classes:

Client, ConnectionWithStatus

public interface IConnection

Method Summary

Methods

Modifier and Type	Method and Description
void	close() close this connection
Iterator<TaskMessage>	recv(int flags, int clientId) receive a batch message iterator (consists taskId and payload)
void	send(int taskId, byte[] payload) send a message with taskId and payload
void	send(Iterator<TaskMessage> msgs) send batch messages

Method Detail

recv

Iterator<TaskMessage> recv(int flags,
                         int clientId)

receive a batch message iterator (consists taskId and payload)

Parameters:

flags - 0: block, 1: non-block

Returns:

send

void send(int taskId,
        byte[] payload)

send a message with taskId and payload

Parameters:

taskId - task ID

payload -

send

void send(Iterator<TaskMessage> msgs)

send batch messages

Parameters:

msgs -

close

void close()

close this connection