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(String, String)

Method Index

 o Cast(byte[])
Send to all members
 o Connect(long)
Start receiving (and storing) msgs
 o Destroy()
Deletes the channel
 o Disconnect()
Stop receiving msgs
 o dispatchPull(iBusURL, Posting)
 o dispatchPush(iBusURL, Posting)
 o error(iBusURL, String)
 o GetAddress()
 o GetMembers()
Get all members
 o GetName()
 o GetNumMembers()
Get number of members connected to channel including caller
 o getState(iBusURL)
 o Receive(long)
Receive a message (must be connected)
 o Send(Message)
Send a message
 o Send(Object, byte[])
Send to 1 member
 o Send(Vector, byte[])
Send to a subset of the members
 o SetMembershipListener(MembershipListener)
 o setState(iBusURL, Serializable)
 o viewChange(View)

Constructors

 o IbusChannel
 public IbusChannel(String channel_name,
                    String props)

Methods

 o Connect
 public void Connect(long timeout) throws Exception
Start receiving (and storing) msgs

Overrides:
Connect in class Channel
 o Disconnect
 public void Disconnect()
Stop receiving msgs

Overrides:
Disconnect in class Channel
 o Destroy
 public void Destroy()
Deletes the channel

Overrides:
Destroy in class Channel
 o Cast
 public void Cast(byte msg[]) throws Exception
Send to all members

Overrides:
Cast in class Channel
 o Send
 public void Send(Object dest_addr,
                  byte msg[]) throws Exception
Send to 1 member

Overrides:
Send in class Channel
 o Send
 public void Send(Vector dests,
                  byte msg[]) throws Exception
Send to a subset of the members

Overrides:
Send in class Channel
 o Send
 public void Send(Message msg) throws Exception
Send a message

Overrides:
Send in class Channel
 o Receive
 public Message Receive(long timeout) throws NotConnected, TimeoutException
Receive a message (must be connected)

Overrides:
Receive in class Channel
 o GetMembers
 public synchronized Vector GetMembers()
Get all members

Overrides:
GetMembers in class Channel
 o GetNumMembers
 public synchronized int GetNumMembers()
Get number of members connected to channel including caller

Overrides:
GetNumMembers in class Channel
 o SetMembershipListener
 public void SetMembershipListener(MembershipListener listener)
Overrides:
SetMembershipListener in class Channel
 o GetAddress
 public Object GetAddress()
Overrides:
GetAddress in class Channel
 o GetName
 public String GetName()
Overrides:
GetName 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