|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.jgroups.blocks.NotificationBus
@Deprecated public class NotificationBus
This class provides notification sending and handling capability. Producers can send notifications to all registered consumers. Provides hooks to implement shared group state, which allows an application programmer to maintain a local cache which is replicated by all instances. NotificationBus sits on top of a channel, however it creates its channel itself, so the application programmers do not have to provide their own channel.
Nested Class Summary | |
---|---|
static interface |
NotificationBus.Consumer
Deprecated. |
Field Summary | |
---|---|
protected Log |
log
Deprecated. |
Constructor Summary | |
---|---|
NotificationBus()
Deprecated. |
|
NotificationBus(Channel channel,
java.lang.String bus_name)
Deprecated. |
|
NotificationBus(java.lang.String bus_name)
Deprecated. |
|
NotificationBus(java.lang.String bus_name,
java.lang.String properties)
Deprecated. |
Method Summary | |
---|---|
void |
block()
Deprecated. Called (usually by the FLUSH protocol), as an indication that the member should stop sending messages. |
java.io.Serializable |
getCache()
Deprecated. |
java.io.Serializable |
getCacheFromCoordinator(long timeout,
int max_tries)
Deprecated. Determines the coordinator and asks it for its cache. |
java.io.Serializable |
getCacheFromMember(Address mbr,
long timeout,
int max_tries)
Deprecated. Determines the coordinator and asks it for its cache. |
Channel |
getChannel()
Deprecated. Answers the Channel. |
Address |
getLocalAddress()
Deprecated. |
java.util.Vector |
getMembership()
Deprecated. Returns a reference to the real membership: don't modify. |
byte[] |
getState()
Deprecated. Answers the group state; e.g., when joining. |
boolean |
isCoordinator()
Deprecated. |
void |
notifyConsumer(java.io.Serializable n)
Deprecated. Don't multicast this to all members, just apply it to local consumers. |
void |
receive(Message msg)
Deprecated. Called when a message is received. |
void |
sendNotification(Address dest,
java.io.Serializable n)
Deprecated. Pack the argument in a Info, serialize that one into the message buffer and send the message |
void |
sendNotification(java.io.Serializable n)
Deprecated. Pack the argument in a Info, serialize that one into the message buffer and send the message |
void |
setConsumer(NotificationBus.Consumer c)
Deprecated. |
void |
setState(byte[] state)
Deprecated. Sets the group state; e.g., when joining. |
void |
start()
Deprecated. |
void |
stop()
Deprecated. |
void |
suspect(Address suspected_mbr)
Deprecated. Called whenever a member is suspected of having crashed, but has not yet been excluded. |
void |
viewAccepted(View new_view)
Deprecated. 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 |
Field Detail |
---|
protected final Log log
Constructor Detail |
---|
public NotificationBus() throws java.lang.Exception
java.lang.Exception
public NotificationBus(java.lang.String bus_name) throws java.lang.Exception
java.lang.Exception
public NotificationBus(java.lang.String bus_name, java.lang.String properties) throws java.lang.Exception
java.lang.Exception
public NotificationBus(Channel channel, java.lang.String bus_name) throws java.lang.Exception
java.lang.Exception
Method Detail |
---|
public void setConsumer(NotificationBus.Consumer c)
public Address getLocalAddress()
public java.util.Vector getMembership()
public Channel getChannel()
public boolean isCoordinator()
public void start() throws java.lang.Exception
java.lang.Exception
public void stop()
public void sendNotification(java.io.Serializable n)
public void sendNotification(Address dest, java.io.Serializable n)
public java.io.Serializable getCacheFromCoordinator(long timeout, int max_tries)
timeout
- Max number of msecs until the call returnsmax_tries
- Max number of attempts to fetch the cache from the coordinatorpublic java.io.Serializable getCacheFromMember(Address mbr, long timeout, int max_tries)
mbr
- The address of the member from which to fetch the state. If null, the current coordinator
will be asked for the statetimeout
- Max number of msecs until the call returns - if timeout elapses
null will be returnedmax_tries
- Max number of attempts to fetch the cache from the coordinator (will be set to 1 if < 1)public void notifyConsumer(java.io.Serializable n)
public void receive(Message msg)
MessageListener
receive
in interface MessageListener
public byte[] getState()
MessageListener
getState
in interface MessageListener
public void setState(byte[] state)
MessageListener
setState
in interface MessageListener
public void viewAccepted(View new_view)
MembershipListener
Channel.connect(String)
returns.
viewAccepted
in interface MembershipListener
public void suspect(Address suspected_mbr)
MembershipListener
suspect
in interface MembershipListener
public void block()
MembershipListener
ExtendedMembershipListener.unblock()
.
Note that block() is the equivalent of reception of a BlockEvent in the pull mode.
block
in interface MembershipListener
public java.io.Serializable getCache()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |