Package org.jgroups.tests

Class MessageSendTest

java.lang.Object

org.jgroups.tests.MessageSendTest

All Implemented Interfaces:

Receiver

public class MessageSendTest
extends Object
implements Receiver

Tests sending different types of Message implementations over a given protocol stack

Since:

5.0

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	MessageSendTest.MyData
protected static class	MessageSendTest.MyHeader
static class	MessageSendTest.MySizeData
protected static class	MessageSendTest.Person

Field Summary

Fields

Modifier and Type	Field	Description
protected final AckCollector	acks
protected JChannel	ch
protected static short	ID
protected View	view

Constructor Summary

Constructors

Constructor	Description
MessageSendTest()

Method Summary

Modifier and Type	Method	Description
protected static int	findFragSize(JChannel ch)
static void	main(String[] args)
void	receive(Message msg)	Called when a message is received.
protected void	send(Message msg)
protected void	start(String props, String name)
void	viewAccepted(View view)	Called when a change in membership has occurred.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.jgroups.Receiver

block, getState, receive, setState, unblock

Field Details

ch

protected JChannel ch

acks

protected final AckCollector acks

view

protected View view

ID

protected static short ID

Constructor Details

MessageSendTest

public MessageSendTest()

Method Details

start

protected void start(String props,
 String name)
              throws Exception

Throws:

Exception

send

protected void send(Message msg)
             throws Exception

Throws:

Exception

findFragSize

protected static int findFragSize(JChannel ch)

receive

public void receive(Message msg)

Description copied from interface: Receiver

Called when a message is received.

Specified by:

receive in interface Receiver

Parameters:

msg - The message

viewAccepted

public void viewAccepted(View view)

Description copied from interface: Receiver

Called when a change in membership has occurred. No long running actions, sending of messages or anything that could block should be done in this callback. If some long running action needs to be performed, it should be done in a separate thread.

Note that on reception of the first view (a new member just joined), the channel will not yet be in the connected state. This only happens when JChannel.connect(String) returns.

Specified by:

viewAccepted in interface Receiver

main

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

Throws:

Exception