org.jacorb.notification

Class AbstractChannelFactory

java.lang.Object

org.jacorb.notification.AbstractChannelFactory

All Implemented Interfaces:

Disposable, ManageableServant

Direct Known Subclasses:

EventChannelFactoryImpl, TypedEventChannelFactoryImpl

public abstract class AbstractChannelFactory
extends java.lang.Object
implements ManageableServant, Disposable

Version:

$Id: AbstractChannelFactory.java,v 1.24 2009-05-03 21:34:46 andre.spiegel Exp $

Author:

Alphonse Bendt

Field Summary

Fields

Modifier and Type	Field and Description
protected org.jacorb.config.Configuration	config_
protected MutablePicoContainer	container_
protected org.slf4j.Logger	logger_
protected Object	thisRef_

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractChannelFactory(MutablePicoContainer container, ORB orb)

Method Summary

Modifier and Type	Method and Description
POA	_default_POA()
Object	activate()
protected void	addToChannels(int id, AbstractEventChannel channel)
protected void	channelCreated(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.jacorb.config.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 MutablePicoContainer	newContainerForChannel()
protected abstract AbstractEventChannel	newEventChannel()
static AbstractChannelFactory	newFactory(ORB optionalORB, MutablePicoContainer optionalContainer, java.util.Properties props)
static AbstractChannelFactory	newFactory(java.util.Properties props)
void	registerName(java.util.Properties props)
void	registerName(java.lang.String nameId, java.lang.String nameKind)
void	setDestroyMethod(java.lang.Runnable destroyMethod)
void	shutdown(org.jacorb.notification.AbstractChannelFactory.ShutdownCallback cb) shutdown is called by the Java Wrapper
void	unregisterName()
void	writeIOR(java.lang.String fileName)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

container_

protected final MutablePicoContainer container_

config_

protected final org.jacorb.config.Configuration config_

thisRef_

protected final Object thisRef_

logger_

protected final org.slf4j.Logger logger_

Constructor Detail

AbstractChannelFactory

protected AbstractChannelFactory(MutablePicoContainer container,
                                 ORB orb)
                          throws UserException

Throws:

UserException

Method Detail

newEventChannel

protected abstract AbstractEventChannel newEventChannel()
                                                 throws org.jacorb.config.ConfigurationException

Throws:

org.jacorb.config.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.jacorb.config.Configuration getConfiguration()

dispose

public void dispose()

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.jacorb.config.ConfigurationException

Throws:

UnsupportedAdmin

UnsupportedQoS

org.jacorb.config.ConfigurationException

channelCreated

protected void channelCreated(AbstractEventChannel channel)

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(ORB optionalORB,
                                                MutablePicoContainer optionalContainer,
                                                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

registerName

public void registerName(java.util.Properties props)
                  throws java.lang.Exception

Throws:

java.lang.Exception

registerName

public void registerName(java.lang.String nameId,
                         java.lang.String nameKind)
                  throws NotFound,
                         CannotProceed,
                         InvalidName,
                         InvalidName

Throws:

NotFound

CannotProceed

InvalidName

unregisterName

public void unregisterName()
                    throws NotFound,
                           CannotProceed,
                           InvalidName

Throws:

NotFound

CannotProceed

InvalidName

writeIOR

public void writeIOR(java.lang.String fileName)
              throws java.io.IOException

Throws:

java.io.IOException

_default_POA

public POA _default_POA()

newContainerForChannel

protected MutablePicoContainer newContainerForChannel()