Package org.jgroups.demos

Class PubServer

java.lang.Object

org.jgroups.demos.PubServer

All Implemented Interfaces:

Receiver

public class PubServer
extends Object
implements Receiver

Demo which starts an NioServer that accepts messages from clients (PubClient) and forwards them to all connected clients

Since:

3.6.5

Field Summary

Fields

Modifier and Type	Field	Description
protected final Log	log
protected BaseServer	server

Constructor Summary

Constructors

Constructor	Description
PubServer()

Method Summary

Modifier and Type	Method	Description
protected static void	help()
static void	main(String[] args)
void	receive(Address sender, byte[] buf, int offset, int length)	Delivers a message from a given sender to the application
void	receive(Address sender, DataInput in, int length)	Receive data from the given sender
void	receive(Address sender, ByteBuffer buf)	Delivers a message from a given sender to the application
protected void	start(InetAddress bind_addr, int port, boolean nio, int recv_buf_size)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.jgroups.blocks.cs.Receiver

receive

Field Details

server

protected BaseServer server

log

protected final Log log

Constructor Details

PubServer

public PubServer()

Method Details

start

protected void start(InetAddress bind_addr,
 int port,
 boolean nio,
 int recv_buf_size)
              throws Exception

Throws:

Exception

receive

public void receive(Address sender,
 ByteBuffer buf)

Description copied from interface: Receiver

Delivers a message from a given sender to the application

Specified by:

receive in interface Receiver

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

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

Description copied from interface: Receiver

Delivers a message from a given sender to the application

Specified by:

receive in interface Receiver

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

public void receive(Address sender,
 DataInput in,
 int length)
             throws Exception

Description copied from interface: Receiver

Receive data from the given sender

Specified by:

receive in interface Receiver

Parameters:

sender - The sender

in - The data input from which to read

length - The number of bytes to read

Throws:

Exception

main

public static void main(String[] args)
                 throws Exception

Throws:

Exception

help

protected static void help()