org.jgroups.demos

Class PubServer

java.lang.Object

org.jgroups.blocks.cs.ReceiverAdapter

org.jgroups.demos.PubServer

All Implemented Interfaces:

Receiver

public class PubServer
extends ReceiverAdapter

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

Since:

3.6.5

Author:

Bela Ban

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
PubServer()

Method Summary

Modifier and Type	Method and Description
protected static void	help()
static void	main(java.lang.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, java.nio.ByteBuffer buf) The default implementation assumes that Buffer.flip() or Buffer.rewind() was called on buf before invoking this callback
protected void	start(java.net.InetAddress bind_addr, int port, boolean nio)

Methods inherited from class java.lang.Object

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

Field Detail

server

protected BaseServer server

log

protected final Log log

Constructor Detail

PubServer

public PubServer()

Method Detail

start

protected void start(java.net.InetAddress bind_addr,
                     int port,
                     boolean nio)
              throws java.lang.Exception

Throws:

java.lang.Exception

receive

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

Description copied from class: ReceiverAdapter

The default implementation assumes that Buffer.flip() or Buffer.rewind() was called on buf before invoking this callback

Specified by:

receive in interface Receiver

Overrides:

receive in class ReceiverAdapter

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

Overrides:

receive in class ReceiverAdapter

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

main

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

Throws:

java.lang.Exception

help

protected static void help()