@ManagedResource(componentName="RMEndpoint", description="Responsible for Sources and Destinations.") @ManagedNotifications(value=@ManagedNotification(name="org.apache.ws.rm.acknowledgement",notificationTypes="org.apache.cxf.ws.rm.AcknowledgementNotification")) public class ManagedRMEndpoint extends Object implements ManagedComponent
Modifier and Type | Field and Description |
---|---|
static String |
ACKNOWLEDGEMENT_NOTIFICATION |
Constructor and Description |
---|
ManagedRMEndpoint(RMEndpoint endpoint) |
public static final String ACKNOWLEDGEMENT_NOTIFICATION
public ManagedRMEndpoint(RMEndpoint endpoint)
public ObjectName getObjectName() throws JMException
getObjectName
in interface ManagedComponent
JMException
@ManagedOperation(description="Total Number of Queued Messages") @ManagedOperationParameters(value=) public int getQueuedMessageTotalCount(boolean outbound)
@ManagedOperation(description="Number of Queued Messages") @ManagedOperationParameters(value={,}) public int getQueuedMessageCount(String sid, boolean outbound)
@ManagedOperation(description="List of UnAcknowledged Message Numbers") @ManagedOperationParameters(value=) public Long[] getUnAcknowledgedMessageIdentifiers(String sid)
@ManagedOperation(description="Total Number of Deferred Acknowledgements") public int getDeferredAcknowledgementTotalCount()
@ManagedOperation(description="Number of Deferred Acknowledgements") @ManagedOperationParameters(value=) public int getDeferredAcknowledgementCount(String sid)
@ManagedOperation(description="Source Sequence Acknowledged Range") @ManagedOperationParameters(value=) public Long[] getSourceSequenceAcknowledgedRange(String sid)
@ManagedOperation(description="Destination Sequence Acknowledged Range") @ManagedOperationParameters(value=) public Long[] getDestinationSequenceAcknowledgedRange(String sid)
@ManagedOperation(description="Retransmission Status") @ManagedOperationParameters(value={,}) public CompositeData getRetransmissionStatus(String sid, long num) throws JMException
JMException
@ManagedOperation(description="Retransmission Statuses") @ManagedOperationParameters(value=) public CompositeData[] getRetransmissionStatuses(String sid) throws JMException
JMException
@ManagedOperation(description="List of Source Sequence IDs") @ManagedOperationParameters(value=) public String[] getSourceSequenceIds(boolean expired)
@ManagedOperation(description="List of Destination Sequence IDs") public String[] getDestinationSequenceIds()
@ManagedOperation(description="Suspend Retransmission Queue") @ManagedOperationParameters(value=) public void suspendSourceQueue(String sid) throws JMException
JMException
@ManagedOperation(description="Resume Retransmission Queue") @ManagedOperationParameters(value=) public void resumeSourceQueue(String sid) throws JMException
JMException
@ManagedOperation(description="Current Source Sequence Properties") public CompositeData getCurrentSourceSequence() throws JMException
JMException
@ManagedOperation(description="Current Source Sequence Identifier") public String getCurrentSourceSequenceId() throws JMException
JMException
@ManagedOperation(description="Source Sequence Properties") @ManagedOperationParameters(value=) public CompositeData getSourceSequence(String sid) throws JMException
JMException
@ManagedOperation(description="Source Sequences Properties") @ManagedOperationParameters(value=) public CompositeData[] getSourceSequences(boolean expired) throws JMException
JMException
@ManagedOperation(description="Destination Sequence Properties") @ManagedOperationParameters(value=) public CompositeData getDestinationSequence(String sid) throws JMException
JMException
@ManagedOperation(description="Destination Sequences Properties") public CompositeData[] getDestinationSequences() throws JMException
JMException
@ManagedOperation(description="Close Source Sequence") @ManagedOperationParameters(value=) public void closeSourceSequence(String sid) throws JMException
JMException
@ManagedOperation(description="Terminate Source Sequence") @ManagedOperationParameters(value=) public void terminateSourceSequence(String sid) throws JMException
JMException
@ManagedOperation(description="Terminate Destination Sequence") @ManagedOperationParameters(value=) public void terminateDestinationSequence(String sid) throws JMException
JMException
@ManagedOperation(description="Remove Source Sequence") @ManagedOperationParameters(value=) public void removeSourceSequence(String sid) throws JMException
JMException
@ManagedOperation(description="Remove Destination Sequence") @ManagedOperationParameters(value=) public void removeDestinationSequence(String sid) throws JMException
JMException
@ManagedOperation(description="Purge UnAcknowledged Messages") @ManagedOperationParameters(value=) public void purgeUnAcknowledgedMessages(String sid)
@ManagedAttribute(description="Address Attribute", currencyTimeLimit=60) public String getAddress()
@ManagedAttribute(description="Application Message Last Received", currencyTimeLimit=60) public Date getLastApplicationMessage()
@ManagedAttribute(description="Protocol Message Last Received", currencyTimeLimit=60) public Date getLastControlMessage()
@ManagedAttribute(description="Number of Outbound Queued Messages", currencyTimeLimit=10) public int getQueuedMessagesOutboundCount()
@ManagedAttribute(description="Number of Processing Source Sequences", currencyTimeLimit=10) public int getProcessingSourceSequenceCount()
@ManagedAttribute(description="Number of Completed Source Sequences", currencyTimeLimit=10) public int getCompletedSourceSequenceCount()
@ManagedAttribute(description="Number of Processing Destination Sequences", currencyTimeLimit=10) public int getProcessingDestinationSequenceCount()
@ManagedAttribute(description="Number of Completed Destination Sequences", currencyTimeLimit=10) public int getCompletedDestinationSequenceCount()
Apache CXF