public interface Connection
Connection
represents a transport in the
PEPt architecture.
Modifier and Type | Method and Description |
---|---|
void |
close()
Close the
Connection . |
Acceptor |
getAcceptor()
Get the
Acceptor
that created this Connection . |
ConnectionCache |
getConnectionCache() |
ContactInfo |
getContactInfo()
Get the
ContactInfo
that created this Connection . |
EventHandler |
getEventHandler()
Get the
EventHandler
associated with this Acceptor . |
long |
getTimeStamp()
Timestamps are used for connection management, in particular, for
reclaiming idle
Connection s. |
boolean |
isBusy()
Indicates if the
Connection is in the process of
sending or receiving a message. |
boolean |
isServer()
|
boolean |
read()
Called to read incoming messages.
|
void |
registerWaiter(MessageMediator messageMediator)
Register an invocation's
MessageMediator
with the Connection . |
void |
sendWithoutLock(OutputObject outputObject) |
void |
setConnectionCache(ConnectionCache connectionCache) |
void |
setState(String state)
The "state" of the
Connection . |
void |
setTimeStamp(long time)
Timestamps are used for connection management, in particular, for
reclaiming idle
Connection s. |
boolean |
shouldRegisterReadEvent()
Used to determine if the
Connection should register
with the
TransportManager
Selector
to handle read events. |
boolean |
shouldRegisterServerReadEvent()
Used to determine if the
Connection should register
with the
TransportManager
Selector
to handle read events. |
void |
unregisterWaiter(MessageMediator messageMediator)
Unregister an invocation's
MessageMediator
with the Connection . |
InputObject |
waitForResponse(MessageMediator messageMediator)
If a message expect's a response then this method is called.
|
void |
writeLock()
Grab a write lock on the
Connection . |
void |
writeUnlock()
Release a write lock on the
Connection . |
boolean shouldRegisterReadEvent()
Connection
should register
with the
TransportManager
Selector
to handle read events.
For example, an HTTP transport would not register since the requesting
thread would just block on read when waiting for the reply.true
if it should be registered.boolean shouldRegisterServerReadEvent()
Connection
should register
with the
TransportManager
Selector
to handle read events.
For example, an HTTP transport would not register since the requesting
thread would just block on read when waiting for the reply.true
if it should be registered.boolean read()
true
if the thread calling read can be released.void close()
Connection
.ContactInfo getContactInfo()
ContactInfo
that created this Connection
.ContactInfo
EventHandler getEventHandler()
EventHandler
associated with this Acceptor
.EventHandler
boolean isServer()
true
if Connection
an
Acceptor
created the Connection
.boolean isBusy()
Connection
is in the process of
sending or receiving a message.true
if the Connection
is busy.long getTimeStamp()
Connection
s.Connection
was last used.void setTimeStamp(long time)
Connection
s.time
- - the "time" the Connection
was last used.void setState(String state)
Connection
.
param statevoid writeLock()
Connection
.
If another thread already has a write lock then the calling
thread will block until the lock is released. The calling
thread must call
writeUnlock()
when it is done.void writeUnlock()
Connection
.void sendWithoutLock(OutputObject outputObject)
void registerWaiter(MessageMediator messageMediator)
MessageMediator
with the Connection
.
This is useful in protocols which support fragmentation.messageMediator
- InputObject waitForResponse(MessageMediator messageMediator)
messageMediator
- void unregisterWaiter(MessageMediator messageMediator)
MessageMediator
with the Connection
.messageMediator
- void setConnectionCache(ConnectionCache connectionCache)
ConnectionCache getConnectionCache()
Copyright © 2021 JBoss by Red Hat. All rights reserved.