Method Summary |
|
public void | clientCreated(Client client) |
public void | clientDestroyed(Client client) |
RMEndpoint | createReliableEndpoint(Endpoint endpoint) |
public BindingFaultFactory | getBindingFaultFactory(Binding binding) |
public Bus | getBus() |
public DeliveryAssuranceType | getDeliveryAssurance() |
public Destination | getDestination(Message message) |
public DestinationPolicyType | getDestinationPolicy() |
public SequenceIdentifierGenerator | getIdGenerator() |
public RMAssertion | getRMAssertion() |
public synchronized RMEndpoint | getReliableEndpoint(Message message) |
Map<Endpoint, RMEndpoint> | getReliableEndpointsMap() |
public RetransmissionQueue | getRetransmissionQueue() |
public SourceSequence | getSequence(Identifier inSeqId, Message message, AddressingProperties maps) |
public Source | getSource(Message message) |
public SourcePolicyType | getSourcePolicy() |
public RMStore | getStore() |
public Timer | getTimer() |
void | initialise() |
void | recoverReliableEndpoint(Endpoint endpoint, Conduit conduit) |
public void | register() |
void | registerListeners() |
public void | setBus(Bus b) |
public void | setDeliveryAssurance(DeliveryAssuranceType deliveryAssurance) |
public void | setDestinationPolicy(DestinationPolicyType destinationPolicy) |
public void | setIdGenerator(SequenceIdentifierGenerator generator) |
public void | setRMAssertion(RMAssertion rma) |
void | setReliableEndpointsMap(Map<Endpoint, RMEndpoint> map) |
public void | setRetransmissionQueue(RetransmissionQueue rq) |
public void | setSourcePolicy(SourcePolicyType sp) |
public void | setStore(RMStore s) |
public void | shutdown() |
synchronized void | shutdownReliableEndpoint(Endpoint e) |
public void | startServer(Server server) |
public void | stopServer(Server server) |