public static final class ParserTable.TestAcceptor1 extends Object implements Acceptor
Constructor and Description |
---|
TestAcceptor1() |
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 . |
boolean |
equals(Object other) |
MessageMediator |
finishCreatingMessageMediator(Broker xbroker,
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 Acceptor.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 . |
int |
hashCode() |
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 . |
void |
setUseSelectThreadForConnections(boolean x) |
void |
setUseWorkerThreadForConnections(boolean x) |
boolean |
shouldRegisterAcceptEvent()
Used to determine if the
Acceptor should register
with
Selector
to handle accept events. |
boolean |
shouldUseSelectThreadForConnections() |
boolean |
shouldUseWorkerThreadForConnections() |
public boolean initialize()
Acceptor
Acceptor
.
For example, initialization may mean to create a
ServerSocketChannel
.
Note: this must be prepared to be be called multiple times.initialize
in interface Acceptor
true
when it performs initializatin
actions (typically the first call.public boolean initialized()
Acceptor
Acceptor
has been initialized.initialized
in interface Acceptor
trueAcceptor
has been
initialized.public String getConnectionCacheType()
Acceptor
Acceptor
as given by getConnectionCacheType
.getConnectionCacheType
in interface Acceptor
String
public void setConnectionCache(InboundConnectionCache connectionCache)
Acceptor
InboundConnectionCache
to be used by this Acceptor
.
PEPt uses separate caches for each type of Acceptor
as given by Acceptor.getConnectionCacheType()
.
Acceptor.setConnectionCache(com.sun.corba.se.pept.transport.InboundConnectionCache)
and Acceptor.getConnectionCache()
support
an optimzation to avoid hashing to find that cache.setConnectionCache
in interface Acceptor
public InboundConnectionCache getConnectionCache()
Acceptor
InboundConnectionCache
used by this Acceptor
PEPt uses separate caches for each type of Acceptor
as given by Acceptor.getConnectionCacheType()
.
Acceptor.setConnectionCache(com.sun.corba.se.pept.transport.InboundConnectionCache)
and Acceptor.getConnectionCache()
support
an optimzation to avoid hashing to find that cache.getConnectionCache
in interface Acceptor
ConnectionCache
public boolean shouldRegisterAcceptEvent()
Acceptor
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.shouldRegisterAcceptEvent
in interface Acceptor
true
if the Acceptor
should be
registered with
Selector
public void setUseSelectThreadForConnections(boolean x)
public boolean shouldUseSelectThreadForConnections()
public void setUseWorkerThreadForConnections(boolean x)
public boolean shouldUseWorkerThreadForConnections()
public void accept()
Acceptor
Acceptor
or by a
ListenerThread
.
It results in a
Connection
being created.public void close()
Acceptor
Acceptor
.public EventHandler getEventHandler()
Acceptor
EventHandler
associated with this Acceptor
.getEventHandler
in interface Acceptor
EventHandler
public MessageMediator createMessageMediator(Broker xbroker, Connection xconnection)
Acceptor
MessageMediator
to hold internal data for a message received using the specific
encoding, protocol, transport combination represented by this
Acceptor
.createMessageMediator
in interface Acceptor
MessageMediator
public MessageMediator finishCreatingMessageMediator(Broker xbroker, Connection xconnection, MessageMediator messageMediator)
Acceptor
MessageMediator
to with internal data for a message received using the specific
encoding, protocol, transport combination represented by this
Acceptor
.finishCreatingMessageMediator
in interface Acceptor
MessageMediator
public InputObject createInputObject(Broker broker, MessageMediator messageMediator)
Acceptor
InputObject
for the specific encoding represented by this
Acceptor
.createInputObject
in interface Acceptor
InputObject
public OutputObject createOutputObject(Broker broker, MessageMediator messageMediator)
Acceptor
OutputObject
for the specific encoding represented by this
Acceptor
.createOutputObject
in interface Acceptor
OutputObject
Copyright © 2021 JBoss by Red Hat. All rights reserved.