org.hibernate.search.backend.impl.jgroups
Class JGroupsMasterMessageListener

java.lang.Object
  org.hibernate.search.backend.impl.jgroups.JGroupsMasterMessageListener

All Implemented Interfaces:

org.jgroups.MembershipListener, org.jgroups.MessageListener, org.jgroups.Receiver

public class JGroupsMasterMessageListener
extends Object
implements org.jgroups.Receiver

Listen for messages from slave nodes and apply them into LuceneBackendQueueProcessor

Author:

Lukasz Moren, Sanne Grinovero (C) 2011 Red Hat Inc.

See Also:

LuceneBackendQueueProcessor, LuceneBackendQueueTask, Receiver

Constructor Summary

JGroupsMasterMessageListener(BuildContext context, NodeSelectorStrategyHolder masterNodeSelector)

Method Summary

void	block()
void	getState(OutputStream arg0)
void	receive(org.jgroups.Message message)
void	setState(InputStream arg0)
void	suspect(org.jgroups.Address suspected_mbr)
void	unblock()
void	viewAccepted(org.jgroups.View view)

Methods inherited from class java.lang.Object

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

Constructor Detail

JGroupsMasterMessageListener

public JGroupsMasterMessageListener(BuildContext context,
                                    NodeSelectorStrategyHolder masterNodeSelector)

Method Detail

receive

public void receive(org.jgroups.Message message)

Specified by:

receive in interface org.jgroups.MessageListener

viewAccepted

public void viewAccepted(org.jgroups.View view)

Specified by:

viewAccepted in interface org.jgroups.MembershipListener

suspect

public void suspect(org.jgroups.Address suspected_mbr)

Specified by:

suspect in interface org.jgroups.MembershipListener

block

public void block()

Specified by:

block in interface org.jgroups.MembershipListener

getState

public void getState(OutputStream arg0)
              throws Exception

Specified by:

getState in interface org.jgroups.MessageListener

Throws:

Exception

setState

public void setState(InputStream arg0)
              throws Exception

Specified by:

setState in interface org.jgroups.MessageListener

Throws:

Exception

unblock

public void unblock()

Specified by:

unblock in interface org.jgroups.MembershipListener