Package org.apache.cxf.ws.rm
Class ManagedRMEndpoint
- java.lang.Object
-
- org.apache.cxf.ws.rm.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.
-
-
Field Summary
Fields Modifier and Type Field Description static String
ACKNOWLEDGEMENT_NOTIFICATION
-
Constructor Summary
Constructors Constructor Description ManagedRMEndpoint(RMEndpoint endpoint)
-
Method Summary
-
-
-
Field Detail
-
ACKNOWLEDGEMENT_NOTIFICATION
public static final String ACKNOWLEDGEMENT_NOTIFICATION
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
ManagedRMEndpoint
public ManagedRMEndpoint(RMEndpoint endpoint)
-
-
Method Detail
-
getObjectName
public ObjectName getObjectName() throws JMException
- Specified by:
getObjectName
in interfaceorg.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()
-
-