public class RMEndpoint extends Object
Constructor and Description |
---|
RMEndpoint(RMManager m,
Endpoint ae)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
Endpoint |
getApplicationEndpoint() |
int |
getApplicationMessageCount() |
BindingInfo |
getBindingInfo(ProtocolVariation protocol) |
Conduit |
getConduit() |
RMConfiguration |
getConfiguration()
Get the RM configuration applied to this endpoint.
|
int |
getControlMessageCount() |
Destination |
getDestination() |
Endpoint |
getEndpoint(ProtocolVariation protocol) |
long |
getLastApplicationMessage() |
long |
getLastControlMessage() |
RMManager |
getManager() |
Proxy |
getProxy() |
Servant |
getServant() |
Service |
getService(ProtocolVariation protocol) |
Source |
getSource() |
void |
handleAccept(String ssid,
long number,
Message msg)
Handle message accepted for source sequence.
|
void |
handleAcknowledgment(String ssid,
long number,
Message msg)
Handle message acknowledgment for source sequence.
|
void |
receivedApplicationMessage()
Indicates that an application message has been received.
|
void |
receivedControlMessage()
Indicates that an RM protocol message has been received.
|
void |
setDestination(Destination destination) |
void |
setSource(Source source) |
public RMManager getManager()
public Endpoint getApplicationEndpoint()
public Endpoint getEndpoint(ProtocolVariation protocol)
public Service getService(ProtocolVariation protocol)
public BindingInfo getBindingInfo(ProtocolVariation protocol)
public Proxy getProxy()
public Servant getServant()
public Destination getDestination()
public void setDestination(Destination destination)
destination
- The destination to set.public Source getSource()
public void setSource(Source source)
source
- The source to set.public long getLastApplicationMessage()
public int getApplicationMessageCount()
public void receivedApplicationMessage()
public long getLastControlMessage()
public int getControlMessageCount()
public void receivedControlMessage()
public Conduit getConduit()
public RMConfiguration getConfiguration()
public void handleAccept(String ssid, long number, Message msg)
ssid
- number
- msg
- public void handleAcknowledgment(String ssid, long number, Message msg)
ssid
- number
- msg
- Apache CXF