public class RSVP extends Protocol
Modifier and Type | Class and Description |
---|---|
protected class |
RSVP.Entry |
protected static class |
RSVP.RsvpHeader |
Modifier and Type | Field and Description |
---|---|
protected boolean |
ack_on_delivery |
protected short |
current_id
ID to be used to identify messages.
|
protected Map<Short,RSVP.Entry> |
ids
Used to store IDs and their acks
|
protected Address |
local_addr |
protected List<Address> |
members |
protected long |
resend_interval |
protected boolean |
throw_exception_on_timeout |
protected long |
timeout |
protected TimeScheduler |
timer |
Constructor and Description |
---|
RSVP() |
Modifier and Type | Method and Description |
---|---|
void |
destroy()
This method is called on a
Channel.close() . |
Object |
down(Event evt)
An event is to be sent down the stack.
|
protected short |
getNextId() |
int |
getPendingRsvpRequests() |
protected void |
handleResponse(Address member,
short id) |
void |
init()
Called after instance has been created (null constructor) and before protocol is started.
|
protected void |
sendResponse(Address dest,
short id) |
Object |
up(Event evt)
An event was received from the layer below.
|
dumpStats, enableStats, getConfigurableObjects, getDownProtocol, getId, getLevel, getName, getProtocolStack, getSocketFactory, getThreadFactory, getTransport, getUpProtocol, getValue, isErgonomics, printStats, providedDownServices, providedUpServices, requiredDownServices, requiredUpServices, resetStatistics, resetStats, setDownProtocol, setErgonomics, setId, setLevel, setProtocolStack, setSocketFactory, setUpProtocol, setValue, setValues, start, statsEnabled, stop
protected long timeout
protected boolean throw_exception_on_timeout
protected boolean ack_on_delivery
protected long resend_interval
protected short current_id
protected TimeScheduler timer
protected Address local_addr
protected final Map<Short,RSVP.Entry> ids
public int getPendingRsvpRequests()
public void init() throws Exception
Protocol
public void destroy()
Protocol
Channel.close()
.
Does some cleanup; after the call the VM will terminatepublic Object down(Event evt)
Protocol
down_prot.down()
. In case of a GET_ADDRESS event (which tries to
retrieve the stack's address from one of the bottom layers), the layer may need to send
a new response event back up the stack using up_prot.up()
.public Object up(Event evt)
Protocol
down_prot.down()
or c) the event (or another event) is sent up
the stack using up_prot.up()
.protected void handleResponse(Address member, short id)
protected void sendResponse(Address dest, short id)
protected short getNextId()
Copyright © 2012 JBoss by Red Hat. All Rights Reserved.