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)
|
Methods inherited from class java.lang.Object |
clone,
equals,
finalize,
getClass,
hashCode,
notify,
notifyAll,
toString,
wait,
wait,
wait |
GMS_StreamImpl
public GMS_StreamImpl(java.lang.String parentCtxName,
java.lang.String myName,
com.anabas.ibus.TopicSession session)
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