Class RMEndpoint


  • public class RMEndpoint
    extends Object
    • Constructor Detail

      • RMEndpoint

        public RMEndpoint​(RMManager m,
                          org.apache.cxf.endpoint.Endpoint ae)
        Constructor.
        Parameters:
        m -
        ae -
    • Method Detail

      • getManager

        public RMManager getManager()
        Returns:
        Returns the bus.
      • getApplicationEndpoint

        public org.apache.cxf.endpoint.Endpoint getApplicationEndpoint()
        Returns:
        Returns the application endpoint.
      • getEndpoint

        public org.apache.cxf.endpoint.Endpoint getEndpoint​(ProtocolVariation protocol)
        Returns:
        Returns the RM protocol endpoint.
      • getService

        public org.apache.cxf.service.Service getService​(ProtocolVariation protocol)
        Returns:
        Returns the RM protocol service.
      • getBindingInfo

        public org.apache.cxf.service.model.BindingInfo getBindingInfo​(ProtocolVariation protocol)
        Returns:
        Returns the RM protocol binding info.
      • getProxy

        public Proxy getProxy()
        Returns:
        Returns the proxy.
      • getServant

        public Servant getServant()
        Returns:
        Returns the servant.
      • getDestination

        public Destination getDestination()
        Returns:
        Returns the destination.
      • setDestination

        public void setDestination​(Destination destination)
        Parameters:
        destination - The destination to set.
      • getSource

        public Source getSource()
        Returns:
        Returns the source.
      • setSource

        public void setSource​(Source source)
        Parameters:
        source - The source to set.
      • getLastApplicationMessage

        public long getLastApplicationMessage()
        Returns:
        The time when last application message was received.
      • getApplicationMessageCount

        public int getApplicationMessageCount()
        Returns:
        The number of times when last application message was received.
      • receivedApplicationMessage

        public void receivedApplicationMessage()
        Indicates that an application message has been received.
      • getLastControlMessage

        public long getLastControlMessage()
        Returns:
        The time when last RM protocol message was received.
      • getControlMessageCount

        public int getControlMessageCount()
        Returns:
        The number of times when RM protocol message was received.
      • receivedControlMessage

        public void receivedControlMessage()
        Indicates that an RM protocol message has been received.
      • getConduit

        public org.apache.cxf.transport.Conduit getConduit()
        Returns:
        Returns the conduit.
      • getConfiguration

        public RMConfiguration getConfiguration()
        Get the RM configuration applied to this endpoint.
        Returns:
        configuration
      • handleAccept

        public void handleAccept​(String ssid,
                                 long number,
                                 org.apache.cxf.message.Message msg)
        Handle message accepted for source sequence. This generates a callback if a receiver is set on the message.
        Parameters:
        ssid -
        number -
        msg -
      • handleAcknowledgment

        public void handleAcknowledgment​(String ssid,
                                         long number,
                                         org.apache.cxf.message.Message msg)
        Handle message acknowledgment for source sequence. This generates a notification of the acknowledgment if JMX is being used, and also generates a callback if a receiver is set on the message.
        Parameters:
        ssid -
        number -
        msg -