Class RMManager


  • public class RMManager
    extends Object
    • Field Detail

      • WSRM_VERSION_PROPERTY

        public static final String WSRM_VERSION_PROPERTY
        Message contextual property giving WS-ReliableMessaging namespace.
        See Also:
        Constant Field Values
      • WSRM_WSA_VERSION_PROPERTY

        public static final String WSRM_WSA_VERSION_PROPERTY
        Message contextual property giving addressing namespace to be used by WS-RM implementation.
        See Also:
        Constant Field Values
      • WSRM_LAST_MESSAGE_PROPERTY

        public static final String WSRM_LAST_MESSAGE_PROPERTY
        Message contextual property giving the last message flag (Boolean).
        See Also:
        Constant Field Values
      • WSRM_INACTIVITY_TIMEOUT_PROPERTY

        public static final String WSRM_INACTIVITY_TIMEOUT_PROPERTY
        Message contextual property giving WS-ReliableMessaging inactivity timeout (Long).
        See Also:
        Constant Field Values
      • WSRM_RETRANSMISSION_INTERVAL_PROPERTY

        public static final String WSRM_RETRANSMISSION_INTERVAL_PROPERTY
        Message contextual property giving WS-ReliableMessaging base retransmission interval (Long).
        See Also:
        Constant Field Values
      • WSRM_EXPONENTIAL_BACKOFF_PROPERTY

        public static final String WSRM_EXPONENTIAL_BACKOFF_PROPERTY
        Message contextual property giving WS-ReliableMessaging exponential backoff flag (Boolean).
        See Also:
        Constant Field Values
      • WSRM_ACKNOWLEDGEMENT_INTERVAL_PROPERTY

        public static final String WSRM_ACKNOWLEDGEMENT_INTERVAL_PROPERTY
        Message contextual property giving WS-ReliableMessaging acknowledgement interval (Long).
        See Also:
        Constant Field Values
    • Constructor Detail

      • RMManager

        public RMManager()
    • Method Detail

      • startServer

        public void startServer​(org.apache.cxf.endpoint.Server server)
      • stopServer

        public void stopServer​(org.apache.cxf.endpoint.Server server)
      • clientCreated

        public void clientCreated​(org.apache.cxf.endpoint.Client client)
      • clientDestroyed

        public void clientDestroyed​(org.apache.cxf.endpoint.Client client)
      • setRMNamespace

        public void setRMNamespace​(String uri)
      • getBus

        public org.apache.cxf.Bus getBus()
      • setBus

        public void setBus​(org.apache.cxf.Bus b)
      • getStore

        public RMStore getStore()
      • setStore

        public void setStore​(RMStore s)
      • setRedeliveryQueue

        public void setRedeliveryQueue​(RedeliveryQueue redeliveryQueue)
      • getTimer

        public Timer getTimer()
      • getBindingFaultFactory

        public BindingFaultFactory getBindingFaultFactory​(org.apache.cxf.binding.Binding binding)
      • setDeliveryAssurance

        public void setDeliveryAssurance​(DeliveryAssuranceType dat)
        Parameters:
        dat - The deliveryAssurance to set.
      • getDestinationPolicy

        public DestinationPolicyType getDestinationPolicy()
        Returns:
        Returns the destinationPolicy.
      • setDestinationPolicy

        public void setDestinationPolicy​(DestinationPolicyType destinationPolicy)
        Parameters:
        destinationPolicy - The destinationPolicy to set.
      • getConfiguration

        public RMConfiguration getConfiguration()
        Get base configuration for manager. This needs to be modified by endpoint policies to get the effective configuration.
        Returns:
        configuration (non-null)
      • setConfiguration

        public void setConfiguration​(RMConfiguration configuration)
        Parameters:
        configuration - (non-null)
      • getEffectiveConfiguration

        public RMConfiguration getEffectiveConfiguration​(org.apache.cxf.message.Message msg)
        Get configuration after applying policies.
        Parameters:
        msg -
        Returns:
        configuration (non-null)
      • setRMAssertion

        public void setRMAssertion​(RMAssertion rma)
        Parameters:
        rma - The rmAssertion to set.
      • getSourcePolicy

        public SourcePolicyType getSourcePolicy()
        Returns:
        Returns the sourcePolicy.
      • setSourcePolicy

        public void setSourcePolicy​(SourcePolicyType sp)
        Parameters:
        sp - The sourcePolicy to set.
      • findReliableEndpoint

        public RMEndpoint findReliableEndpoint​(QName qn)
      • init

        public void init​(org.apache.cxf.Bus b)
      • initializeInterceptorChain

        public void initializeInterceptorChain​(org.apache.cxf.message.Message msg)
        Clones and saves the interceptor chain the first time this is called, so that it can be used for retransmission. Calls after the first are ignored.
        Parameters:
        msg -
      • getRetransmitChain

        public org.apache.cxf.phase.PhaseInterceptorChain getRetransmitChain​(org.apache.cxf.message.Message msg)
        Get interceptor chain for retransmitting a message.
        Returns:
        chain (null if none set)