All Packages  Class Hierarchy  This Package  Previous  Next  Index

Class JavaGroups.IbusChannel 

java.lang.Object
   |
   +----JavaGroups.Channel
           |
           +----JavaGroups.IbusChannel
public class IbusChannel
extends Channel
implements Receiver, Membership
Implementation of a channel using iBus. iBus is a pure Java-based publish/subscribe bus. An entity subscribed to a certain address receives all messages published by any publisher under the same address (or topic).

Constructor Index

o IbusChannel()
o IbusChannel(Object)

Method Index

o BlockOk()
Called to acknowledge a Block (callback in MembershipListener or BlockEvent received from call to Receive).
o Close()
Destroys the channel and its associated resources (e.g.
o Connect(Object)
Connects the channel to a group.
o Disconnect()
Disconnects the channel from the current group (if connected), leaving the group.
o dispatchPull(iBusURL, Posting)
o dispatchPush(iBusURL, Posting)
o error(iBusURL, String)
o GetAllStates(long)
Retrieve all states of the group members.
o GetGroupAddress()
Returns the group address of the group of which the channel is a member.
o GetLocalAddress()
Returns the channel's own address.
o GetOpt(int)
Gets an option.
o getState(iBusURL)
o GetState(long)
Retrieve the state of the group.
o GetView()
Gets the current view.
o Peek(long)
Returns the next message, view, block, suspect or other event without removing it from the queue.
o Receive(long)
Receives a message, a view change or a block event.
o ReturnState(Serializable)
Called by the application is response to receiving a GetState object when calling Receive.
o Send(Message)
Sends a message to a destination.
o SetOpt(int, Object)
Sets an option.
o setState(iBusURL, Serializable)
o viewChange(View)

Constructors

o IbusChannel 
 public IbusChannel() throws ChannelException
o IbusChannel 
 public IbusChannel(Object props) throws ChannelException

Methods

o Connect 
 public void Connect(Object address) throws ChannelClosed
Connects the channel to a group.

Overrides:
Connect in class Channel
o Disconnect 
 public void Disconnect()
Disconnects the channel from the current group (if connected), leaving the group.

Overrides:
Disconnect in class Channel
o Close 
 public void Close()
Destroys the channel and its associated resources (e.g.

Overrides:
Close in class Channel
o Send 
 public void Send(Message msg) throws ChannelNotConnected, ChannelClosed
Sends a message to a destination.

Overrides:
Send in class Channel
o Receive 
 public Object Receive(long timeout) throws ChannelNotConnected, ChannelClosed, Timeout
Receives a message, a view change or a block event.

Overrides:
Receive in class Channel
o Peek 
 public Object Peek(long timeout) throws ChannelNotConnected, ChannelClosed, Timeout
Returns the next message, view, block, suspect or other event without removing it from the queue.

Overrides:
Peek in class Channel
o GetView 
 public View GetView()
Gets the current view.

Overrides:
GetView in class Channel
o GetLocalAddress 
 public Object GetLocalAddress()
Returns the channel's own address.

Overrides:
GetLocalAddress in class Channel
o GetGroupAddress 
 public Object GetGroupAddress()
Returns the group address of the group of which the channel is a member.

Overrides:
GetGroupAddress in class Channel
o SetOpt 
 public void SetOpt(int option,
                    Object value)
Sets an option.

Overrides:
SetOpt in class Channel
o GetOpt 
 public Object GetOpt(int option)
Gets an option.

Overrides:
GetOpt in class Channel
o BlockOk 
 public void BlockOk()
Called to acknowledge a Block (callback in MembershipListener or BlockEvent received from call to Receive).

Overrides:
BlockOk in class Channel
o GetState 
 public Object GetState(long timeout)
Retrieve the state of the group.

Overrides:
GetState in class Channel
o GetAllStates 
 public Vector GetAllStates(long timeout)
Retrieve all states of the group members.

Overrides:
GetAllStates in class Channel
o ReturnState 
 public void ReturnState(Serializable state)
Called by the application is response to receiving a GetState object when calling Receive.

Overrides:
ReturnState in class Channel
o dispatchPull 
 public Posting dispatchPull(iBusURL channel,
                             Posting request)
o dispatchPush 
 public void dispatchPush(iBusURL source,
                          Posting p)
o error 
 public void error(iBusURL url,
                   String details)
o getState 
 public Serializable getState(iBusURL channel)
o setState 
 public void setState(iBusURL channel,
                      Serializable state)
o viewChange 
 public synchronized void viewChange(View newView)

All Packages  Class Hierarchy  This Package  Previous  Next  Index