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:
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 |
m_topicSession
protected com.anabas.ibus.TopicSession m_topicSession
m_defaultSelector
protected GMS_MessageSelector m_defaultSelector
GMS_StreamFactoryImpl
public GMS_StreamFactoryImpl()
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"