com.sun.corba.se.pept.transport

Interface Acceptor

All Known Subinterfaces:

CorbaAcceptor

All Known Implementing Classes:

ParserTable.TestAcceptor1, ParserTable.TestAcceptor2, SocketFactoryAcceptorImpl, SocketOrChannelAcceptorImpl

public interface Acceptor

The primary PEPt server-side plug-in point and enabler for altenate encodings, protocols and transports.

Acceptor is a factory for client-side artifacts used to receive a message (and possibly send a response).

Author:

Harold Carr

Method Summary

Modifier and Type	Method and Description
void	accept() Accept a connection request.
void	close() Close the Acceptor.
InputObject	createInputObject(Broker broker, MessageMediator messageMediator) Used to get a InputObject for the specific encoding represented by this Acceptor.
MessageMediator	createMessageMediator(Broker xbroker, Connection xconnection) Used to get a MessageMediator to hold internal data for a message received using the specific encoding, protocol, transport combination represented by this Acceptor.
OutputObject	createOutputObject(Broker broker, MessageMediator messageMediator) Used to get a OutputObject for the specific encoding represented by this Acceptor.
MessageMediator	finishCreatingMessageMediator(Broker broker, Connection xconnection, MessageMediator messageMediator) Used to finish creating a MessageMediator to with internal data for a message received using the specific encoding, protocol, transport combination represented by this Acceptor.
InboundConnectionCache	getConnectionCache() Get the InboundConnectionCache used by this Acceptor PEPt uses separate caches for each type of Acceptor as given by getConnectionCacheType().
String	getConnectionCacheType() PEPt uses separate caches for each type of Acceptor as given by getConnectionCacheType.
EventHandler	getEventHandler() Get the EventHandler associated with this Acceptor.
boolean	initialize() Used to initialize an Acceptor.
boolean	initialized() Used to determine if an Acceptor has been initialized.
void	setConnectionCache(InboundConnectionCache connectionCache) Set the InboundConnectionCache to be used by this Acceptor.
boolean	shouldRegisterAcceptEvent() Used to determine if the Acceptor should register with Selector to handle accept events.

Method Detail

initialize

boolean initialize()

Used to initialize an Acceptor. For example, initialization may mean to create a ServerSocketChannel. Note: this must be prepared to be be called multiple times.

Returns:

true when it performs initializatin actions (typically the first call.

initialized

boolean initialized()

Used to determine if an Acceptor has been initialized.

Returns:

trueAcceptor has been initialized.

getConnectionCacheType

String getConnectionCacheType()

PEPt uses separate caches for each type of Acceptor as given by getConnectionCacheType.

Returns:

String

setConnectionCache

void setConnectionCache(InboundConnectionCache connectionCache)

Set the InboundConnectionCache to be used by this Acceptor. PEPt uses separate caches for each type of Acceptor as given by getConnectionCacheType(). setConnectionCache(com.sun.corba.se.pept.transport.InboundConnectionCache) and getConnectionCache() support an optimzation to avoid hashing to find that cache.

Parameters:

connectionCache. -

getConnectionCache

InboundConnectionCache getConnectionCache()

Get the InboundConnectionCache used by this Acceptor PEPt uses separate caches for each type of Acceptor as given by getConnectionCacheType(). setConnectionCache(com.sun.corba.se.pept.transport.InboundConnectionCache) and getConnectionCache() support an optimzation to avoid hashing to find that cache.

Returns:

ConnectionCache

shouldRegisterAcceptEvent

boolean shouldRegisterAcceptEvent()

Used to determine if the Acceptor should register with Selector to handle accept events. For example, this may be false in the case of Solaris Doors which do not actively listen.

Returns:

true if the Acceptor should be registered with Selector

accept

void accept()

Accept a connection request. This is called either when the selector gets an accept event for this Acceptor or by a ListenerThread. It results in a Connection being created.

close

void close()

Close the Acceptor.

getEventHandler

EventHandler getEventHandler()

Get the EventHandler associated with this Acceptor.

Returns:

EventHandler

createMessageMediator

MessageMediator createMessageMediator(Broker xbroker,
                                      Connection xconnection)

Used to get a MessageMediator to hold internal data for a message received using the specific encoding, protocol, transport combination represented by this Acceptor.

Returns:

MessageMediator

finishCreatingMessageMediator

MessageMediator finishCreatingMessageMediator(Broker broker,
                                              Connection xconnection,
                                              MessageMediator messageMediator)

Used to finish creating a MessageMediator to with internal data for a message received using the specific encoding, protocol, transport combination represented by this Acceptor.

Returns:

MessageMediator

createInputObject

InputObject createInputObject(Broker broker,
                              MessageMediator messageMediator)

Used to get a InputObject for the specific encoding represented by this Acceptor.

Returns:

InputObject

createOutputObject

OutputObject createOutputObject(Broker broker,
                                MessageMediator messageMediator)

Used to get a OutputObject for the specific encoding represented by this Acceptor.

Returns:

OutputObject