org.apache.cxf.ws.rm
Class ManagedRMEndpoint

java.lang.Object
  org.apache.cxf.ws.rm.ManagedRMEndpoint

All Implemented Interfaces:

ManagedComponent

@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

The ManagedRMEndpoint is a JMX managed bean for RMEndpoint.

ACKNOWLEDGEMENT_NOTIFICATION

public static final String ACKNOWLEDGEMENT_NOTIFICATION

See Also:

Constant Field Values

ManagedRMEndpoint

public ManagedRMEndpoint(RMEndpoint endpoint)

getObjectName

public ObjectName getObjectName()
                         throws JMException

Specified by:

getObjectName in interface ManagedComponent

Throws:

JMException

getQueuedMessageTotalCount

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

getQueuedMessageCount

@ManagedOperation(description="Number of Queued Messages")
@ManagedOperationParameters(value={,})
public int getQueuedMessageCount(String sid,
                                                                                             boolean outbound)

getUnAcknowledgedMessageIdentifiers

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

getDeferredAcknowledgementTotalCount

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

getDeferredAcknowledgementCount

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

getSourceSequenceAcknowledgedRange

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

getDestinationSequenceAcknowledgedRange

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

getRetransmissionStatus

@ManagedOperation(description="Retransmission Status")
@ManagedOperationParameters(value={,})
public CompositeData getRetransmissionStatus(String sid,
                                                                                                         long num)
                                      throws JMException

Throws:

JMException

getRetransmissionStatuses

@ManagedOperation(description="Retransmission Statuses")
@ManagedOperationParameters(value=)
public CompositeData[] getRetransmissionStatuses(String sid)
                                          throws JMException

Throws:

JMException

getSourceSequenceIds

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

getDestinationSequenceIds

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

suspendSourceQueue

@ManagedOperation(description="Suspend Retransmission Queue")
@ManagedOperationParameters(value=)
public void suspendSourceQueue(String sid)
                        throws JMException

Throws:

JMException

resumeSourceQueue

@ManagedOperation(description="Resume Retransmission Queue")
@ManagedOperationParameters(value=)
public void resumeSourceQueue(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(value=)
public CompositeData getSourceSequence(String sid)
                                throws JMException

Throws:

JMException

getSourceSequences

@ManagedOperation(description="Source Sequences Properties")
@ManagedOperationParameters(value=)
public CompositeData[] getSourceSequences(boolean expired)
                                   throws JMException

Throws:

JMException

getDestinationSequence

@ManagedOperation(description="Destination Sequence Properties")
@ManagedOperationParameters(value=)
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(value=)
public void closeSourceSequence(String sid)
                         throws JMException

Throws:

JMException

terminateSourceSequence

@ManagedOperation(description="Terminate Source Sequence")
@ManagedOperationParameters(value=)
public void terminateSourceSequence(String sid)
                             throws JMException

Throws:

JMException

terminateDestinationSequence

@ManagedOperation(description="Terminate Destination Sequence")
@ManagedOperationParameters(value=)
public void terminateDestinationSequence(String sid)
                                  throws JMException

Throws:

JMException

removeSourceSequence

@ManagedOperation(description="Remove Source Sequence")
@ManagedOperationParameters(value=)
public void removeSourceSequence(String sid)
                          throws JMException

Throws:

JMException

removeDestinationSequence

@ManagedOperation(description="Remove Destination Sequence")
@ManagedOperationParameters(value=)
public void removeDestinationSequence(String sid)
                               throws JMException

Throws:

JMException

purgeUnAcknowledgedMessages

@ManagedOperation(description="Purge UnAcknowledged Messages")
@ManagedOperationParameters(value=)
public void purgeUnAcknowledgedMessages(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()

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()