com.anabas.ibus
Class GMS_StreamImpl

java.lang.Object
  |
  +--com.anabas.ibus.GMS_StreamImpl

public class GMS_StreamImpl
extends java.lang.Object
implements GMS_Stream

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


Constructor Summary
GMS_StreamImpl(java.lang.String parentCtxName, java.lang.String myName, com.anabas.ibus.TopicSession session)
           
 
Method Summary
protected  com.anabas.ibus.TopicSubscriber createIBusSubscriber()
          Utility function to create a TopicSubscriber with all of the appropriate default message selectors.
 GMS_StreamPublisher createPublisher()
           
 GMS_StreamSubscriber createSubscriber()
           
 GMS_Destination findDestination(GMS_DestinationSelector d)
          Same as StreamContext.search() but only does so in this stream.
protected  GMS_MessageSelector getDefaultMessageSelector()
           
 java.lang.String getName()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

GMS_StreamImpl

public GMS_StreamImpl(java.lang.String parentCtxName,
                      java.lang.String myName,
                      com.anabas.ibus.TopicSession session)
Method Detail

getDefaultMessageSelector

protected GMS_MessageSelector getDefaultMessageSelector()

findDestination

public GMS_Destination findDestination(GMS_DestinationSelector d)
                                throws GXO_AccessDeniedException
Same as StreamContext.search() but only does so in this stream.
Specified by:
findDestination in interface GMS_Stream
Returns:
A destination object that matches the destination selector. null if no matches.

getName

public java.lang.String getName()
Specified by:
getName in interface GMS_Stream
Returns:
The name of the stream.

createIBusSubscriber

protected com.anabas.ibus.TopicSubscriber createIBusSubscriber()
                                                        throws javax.jms.JMSException
Utility function to create a TopicSubscriber with all of the appropriate default message selectors.

createSubscriber

public GMS_StreamSubscriber createSubscriber()
Specified by:
createSubscriber in interface GMS_Stream
Returns:
null if it can't create a subscriber

createPublisher

public GMS_StreamPublisher createPublisher()
Specified by:
createPublisher in interface GMS_Stream
Returns:
null if it can't create a publisher