UnicastTest.MyReceiver

java.lang.Object

org.jgroups.tests.UnicastTest.MyReceiver

All Implemented Interfaces:: Receiver

Enclosing class:: UnicastTest

protected class UnicastTest.MyReceiver extends Object implements Receiver

Field Summary

Fields

Modifier and Type

Field

Description

protected AtomicLong

current_value

protected long

print

protected long

start

protected AtomicLong

total_bytes
Constructor Summary

Constructors

Modifier

Constructor

Description

protected

MyReceiver()
Method Summary

Modifier and Type

Method

Description

void

receive(Message msg)

Called when a message is received.

void

viewAccepted(View new_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
- start
  
  protected long start
- print
  
  protected long print
- current_value
  
  protected AtomicLong current_value
- total_bytes
  
  protected AtomicLong total_bytes
Constructor Details
- MyReceiver
  
  protected MyReceiver()
Method Details
- 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 new_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