org.jacorb.notification
Class AbstractChannelFactory

java.lang.Object
  extended byorg.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_
           
 
Constructor Summary
protected AbstractChannelFactory(org.picocontainer.PicoContainer container, ORB orb)
           
 
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
 

Field Detail

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_
Constructor Detail

AbstractChannelFactory

protected AbstractChannelFactory(org.picocontainer.PicoContainer container,
                                 ORB orb)
                          throws UserException
Method Detail

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()