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).
-
IbusChannel(String, String)
-
-
Cast(byte[])
- Send to all members
-
Connect(long)
- Start receiving (and storing) msgs
-
Destroy()
- Deletes the channel
-
Disconnect()
- Stop receiving msgs
-
dispatchPull(iBusURL, Posting)
-
-
dispatchPush(iBusURL, Posting)
-
-
error(iBusURL, String)
-
-
GetAddress()
-
-
GetMembers()
- Get all members
-
GetName()
-
-
GetNumMembers()
- Get number of members connected to channel including caller
-
getState(iBusURL)
-
-
Receive(long)
- Receive a message (must be connected)
-
Send(Message)
- Send a message
-
Send(Object, byte[])
- Send to 1 member
-
Send(Vector, byte[])
- Send to a subset of the members
-
SetMembershipListener(MembershipListener)
-
-
setState(iBusURL, Serializable)
-
-
viewChange(View)
-
IbusChannel
public IbusChannel(String channel_name,
String props)
Connect
public void Connect(long timeout) throws Exception
- Start receiving (and storing) msgs
- Overrides:
- Connect in class Channel
Disconnect
public void Disconnect()
- Stop receiving msgs
- Overrides:
- Disconnect in class Channel
Destroy
public void Destroy()
- Deletes the channel
- Overrides:
- Destroy in class Channel
Cast
public void Cast(byte msg[]) throws Exception
- Send to all members
- Overrides:
- Cast in class Channel
Send
public void Send(Object dest_addr,
byte msg[]) throws Exception
- Send to 1 member
- Overrides:
- Send in class Channel
Send
public void Send(Vector dests,
byte msg[]) throws Exception
- Send to a subset of the members
- Overrides:
- Send in class Channel
Send
public void Send(Message msg) throws Exception
- Send a message
- Overrides:
- Send in class Channel
Receive
public Message Receive(long timeout) throws NotConnected, TimeoutException
- Receive a message (must be connected)
- Overrides:
- Receive in class Channel
GetMembers
public synchronized Vector GetMembers()
- Get all members
- Overrides:
- GetMembers in class Channel
GetNumMembers
public synchronized int GetNumMembers()
- Get number of members connected to channel including caller
- Overrides:
- GetNumMembers in class Channel
SetMembershipListener
public void SetMembershipListener(MembershipListener listener)
- Overrides:
- SetMembershipListener in class Channel
GetAddress
public Object GetAddress()
- Overrides:
- GetAddress in class Channel
GetName
public String GetName()
- Overrides:
- GetName in class Channel
dispatchPull
public Posting dispatchPull(iBusURL channel,
Posting request)
dispatchPush
public void dispatchPush(iBusURL source,
Posting p)
error
public void error(iBusURL url,
String details)
getState
public Serializable getState(iBusURL channel)
setState
public void setState(iBusURL channel,
Serializable state)
viewChange
public synchronized void viewChange(View newView)
All Packages Class Hierarchy This Package Previous Next Index