Class ManagedRMEndpoint

  • All Implemented Interfaces:
    org.apache.cxf.management.ManagedComponent

    @ManagedResource(componentName="RMEndpoint",
                     description="Responsible for Sources and Destinations.")
    @ManagedNotifications(@ManagedNotification(name="org.apache.ws.rm.acknowledgement",notificationTypes="org.apache.cxf.ws.rm.AcknowledgementNotification"))
    public class ManagedRMEndpoint
    extends Object
    implements org.apache.cxf.management.ManagedComponent
    The ManagedRMEndpoint is a JMX managed bean for RMEndpoint.
    • Constructor Detail

      • ManagedRMEndpoint

        public ManagedRMEndpoint​(RMEndpoint endpoint)
    • Method Detail

      • getObjectName

        public ObjectName getObjectName()
                                 throws JMException
        Specified by:
        getObjectName in interface org.apache.cxf.management.ManagedComponent
        Throws:
        JMException
      • getQueuedMessageTotalCount

        @ManagedOperation(description="Total Number of Queued Messages")
        @ManagedOperationParameters()
        public int getQueuedMessageTotalCount​(boolean outbound)
      • getQueuedMessageCount

        @ManagedOperation(description="Number of Queued Messages")
        @ManagedOperationParameters({@ManagedOperationParameter(name="sequenceId",description="The sequence identifier"),})
        public int getQueuedMessageCount​(String sid,
                                         boolean outbound)
      • getUnAcknowledgedMessageIdentifiers

        @ManagedOperation(description="List of UnAcknowledged Message Numbers")
        @ManagedOperationParameters()
        public Long[] getUnAcknowledgedMessageIdentifiers​(String sid)
      • getDeferredAcknowledgementTotalCount

        @ManagedOperation(description="Total Number of Deferred Acknowledgements")
        public int getDeferredAcknowledgementTotalCount()
      • getDeferredAcknowledgementCount

        @ManagedOperation(description="Number of Deferred Acknowledgements")
        @ManagedOperationParameters()
        public int getDeferredAcknowledgementCount​(String sid)
      • getSourceSequenceAcknowledgedRange

        @ManagedOperation(description="Source Sequence Acknowledged Range")
        @ManagedOperationParameters()
        public Long[] getSourceSequenceAcknowledgedRange​(String sid)
      • getDestinationSequenceAcknowledgedRange

        @ManagedOperation(description="Destination Sequence Acknowledged Range")
        @ManagedOperationParameters()
        public Long[] getDestinationSequenceAcknowledgedRange​(String sid)
      • getRetransmissionStatus

        @ManagedOperation(description="Retransmission Status")
        @ManagedOperationParameters({@ManagedOperationParameter(name="sequenceId",description="The sequence identifier"),})
        public CompositeData getRetransmissionStatus​(String sid,
                                                     long num)
                                              throws JMException
        Throws:
        JMException
      • getRetransmissionStatuses

        @ManagedOperation(description="Retransmission Statuses")
        @ManagedOperationParameters()
        public CompositeData[] getRetransmissionStatuses​(String sid)
                                                  throws JMException
        Throws:
        JMException
      • getRedeliveryStatus

        @ManagedOperation(description="Redelivery Status")
        @ManagedOperationParameters({@ManagedOperationParameter(name="sequenceId",description="The sequence identifier"),})
        public CompositeData getRedeliveryStatus​(String sid,
                                                 long num)
                                          throws JMException
        Throws:
        JMException
      • getRedeliveryStatuses

        @ManagedOperation(description="Redelivery Statuses")
        @ManagedOperationParameters()
        public CompositeData[] getRedeliveryStatuses​(String sid)
                                              throws JMException
        Throws:
        JMException
      • getUnDeliveredMessageIdentifiers

        @ManagedOperation(description="List of UnDelivered Message Numbers")
        @ManagedOperationParameters()
        public Long[] getUnDeliveredMessageIdentifiers​(String sid)
      • getSourceSequenceIds

        @ManagedOperation(description="List of Source Sequence IDs")
        @ManagedOperationParameters()
        public String[] getSourceSequenceIds​(boolean expired)
      • getDestinationSequenceIds

        @ManagedOperation(description="List of Destination Sequence IDs")
        public String[] getDestinationSequenceIds()
      • suspendSourceQueue

        @ManagedOperation(description="Suspend Retransmission Queue")
        @ManagedOperationParameters()
        public void suspendSourceQueue​(String sid)
                                throws JMException
        Throws:
        JMException
      • resumeSourceQueue

        @ManagedOperation(description="Resume Retransmission Queue")
        @ManagedOperationParameters()
        public void resumeSourceQueue​(String sid)
                               throws JMException
        Throws:
        JMException
      • suspendDestinationQueue

        @ManagedOperation(description="Suspend Redelivery Queue")
        @ManagedOperationParameters()
        public void suspendDestinationQueue​(String sid)
                                     throws JMException
        Throws:
        JMException
      • resumeDestinationQueue

        @ManagedOperation(description="Resume Redelivery Queue")
        @ManagedOperationParameters()
        public void resumeDestinationQueue​(String sid)
                                    throws JMException
        Throws:
        JMException
      • getCurrentSourceSequence

        @ManagedOperation(description="Current Source Sequence Properties")
        public CompositeData getCurrentSourceSequence()
                                               throws JMException
        Throws:
        JMException
      • getCurrentSourceSequenceId

        @ManagedOperation(description="Current Source Sequence Identifier")
        public String getCurrentSourceSequenceId()
                                          throws JMException
        Throws:
        JMException
      • getSourceSequence

        @ManagedOperation(description="Source Sequence Properties")
        @ManagedOperationParameters()
        public CompositeData getSourceSequence​(String sid)
                                        throws JMException
        Throws:
        JMException
      • getSourceSequences

        @ManagedOperation(description="Source Sequences Properties")
        @ManagedOperationParameters()
        public CompositeData[] getSourceSequences​(boolean expired)
                                           throws JMException
        Throws:
        JMException
      • getDestinationSequence

        @ManagedOperation(description="Destination Sequence Properties")
        @ManagedOperationParameters()
        public CompositeData getDestinationSequence​(String sid)
                                             throws JMException
        Throws:
        JMException
      • getDestinationSequences

        @ManagedOperation(description="Destination Sequences Properties")
        public CompositeData[] getDestinationSequences()
                                                throws JMException
        Throws:
        JMException
      • closeSourceSequence

        @ManagedOperation(description="Close Source Sequence")
        @ManagedOperationParameters()
        public void closeSourceSequence​(String sid)
                                 throws JMException
        Throws:
        JMException
      • terminateSourceSequence

        @ManagedOperation(description="Terminate Source Sequence")
        @ManagedOperationParameters()
        public void terminateSourceSequence​(String sid)
                                     throws JMException
        Throws:
        JMException
      • terminateDestinationSequence

        @ManagedOperation(description="Terminate Destination Sequence")
        @ManagedOperationParameters()
        public void terminateDestinationSequence​(String sid)
                                          throws JMException
        Throws:
        JMException
      • removeSourceSequence

        @ManagedOperation(description="Remove Source Sequence")
        @ManagedOperationParameters()
        public void removeSourceSequence​(String sid)
                                  throws JMException
        Throws:
        JMException
      • removeDestinationSequence

        @ManagedOperation(description="Remove Destination Sequence")
        @ManagedOperationParameters()
        public void removeDestinationSequence​(String sid)
                                       throws JMException
        Throws:
        JMException
      • purgeUnAcknowledgedMessages

        @ManagedOperation(description="Purge UnAcknowledged Messages")
        @ManagedOperationParameters()
        public void purgeUnAcknowledgedMessages​(String sid)
      • purgeUnDeliverededMessages

        @ManagedOperation(description="Purge UnDelivered Messages")
        @ManagedOperationParameters()
        public void purgeUnDeliverededMessages​(String sid)
      • getAddress

        @ManagedAttribute(description="Address Attribute",
                          currencyTimeLimit=60)
        public String getAddress()
      • getLastApplicationMessage

        @ManagedAttribute(description="Application Message Last Received",
                          currencyTimeLimit=60)
        public Date getLastApplicationMessage()
      • getLastControlMessage

        @ManagedAttribute(description="Protocol Message Last Received",
                          currencyTimeLimit=60)
        public Date getLastControlMessage()
      • getQueuedMessagesOutboundCount

        @ManagedAttribute(description="Number of Outbound Queued Messages",
                          currencyTimeLimit=10)
        public int getQueuedMessagesOutboundCount()
      • getQueuedMessagesInboundCount

        @ManagedAttribute(description="Number of Inbound Queued Messages",
                          currencyTimeLimit=10)
        public int getQueuedMessagesInboundCount()
      • getProcessingSourceSequenceCount

        @ManagedAttribute(description="Number of Processing Source Sequences",
                          currencyTimeLimit=10)
        public int getProcessingSourceSequenceCount()
      • getCompletedSourceSequenceCount

        @ManagedAttribute(description="Number of Completed Source Sequences",
                          currencyTimeLimit=10)
        public int getCompletedSourceSequenceCount()
      • getProcessingDestinationSequenceCount

        @ManagedAttribute(description="Number of Processing Destination Sequences",
                          currencyTimeLimit=10)
        public int getProcessingDestinationSequenceCount()
      • getCompletedDestinationSequenceCount

        @ManagedAttribute(description="Number of Completed Destination Sequences",
                          currencyTimeLimit=10)
        public int getCompletedDestinationSequenceCount()