com.anabas.ibus
Class GMS_StreamFactoryImpl

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

public class GMS_StreamFactoryImpl
extends java.lang.Object
implements GMS_StreamFactory

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


Field Summary
protected  GMS_MessageSelector m_defaultSelector
           
protected  com.anabas.ibus.TopicSession m_topicSession
           
 
Constructor Summary
GMS_StreamFactoryImpl()
           
 
Method Summary
 GMS_Stream createStream(java.lang.String name, java.util.Hashtable params)
          Creates a stream with a default selector set in the context factory.
 void initIBus()
          Initialize IBus connection.
 void setProperty(java.lang.String str, java.lang.Object obj)
          Sets setup properties for the event bus factory.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

m_topicSession

protected com.anabas.ibus.TopicSession m_topicSession

m_defaultSelector

protected GMS_MessageSelector m_defaultSelector
Constructor Detail

GMS_StreamFactoryImpl

public GMS_StreamFactoryImpl()
Method Detail

setProperty

public void setProperty(java.lang.String str,
                        java.lang.Object obj)
Sets setup properties for the event bus factory. Such as connection parameters, authentication parameters, ...
Specified by:
setProperty in interface GMS_StreamFactory

initIBus

public void initIBus()
              throws javax.jms.JMSException
Initialize IBus connection. Invoked internally when the first stream is created.

createStream

public GMS_Stream createStream(java.lang.String name,
                               java.util.Hashtable params)
                        throws GXO_AccessDeniedException
Creates a stream with a default selector set in the context factory.
Specified by:
createStream in interface GMS_StreamFactory
Tags copied from interface: GMS_StreamFactory
Parameters:
params - A list of parameters for the stream. For example: "min_latency" - "50ms" "encrypted" - "true" "persistent" - "none"