org.jacorb.notification
Class AbstractChannelFactory
java.lang.Object
org.jacorb.notification.AbstractChannelFactory
- All Implemented Interfaces:
- org.picocontainer.Disposable, Disposable, ManageableServant
- Direct Known Subclasses:
- EventChannelFactoryImpl, TypedEventChannelFactoryImpl
- public abstract class AbstractChannelFactory
- extends java.lang.Object
- implements ManageableServant, Disposable
- Version:
- $Id: AbstractChannelFactory.java,v 1.12 2005/05/04 13:58:47 alphonse.bendt Exp $
- Author:
- Alphonse Bendt
Field Summary |
protected org.picocontainer.defaults.ComponentAdapterFactory |
componentAdapterFactory_
|
protected org.apache.avalon.framework.configuration.Configuration |
config_
|
protected org.picocontainer.MutablePicoContainer |
container_
|
protected org.apache.avalon.framework.logger.Logger |
logger_
|
protected Object |
thisRef_
|
Method Summary |
POA |
_default_POA()
|
Object |
activate()
|
protected void |
addToChannels(int id,
AbstractEventChannel channel)
|
protected abstract Object |
create_abstract_channel(Property[] admin,
Property[] qos,
IntHolder id)
|
protected AbstractEventChannel |
create_channel_servant(IntHolder id,
Property[] qosProps,
Property[] adminProps)
|
void |
deactivate()
|
void |
destroy()
|
void |
dispose()
|
protected AbstractEventChannel |
get_event_channel_servant(int id)
|
protected int[] |
getAllChannels()
|
protected java.util.Iterator |
getChannelIterator()
|
protected org.apache.avalon.framework.configuration.Configuration |
getConfiguration()
|
java.lang.String |
getCorbaLoc()
|
java.lang.String |
getIOR()
|
protected java.lang.String |
getLocalAddress()
|
protected int |
getLocalPort()
|
protected abstract java.lang.String |
getObjectName()
|
protected ORB |
getORB()
|
protected abstract Servant |
getServant()
|
protected abstract java.lang.String |
getShortcut()
|
protected org.picocontainer.MutablePicoContainer |
newContainerForChannel()
|
protected abstract AbstractEventChannel |
newEventChannel()
|
static AbstractChannelFactory |
newFactory(ORB orb,
boolean startThread,
java.util.Properties props)
|
static AbstractChannelFactory |
newFactory(org.picocontainer.PicoContainer container,
ORB orb,
boolean startThread,
java.util.Properties props)
|
static AbstractChannelFactory |
newFactory(org.picocontainer.PicoContainer container,
java.util.Properties props)
|
static AbstractChannelFactory |
newFactory(java.util.Properties props)
|
void |
setDestroyMethod(java.lang.Runnable destroyMethod)
|
void |
shutdown(org.jacorb.notification.AbstractChannelFactory.ShutdownCallback cb)
shutdown is called by the Java Wrapper |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
container_
protected final org.picocontainer.MutablePicoContainer container_
componentAdapterFactory_
protected final org.picocontainer.defaults.ComponentAdapterFactory componentAdapterFactory_
config_
protected final org.apache.avalon.framework.configuration.Configuration config_
thisRef_
protected final Object thisRef_
logger_
protected final org.apache.avalon.framework.logger.Logger logger_
AbstractChannelFactory
protected AbstractChannelFactory(org.picocontainer.PicoContainer container,
ORB orb)
throws UserException
newEventChannel
protected abstract AbstractEventChannel newEventChannel()
throws org.apache.avalon.framework.configuration.ConfigurationException
- Throws:
org.apache.avalon.framework.configuration.ConfigurationException
create_abstract_channel
protected abstract Object create_abstract_channel(Property[] admin,
Property[] qos,
IntHolder id)
throws UnsupportedAdmin,
UnsupportedQoS
- Throws:
UnsupportedAdmin
UnsupportedQoS
getObjectName
protected abstract java.lang.String getObjectName()
getShortcut
protected abstract java.lang.String getShortcut()
getServant
protected abstract Servant getServant()
getLocalPort
protected int getLocalPort()
getLocalAddress
protected java.lang.String getLocalAddress()
activate
public Object activate()
- Specified by:
activate
in interface ManageableServant
setDestroyMethod
public void setDestroyMethod(java.lang.Runnable destroyMethod)
getORB
protected ORB getORB()
deactivate
public final void deactivate()
- Specified by:
deactivate
in interface ManageableServant
getConfiguration
protected org.apache.avalon.framework.configuration.Configuration getConfiguration()
dispose
public void dispose()
- Specified by:
dispose
in interface org.picocontainer.Disposable
addToChannels
protected void addToChannels(int id,
AbstractEventChannel channel)
getAllChannels
protected int[] getAllChannels()
get_event_channel_servant
protected AbstractEventChannel get_event_channel_servant(int id)
throws ChannelNotFound
- Throws:
ChannelNotFound
getChannelIterator
protected java.util.Iterator getChannelIterator()
create_channel_servant
protected AbstractEventChannel create_channel_servant(IntHolder id,
Property[] qosProps,
Property[] adminProps)
throws UnsupportedAdmin,
UnsupportedQoS,
org.apache.avalon.framework.configuration.ConfigurationException
- Throws:
UnsupportedAdmin
UnsupportedQoS
org.apache.avalon.framework.configuration.ConfigurationException
destroy
public void destroy()
shutdown
public void shutdown(org.jacorb.notification.AbstractChannelFactory.ShutdownCallback cb)
- shutdown is called by the Java Wrapper
getIOR
public java.lang.String getIOR()
getCorbaLoc
public java.lang.String getCorbaLoc()
newFactory
public static AbstractChannelFactory newFactory(org.picocontainer.PicoContainer container,
ORB orb,
boolean startThread,
java.util.Properties props)
throws java.lang.Exception
- Throws:
java.lang.Exception
newFactory
public static AbstractChannelFactory newFactory(ORB orb,
boolean startThread,
java.util.Properties props)
throws java.lang.Exception
- Throws:
java.lang.Exception
newFactory
public static AbstractChannelFactory newFactory(org.picocontainer.PicoContainer container,
java.util.Properties props)
throws java.lang.Exception
- Throws:
java.lang.Exception
newFactory
public static AbstractChannelFactory newFactory(java.util.Properties props)
throws java.lang.Exception
- Throws:
java.lang.Exception
_default_POA
public POA _default_POA()
newContainerForChannel
protected org.picocontainer.MutablePicoContainer newContainerForChannel()