Package org.jgroups.blocks.cs

Interface Receiver

All Known Implementing Classes:

BasicTCP, DiagnosticsHandler, FD_SOCK2, GossipRouter, PubClient, PubServer, ReceiverAdapter, RouterStub, TCP, TCP_NIO2

public interface Receiver

Receiver interface to be used with BaseServer instances

Since:

3.6.5

Author:

Bela Ban

Method Summary

Modifier and Type	Method	Description
void	receive(Address sender, byte[] buf, int offset, int length)	Delivers a message from a given sender to the application
default void	receive(Address sender, java.io.DataInput in)	Deprecated, for removal: This API element is subject to removal in a future version.
default void	receive(Address sender, java.io.DataInput in, int length)	Receive data from the given sender
default void	receive(Address sender, java.nio.ByteBuffer buf)	Delivers a message from a given sender to the application

Method Detail

receive

void receive(Address sender,
             byte[] buf,
             int offset,
             int length)

Delivers a message from a given sender to the application

Parameters:

sender - The sender of the message

buf - The buffer. An application typically de-serializes data from the buffer into objects used by the application. Note that when receive() returns, it is not safe to use the buffer any longer; if an application needs to use a buffer after this callback returns, it must make a copy.

offset - The offset at which the received data starts

length - The length of the received data

receive

default void receive(Address sender,
                     java.nio.ByteBuffer buf)

Delivers a message from a given sender to the application

Parameters:

sender - The sender of the message

buf - The buffer. An application typically de-serializes data from the buffer into objects used by the application. Note that when receive() returns, it is not safe to use the buffer any longer; if an application needs to use a buffer after this callback returns, it must make a copy.

Note that buf could be a direct ByteBuffer.

receive

@Deprecated(since="5.3.3",
            forRemoval=true)
default void receive(Address sender,
                     java.io.DataInput in)
              throws java.lang.Exception

Deprecated, for removal: This API element is subject to removal in a future version.

Throws:

java.lang.Exception

receive

default void receive(Address sender,
                     java.io.DataInput in,
                     int length)
              throws java.lang.Exception

Receive data from the given sender

Parameters:

sender - The sender

in - The data input from which to read

length - The number of bytes to read

Throws:

java.lang.Exception