|
ActiveMQ example source code file (BrokerViewMBean.java)
The ActiveMQ BrokerViewMBean.java source code/** * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package org.apache.activemq.broker.jmx; import javax.management.ObjectName; import org.apache.activemq.Service; /** * @author David Martin Clavo david(dot)martin(dot)clavo(at)gmail.com (for the reloadLog4jProperties method) * */ public interface BrokerViewMBean extends Service { /** * @return The unique id of the broker. */ @MBeanInfo("The unique id of the broker.") String getBrokerId(); /** * @return The name of the broker. */ @MBeanInfo("The name of the broker.") String getBrokerName(); /** * @return The name of the broker. */ @MBeanInfo("The version of the broker.") String getBrokerVersion(); /** * The Broker will fush it's caches so that the garbage collector can * recalaim more memory. * * @throws Exception */ @MBeanInfo("Runs the Garbage Collector.") void gc() throws Exception; @MBeanInfo("Reset all broker statistics.") void resetStatistics(); @MBeanInfo("Enable broker statistics.") void enableStatistics(); @MBeanInfo("Disable broker statistics.") void disableStatistics(); @MBeanInfo("Broker statistics enabled.") boolean isStatisticsEnabled(); @MBeanInfo("Number of messages that have been sent to the broker.") long getTotalEnqueueCount(); @MBeanInfo("Number of messages that have been acknowledged on the broker.") long getTotalDequeueCount(); @MBeanInfo("Number of message consumers subscribed to destinations on the broker.") long getTotalConsumerCount(); @MBeanInfo("Number of unacknowledged messages on the broker.") long getTotalMessageCount(); @MBeanInfo("Percent of memory limit used.") int getMemoryPercentUsage(); @MBeanInfo("Memory limit, in bytes, used for holding undelivered messages before paging to temporary storage.") long getMemoryLimit(); void setMemoryLimit(@MBeanInfo("bytes") long limit); @MBeanInfo("Percent of store limit used.") int getStorePercentUsage(); @MBeanInfo("Disk limit, in bytes, used for persistent messages before producers are blocked.") long getStoreLimit(); void setStoreLimit(@MBeanInfo("bytes") long limit); @MBeanInfo("Percent of temp limit used.") int getTempPercentUsage(); @MBeanInfo("Disk limit, in bytes, used for non-persistent messages and temporary date before producers are blocked.") long getTempLimit(); void setTempLimit(@MBeanInfo("bytes") long limit); @MBeanInfo("Messages are synchronized to disk.") boolean isPersistent(); @MBeanInfo("Slave broker.") boolean isSlave(); /** * Shuts down the JVM. * * @param exitCode the exit code that will be reported by the JVM process * when it exits. */ @MBeanInfo("Shuts down the JVM.") void terminateJVM(@MBeanInfo("exitCode") int exitCode); /** * Stop the broker and all it's components. */ @MBeanInfo("Stop the broker and all its components.") void stop() throws Exception; @MBeanInfo("Poll for queues matching queueName are empty before stopping") void stopGracefully(String connectorName, String queueName, long timeout, long pollInterval) throws Exception; @MBeanInfo("Topics (broadcasted 'queues'); generally system information.") ObjectName[] getTopics(); @MBeanInfo("Standard Queues containing AIE messages.") ObjectName[] getQueues(); @MBeanInfo("Temporary Topics; generally unused.") ObjectName[] getTemporaryTopics(); @MBeanInfo("Temporary Queues; generally temporary message response holders.") ObjectName[] getTemporaryQueues(); @MBeanInfo("Topic Subscribers") ObjectName[] getTopicSubscribers(); @MBeanInfo("Durable (persistent) topic subscribers") ObjectName[] getDurableTopicSubscribers(); @MBeanInfo("Inactive (disconnected persistent) topic subscribers") ObjectName[] getInactiveDurableTopicSubscribers(); @MBeanInfo("Queue Subscribers.") ObjectName[] getQueueSubscribers(); @MBeanInfo("Temporary Topic Subscribers.") ObjectName[] getTemporaryTopicSubscribers(); @MBeanInfo("Temporary Queue Subscribers.") ObjectName[] getTemporaryQueueSubscribers(); @MBeanInfo("Adds a Connector to the broker.") String addConnector(@MBeanInfo("discoveryAddress") String discoveryAddress) throws Exception; @MBeanInfo("Adds a Network Connector to the broker.") String addNetworkConnector(@MBeanInfo("discoveryAddress") String discoveryAddress) throws Exception; @MBeanInfo("Removes a Connector from the broker.") boolean removeConnector(@MBeanInfo("connectorName") String connectorName) throws Exception; @MBeanInfo("Removes a Network Connector from the broker.") boolean removeNetworkConnector(@MBeanInfo("connectorName") String connectorName) throws Exception; /** * Adds a Topic destination to the broker. * * @param name The name of the Topic * @throws Exception */ @MBeanInfo("Adds a Topic destination to the broker.") void addTopic(@MBeanInfo("name") String name) throws Exception; /** * Adds a Queue destination to the broker. * * @param name The name of the Queue * @throws Exception */ @MBeanInfo("Adds a Queue destination to the broker.") void addQueue(@MBeanInfo("name") String name) throws Exception; /** * Removes a Topic destination from the broker. * * @param name The name of the Topic * @throws Exception */ @MBeanInfo("Removes a Topic destination from the broker.") void removeTopic(@MBeanInfo("name") String name) throws Exception; /** * Removes a Queue destination from the broker. * * @param name The name of the Queue * @throws Exception */ @MBeanInfo("Removes a Queue destination from the broker.") void removeQueue(@MBeanInfo("name") String name) throws Exception; /** * Creates a new durable topic subscriber * * @param clientId the JMS client ID * @param subscriberName the durable subscriber name * @param topicName the name of the topic to subscribe to * @param selector a selector or null * @return the object name of the MBean registered in JMX */ @MBeanInfo(value="Creates a new durable topic subscriber.") ObjectName createDurableSubscriber(@MBeanInfo("clientId") String clientId, @MBeanInfo("subscriberName") String subscriberName, @MBeanInfo("topicName") String topicName, @MBeanInfo("selector") String selector) throws Exception; /** * Destroys a durable subscriber * * @param clientId the JMS client ID * @param subscriberName the durable subscriber name */ @MBeanInfo(value="Destroys a durable subscriber.") void destroyDurableSubscriber(@MBeanInfo("clientId") String clientId, @MBeanInfo("subscriberName") String subscriberName) throws Exception; /** * Reloads log4j.properties from the classpath. * This methods calls org.apache.activemq.transport.TransportLoggerControl.reloadLog4jProperties * @throws Throwable */ @MBeanInfo(value="Reloads log4j.properties from the classpath.") public void reloadLog4jProperties() throws Throwable; @MBeanInfo("The url of the openwire connector") String getOpenWireURL(); @MBeanInfo("The url of the stomp connector") String getStompURL(); @MBeanInfo("The url of the SSL connector") String getSslURL(); @MBeanInfo("The url of the Stomp SSL connector") String getStompSslURL(); @MBeanInfo("The url of the VM connector") String getVMURL(); @MBeanInfo("The location of the data directory") public String getDataDirectory(); @MBeanInfo("JMSJobScheduler") ObjectName getJMSJobScheduler(); } Other ActiveMQ examples (source code examples)Here is a short list of links related to this ActiveMQ BrokerViewMBean.java source code file: |
... this post is sponsored by my books ... | |
#1 New Release! |
FP Best Seller |
Copyright 1998-2021 Alvin Alexander, alvinalexander.com
All Rights Reserved.
A percentage of advertising revenue from
pages under the /java/jwarehouse
URI on this website is
paid back to open source projects.