com.anabas.gxo
Interface GMS_StreamPublisher

All Known Implementing Classes:
GMS_PublisherImpl

public interface GMS_StreamPublisher

Title: Description: Copyright: Copyright (c) 2000 Company:


Method Summary
 void broadcast(GMS_Message m)
          Broadcast the message to all subscribers in this channel.
 GMS_DestinationSelector createDestinationSelector(java.lang.String name)
          Creates an instance of the specified desintation selector type.
 GMS_Message createMessage(short msgType, short bodyType)
          Get a list of Destinations that are subscribed to this channel.
 GMS_Message request(GMS_Message m, GMS_Destination dst, long timeout)
          Sends a message and waits for a response
 void sendMessage(GMS_Message m, GMS_Destination d)
          Multicast the message to a Destinations.
 

Method Detail

createDestinationSelector

public GMS_DestinationSelector createDestinationSelector(java.lang.String name)
Creates an instance of the specified desintation selector type. The name must be the name of cone of the destination selector instances without the package name. For example MulticastDestinationSelector.
Parameters:
name - The Class name (w/o package name. Assumes com.anabas.gxo) of the destination selector to create.
Returns:
An instance of the specified destination selector. null if the type is not supported.

createMessage

public GMS_Message createMessage(short msgType,
                                 short bodyType)
                          throws GXO_Exception
Get a list of Destinations that are subscribed to this channel.
Parameters:
type - The type of the message as listed in the Message public static final variables.

request

public GMS_Message request(GMS_Message m,
                           GMS_Destination dst,
                           long timeout)
                    throws GXO_Exception
Sends a message and waits for a response
Parameters:
timeout - in milliseconds. 0 means infinite wait.

sendMessage

public void sendMessage(GMS_Message m,
                        GMS_Destination d)
                 throws GXO_Exception
Multicast the message to a Destinations. By default, the message will also be delivered to the local client. If the message is not desired to be delivered to the local client, use the alternate sendMessage function.

broadcast

public void broadcast(GMS_Message m)
               throws GXO_Exception
Broadcast the message to all subscribers in this channel.