|
Sonic Management API | |||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES All Classes | |||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface IBrokerProxy
Remote interface to a runtime instance of a Broker.
Management attributes and operations are documented in this interface.
An implementation of this interface can be created using the MQProxyFactory class. Each implementation instance is valid for the life of the provided JMS/JMX Connector and MBean ObjectName. The implementation is built using remote JMX MBeanServer calls.
For each JMX MBean attribute, this interface provides an associated get method (for readable attributes) and/or a set method (for writable attributes).
For each JMX MBean operation, this interface provides an associated method with a signature as described by the MBean's operation meta-data. Each JMX MBean operation has an associated impact:
All exceptions emitted by implementations are wrapped as a ProxyRuntimeException.
Field Summary | |
---|---|
static java.lang.String |
APPLICATION_ALERT_BROKER_BYTES_DELIVEREDPERSECOND_NOTIFICATION_ID
Notification type constant for the notification application.alert.broker.bytes.DeliveredPerSecond. |
static java.lang.String |
APPLICATION_ALERT_BROKER_BYTES_RECEIVEDPERSECOND_NOTIFICATION_ID
Notification type constant for the notification application.alert.broker.bytes.ReceivedPerSecond. |
static java.lang.String |
APPLICATION_ALERT_BROKER_BYTES_TOPICDBSIZE_NOTIFICATION_ID
Notification type constant for the notification application.alert.broker.bytes.TopicDBSize. |
static java.lang.String |
APPLICATION_ALERT_BROKER_CONNECTIONS_COUNT_NOTIFICATION_ID
Notification type constant for the notification application.alert.broker.connections.Count. |
static java.lang.String |
APPLICATION_ALERT_BROKER_CONNECTIONS_REJECTEDPERMINUTE_NOTIFICATION_ID
Notification type constant for the notification application.alert.broker.connections.RejectedPerMinute. |
static java.lang.String |
APPLICATION_ALERT_BROKER_MESSAGES_DELIVEREDPERSECOND_NOTIFICATION_ID
Notification type constant for the notification application.alert.broker.messages.DeliveredPerSecond. |
static java.lang.String |
APPLICATION_ALERT_BROKER_MESSAGES_RECEIVEDPERSECOND_NOTIFICATION_ID
Notification type constant for the notification application.alert.broker.messages.ReceivedPerSecond. |
static java.lang.String |
APPLICATION_ALERT_CONNECTION_BYTES_DELIVEREDPERSECOND_NOTIFICATION_ID
Notification type constant for the notification application.alert.connection.bytes.DeliveredPerSecond. |
static java.lang.String |
APPLICATION_ALERT_CONNECTION_BYTES_RECEIVEDPERSECOND_NOTIFICATION_ID
Notification type constant for the notification application.alert.connection.bytes.ReceivedPerSecond. |
static java.lang.String |
APPLICATION_ALERT_CONNECTION_MESSAGES_DELIVEREDPERSECOND_NOTIFICATION_ID
Notification type constant for the notification application.alert.connection.messages.DeliveredPerSecond. |
static java.lang.String |
APPLICATION_ALERT_CONNECTION_MESSAGES_RECEIVEDPERSECOND_NOTIFICATION_ID
Notification type constant for the notification application.alert.connection.messages.ReceivedPerSecond. |
static java.lang.String |
APPLICATION_ALERT_QUEUE_MESSAGES_COUNT_NOTIFICATION_ID
Notification type constant for the notification application.alert.queue.messages.Count. |
static java.lang.String |
APPLICATION_ALERT_QUEUE_MESSAGES_DELIVEREDPERSECOND_NOTIFICATION_ID
Notification type constant for the notification application.alert.queue.messages.DeliveredPerSecond. |
static java.lang.String |
APPLICATION_ALERT_QUEUE_MESSAGES_RECEIVEDPERSECOND_NOTIFICATION_ID
Notification type constant for the notification application.alert.queue.messages.ReceivedPerSecond. |
static java.lang.String |
APPLICATION_ALERT_QUEUE_MESSAGES_SIZE_NOTIFICATION_ID
Notification type constant for the notification application.alert.queue.messages.Size. |
static java.lang.String |
APPLICATION_CONNECTION_CONNECT_NOTIFICATION_ID
Notification type constant for the notification application.connection.Connect. |
static java.lang.String |
APPLICATION_CONNECTION_DISCONNECT_NOTIFICATION_ID
Notification type constant for the notification application.connection.Disconnect. |
static java.lang.String |
APPLICATION_CONNECTION_DROP_NOTIFICATION_ID
Notification type constant for the notification application.connection.Drop. |
static java.lang.String |
APPLICATION_CONNECTION_RECONNECT_NOTIFICATION_ID
Notification type constant for the notification application.connection.Reconnect. |
static java.lang.String |
APPLICATION_CONNECTION_REDIRECT_NOTIFICATION_ID
Notification type constant for the notification application.connection.Redirect. |
static java.lang.String |
APPLICATION_CONNECTION_REJECT_NOTIFICATION_ID
Notification type constant for the notification application.connection.Reject. |
static java.lang.String |
APPLICATION_CONNECTION_REPLICATIONCONNECT_NOTIFICATION_ID
Notification type constant for the notification application.connection.ReplicationConnect. |
static java.lang.String |
APPLICATION_CONNECTION_REPLICATIONDISCONNECT_NOTIFICATION_ID
Notification type constant for the notification application.connection.ReplicationDisconnect. |
static java.lang.String |
APPLICATION_CONNECTION_REPLICATIONRETRY_NOTIFICATION_ID
Notification type constant for the notification application.connection.ReplicationRetry. |
static java.lang.String |
APPLICATION_FLOWCONTROL_CLUSTERCONNECTIONPAUSE_NOTIFICATION_ID
Notification type constant for the notification application.flowcontrol.ClusterConnectionPause. |
static java.lang.String |
APPLICATION_FLOWCONTROL_CLUSTERCONNECTIONRESUME_NOTIFICATION_ID
Notification type constant for the notification application.flowcontrol.ClusterConnectionResume. |
static java.lang.String |
APPLICATION_FLOWCONTROL_ENDFLOWTODISK_NOTIFICATION_ID
Notification type constant for the notification application.flowcontrol.EndFlowToDisk. |
static java.lang.String |
APPLICATION_FLOWCONTROL_PUBPAUSE_NOTIFICATION_ID
Notification type constant for the notification application.flowcontrol.PubPause. |
static java.lang.String |
APPLICATION_FLOWCONTROL_PUBRESUME_NOTIFICATION_ID
Notification type constant for the notification application.flowcontrol.PubResume. |
static java.lang.String |
APPLICATION_FLOWCONTROL_RMREORDERBUFFERAVAILABLE_NOTIFICATION_ID
Notification type constant for the notification application.flowcontrol.RMReorderBufferAvailable. |
static java.lang.String |
APPLICATION_FLOWCONTROL_RMREORDERBUFFERFULL_NOTIFICATION_ID
Notification type constant for the notification application.flowcontrol.RMReorderBufferFull. |
static java.lang.String |
APPLICATION_FLOWCONTROL_ROUTINGCONNECTIONPAUSE_NOTIFICATION_ID
Notification type constant for the notification application.flowcontrol.RoutingConnectionPause. |
static java.lang.String |
APPLICATION_FLOWCONTROL_ROUTINGCONNECTIONRESUME_NOTIFICATION_ID
Notification type constant for the notification application.flowcontrol.RoutingConnectionResume. |
static java.lang.String |
APPLICATION_FLOWCONTROL_ROUTINGCONNECTIONSENDERPAUSE_NOTIFICATION_ID
Notification type constant for the notification application.flowcontrol.RoutingConnectionSenderPause. |
static java.lang.String |
APPLICATION_FLOWCONTROL_ROUTINGCONNECTIONSENDERRESUME_NOTIFICATION_ID
Notification type constant for the notification application.flowcontrol.RoutingConnectionSenderResume. |
static java.lang.String |
APPLICATION_FLOWCONTROL_SENDPAUSE_NOTIFICATION_ID
Notification type constant for the notification application.flowcontrol.SendPause. |
static java.lang.String |
APPLICATION_FLOWCONTROL_SENDRESUME_NOTIFICATION_ID
Notification type constant for the notification application.flowcontrol.SendResume. |
static java.lang.String |
APPLICATION_FLOWCONTROL_STARTFLOWTODISK_NOTIFICATION_ID
Notification type constant for the notification application.flowcontrol.StartFlowToDisk. |
static java.lang.String |
APPLICATION_GLOBALSUBSCRIPTIONS_SUBSCRIBEFAILURE_NOTIFICATION_ID
Notification type constant for the notification application.globalSubscriptions.SubscribeFailure. |
static java.lang.String |
APPLICATION_GLOBALSUBSCRIPTIONS_SUBSCRIPTIONDELETED_NOTIFICATION_ID
Notification type constant for the notification application.globalSubscriptions.SubscriptionDeleted. |
static java.lang.String |
APPLICATION_GLOBALSUBSCRIPTIONS_SUBSCRIPTIONEXPIRED_NOTIFICATION_ID
Notification type constant for the notification application.globalSubscriptions.SubscriptionExpired. |
static java.lang.String |
APPLICATION_MESSAGE_UNDELIVERED_NOTIFICATION_ID
Notification type constant for the notification application.message.Undelivered. |
static java.lang.String |
APPLICATION_SESSION_ACKNOWLEDGEMENTPAUSE_NOTIFICATION_ID
Notification type constant for the notification application.session.AcknowledgementPause. |
static java.lang.String |
APPLICATION_SESSION_ENDRECEIVE_NOTIFICATION_ID
Notification type constant for the notification application.session.EndReceive. |
static java.lang.String |
APPLICATION_SESSION_STARTRECEIVE_NOTIFICATION_ID
Notification type constant for the notification application.session.StartReceive. |
static java.lang.String |
APPLICATION_SESSION_SUBSCRIBE_NOTIFICATION_ID
Notification type constant for the notification application.session.Subscribe. |
static java.lang.String |
APPLICATION_SESSION_SUBSCRIBERPAUSE_NOTIFICATION_ID
Notification type constant for the notification application.session.SubscriberPause. |
static java.lang.String |
APPLICATION_SESSION_SUBSCRIBERRESUME_NOTIFICATION_ID
Notification type constant for the notification application.session.SubscriberResume. |
static java.lang.String |
APPLICATION_SESSION_SUBSCRIPTIONMESSAGESTRIMMEDFROMDB_NOTIFICATION_ID
Notification type constant for the notification application.session.SubscriptionMessagesTrimmedFromDB. |
static java.lang.String |
APPLICATION_SESSION_SUBSCRIPTIONTRIMINVOCATIONCANCELLED_NOTIFICATION_ID
Notification type constant for the notification application.session.SubscriptionTrimInvocationCancelled. |
static java.lang.String |
APPLICATION_SESSION_SUBSCRIPTIONTRIMINVOCATIONCOMPLETED_NOTIFICATION_ID
Notification type constant for the notification application.session.SubscriptionTrimInvocationCompleted. |
static java.lang.String |
APPLICATION_SESSION_SUBSCRIPTIONTRIMINVOCATIONINITIATED_NOTIFICATION_ID
Notification type constant for the notification application.session.SubscriptionTrimInvocationInitiated. |
static java.lang.String |
APPLICATION_SESSION_UNSUBSCRIBE_NOTIFICATION_ID
Notification type constant for the notification application.session.Unsubscribe. |
static java.lang.String |
APPLICATION_STATE_ACCEPTORSTATUS_NOTIFICATION_ID
Notification type constant for the notification application.state.AcceptorStatus. |
static java.lang.String |
APPLICATION_STATE_DBCOMPACT_NOTIFICATION_ID
Notification type constant for the notification application.state.DbCompact. |
static java.lang.String |
APPLICATION_STATE_DMQCAPACITY_NOTIFICATION_ID
Notification type constant for the notification application.state.DmqCapacity. |
static java.lang.String |
APPLICATION_STATE_LOGCAPACITY_NOTIFICATION_ID
Notification type constant for the notification application.state.LogCapacity. |
static java.lang.String |
APPLICATION_STATE_PRIMARYACCEPTORSTATUS_NOTIFICATION_ID
Notification type constant for the notification application.state.PrimaryAcceptorStatus. |
static java.lang.String |
APPLICATION_STATE_REPLICATIONACTIVATE_NOTIFICATION_ID
Notification type constant for the notification application.state.ReplicationActivate. |
static java.lang.String |
APPLICATION_STATE_REPLICATIONCHANNELSWITCH_NOTIFICATION_ID
Notification type constant for the notification application.state.ReplicationChannelSwitch. |
static java.lang.String |
APPLICATION_STATE_REPLICATIONSTATECHANGE_NOTIFICATION_ID
Notification type constant for the notification application.state.ReplicationStateChange. |
static IMetricIdentity |
BROKER_BYTES_DELIVEREDPERSECOND_METRIC_ID
Metric identity constant for the metric broker.bytes.DeliveredPerSecond. |
static IMetricIdentity |
BROKER_BYTES_RECEIVEDPERSECOND_METRIC_ID
Metric identity constant for the metric broker.bytes.ReceivedPerSecond. |
static IMetricIdentity |
BROKER_BYTES_TOPICDBSIZE_METRIC_ID
Metric identity constant for the metric broker.bytes.TopicDBSize. |
static IMetricIdentity |
BROKER_CONNECTIONS_COUNT_METRIC_ID
Metric identity constant for the metric broker.connections.Count. |
static IMetricIdentity |
BROKER_CONNECTIONS_REJECTEDPERMINUTE_METRIC_ID
Metric identity constant for the metric broker.connections.RejectedPerMinute. |
static IMetricIdentity |
BROKER_MESSAGES_DELIVERED_METRIC_ID
Metric identity constant for the metric broker.messages.Delivered. |
static IMetricIdentity |
BROKER_MESSAGES_DELIVEREDPERSECOND_METRIC_ID
Metric identity constant for the metric broker.messages.DeliveredPerSecond. |
static IMetricIdentity |
BROKER_MESSAGES_RECEIVED_METRIC_ID
Metric identity constant for the metric broker.messages.Received. |
static IMetricIdentity |
BROKER_MESSAGES_RECEIVEDPERSECOND_METRIC_ID
Metric identity constant for the metric broker.messages.ReceivedPerSecond. |
static IMetricIdentity |
CONNECTION_BYTES_DELIVERED_METRIC_ID
Parent metric identity constant for the instance metric connection.bytes.Delivered. |
static IMetricIdentity |
CONNECTION_BYTES_DELIVEREDPERSECOND_METRIC_ID
Parent metric identity constant for the instance metric connection.bytes.DeliveredPerSecond. |
static IMetricIdentity |
CONNECTION_BYTES_RECEIVED_METRIC_ID
Parent metric identity constant for the instance metric connection.bytes.Received. |
static IMetricIdentity |
CONNECTION_BYTES_RECEIVEDPERSECOND_METRIC_ID
Parent metric identity constant for the instance metric connection.bytes.ReceivedPerSecond. |
static IMetricIdentity |
CONNECTION_MESSAGES_DELIVERED_METRIC_ID
Parent metric identity constant for the instance metric connection.messages.Delivered. |
static IMetricIdentity |
CONNECTION_MESSAGES_DELIVEREDPERSECOND_METRIC_ID
Parent metric identity constant for the instance metric connection.messages.DeliveredPerSecond. |
static IMetricIdentity |
CONNECTION_MESSAGES_RECEIVED_METRIC_ID
Parent metric identity constant for the instance metric connection.messages.Received. |
static IMetricIdentity |
CONNECTION_MESSAGES_RECEIVEDPERSECOND_METRIC_ID
Parent metric identity constant for the instance metric connection.messages.ReceivedPerSecond. |
static IMetricIdentity |
QUEUE_MESSAGES_COUNT_METRIC_ID
Parent metric identity constant for the instance metric queue.messages.Count. |
static IMetricIdentity |
QUEUE_MESSAGES_DELIVEREDPERSECOND_METRIC_ID
Parent metric identity constant for the instance metric queue.messages.DeliveredPerSecond. |
static IMetricIdentity |
QUEUE_MESSAGES_MAXDEPTH_METRIC_ID
Parent metric identity constant for the instance metric queue.messages.MaxDepth. |
static IMetricIdentity |
QUEUE_MESSAGES_RECEIVEDPERSECOND_METRIC_ID
Parent metric identity constant for the instance metric queue.messages.ReceivedPerSecond. |
static IMetricIdentity |
QUEUE_MESSAGES_SIZE_METRIC_ID
Parent metric identity constant for the instance metric queue.messages.Size. |
static java.lang.String |
SYSTEM_STATE_OFFLINE_NOTIFICATION_ID
Notification type constant for the notification system.state.Offline. |
static java.lang.String |
SYSTEM_STATE_ONLINE_NOTIFICATION_ID
Notification type constant for the notification system.state.Online. |
Method Summary | |
---|---|
void |
activateWaitingBroker()
Invokes the activateWaitingBroker operation. |
void |
addNotificationListener(NotificationListener listener,
NotificationFilter filter,
java.lang.Object handback)
Adds a notification listener. |
void |
cancelReliableSequences(java.util.ArrayList ids)
Invokes the cancelReliableSequences operation. |
void |
clearDuplicateDetectionData()
Invokes the clearDuplicateDetectionData operation. |
void |
clearError()
Invokes the clearError operation. |
void |
closeBrowser(IBrowseToken token)
Invokes the closeBrowser operation. |
void |
commitPreparedXABranches(java.lang.Integer[] tIDs)
Invokes the commitPreparedXABranches operation. |
IBrowseToken |
createDurableBrowseToken(java.lang.String userId,
java.lang.String jmsClientId,
java.lang.String uniqueName,
java.lang.Boolean isConnectionConsumer,
java.lang.Boolean local)
Invokes the createDurableBrowseToken operation. |
IBrowseToken |
createDurableBrowseTokenFromDSD(IDurableSubscriptionData dsd,
java.lang.Boolean isLocal)
Invokes the createDurableBrowseTokenFromDSD operation. |
IMessageHeaderToken |
createDurableMessageHeaderToken(java.lang.String userId,
java.lang.String jmsClientId,
java.lang.String uniqueName,
java.lang.Boolean isConnectionConsumer,
java.lang.String messageId)
Invokes the createDurableMessageHeaderToken operation. |
IMessageHeaderToken |
createDurableMessageHeaderTokenDSD(IDurableSubscriptionData dsd,
java.lang.String messageId)
Invokes the createDurableMessageHeaderTokenDSD operation. |
void |
deleteDurableSubscriptions(java.lang.String user,
java.util.ArrayList subscriptions)
Invokes the deleteDurableSubscriptions operation. |
void |
deleteGlobalQueueAdvertisements(java.util.ArrayList advertisements)
Invokes the deleteGlobalQueueAdvertisements operation. |
void |
deleteQueueMessages(java.util.ArrayList queues)
Invokes the deleteQueueMessages operation. |
void |
deleteRemoteSubscriptions(java.util.ArrayList remoteNodes)
Invokes the deleteRemoteSubscriptions operation. |
void |
disableAlerts(IAlert[] alerts)
Invokes the disableAlerts operation. |
void |
disableMetrics(IMetricIdentity[] ids)
Invokes the disableMetrics operation. |
void |
dropConnections(java.util.ArrayList connections)
Invokes the dropConnections operation. |
void |
enableAlerts(IAlert[] alerts)
Invokes the enableAlerts operation. |
void |
enableMetrics(IMetricIdentity[] ids)
Invokes the enableMetrics operation. |
void |
forceCRLUpdate(java.lang.String distributionPoint)
Invokes the forceCRLUpdate operation. |
IMetricIdentity[] |
getActiveMetrics(IMetricIdentity[] ids)
Invokes the getActiveMetrics operation. |
AttributeList |
getAttributes(java.lang.String[] attributeNames)
Gets the values of several attributes of a Broker component. |
java.lang.String |
getBrokerName()
Gets the value of the BrokerName attribute. |
java.util.ArrayList |
getBrowseMessages(IBrowseToken ibt,
java.lang.Integer maxMessages)
Invokes the getBrowseMessages operation. |
java.lang.String |
getClassname()
Gets the value of the Classname attribute. |
java.lang.String |
getClasspath()
Gets the value of the Classpath attribute. |
java.lang.String |
getClusterName()
Gets the value of the ClusterName attribute. |
java.lang.String |
getConfigID()
Gets the value of the ConfigID attribute. |
java.util.ArrayList |
getConnectionMemberDetails(java.util.ArrayList refs)
Invokes the getConnectionMemberDetails operation. |
IConnectionMemberDetails |
getConnectionMemberDetails(java.lang.Long ref)
Invokes the getConnectionMemberDetails operation. |
java.util.ArrayList |
getConnections(java.lang.String prefix)
Invokes the getConnections operation. |
java.util.ArrayList |
getConnectionTree(java.util.ArrayList nodes,
java.lang.Integer depth)
Invokes the getConnectionTree operation. |
java.lang.String[] |
getCRLList()
Invokes the getCRLList operation. |
java.lang.Integer |
getDBCompactState()
Gets the value of the DBCompactState attribute. |
java.lang.String |
getDBCompactStateString()
Gets the value of the DBCompactStateString attribute. |
java.util.ArrayList |
getDurableSubscriptions(java.lang.String user)
Invokes the getDurableSubscriptions operation. |
IAlert[] |
getEnabledAlerts(IMetricIdentity[] ids)
Invokes the getEnabledAlerts operation. |
IMetricIdentity[] |
getEnabledMetrics(IMetricIdentity[] ids)
Invokes the getEnabledMetrics operation. |
java.lang.String[] |
getExternalUsers(java.lang.String prefix)
Invokes the getExternalUsers operation. |
java.util.ArrayList |
getGlobalQueueAdvertisements(java.lang.String prefix)
Invokes the getGlobalQueueAdvertisements operation. |
java.lang.String[] |
getInstanceMetricNames(IMetricIdentity id)
Invokes the getInstanceMetricNames operation. |
java.lang.String |
getLastError()
Gets the value of the LastError attribute. |
java.lang.Integer |
getLastErrorLevel()
Gets the value of the LastErrorLevel attribute. |
java.lang.String |
getLastErrorLevelString()
Gets the value of the LastErrorLevelString attribute. |
IMessage |
getMessage(IMessageHeaderToken ht)
Invokes the getMessage operation. |
java.lang.Integer |
getMetricsCollectionInterval()
Gets the value of the MetricsCollectionInterval attribute. |
IMetricsData |
getMetricsData(IMetricIdentity[] ids,
java.lang.Boolean returnTriggeredAlerts)
Invokes the getMetricsData operation. |
IMetricInfo[] |
getMetricsInfo()
Invokes the getMetricsInfo operation. |
java.lang.Integer |
getMetricsRefreshInterval()
Gets the value of the MetricsRefreshInterval attribute. |
java.util.ArrayList |
getPreparedXABranches()
Invokes the getPreparedXABranches operation. |
java.util.ArrayList |
getQueues(java.lang.String prefix)
Invokes the getQueues operation. |
java.lang.String |
getReleaseVersion()
Gets the value of the ReleaseVersion attribute. |
java.util.ArrayList |
getReliableReceiveSequences()
Invokes the getReliableReceiveSequences operation. |
java.util.ArrayList |
getReliableSendSequences()
Invokes the getReliableSendSequences operation. |
java.util.ArrayList |
getRemoteSubscriptionSummary(java.lang.String nodePattern)
Invokes the getRemoteSubscriptionSummary operation. |
java.util.ArrayList |
getRemoteSubscriptionSummary(java.lang.String nodePattern,
java.lang.Boolean getAllNodes)
Invokes the getRemoteSubscriptionSummary operation. |
java.util.ArrayList |
getRemoteSubscriptionTopics(java.lang.String node,
java.lang.String topicPattern)
Invokes the getRemoteSubscriptionTopics operation. |
java.lang.Boolean |
getRepeatMetricAlerts()
Gets the value of the RepeatMetricAlerts attribute. |
java.lang.String[] |
getReplicationConnections()
Invokes the getReplicationConnections operation. |
java.lang.Integer |
getReplicationConnectionState(java.lang.String name)
Invokes the getReplicationConnectionState operation. |
java.lang.String |
getReplicationConnectionStateString(java.lang.String name)
Invokes the getReplicationConnectionStateString operation. |
java.lang.Integer |
getReplicationState()
Gets the value of the ReplicationState attribute. |
java.lang.String |
getReplicationStateString()
Gets the value of the ReplicationStateString attribute. |
java.lang.String |
getReplicationType()
Gets the value of the ReplicationType attribute. |
java.lang.String |
getRoutingNodeName()
Gets the value of the RoutingNodeName attribute. |
java.util.ArrayList |
getRoutingStatistics(java.lang.String prefix)
Invokes the getRoutingStatistics operation. |
java.lang.Boolean |
getSecurityEnabled()
Gets the value of the SecurityEnabled attribute. |
java.lang.Short |
getState()
Gets the value of the State attribute. |
java.lang.String |
getStateString()
Gets the value of the StateString attribute. |
java.util.ArrayList |
getSubscribers(java.util.ArrayList refs)
Invokes the getSubscribers operation. |
java.util.ArrayList |
getSubscribers(java.lang.Long ref)
Invokes the getSubscribers operation. |
java.util.ArrayList |
getSubscribers(java.lang.String connectId,
java.lang.String userId)
Invokes the getSubscribers operation. |
java.lang.Integer |
getTraceMask()
Gets the value of the TraceMask attribute. |
java.lang.String |
getTraceMaskValues()
Gets the value of the TraceMaskValues attribute. |
java.lang.Long |
getUptime()
Gets the value of the Uptime attribute. |
java.util.ArrayList |
getUsersWithDurableSubscriptions(java.lang.String prefix)
Invokes the getUsersWithDurableSubscriptions operation. |
void |
initDuplicateDetectionStore(java.lang.Short action)
Invokes the initDuplicateDetectionStore operation. |
void |
initMessageStore(java.lang.Short action)
Invokes the initMessageStore operation. |
void |
reconcileRemoteSubscriptions(java.util.ArrayList remoteNodes)
Invokes the reconcileRemoteSubscriptions operation. |
java.lang.Boolean |
refreshSecurity(java.lang.String prefix)
Invokes the refreshSecurity operation. |
void |
reload()
Invokes the reload operation. |
void |
removeMessage(IMessageHeaderToken ht)
Invokes the removeMessage operation. |
void |
removeNotificationListener(NotificationListener listener)
Removes a notification listener. |
void |
resetMetrics()
Invokes the resetMetrics operation. |
void |
rollbackPreparedXABranches(java.lang.Integer[] tIDs)
Invokes the rollbackPreparedXABranches operation. |
IMessageHeader |
searchMessage(IMessageHeaderToken ht)
Invokes the searchMessage operation. |
AttributeList |
setAttributes(AttributeList attributes)
Sets the values of several attributes of a Broker component. |
void |
setBrowseInactiveTimeout(IBrowseToken bt,
java.lang.Integer timeout)
Invokes the setBrowseInactiveTimeout operation. |
void |
setMetricsCollectionInterval(java.lang.Integer value)
Sets the value of the MetricsCollectionInterval attribute. |
void |
setMetricsRefreshInterval(java.lang.Integer value)
Sets the value of the MetricsRefreshInterval attribute. |
void |
setRepeatMetricAlerts(java.lang.Boolean value)
Sets the value of the RepeatMetricAlerts attribute. |
void |
setTraceMask(java.lang.Integer value)
Sets the value of the TraceMask attribute. |
void |
start()
Invokes the start operation. |
void |
startDBCompact()
Invokes the startDBCompact operation. |
void |
startDBCompactWorkdir(java.lang.String workdir)
Invokes the startDBCompactWorkdir operation. |
void |
stop()
Invokes the stop operation. |
void |
stopDBCompact()
Invokes the stopDBCompact operation. |
void |
syncMessageStore(java.lang.String sourceWorkingDir)
Invokes the syncMessageStore operation. |
void |
trimMessages(IBrowseToken ibt,
java.lang.Long dateTime)
Invokes the trimMessages operation. |
Field Detail |
---|
static final java.lang.String APPLICATION_ALERT_BROKER_BYTES_DELIVEREDPERSECOND_NOTIFICATION_ID
Description: Alert for metric broker.bytes.DeliveredPerSecond
static final java.lang.String APPLICATION_ALERT_BROKER_BYTES_RECEIVEDPERSECOND_NOTIFICATION_ID
Description: Alert for metric broker.bytes.ReceivedPerSecond
static final java.lang.String APPLICATION_ALERT_BROKER_BYTES_TOPICDBSIZE_NOTIFICATION_ID
Description: Alert for metric broker.bytes.TopicDBSize
static final java.lang.String APPLICATION_ALERT_BROKER_CONNECTIONS_COUNT_NOTIFICATION_ID
Description: Alert for metric broker.connections.Count
static final java.lang.String APPLICATION_ALERT_BROKER_CONNECTIONS_REJECTEDPERMINUTE_NOTIFICATION_ID
Description: Alert for metric broker.connections.RejectedPerMinute
static final java.lang.String APPLICATION_ALERT_BROKER_MESSAGES_DELIVEREDPERSECOND_NOTIFICATION_ID
Description: Alert for metric broker.messages.DeliveredPerSecond
static final java.lang.String APPLICATION_ALERT_BROKER_MESSAGES_RECEIVEDPERSECOND_NOTIFICATION_ID
Description: Alert for metric broker.messages.ReceivedPerSecond
static final java.lang.String APPLICATION_ALERT_CONNECTION_BYTES_DELIVEREDPERSECOND_NOTIFICATION_ID
Description: Alert for metric connection.bytes.DeliveredPerSecond
static final java.lang.String APPLICATION_ALERT_CONNECTION_BYTES_RECEIVEDPERSECOND_NOTIFICATION_ID
Description: Alert for metric connection.bytes.ReceivedPerSecond
static final java.lang.String APPLICATION_ALERT_CONNECTION_MESSAGES_DELIVEREDPERSECOND_NOTIFICATION_ID
Description: Alert for metric connection.messages.DeliveredPerSecond
static final java.lang.String APPLICATION_ALERT_CONNECTION_MESSAGES_RECEIVEDPERSECOND_NOTIFICATION_ID
Description: Alert for metric connection.messages.ReceivedPerSecond
static final java.lang.String APPLICATION_ALERT_QUEUE_MESSAGES_COUNT_NOTIFICATION_ID
Description: Alert for metric queue.messages.Count
application.alert.queue.messages.Count
static final java.lang.String APPLICATION_ALERT_QUEUE_MESSAGES_DELIVEREDPERSECOND_NOTIFICATION_ID
Description: Alert for metric queue.messages.DeliveredPerSecond
static final java.lang.String APPLICATION_ALERT_QUEUE_MESSAGES_RECEIVEDPERSECOND_NOTIFICATION_ID
Description: Alert for metric queue.messages.ReceivedPerSecond
static final java.lang.String APPLICATION_ALERT_QUEUE_MESSAGES_SIZE_NOTIFICATION_ID
Description: Alert for metric queue.messages.Size
application.alert.queue.messages.Size
static final java.lang.String APPLICATION_CONNECTION_CONNECT_NOTIFICATION_ID
Description: Connection connect.
application.connection.Connect
static final java.lang.String APPLICATION_CONNECTION_DISCONNECT_NOTIFICATION_ID
Description: Connection disconnect.
application.connection.Disconnect
static final java.lang.String APPLICATION_CONNECTION_DROP_NOTIFICATION_ID
Description: Connection dropped/aborted.
application.connection.Drop
static final java.lang.String APPLICATION_CONNECTION_RECONNECT_NOTIFICATION_ID
Description: Connection reconnect.
application.connection.Reconnect
static final java.lang.String APPLICATION_CONNECTION_REDIRECT_NOTIFICATION_ID
Description: Connection redirected to another broker.
application.connection.Redirect
static final java.lang.String APPLICATION_CONNECTION_REJECT_NOTIFICATION_ID
Description: Connection attempt rejected.
application.connection.Reject
static final java.lang.String APPLICATION_CONNECTION_REPLICATIONCONNECT_NOTIFICATION_ID
Description: Replication connection connect.
static final java.lang.String APPLICATION_CONNECTION_REPLICATIONDISCONNECT_NOTIFICATION_ID
Description: Replication connection disconnect.
static final java.lang.String APPLICATION_CONNECTION_REPLICATIONRETRY_NOTIFICATION_ID
Description: Replication connection retry.
application.connection.ReplicationRetry
static final java.lang.String APPLICATION_FLOWCONTROL_CLUSTERCONNECTIONPAUSE_NOTIFICATION_ID
Description: Cluster connection paused due to flow control.
static final java.lang.String APPLICATION_FLOWCONTROL_CLUSTERCONNECTIONRESUME_NOTIFICATION_ID
Description: Cluster connection resumed after flow control.
static final java.lang.String APPLICATION_FLOWCONTROL_ENDFLOWTODISK_NOTIFICATION_ID
Description: Subscriber has stopped flowing messages to disk.
application.flowcontrol.EndFlowToDisk
static final java.lang.String APPLICATION_FLOWCONTROL_PUBPAUSE_NOTIFICATION_ID
Description: Publisher paused due to flow control.
application.flowcontrol.PubPause
static final java.lang.String APPLICATION_FLOWCONTROL_PUBRESUME_NOTIFICATION_ID
Description: Publisher resumed after flow control.
application.flowcontrol.PubResume
static final java.lang.String APPLICATION_FLOWCONTROL_RMREORDERBUFFERAVAILABLE_NOTIFICATION_ID
Description: Reliable Message Re-order Buffer Available.
static final java.lang.String APPLICATION_FLOWCONTROL_RMREORDERBUFFERFULL_NOTIFICATION_ID
Description: Reliable Message Re-order Buffer Full.
static final java.lang.String APPLICATION_FLOWCONTROL_ROUTINGCONNECTIONPAUSE_NOTIFICATION_ID
Description: Routing connection paused due to flow control.
static final java.lang.String APPLICATION_FLOWCONTROL_ROUTINGCONNECTIONRESUME_NOTIFICATION_ID
Description: Routing connection resumed after flow control.
static final java.lang.String APPLICATION_FLOWCONTROL_ROUTINGCONNECTIONSENDERPAUSE_NOTIFICATION_ID
Description: (Sender side notification) Routing connection paused due to flow control.
static final java.lang.String APPLICATION_FLOWCONTROL_ROUTINGCONNECTIONSENDERRESUME_NOTIFICATION_ID
Description: (Sender side notification) Routing connection resumed after flow control.
static final java.lang.String APPLICATION_FLOWCONTROL_SENDPAUSE_NOTIFICATION_ID
Description: Sender paused due to flow control.
application.flowcontrol.SendPause
static final java.lang.String APPLICATION_FLOWCONTROL_SENDRESUME_NOTIFICATION_ID
Description: Sender resumed after flow control.
application.flowcontrol.SendResume
static final java.lang.String APPLICATION_FLOWCONTROL_STARTFLOWTODISK_NOTIFICATION_ID
Description: Subscriber has started flowing messages to disk.
application.flowcontrol.StartFlowToDisk
static final java.lang.String APPLICATION_GLOBALSUBSCRIPTIONS_SUBSCRIBEFAILURE_NOTIFICATION_ID
Description: Subscription undelivered to requested remote node.
static final java.lang.String APPLICATION_GLOBALSUBSCRIPTIONS_SUBSCRIPTIONDELETED_NOTIFICATION_ID
Description: Remote subscription manually deleted.
static final java.lang.String APPLICATION_GLOBALSUBSCRIPTIONS_SUBSCRIPTIONEXPIRED_NOTIFICATION_ID
Description: Remote subscription has expired.
static final java.lang.String APPLICATION_MESSAGE_UNDELIVERED_NOTIFICATION_ID
Description: Message undelivered to requested destination.
application.message.Undelivered
static final java.lang.String APPLICATION_SESSION_ACKNOWLEDGEMENTPAUSE_NOTIFICATION_ID
Description: Durable subscriber paused acknowledging messages (while acknowledgement monitoring is enabled).
application.session.AcknowledgementPause
static final java.lang.String APPLICATION_SESSION_ENDRECEIVE_NOTIFICATION_ID
Description: Close queue receiver.
application.session.EndReceive
static final java.lang.String APPLICATION_SESSION_STARTRECEIVE_NOTIFICATION_ID
Description: Open queue receiver.
application.session.StartReceive
static final java.lang.String APPLICATION_SESSION_SUBSCRIBE_NOTIFICATION_ID
Description: Client subscription.
application.session.Subscribe
static final java.lang.String APPLICATION_SESSION_SUBSCRIBERPAUSE_NOTIFICATION_ID
Description: Durable subscription pause.
application.session.SubscriberPause
static final java.lang.String APPLICATION_SESSION_SUBSCRIBERRESUME_NOTIFICATION_ID
Description: Durable subscription resumption.
application.session.SubscriberResume
static final java.lang.String APPLICATION_SESSION_SUBSCRIPTIONMESSAGESTRIMMEDFROMDB_NOTIFICATION_ID
Description: Durable Subscription Trim Operation completed message deletions from DB.
static final java.lang.String APPLICATION_SESSION_SUBSCRIPTIONTRIMINVOCATIONCANCELLED_NOTIFICATION_ID
Description: Durable Subscription Trim Operation cancelled.
static final java.lang.String APPLICATION_SESSION_SUBSCRIPTIONTRIMINVOCATIONCOMPLETED_NOTIFICATION_ID
Description: Durable Subscription Trim Operation returned.
static final java.lang.String APPLICATION_SESSION_SUBSCRIPTIONTRIMINVOCATIONINITIATED_NOTIFICATION_ID
Description: Durable Subscription Trim Operation invoked.
static final java.lang.String APPLICATION_SESSION_UNSUBSCRIBE_NOTIFICATION_ID
Description: Client unsubscribe.
application.session.Unsubscribe
static final java.lang.String APPLICATION_STATE_ACCEPTORSTATUS_NOTIFICATION_ID
Description: An acceptor failed to successufly be started
application.state.AcceptorStatus
static final java.lang.String APPLICATION_STATE_DBCOMPACT_NOTIFICATION_ID
Description: A change has occured in the database compaction state.
application.state.DbCompact
static final java.lang.String APPLICATION_STATE_DMQCAPACITY_NOTIFICATION_ID
Description: Dead Message Queue capacity warning.
application.state.DmqCapacity
static final java.lang.String APPLICATION_STATE_LOGCAPACITY_NOTIFICATION_ID
Description: Recovery log capacity warning.
application.state.LogCapacity
static final java.lang.String APPLICATION_STATE_PRIMARYACCEPTORSTATUS_NOTIFICATION_ID
Description: The primary acceptor failed to successufly be started
application.state.PrimaryAcceptorStatus
static final java.lang.String APPLICATION_STATE_REPLICATIONACTIVATE_NOTIFICATION_ID
Description: Replication connection activation.
application.state.ReplicationActivate
static final java.lang.String APPLICATION_STATE_REPLICATIONCHANNELSWITCH_NOTIFICATION_ID
Description: Replication channel switch.
static final java.lang.String APPLICATION_STATE_REPLICATIONSTATECHANGE_NOTIFICATION_ID
Description: Replication state change.
application.state.ReplicationStateChange
static final IMetricIdentity BROKER_BYTES_DELIVEREDPERSECOND_METRIC_ID
Description: Broker wide bytes delivered per second (includes internal/management messages).
broker.bytes.DeliveredPerSecond
static final IMetricIdentity BROKER_BYTES_RECEIVEDPERSECOND_METRIC_ID
Description: Broker wide bytes received per second (includes internal/management messages).
broker.bytes.ReceivedPerSecond
static final IMetricIdentity BROKER_BYTES_TOPICDBSIZE_METRIC_ID
Description: Total size in bytes of topic message store
broker.bytes.TopicDBSize
static final IMetricIdentity BROKER_CONNECTIONS_COUNT_METRIC_ID
Description: Inbound connection count to broker.
broker.connections.Count
static final IMetricIdentity BROKER_CONNECTIONS_REJECTEDPERMINUTE_METRIC_ID
Description: Rejected connect attempts per minute.
broker.connections.RejectedPerMinute
static final IMetricIdentity BROKER_MESSAGES_DELIVERED_METRIC_ID
Description: Application messages delivered since start/reset (excludes internal/management messages).
broker.messages.Delivered
static final IMetricIdentity BROKER_MESSAGES_DELIVEREDPERSECOND_METRIC_ID
Description: Application messages delivered per second (excludes internal/management messages).
broker.messages.DeliveredPerSecond
static final IMetricIdentity BROKER_MESSAGES_RECEIVED_METRIC_ID
Description: Application messages received since start/reset (excludes internal/management messages).
broker.messages.Received
static final IMetricIdentity BROKER_MESSAGES_RECEIVEDPERSECOND_METRIC_ID
Description: Application messages received per second (excludes internal/management messages).
broker.messages.ReceivedPerSecond
static final IMetricIdentity CONNECTION_BYTES_DELIVERED_METRIC_ID
Description: Bytes delivered to a connection (includes internal/management messages).
connection.bytes.Delivered
static final IMetricIdentity CONNECTION_BYTES_DELIVEREDPERSECOND_METRIC_ID
Description: Bytes delivered to a connection/sec (includes internal/management messages).
connection.bytes.DeliveredPerSecond
static final IMetricIdentity CONNECTION_BYTES_RECEIVED_METRIC_ID
Description: Bytes received by a connection (includes internal/management messages).
connection.bytes.Received
static final IMetricIdentity CONNECTION_BYTES_RECEIVEDPERSECOND_METRIC_ID
Description: Bytes received by a connection per second (includes internal/management messages).
connection.bytes.ReceivedPerSecond
static final IMetricIdentity CONNECTION_MESSAGES_DELIVERED_METRIC_ID
Description: Messages delivered to a connection (excludes internal/management messages).
connection.messages.Delivered
static final IMetricIdentity CONNECTION_MESSAGES_DELIVEREDPERSECOND_METRIC_ID
Description: Messages delivered to a connection/sec (excludes internal/management messages).
connection.messages.DeliveredPerSecond
static final IMetricIdentity CONNECTION_MESSAGES_RECEIVED_METRIC_ID
Description: Messages received by a connection (excludes internal/management messages).
connection.messages.Received
static final IMetricIdentity CONNECTION_MESSAGES_RECEIVEDPERSECOND_METRIC_ID
Description: Messages received by a connection per second (excludes internal/management messages).
connection.messages.ReceivedPerSecond
static final IMetricIdentity QUEUE_MESSAGES_COUNT_METRIC_ID
Description: Number of messages in a queue.
queue.messages.Count
static final IMetricIdentity QUEUE_MESSAGES_DELIVEREDPERSECOND_METRIC_ID
Description: Messages delivered to a queue per second (including rejected messages).
queue.messages.DeliveredPerSecond
static final IMetricIdentity QUEUE_MESSAGES_MAXDEPTH_METRIC_ID
Description: Maximum number of messages in a queue during a collection interval.
queue.messages.MaxDepth
static final IMetricIdentity QUEUE_MESSAGES_RECEIVEDPERSECOND_METRIC_ID
Description: Messages received by a queue per second
queue.messages.ReceivedPerSecond
static final IMetricIdentity QUEUE_MESSAGES_SIZE_METRIC_ID
Description: Size of messages in a queue.
queue.messages.Size
static final java.lang.String SYSTEM_STATE_OFFLINE_NOTIFICATION_ID
Description: Component stop complete.
system.state.Offline
static final java.lang.String SYSTEM_STATE_ONLINE_NOTIFICATION_ID
Description: Component start complete.
system.state.Online
Method Detail |
---|
void activateWaitingBroker()
Activate a broker in the WAITING state.
Impact: ACTION
void addNotificationListener(NotificationListener listener, NotificationFilter filter, java.lang.Object handback)
A Broker component publishes the following notifications:
application.alert.broker.bytes.DeliveredPerSecond
application.alert.broker.bytes.ReceivedPerSecond
application.alert.broker.bytes.TopicDBSize
application.alert.broker.connections.Count
application.alert.broker.connections.RejectedPerMinute
application.alert.broker.messages.DeliveredPerSecond
application.alert.broker.messages.ReceivedPerSecond
application.alert.connection.bytes.DeliveredPerSecond
application.alert.connection.bytes.ReceivedPerSecond
application.alert.connection.messages.DeliveredPerSecond
application.alert.connection.messages.ReceivedPerSecond
application.alert.queue.messages.Count
application.alert.queue.messages.DeliveredPerSecond
application.alert.queue.messages.ReceivedPerSecond
application.alert.queue.messages.Size
application.connection.Connect
application.connection.Disconnect
application.connection.Drop
application.connection.Reconnect
application.connection.Redirect
application.connection.Reject
application.connection.ReplicationConnect
application.connection.ReplicationDisconnect
application.connection.ReplicationRetry
application.flowcontrol.ClusterConnectionPause
application.flowcontrol.ClusterConnectionResume
application.flowcontrol.EndFlowToDisk
application.flowcontrol.PubPause
application.flowcontrol.PubResume
application.flowcontrol.RMReorderBufferAvailable
application.flowcontrol.RMReorderBufferFull
application.flowcontrol.RoutingConnectionPause
application.flowcontrol.RoutingConnectionResume
application.flowcontrol.RoutingConnectionSenderPause
application.flowcontrol.RoutingConnectionSenderResume
application.flowcontrol.SendPause
application.flowcontrol.SendResume
application.flowcontrol.StartFlowToDisk
application.globalSubscriptions.SubscribeFailure
application.globalSubscriptions.SubscriptionDeleted
application.globalSubscriptions.SubscriptionExpired
application.message.Undelivered
application.session.AcknowledgementPause
application.session.EndReceive
application.session.StartReceive
application.session.Subscribe
application.session.SubscriberPause
application.session.SubscriberResume
application.session.SubscriptionMessagesTrimmedFromDB
application.session.SubscriptionTrimInvocationCancelled
application.session.SubscriptionTrimInvocationCompleted
application.session.SubscriptionTrimInvocationInitiated
application.session.Unsubscribe
application.state.AcceptorStatus
application.state.DbCompact
application.state.DmqCapacity
application.state.LogCapacity
application.state.PrimaryAcceptorStatus
application.state.ReplicationActivate
application.state.ReplicationChannelSwitch
application.state.ReplicationStateChange
system.state.Offline
system.state.Online
listener
- The listener object which will handle the notifications emitted component.filter
- The filter object. If filter is null, no filtering will be performed before handling notifications.handback
- The context to be sent to the listener when a notification is emitted.removeNotificationListener(javax.management.NotificationListener)
void cancelReliableSequences(java.util.ArrayList ids)
Management operation that supports cancelling of Web Service Reliable Messaging sequences.
Reliable sequences are identified by a universally unique identifier(UUID). A UUID identifies either a reliable send sequence or a receive receive sequence.
Cancelling a send sequence includes standard JMS undelivered message processing for messages that have been produced by Sonic JMS clients for Web Service transmission and that are pending acknowledgement by the remote RM Destination.
If a JMS client sends messages after a send sequence has been cancelled, the fault 'Sequence terminated' or 'Unknown sequence' may be generated and standard JMS undelivered message processing applied.
Cancelling a receive sequence causes a Web Service Reliable Messaging sequence fault, 'Sequence terminated', to be sent to the remote RM Source; if additional messages are received from the RM Source, these will be faulted with 'Unknown sequence'.
Impact: ACTION
ids
- ArrayList of String sequence identifiers that identify reliable sequences to be cancelled.void clearDuplicateDetectionData()
Remove the duplicate detection data from the duplicate detection store
Impact: ACTION
void clearError()
Clear existing error condition.
Impact: ACTION
getLastErrorLevel()
void closeBrowser(IBrowseToken token)
Cleanup all state information associated with the given IBrowseToken.
Impact: INFO
token
- The browse token representing a browser.void commitPreparedXABranches(java.lang.Integer[] tIDs)
Commit the given set of prepared XA branches.
Impact: ACTION
tIDs
- The internal TIDs of the branches to commit.IBrowseToken createDurableBrowseToken(java.lang.String userId, java.lang.String jmsClientId, java.lang.String uniqueName, java.lang.Boolean isConnectionConsumer, java.lang.Boolean local)
Create a durable browse token for durable operations.
Impact: INFO
userId
- The user that created the durable subscriber.jmsClientId
- The JMS Client ID of the durable subscriber.uniqueName
- The name used to identify this subscription.isConnectionConsumer
- True if this durable subscription is in use for a Connection Consumer.local
- True if this durable browser should only browse information on the local broker. False if this durable browser should browse all message for this durable subscription across the cluster.IBrowseToken createDurableBrowseTokenFromDSD(IDurableSubscriptionData dsd, java.lang.Boolean isLocal)
Create a durable browse token for durable operations from a IDurableSubscriptionData.
Impact: INFO
dsd
- A reference to the IDurableSubscriptionData to be browsed.isLocal
- True if this durable browser should only browse information on the local broker. False if this durable browser should browse all message for this durable subscription across the cluster.IMessageHeaderToken createDurableMessageHeaderToken(java.lang.String userId, java.lang.String jmsClientId, java.lang.String uniqueName, java.lang.Boolean isConnectionConsumer, java.lang.String messageId)
Create a message header token for use in other operations. A message header token represents a message in a specific durable subscription.
Impact: INFO
userId
- The user that created the durable subscriber.jmsClientId
- The JMS Client ID of the durable subscriber.uniqueName
- The name used to identify this subscription.isConnectionConsumer
- True if this durable subscription is in use for a Connection Consumer.messageId
- The JMS MessageID of the message.IMessageHeaderToken createDurableMessageHeaderTokenDSD(IDurableSubscriptionData dsd, java.lang.String messageId)
Create a message header token for use in other operations from a IDurableSubscriptionData
Impact: INFO
dsd
- A reference to the IDurableSubscriptionData to be browsed.messageId
- The JMS MessageID of the message.void deleteDurableSubscriptions(java.lang.String user, java.util.ArrayList subscriptions)
Deletes the subscriptions for the given a user and a list of durable subscriptions. If the user is currently connected and applicable durable subscriptions are active, then the operation will fail (return an exception) after having deleted inactive subscriptions for that user.
The broker must be in an online state in order to invoke this operation.
Impact: ACTION
user
- The user for which applicable durable subscriptions will be deleted.subscriptions
- A list of IDurableSubscriptionData objects describing the user subscriptions to delete. IDurableSubscriptionData objects are initially obtained by invoking getDurableSubscriptions(String) on this component. If no list is provided (null), then all durable subscriptions for the given user will be deleted.void deleteGlobalQueueAdvertisements(java.util.ArrayList advertisements)
Deletes the given set of global queue advertisements known by this broker.
The broker must be in an online state in order to invoke this operation.
Impact: ACTION
advertisements
- A list of IGlobalQueueRouteData objects describing the advertisements to delete. IGlobalQueueRouteData objects are initially obtained by invoking getGlobalQueueAdvertisements(String) on this component.void deleteQueueMessages(java.util.ArrayList queues)
Deletes all messages from the given list of queues currently managed by the broker.
The broker must be in an online state in order to invoke this operation.
If there are active senders to an applicable queue, then it is possble that calling getQueues(String) immediately after invoking this operation will not yield a message count of 0 (since further messages may have arrived).
Impact: ACTION
queues
- A list of queue names describing the queues to have their messages deleted.void deleteRemoteSubscriptions(java.util.ArrayList remoteNodes)
Deletes remote subscriptions propagated by given remote nodes.
Deletes propagated remote subscriptions within the routing node to which this broker is a member. Remote subscriptions propagated by specified remote routing nodes are deleted.
Impact: ACTION
remoteNodes
- An array list of java.lang.String objects supplying names of remote routing nodes which are propagating subscriptions and for which propagated remote subscriptions deletion is required.void disableAlerts(IAlert[] alerts)
Disable threshold alerts on a metric.
Impact: ACTION
Metrics that allow alert thresholds to be specified are:
broker.bytes.DeliveredPerSecond
broker.bytes.ReceivedPerSecond
broker.bytes.TopicDBSize
broker.connections.Count
broker.connections.RejectedPerMinute
broker.messages.DeliveredPerSecond
broker.messages.ReceivedPerSecond
connection.bytes.DeliveredPerSecond
connection.bytes.ReceivedPerSecond
connection.messages.DeliveredPerSecond
connection.messages.ReceivedPerSecond
queue.messages.Count
queue.messages.DeliveredPerSecond
queue.messages.ReceivedPerSecond
queue.messages.Size
alerts
- A list of alerts to disable.enableAlerts(com.sonicsw.mf.common.metrics.IAlert[])
,
getEnabledAlerts(com.sonicsw.mf.common.metrics.IMetricIdentity[])
void disableMetrics(IMetricIdentity[] ids)
Disable the given set of dynamic metrics.
Impact: ACTION
Dynamic metrics are:
broker.bytes.DeliveredPerSecond
broker.bytes.ReceivedPerSecond
broker.bytes.TopicDBSize
broker.connections.Count
broker.connections.RejectedPerMinute
broker.messages.Delivered
broker.messages.DeliveredPerSecond
broker.messages.Received
broker.messages.ReceivedPerSecond
connection.bytes.Delivered
connection.bytes.DeliveredPerSecond
connection.bytes.Received
connection.bytes.ReceivedPerSecond
connection.messages.Delivered
connection.messages.DeliveredPerSecond
connection.messages.Received
connection.messages.ReceivedPerSecond
queue.messages.Count
queue.messages.DeliveredPerSecond
queue.messages.MaxDepth
queue.messages.ReceivedPerSecond
queue.messages.Size
ids
- A list of metrics identity patterns.enableMetrics(com.sonicsw.mf.common.metrics.IMetricIdentity[])
,
getActiveMetrics(com.sonicsw.mf.common.metrics.IMetricIdentity[])
,
getEnabledMetrics(com.sonicsw.mf.common.metrics.IMetricIdentity[])
,
getMetricsData(com.sonicsw.mf.common.metrics.IMetricIdentity[], java.lang.Boolean)
,
getMetricsInfo()
,
resetMetrics()
void dropConnections(java.util.ArrayList connections)
Drops the given set of connections to this broker.
The broker must be in an online state in order to invoke this operation.
Impact: ACTION
connections
- A list of Long (connectionMemberRef) or IConnectionData objects identifying the client connections to drop. IConnectionData objects are initially obtained by invoking getConnections(String) on this component. If the broker supports connectionMemberRef's (i.e. IConnectionData.getConnectionMemberRef() returns non-null) these Long values provide a more efficient means of identifying the connections.void enableAlerts(IAlert[] alerts)
Enable threshold alerts on a metric.
Impact: ACTION
Metrics that allow alert thresholds to be specified are:
broker.bytes.DeliveredPerSecond
broker.bytes.ReceivedPerSecond
broker.bytes.TopicDBSize
broker.connections.Count
broker.connections.RejectedPerMinute
broker.messages.DeliveredPerSecond
broker.messages.ReceivedPerSecond
connection.bytes.DeliveredPerSecond
connection.bytes.ReceivedPerSecond
connection.messages.DeliveredPerSecond
connection.messages.ReceivedPerSecond
queue.messages.Count
queue.messages.DeliveredPerSecond
queue.messages.ReceivedPerSecond
queue.messages.Size
alerts
- A list of alerts to enable.disableAlerts(com.sonicsw.mf.common.metrics.IAlert[])
,
getEnabledAlerts(com.sonicsw.mf.common.metrics.IMetricIdentity[])
void enableMetrics(IMetricIdentity[] ids)
Enable the given set of dynamic metrics.
Impact: ACTION
Dynamic metrics are:
broker.bytes.DeliveredPerSecond
broker.bytes.ReceivedPerSecond
broker.bytes.TopicDBSize
broker.connections.Count
broker.connections.RejectedPerMinute
broker.messages.Delivered
broker.messages.DeliveredPerSecond
broker.messages.Received
broker.messages.ReceivedPerSecond
connection.bytes.Delivered
connection.bytes.DeliveredPerSecond
connection.bytes.Received
connection.bytes.ReceivedPerSecond
connection.messages.Delivered
connection.messages.DeliveredPerSecond
connection.messages.Received
connection.messages.ReceivedPerSecond
queue.messages.Count
queue.messages.DeliveredPerSecond
queue.messages.MaxDepth
queue.messages.ReceivedPerSecond
queue.messages.Size
ids
- A list of metrics identity patterns.disableMetrics(com.sonicsw.mf.common.metrics.IMetricIdentity[])
,
getActiveMetrics(com.sonicsw.mf.common.metrics.IMetricIdentity[])
,
getEnabledMetrics(com.sonicsw.mf.common.metrics.IMetricIdentity[])
,
getMetricsData(com.sonicsw.mf.common.metrics.IMetricIdentity[], java.lang.Boolean)
,
getMetricsInfo()
,
resetMetrics()
void forceCRLUpdate(java.lang.String distributionPoint)
Force immediate refresh of the cached CRL.
Impact: ACTION
distributionPoint
- LDAP DN of the cached CRL.IMetricIdentity[] getActiveMetrics(IMetricIdentity[] ids)
Gets the the list of metrics currently active in this component.
Impact: INFO
ids
- A list of metrics identity patterns.disableMetrics(com.sonicsw.mf.common.metrics.IMetricIdentity[])
,
enableMetrics(com.sonicsw.mf.common.metrics.IMetricIdentity[])
,
getEnabledMetrics(com.sonicsw.mf.common.metrics.IMetricIdentity[])
,
getMetricsData(com.sonicsw.mf.common.metrics.IMetricIdentity[], java.lang.Boolean)
,
getMetricsInfo()
,
resetMetrics()
AttributeList getAttributes(java.lang.String[] attributeNames)
Getting multiple attribute values at once is typically more efficient than getting individual attribute values.
Readable attributes (and their datatypes) exposed by a Broker are:
BrokerName
(java.lang.String)
Classname
(java.lang.String)
Classpath
(java.lang.String)
ClusterName
(java.lang.String)
ConfigID
(java.lang.String)
DBCompactState
(java.lang.Integer)
DBCompactStateString
(java.lang.String)
LastError
(java.lang.String)
LastErrorLevel
(java.lang.Integer)
LastErrorLevelString
(java.lang.String)
MetricsCollectionInterval
(java.lang.Integer)
MetricsRefreshInterval
(java.lang.Integer)
ReleaseVersion
(java.lang.String)
RepeatMetricAlerts
(java.lang.Boolean)
ReplicationState
(java.lang.Integer)
ReplicationStateString
(java.lang.String)
ReplicationType
(java.lang.String)
RoutingNodeName
(java.lang.String)
SecurityEnabled
(java.lang.Boolean)
State
(java.lang.Short)
StateString
(java.lang.String)
TraceMask
(java.lang.Integer)
TraceMaskValues
(java.lang.String)
Uptime
(java.lang.Long)
attributeNames
- A list of the attribute names of attributes to be retrieved.
setAttributes(javax.management.AttributeList)
java.lang.String getBrokerName()
java.util.ArrayList getBrowseMessages(IBrowseToken ibt, java.lang.Integer maxMessages)
Get the next set of messages for a durable browser.
The number of messages returned may be less than or equal to the maximum number specified.
Impact: INFO
ibt
- An IBrowseToken representing an active durable browser.maxMessages
- The maximum number of messages to return.java.lang.String getClassname()
java.lang.String getClasspath()
java.lang.String getClusterName()
java.lang.String getConfigID()
java.util.ArrayList getConnectionMemberDetails(java.util.ArrayList refs)
Gets the details of the requested connection members.
The result is an ArrayList of IConnectionMemberDetails instances, one instance per requested member. The ArrayList will contain a null element for any connection members that no longer exist.
The broker must be in an online state in order to invoke this operation.
Impact: INFO
refs
- An ArrayList of Longs, each representing a connection member reference id, for which to retrieve the member's details.IConnectionMemberDetails getConnectionMemberDetails(java.lang.Long ref)
Gets the details of the requested connection member.
The result will be null if the member reference id no longer exists.
The broker must be in an online state in order to invoke this operation.
Impact: INFO
ref
- The connection member reference id for which to retrieve the member's details.java.util.ArrayList getConnections(java.lang.String prefix)
Gets the set of current connections to this broker.
The broker must be in an online state in order to invoke this operation.
Impact: INFO
prefix
- When specifed, filters the list of returned connections to those with a user name starting with, or equal to, the given filter. If not specified (null or empty string), all connected clients will be returned.java.util.ArrayList getConnectionTree(java.util.ArrayList nodes, java.lang.Integer depth)
Gets full or partial tree of connection member information. Exposes the hierachy of currently-connected connections, sessions, consumers, etc.
The result is an ArrayList of IConnectionTreeNode instances, one instance per requested node. The ArrayList will contain a null element for any connection members that no longer exist.
The broker must be in an online state in order to invoke this operation.
Impact: INFO
nodes
- An ArrayList of Longs, each representing a connection member reference id, for which to retrieve a connection sub-tree, or null to retrieve the whole tree.depth
- The maximum depth of child nodes to retrieve.java.lang.String[] getCRLList()
Return the names of all known CRLs.
Impact: INFO
java.lang.Integer getDBCompactState()
java.lang.String getDBCompactStateString()
java.util.ArrayList getDurableSubscriptions(java.lang.String user)
Gets the set of durable subscriptions for the given user.
The broker must be in an online state in order to invoke this operation.
Impact: INFO
user
- The user name for which the list of durable subscriptions will be returned.IAlert[] getEnabledAlerts(IMetricIdentity[] ids)
Get all metric threshold alerts enabled by this component.
Impact: INFO
ids
- A list of metrics identities for which to get the enabled alerts.disableAlerts(com.sonicsw.mf.common.metrics.IAlert[])
,
enableAlerts(com.sonicsw.mf.common.metrics.IAlert[])
IMetricIdentity[] getEnabledMetrics(IMetricIdentity[] ids)
Get the list of metric patterns that have been enabled for this component.
Impact: INFO
ids
- A list of metrics identities for which to get the enabled alerts.disableMetrics(com.sonicsw.mf.common.metrics.IMetricIdentity[])
,
enableMetrics(com.sonicsw.mf.common.metrics.IMetricIdentity[])
,
getActiveMetrics(com.sonicsw.mf.common.metrics.IMetricIdentity[])
,
getMetricsData(com.sonicsw.mf.common.metrics.IMetricIdentity[], java.lang.Boolean)
,
getMetricsInfo()
,
resetMetrics()
java.lang.String[] getExternalUsers(java.lang.String prefix)
This operation is used in the PASS feature. If a Broker is connected to an External Authentication Domain, then this operation can be invoked to get the list of external users cached by the broker. The broker must be in an online state in order to invoke this operation. Returns a list of external users cached by the broker.
Impact: INFO
prefix
- Not implemented/used in this release.java.util.ArrayList getGlobalQueueAdvertisements(java.lang.String prefix)
Gets the set of global queue advertisements known by this broker.
The broker must be in an online state in order to invoke this operation.
Impact: INFO
prefix
- When specifed, filters the list of returned advertisements to those with a node name starting with, or equal to, the given filter. If not specified (null or empty string), all advertisements will be returned.java.lang.String[] getInstanceMetricNames(IMetricIdentity id)
Get the instance names to which the given instance metric may be applied. An array of instance names. If there are no instances the broker will a zero length array. If the metric identity is either unknown or not that of an instance metric, then the broker will return null.
Impact: INFO
id
- The instance metric parent identity.java.lang.String getLastError()
java.lang.Integer getLastErrorLevel()
java.lang.String getLastErrorLevelString()
IMessage getMessage(IMessageHeaderToken ht)
Retrieve a message from a durable subscriber.
Impact: INFO
ht
- A IMessageHeaderToken that represents the javax.jms.Message to retrieve.java.lang.Integer getMetricsCollectionInterval()
setMetricsCollectionInterval(java.lang.Integer)
IMetricsData getMetricsData(IMetricIdentity[] ids, java.lang.Boolean returnTriggeredAlerts)
Gets metric values for a given set of metrics. If a requested metric was not enabled or is otherwise unknown, then no data for that metric will be included in the results.
Impact: INFO
ids
- A list of active metrics, either individual metrics or instances.returnTriggeredAlerts
- If true, each metric returned should include a list of triggered (exceeded) alerts for these metrics.disableMetrics(com.sonicsw.mf.common.metrics.IMetricIdentity[])
,
enableMetrics(com.sonicsw.mf.common.metrics.IMetricIdentity[])
,
getActiveMetrics(com.sonicsw.mf.common.metrics.IMetricIdentity[])
,
getEnabledMetrics(com.sonicsw.mf.common.metrics.IMetricIdentity[])
,
getMetricsInfo()
,
resetMetrics()
IMetricInfo[] getMetricsInfo()
Gets the meta-data for all metrics supported by this component.
Impact: INFO
disableMetrics(com.sonicsw.mf.common.metrics.IMetricIdentity[])
,
enableMetrics(com.sonicsw.mf.common.metrics.IMetricIdentity[])
,
getActiveMetrics(com.sonicsw.mf.common.metrics.IMetricIdentity[])
,
getEnabledMetrics(com.sonicsw.mf.common.metrics.IMetricIdentity[])
,
getMetricsData(com.sonicsw.mf.common.metrics.IMetricIdentity[], java.lang.Boolean)
,
resetMetrics()
java.lang.Integer getMetricsRefreshInterval()
setMetricsRefreshInterval(java.lang.Integer)
java.util.ArrayList getPreparedXABranches()
Gets the set of prepared XA branches.
Impact: INFO
java.util.ArrayList getQueues(java.lang.String prefix)
Gets the set of queues known by this broker.
The list will potentially include all queue types (system, temporary, global and clusterwide).
The broker must be in an online state in order to invoke this operation.
Impact: INFO
prefix
- When specifed, filters the list of returned queues to those with a queue name starting with, or equal to, the given filter. If not specified (null or empty string), all queues will be returned.java.lang.String getReleaseVersion()
java.util.ArrayList getReliableReceiveSequences()
For each remote broker, get reliable receive sequences.
Impact: INFO
java.util.ArrayList getReliableSendSequences()
For each remote broker, get reliable send sequences.
Impact: INFO
java.util.ArrayList getRemoteSubscriptionSummary(java.lang.String nodePattern)
For each remote node, get remote subscription summary information (accepts optional node name filter).
For remote routing nodes whose name starts with an optional prefix, get summary information on all propagated subscriptions. Summary information is only returned for remote routing node names that match the prefix and that are propagating subscriptions.
Equivalent to getRemoteSubscriptionSummary(nodePrefix,Boolean.FALSE)
Impact: INFO
nodePattern
- Remote routing node names match prefix. Null or zero-length string matches all remote routing nodes names.java.util.ArrayList getRemoteSubscriptionSummary(java.lang.String nodePattern, java.lang.Boolean getAllNodes)
Get all remote nodes, for each node, get remote subscription summary information (accepts optional node name filter).
For remote routing nodes whose name starts with an optional prefix, get summary information on all propagated remote subscriptions. Summary information is only returned for remote routing node names that match the prefix. Summary information will be returned for all configured remote routing nodes that match the prefix regardless of whether they are propagating subscriptions if the getAllNodes
parameter is true.
Impact: INFO
nodePattern
- Remote routing node names match prefix. Null or zero-length string matches all remote routing nodes names.getAllNodes
- If true, return subscription information for all configured routing nodes that match the node prefix including nodes that are not propagating subscriptions. If false, return subscription information for routing nodes that match the node prefix and that are propagating subscriptions.java.util.ArrayList getRemoteSubscriptionTopics(java.lang.String node, java.lang.String topicPattern)
Retrieves remote subscription topics for a given remote node and optional matching topic pattern.
For a given remote routing node name and topic pattern, retrieve propagated remote subscription topics that match the given topic pattern.
Impact: INFO
node
- Name of remote routing node that is propagating remote subscriptions.topicPattern
- Optional topic pattern in subject namespace syntax. Null, empty string and "#" match all topics.java.lang.Boolean getRepeatMetricAlerts()
setRepeatMetricAlerts(java.lang.Boolean)
java.lang.String[] getReplicationConnections()
Retrieve the names of defined replication connections.
Impact: INFO
java.lang.Integer getReplicationConnectionState(java.lang.String name)
Retrieve the current state of a replication connection.
Impact: INFO
name
- The name of the replication connection.java.lang.String getReplicationConnectionStateString(java.lang.String name)
Retrieve the name of the current state of a replication connection.
Impact: INFO
name
- The name of the replication connection.java.lang.Integer getReplicationState()
java.lang.String getReplicationStateString()
java.lang.String getReplicationType()
java.lang.String getRoutingNodeName()
java.util.ArrayList getRoutingStatistics(java.lang.String prefix)
Gets a list of nodes that have outstanding messsage to be routed. The list will include IRouteStatistic objects.
An IRouteStatistic object may exist for the local node name. This will contain information for messages bound to other brokers in a cluster.
The broker must be in an online state in order to invoke this operation.
Impact: INFO
prefix
- When specifed, filters the list of returned route statistics to those with a Remote node name starting with, or equal to, the given filter. If not specified (null or empty string), all queues will be returned.java.lang.Boolean getSecurityEnabled()
java.lang.Short getState()
getStateString()
,
IComponentState
java.lang.String getStateString()
getState()
,
IComponentState.STATE_TEXT
java.util.ArrayList getSubscribers(java.util.ArrayList refs)
Gets lists of subscribers for a batch of connections. When dealing with multiple connections this is more efficient than calling getSubscribers individually for each connection.
The result is an ArrayList of ArrayLists of ISubscriberData instances, one ArrayList per requested connection member.
With a large number of connections each with many subscribers (especially subscribers with large multi-topic destinations) it is possible the response could exceed the Management Broker's CONNECTION_TUNING_PARAMETERS.MAX_MSG_SIZE setting (default 10Mb), resulting in the request failing. In this case the Management Broker will log an EMsgTooBigException. Where the total number of subscribers is expected to be a few thousand or so, applications should use this API for appropriately-sized batches of connections rather than requesting the subscribers for all connections in a single call.
The broker must be in an online state in order to invoke this operation.
Impact: INFO
refs
- An ArrayList of Longs, each representing the connection member reference id of a connection for which the list of subscribers should be returned.java.util.ArrayList getSubscribers(java.lang.Long ref)
Gets the list of subscribers for the given connection.
The result is an ArrayList of ISubscriberData instances. An empty list is returned if the connection has no subscribers, no longer exists, or does not represent a Connection.
The broker must be in an online state in order to invoke this operation.
Impact: INFO
ref
- The connection member reference id of a connection for which the list of subscribers should be returned.java.util.ArrayList getSubscribers(java.lang.String connectId, java.lang.String userId)
Gets the list of subscribers for the given connection.
The alternative overloadings that take connection member references are preferred, provided the broker supports connection member references (SonicMQ 8.0 or later). This overloading will likely be deprecated in a future release.
Impact: INFO
connectId
- The connectId for which the list of subscribers will be returned.userId
- The userId for which the list of subscribers will be returned,java.lang.Integer getTraceMask()
setTraceMask(java.lang.Integer)
,
getTraceMaskValues()
java.lang.String getTraceMaskValues()
getTraceMask()
,
setTraceMask(java.lang.Integer)
java.lang.Long getUptime()
java.util.ArrayList getUsersWithDurableSubscriptions(java.lang.String prefix)
Gets the set of users that have durable subscriptions. The list will include both connected and disconnected durable subscribers
The broker must be in an online state in order to invoke this operation.
Impact: INFO
prefix
- When specifed, filters the list of returned users to those with a user name starting with, or equal to, the given filter. If not specified (null or empty string), all users with durable subscriptions will be returned.void initDuplicateDetectionStore(java.lang.Short action)
(Re)Initialize the duplicate transaction detection table (0 = Create, 1 = Recreate, 2 = Delete, 3 = Upgrade).
The broker must be in an offline state in order to invoke this operation.
Impact: ACTION
action
- The initialize action to be taken. Possible values are: 0 - create the duplicate detection tables, 1 - recreate the duplicate detection tables, 2 - delete the broker duplicate detection tables, 3 - upgrade from a prior version.void initMessageStore(java.lang.Short action)
(Re)Initialize the message store, recovery logs and duplicate transaction detection table (0 = Create, 1 = Recreate, 2 = Delete, 3 = Upgrade).
The broker must be in an offline state in order to invoke this operation.
In order to effect a broker name change, the broker should be stopped, have its database tables deleted, have its configured name changed, the database tables created and the broker restarted.
Impact: ACTION
action
- The initialize action to be taken. Possible values are: 0 - create the broker specific database tables, 1 - recreate the broker specific database tables, 2 - delete the broker specific database tables, 3 - upgrade from a prior version.void reconcileRemoteSubscriptions(java.util.ArrayList remoteNodes)
Bi-laterally reconciles remote subscriptions with given remote nodes.
Bi-laterally reconciles remote subscriptions with given remote nodes. Reconciliation synchronizes propagated remote subscription information between nodes.
Impact: ACTION
remoteNodes
- An array list of java.lang.String objects supplying names of remote routing nodes with which to bi-laterally reconcile remote subscriptions.java.lang.Boolean refreshSecurity(java.lang.String prefix)
This operation is used in the PASS feature. If a Broker is connected to an External Authentication Domain, then this operation can be invoked to get the list of external users cached by the broker. The broker must be in an online state in order to invoke this operation. Returns true if the operation was successful.
Impact: ACTION
prefix
- Not implemented/used in this release.void reload()
Asynchronously reload the component and restart the component if it was previously online.
Impact: ACTION
void removeMessage(IMessageHeaderToken ht)
Remove a message from a durable subscriber.
Impact: ACTION
ht
- An IMessageHeaderToken that represents the javax.jms.Message to remove.void removeNotificationListener(NotificationListener listener)
This method will remove all the information related to the given listener.
listener
- The listener object which will handle the notifications emitted by the registered MBean.addNotificationListener(javax.management.NotificationListener, javax.management.NotificationFilter, Object)
void resetMetrics()
Reset all metrics to their initial state.
Impact: ACTION
disableMetrics(com.sonicsw.mf.common.metrics.IMetricIdentity[])
,
enableMetrics(com.sonicsw.mf.common.metrics.IMetricIdentity[])
,
getActiveMetrics(com.sonicsw.mf.common.metrics.IMetricIdentity[])
,
getEnabledMetrics(com.sonicsw.mf.common.metrics.IMetricIdentity[])
,
getMetricsData(com.sonicsw.mf.common.metrics.IMetricIdentity[], java.lang.Boolean)
,
getMetricsInfo()
void rollbackPreparedXABranches(java.lang.Integer[] tIDs)
Rollback the given set of prepared XA branches.
Impact: ACTION
tIDs
- The internal TIDs of the branches to rollback.IMessageHeader searchMessage(IMessageHeaderToken ht)
Search for a message from a durable subscriber.
Impact: INFO
ht
- An IMessageHeaderToken that represents the javax.jms.Message to retrieve.AttributeList setAttributes(AttributeList attributes)
Setting multiple attribute values at once is typically more efficient than setting individual attribute values.
Settable attributes (and their datatypes) exposed by a Broker are:
MetricsCollectionInterval
(java.lang.Integer)
MetricsRefreshInterval
(java.lang.Integer)
RepeatMetricAlerts
(java.lang.Boolean)
TraceMask
(java.lang.Integer)
attributes
- A list of attributes: The identification of the attributes to be set and the values they are to be set to.
getAttributes(java.lang.String[])
void setBrowseInactiveTimeout(IBrowseToken bt, java.lang.Integer timeout)
Set the browser inactivity timeout. Default is 15 minutes. Afterthe given period of inactivity, the browser will remove any broker-side state information. Any operation on the browse token after the inactivity period will result in an exception.
Impact: INFO
bt
- An IBrowseToken that should timeout in at least the specified time.timeout
- The amount of until a inactivity timeout occurs (in seconds).void setMetricsCollectionInterval(java.lang.Integer value)
value
- Metrics collection interval (in minutes)getMetricsCollectionInterval()
void setMetricsRefreshInterval(java.lang.Integer value)
value
- Metrics refresh interval (in seconds)getMetricsRefreshInterval()
void setRepeatMetricAlerts(java.lang.Boolean value)
value
- Repeat metric alert notifications.getRepeatMetricAlerts()
void setTraceMask(java.lang.Integer value)
value
- Debug bit mask.getTraceMask()
,
getTraceMaskValues()
void start()
Start providing service.
Impact: ACTION
stop()
void startDBCompact()
Start a database compaction operation on the broker.
The broker must be offline.
Impact: ACTION
void startDBCompactWorkdir(java.lang.String workdir)
Start a database compaction, specifying an alternate location for workfiles generated during the operation. This variant is useful if the current volume hosting the message store is near capacity. The workDir parameter is relative to working directory of the container hosting the broker.
Impact: ACTION
workdir
- A relative path to be used as the location for temporary files.void stop()
Stop providing service.
Impact: ACTION
start()
void stopDBCompact()
Stop an in-progress db compact operation. If none is pending, it is a no-op.
Impact: ACTION
void syncMessageStore(java.lang.String sourceWorkingDir)
Synchronize the message store of this broker to that of its replicated peer.
Impact: ACTION
sourceWorkingDir
- The source broker's container working directory as visible to broker on which the operation is invoked.void trimMessages(IBrowseToken ibt, java.lang.Long dateTime)
When a message is persisted for a durable subscription a timestamp is added indicating the time it was placed into the database. The trimMessages method allows callers to delete all messages stored prior to (and including) the date/time value provided for a specific durable subscription.
Impact: INFO
ibt
- An IBrowseToken representing an active durable browser.dateTime
- An Long value representing the trim time.
|
Sonic Management API | |||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES All Classes | |||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |