public class RpcDispatcherBlocking extends Object implements MembershipListener
Constructor and Description |
---|
RpcDispatcherBlocking(String props,
long timeout) |
Modifier and Type | Method and Description |
---|---|
void |
block()
Block sending and receiving of messages until viewAccepted() is called
|
static void |
main(String[] args) |
void |
print(int i) |
void |
start() |
void |
suspect(Address suspected_mbr)
Called when a member is suspected
|
void |
unblock()
Called after the FLUSH protocol has unblocked previously blocked senders, and
messages can be sent again.
|
void |
viewAccepted(View new_view)
Called when a change in membership has occurred.
|
public RpcDispatcherBlocking(String props, long timeout)
public void viewAccepted(View new_view)
MembershipListener
Channel.connect(String)
returns.viewAccepted
in interface MembershipListener
public void suspect(Address suspected_mbr)
suspect
in interface MembershipListener
public void block()
block
in interface MembershipListener
public void unblock()
MembershipListener
Note that during new view installation we provide guarantee that unblock invocation strictly follows view installation at some node A belonging to that view . However, some other message M may squeeze in between view and unblock callbacks. For more details see https://jira.jboss.org/jira/browse/JGRP-986
unblock
in interface MembershipListener
public static void main(String[] args)
Copyright © 2024 JBoss, a division of Red Hat. All rights reserved.