Uses of Interface
org.jgroups.Address

Packages that use Address

org.jgroups	Provides top-level public JGroups classes such as Channel, Message, etc.
org.jgroups.blocks	Provides building blocks that are layered on top of channels.
org.jgroups.debug	Provides debug support, including testing, profiling, and a graphical view of a protocol stack.
org.jgroups.demos	Provides demonstrations of JGroups functionality.
org.jgroups.demos.wb	A distributed whiteboard applet implemented using JGroups.
org.jgroups.jmx
org.jgroups.jmx.protocols
org.jgroups.mux
org.jgroups.protocols	Provides implementations of transport protocols which are responsible for sending and receiving messages to/from the network.
org.jgroups.protocols.pbcast	Supports probabilistic broadcasts.
org.jgroups.stack	Support for managing protocol stacks.
org.jgroups.util	Provides useful functionality which cannot be assigned to any particular other package.

Uses of Address in org.jgroups

Fields in org.jgroups declared as Address

protected Address	Message.dest_addr
protected Address	Message.src_addr

Fields in org.jgroups with type parameters of type Address

protected java.util.Vector<Address>

View.members A list containing all the members of the view This list is always ordered, with the coordinator being the first member.

Methods in org.jgroups that return Address

Address	ViewId.getCoordAddress() returns the address of the member that issued this view
Address	View.getCreator() returns the creator of this view if this view was created with the empty constructur, null will be returned
Address	Message.getDest()
Address	JChannel.getLocalAddress() returns the local address of the channel returns null if the channel is closed
abstract Address	Channel.getLocalAddress() Returns the channel's own address.
Address	Message.getSrc()

Methods in org.jgroups that return types with arguments of type Address

java.util.Vector<Address>	Membership.getMembers() returns a copy (clone) of the members in this membership.
java.util.Vector<Address>	View.getMembers() Returns a reference to the List of members (ordered) Do NOT change this list, hence your will invalidate the view Make a copy if you have to modify it.

Methods in org.jgroups with parameters of type Address

void	Membership.add(Address new_member) Adds a new member to this membership.
void	ChannelListenerAdapter.channelReconnected(Address addr)
void	ChannelListener.channelReconnected(Address addr)
void	JChannel.connect(java.lang.String cluster_name, Address target, java.lang.String state_id, long timeout) Connects this channel to a group and gets a state from a specified state provider.
abstract void	Channel.connect(java.lang.String cluster_name, Address target, java.lang.String state_id, long timeout) Connects the channel to a group and fetches the state
boolean	Membership.contains(Address member) Returns true if the provided member belongs to this membership
boolean	View.containsMember(Address mbr) returns true, if this view contains a certain member
boolean	JChannel.getState(Address target, long timeout) Retrieves the current group state.
abstract boolean	Channel.getState(Address target, long timeout) Retrieve the state of the group.
boolean	JChannel.getState(Address target, java.lang.String state_id, long timeout) Retrieves a substate (or partial state) from the target.
abstract boolean	Channel.getState(Address target, java.lang.String state_id, long timeout) Fetches a partial state identified by state_id.
boolean	JChannel.getState(Address target, java.lang.String state_id, long timeout, boolean useFlushIfPresent) Retrieves a substate (or partial state) from the target.
protected void	Channel.notifyChannelReconnected(Address addr)
void	Membership.remove(Address old_member) removes an member from the membership.
void	JChannel.send(Address dst, Address src, java.io.Serializable obj) creates a new message with the destination address, and the source address and the object as the message value
abstract void	Channel.send(Address dst, Address src, java.io.Serializable obj) Helper method.
void	Message.setDest(Address new_dest)
void	Message.setSrc(Address new_src)
void	ExtendedReceiverAdapter.suspect(Address suspected_mbr)
void	MembershipListener.suspect(Address suspected_mbr) Called whenever a member is suspected of having crashed, but has not yet been excluded.
void	ReceiverAdapter.suspect(Address suspected_mbr)

Constructors in org.jgroups with parameters of type Address

MergeView(Address creator, long id, java.util.Vector<Address> members, java.util.Vector<View> subgroups)
Creates a new view

Message(Address dest)
Public constructor

Message(Address dest, Address src, byte[] buf)
Public constructor

Message(Address dest, Address src, byte[] buf, int offset, int length)
Constructs a message.

Message(Address dest, Address src, java.io.Serializable obj)
Public constructor

View(Address creator, long id, java.util.Vector<Address> members)
Creates a new view

ViewId(Address coord_addr)
Creates a ViewID with the coordinator address and a Lamport timestamp of 0.

ViewId(Address coord_addr, long id)
Creates a ViewID with the coordinator address and the given Lamport timestamp.

Constructor parameters in org.jgroups with type arguments of type Address

MergeView(Address creator, long id, java.util.Vector<Address> members, java.util.Vector<View> subgroups)
Creates a new view

MergeView(ViewId vid, java.util.Vector<Address> members, java.util.Vector<View> subgroups)
Creates a new view

View(Address creator, long id, java.util.Vector<Address> members)
Creates a new view

View(ViewId vid, java.util.Vector<Address> members)
Creates a new view

Uses of Address in org.jgroups.blocks

Fields in org.jgroups.blocks declared as Address

protected Address	RequestCorrelator.local_addr The address of this group member
protected Address	MessageDispatcher.local_addr

Fields in org.jgroups.blocks with type parameters of type Address

protected java.util.Stack<Address>	RequestCorrelator.call_stack This field is used only if deadlock detection is enabled.
java.util.Stack<Address>	RequestCorrelator.Header.callStack Stack<Address>.
java.util.List<Address>	RequestCorrelator.Header.dest_mbrs Contains a list of members who should receive the request (others will drop).

Methods in org.jgroups.blocks that return Address

Address	GroupRequest.getCaller()
Address	RequestCorrelator.getLocalAddress()
Address	BasicConnectionTable.getLocalAddress()
Address	ReplicatedTree.getLocalAddress()
Address	NotificationBus.getLocalAddress()
Address	DistributedHashtable.getLocalAddress() Deprecated.
Address	DistributedQueue.getLocalAddress()
Address	ReplicatedHashMap.getLocalAddress()
Address	ReplicatedHashtable.getLocalAddress() Deprecated.

Methods in org.jgroups.blocks that return types with arguments of type Address

java.util.Vector<Address>

GroupRequest.getSuspects() Returns the list of suspected members.

Methods in org.jgroups.blocks with parameters of type Address

java.lang.Object	RpcDispatcher.callRemoteMethod(Address dest, MethodCall method_call, int mode, long timeout)
java.lang.Object	RpcDispatcher.callRemoteMethod(Address dest, MethodCall method_call, int mode, long timeout, boolean oob)
java.lang.Object	RpcDispatcher.callRemoteMethod(Address dest, java.lang.String method_name, java.lang.Object[] args, java.lang.Class[] types, int mode, long timeout)
java.lang.Object	RpcDispatcher.callRemoteMethod(Address dest, java.lang.String method_name, java.lang.Object[] args, java.lang.String[] signature, int mode, long timeout)
void	RpcDispatcher.channelReconnected(Address new_addr)
void	PullPushAdapter.channelReconnected(Address addr) Deprecated.
void	BasicConnectionTable.ConnectionListener.connectionClosed(Address peer_addr)
void	BasicConnectionTable.ConnectionListener.connectionOpened(Address peer_addr)
java.io.Serializable	NotificationBus.getCacheFromMember(Address mbr, long timeout, int max_tries) Determines the coordinator and asks it for its cache.
boolean	RspFilter.isAcceptable(java.lang.Object response, Address sender) Determines whether a response from a given sender should be added to the response list of the request
void	NotificationBus.Consumer.memberJoined(Address mbr)
void	NotificationBus.Consumer.memberLeft(Address mbr)
protected void	PullPushAdapter.notifySuspect(Address suspected_mbr) Deprecated.
void	BasicConnectionTable.receive(Address sender, byte[] data, int offset, int length) Calls the receiver callback.
void	BasicConnectionTable.Receiver.receive(Address sender, byte[] data, int offset, int length)
void	RspCollector.receiveResponse(java.lang.Object response_value, Address sender)
void	GroupRequest.receiveResponse(java.lang.Object response_value, Address sender) Callback (called by RequestCorrelator or Transport).
void	RequestCorrelator.receiveSuspect(Address mbr) Event.SUSPECT event received from a layer below.
void	BasicConnectionTable.remove(Address addr) Remove addrfrom connection table.
protected void	ConnectionTableNIO.runRequest(Address addr, java.nio.ByteBuffer buf)
void	BasicConnectionTable.send(Address dest, byte[] data, int offset, int length)
void	NotificationBus.sendNotification(Address dest, java.io.Serializable n) Pack the argument in a Info, serialize that one into the message buffer and send the message
void	GroupRequest.setCaller(Address caller)
void	RequestCorrelator.setLocalAddress(Address local_addr)
void	ReplicatedTree.suspect(Address suspected_mbr) Called when a member is suspected
void	VotingAdapter.suspect(Address suspected) Callback for notification that one node is suspected
void	MembershipListenerAdapter.suspect(Address suspected_mbr) Notify membership listener that some node was suspected.
void	RspCollector.suspect(Address mbr)
void	NotificationBus.suspect(Address suspected_mbr)
void	DistributedHashtable.suspect(Address suspected_mbr) Deprecated. Called when a member is suspected
void	DistributedLockManager.suspect(Address suspected_mbr)
void	DistributedQueue.suspect(Address suspected_mbr) Called when a member is suspected
void	GroupRequest.suspect(Address suspected_member) Callback (called by RequestCorrelator or Transport).
void	ReplicatedHashMap.suspect(Address suspected_mbr) Called when a member is suspected
void	DistributedTree.suspect(Address suspected_mbr) Called when a member is suspected
void	ReplicatedHashtable.suspect(Address suspected_mbr) Deprecated. Called when a member is suspected

Method parameters in org.jgroups.blocks with type arguments of type Address

void	GroupRequest.reset(java.util.Vector<Address> mbrs) This method sets the membership variable to the value of members.
void	BasicConnectionTable.retainAll(java.util.Collection<Address> current_mbrs) Removes all connections from ConnectionTable which are not in current_mbrs
void	RequestCorrelator.sendRequest(long id, java.util.List<Address> dest_mbrs, Message msg, RspCollector coll)
void	RequestCorrelator.sendRequest(long id, java.util.List<Address> dest_mbrs, Message msg, RspCollector coll, boolean use_anycasting) Send a request to a group.
void	ReplicatedHashMap.Notification.viewChange(View view, java.util.Vector<Address> new_mbrs, java.util.Vector<Address> old_mbrs)
void	ReplicatedHashMap.Notification.viewChange(View view, java.util.Vector<Address> new_mbrs, java.util.Vector<Address> old_mbrs)

Constructors in org.jgroups.blocks with parameters of type Address

RequestCorrelator(java.lang.String name, java.lang.Object transport, RequestHandler handler, Address local_addr)

RequestCorrelator(java.lang.String name, java.lang.Object transport, RequestHandler handler, boolean deadlock_detection, Address local_addr)

RequestCorrelator(java.lang.String name, java.lang.Object transport, RequestHandler handler, boolean deadlock_detection, Address local_addr, boolean concurrent_processing)

Constructor parameters in org.jgroups.blocks with type arguments of type Address

GroupRequest(Message m, RequestCorrelator corr, java.util.Vector<Address> members, int rsp_mode)

GroupRequest(Message m, RequestCorrelator corr, java.util.Vector<Address> members, int rsp_mode, long timeout, int expected_mbrs)

GroupRequest(Message m, Transport transport, java.util.Vector<Address> members, int rsp_mode)

GroupRequest(Message m, Transport transport, java.util.Vector<Address> members, int rsp_mode, long timeout, int expected_mbrs)

Uses of Address in org.jgroups.debug

Methods in org.jgroups.debug with parameters of type Address

void	Simulator.addMember(Address addr)
void	Simulator.addMember(Address addr, Simulator s)
void	Simulator.setLocalAddress(Address addr)

Uses of Address in org.jgroups.demos

Methods in org.jgroups.demos with parameters of type Address

void	Gossip.channelReconnected(Address new_addr)
void	Draw.channelReconnected(Address addr)
void	NotificationBusDemo.memberJoined(Address mbr)
void	NotificationBusDemo.memberLeft(Address mbr)
void	ViewDemo.suspect(Address suspected_mbr) Called when a member is suspected
void	QuoteServer.suspect(Address suspected_mbr)
void	QuoteClient.suspect(Address suspected_mbr)
void	ChatCore.suspect(Address suspected_mbr)
void	Topology.suspect(Address suspected_mbr)

Uses of Address in org.jgroups.demos.wb

Fields in org.jgroups.demos.wb declared as Address

Address

Node.addr

Methods in org.jgroups.demos.wb with parameters of type Address

void	Whiteboard.addNode(java.lang.String lbl, Address addr, int xloc, int yloc)
void	GraphPanel.addNode(java.lang.String lbl, Address addr, int xloc, int yloc)
void	Whiteboard.suspect(Address obj)

Uses of Address in org.jgroups.jmx

Methods in org.jgroups.jmx that return Address

Address	JChannelMBean.getLocalAddress()
Address	JChannel.getLocalAddress()

Methods in org.jgroups.jmx with parameters of type Address

boolean	JChannelMBean.getState(Address target, long timeout)
boolean	JChannel.getState(Address target, long timeout)
void	JChannelMBean.send(Address dst, Address src, java.io.Serializable obj)
void	JChannel.send(Address dst, Address src, java.io.Serializable obj)

Uses of Address in org.jgroups.jmx.protocols

Methods in org.jgroups.jmx.protocols that return Address

Address	TP.getLocalAddress()
Address	TPMBean.getLocalAddress()

Uses of Address in org.jgroups.mux

Methods in org.jgroups.mux that return Address

Address	MuxChannel.getLocalAddress()
Address	Multiplexer.getLocalAddress()
Address	Multiplexer.getStateProvider(Address preferredTarget, java.lang.String service_id) Returns an Address of a state provider for a given service_id.

Methods in org.jgroups.mux with parameters of type Address

void	MuxChannel.connect(java.lang.String cluster_name, Address target, java.lang.String state_id, long timeout)
boolean	MuxChannel.getState(Address target, long timeout)
boolean	MuxChannel.getState(Address target, java.lang.String state_id, long timeout)
boolean	Multiplexer.getState(Address target, java.lang.String id, long timeout)
boolean	MuxChannel.getState(Address target, java.lang.String state_id, long timeout, boolean useFlushIfPresent)
Address	Multiplexer.getStateProvider(Address preferredTarget, java.lang.String service_id) Returns an Address of a state provider for a given service_id.
void	MuxChannel.send(Address dst, Address src, java.io.Serializable obj)
void	Multiplexer.sendServiceDownMessage(java.lang.String service, Address host, boolean bypassFlush)
void	Multiplexer.sendServiceUpMessage(java.lang.String service, Address host, boolean bypassFlush)

Constructors in org.jgroups.mux with parameters of type Address

ServiceInfo(byte type, java.lang.String service, Address host, byte[] state)

Uses of Address in org.jgroups.protocols

Classes in org.jgroups.protocols that implement Address

static class

JMS.JMSAddress Simple Address representing the JMS node ID or JMS topic group.

Fields in org.jgroups.protocols declared as Address

Address	PingRsp.coord_addr
protected Address	TP.local_addr The address (host and port) of this member
protected Address	PARTITION.local_address
Address	PingRsp.own_addr

Fields in org.jgroups.protocols with type parameters of type Address

protected java.util.Vector<Address>

TP.members The members of this group (updated when a member joins or leaves)

Methods in org.jgroups.protocols that return Address

protected Address	UDP.createLocalAddress()
Address	PingRsp.getAddress()
Address	PingRsp.getCoordAddress()
Address	SEQUENCER.getCoordinator()
protected Address	ENCRYPT.getKeyServerAddr()
protected Address	ENCRYPT.getLocal_addr()
Address	TP.getLocalAddress()
Address	SEQUENCER.getLocalAddress()
Address	SEQUENCER.SequencerHeader.getOriginalSender()

Methods in org.jgroups.protocols that return types with arguments of type Address

java.util.List<Address>

TCPPING.getInitialHosts() Returns the list of initial hosts as configured by the user via XML.

Methods in org.jgroups.protocols with parameters of type Address

void	DISCARD.addIgnoreMember(Address sender) Messages from this sender will get dropped
protected void	FD.Broadcaster.addSuspectedMember(Address mbr) Adds a suspected member.
void	FD.BroadcastTask.addSuspectedMember(Address suspect)
void	TCPPING.localAddressSet(Address addr)
void	PING.localAddressSet(Address addr)
void	Discovery.localAddressSet(Address addr) Called after local_addr was set
abstract void	TP.postUnmarshalling(Message msg, Address dest, Address src, boolean multicast)
void	UDP.postUnmarshalling(Message msg, Address dest, Address src, boolean multicast)
void	BasicTCP.postUnmarshalling(Message msg, Address dest, Address src, boolean multicast)
void	SHARED_LOOPBACK.postUnmarshalling(Message msg, Address dest, Address src, boolean multicast)
void	TUNNEL.postUnmarshalling(Message msg, Address dest, Address src, boolean multicast)
abstract void	TP.postUnmarshallingList(Message msg, Address dest, boolean multicast)
void	UDP.postUnmarshallingList(Message msg, Address dest, boolean multicast)
void	BasicTCP.postUnmarshallingList(Message msg, Address dest, boolean multicast)
void	SHARED_LOOPBACK.postUnmarshallingList(Message msg, Address dest, boolean multicast)
void	TUNNEL.postUnmarshallingList(Message msg, Address dest, boolean multicast)
protected void	TP.receive(Address dest, Address sender, byte[] data, int offset, int length) Subclasses must call this method when a unicast or multicast message has been received.
void	BasicTCP.receive(Address sender, byte[] data, int offset, int length) ConnectionTable.Receiver interface
void	SMACK.retransmit(long seqno, Message msg, Address dest)
void	TCP.send(Address dest, byte[] data, int offset, int length)
void	TCP_NIO.send(Address dest, byte[] data, int offset, int length)
abstract void	BasicTCP.send(Address dest, byte[] data, int offset, int length)
abstract void	TP.sendToSingleMember(Address dest, byte[] data, int offset, int length) Send to all members in the group.
void	UDP.sendToSingleMember(Address dest, byte[] data, int offset, int length)
void	BasicTCP.sendToSingleMember(Address dest, byte[] data, int offset, int length)
void	SHARED_LOOPBACK.sendToSingleMember(Address dest, byte[] data, int offset, int length)
void	TUNNEL.sendToSingleMember(Address dest, byte[] data, int offset, int length)
protected void	ENCRYPT.setKeyServerAddr(Address keyServerAddr)
protected void	ENCRYPT.setLocal_addr(Address local_addr)

Method parameters in org.jgroups.protocols with type arguments of type Address

void	TCP.retainAll(java.util.Collection<Address> members)
void	TCP_NIO.retainAll(java.util.Collection<Address> members)
abstract void	BasicTCP.retainAll(java.util.Collection<Address> members)

Constructors in org.jgroups.protocols with parameters of type Address

FD_ALL.Header(byte type, Address suspect)

FD_SOCK.FdHeader(byte type, Address mbr)

FD.FdHeader(byte type, java.util.Vector<Address> mbrs, Address from)

HTOTAL.HTotalHeader(Address dest, Address src)