org.fusesource.web.console.server
Class LocalAgentServiceImpl

java.lang.Object
  org.fusesource.web.console.server.LocalAgentServiceImpl

All Implemented Interfaces:

com.google.gwt.user.client.rpc.RemoteService, java.io.Serializable, AgentService

public class LocalAgentServiceImpl
extends java.lang.Object
implements AgentService, java.io.Serializable

Version:

$Revision: 1.1 $

See Also:

Serialized Form

Constructor Summary

LocalAgentServiceImpl()

Method Summary

void	copyMessages(java.lang.String objectName, java.util.List<java.lang.String> messageIDList, java.lang.String destinationQueueName)
protected DestinationMessage	createDestinationMessage(javax.management.openmbean.CompositeData compositeData)
protected MBeanAttribute	createMBeanAttribute(javax.management.MBeanAttributeInfo info, java.lang.Object value)
protected MBeanOperation	createMBeanOperation(javax.management.MBeanOperationInfo info)
protected java.lang.String[]	createTreePath(javax.management.ObjectName objectName)
void	deleteMessages(java.lang.String objectName, java.util.List<java.lang.String> messageIDList)
protected java.lang.Object	doInvoke(java.lang.String name, java.lang.String operationName, java.lang.Object[] params, java.lang.String[] signature)
protected javax.management.MBeanServer	findMBeanServer()
MBeanAttribute[]	getAttributes(java.lang.String objectName)
MBeanAttribute[][]	getAttributes(java.lang.String[] objectNames)
MBeanAttribute[][]	getAttributes(java.lang.String[] objectNames, MBeanAttribute[] attributes)
org.apache.activemq.web.BrokerFacade	getBrokerFacade()
org.apache.activemq.broker.BrokerService	getBrokerService()
java.util.List<DestinationMessage>	getDestinationMessages(java.lang.String destinationName)
LogResults	getLogEvents(LogFilter filter)
LogFile[]	getLogFiles()
SearchResults	getLogs(java.lang.String file, java.lang.String level, int maxResult, boolean includeStacks)
MBeanAttribute[]	getMBeanInfo(javax.management.ObjectName objectName)
MBeanName[]	getMBeans()
MBeanName[]	getMBeans(java.lang.String filter, java.util.List<java.lang.String> folderPaths)
javax.management.MBeanServer	getMbeanServer()
MBeanOperation[]	getOperations(java.lang.String name)
protected org.apache.activemq.broker.jmx.QueueViewMBean	getQueueMBean(java.lang.String objectName)
protected void	handleException(java.lang.Exception e)
void	installOsgiBundle(java.lang.String url)
java.lang.String	invoke(java.lang.String name, java.lang.String operationName, java.lang.String[] params, java.lang.String[] signature)
OsgiBundle[]	listOsgiBundle()
protected void	logFailed(java.lang.Throwable e)
void	moveMessages(java.lang.String objectName, java.util.List<java.lang.String> messageIDList, java.lang.String destinationQueueName)
boolean	moveMessageTo(java.lang.String messageId, java.lang.String destinationSource, java.lang.String targetDestination)
static AgentServiceAsync	newInstance()
int	retryMessages(java.lang.String objectName, java.util.List<java.lang.String> messageIDList)
java.lang.String	sendMessage(java.lang.String destinationName, DestinationMessage message) Sends a text message to the given destination MBean name with the given headers and body
void	setBrokerService(org.apache.activemq.broker.BrokerService brokerService)
void	setMbeanServer(javax.management.MBeanServer mbeanServer)
void	startOsgiBundle(long id)
void	stopOsgiBundle(long id)
protected java.lang.String	toString(java.lang.Object value)
void	uninstallOsgiBundle(long id)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

LocalAgentServiceImpl

public LocalAgentServiceImpl()

Method Detail

newInstance

public static AgentServiceAsync newInstance()

getMBeans

public MBeanName[] getMBeans()

Specified by:

getMBeans in interface AgentService

getMBeans

public MBeanName[] getMBeans(java.lang.String filter,
                             java.util.List<java.lang.String> folderPaths)

Specified by:

getMBeans in interface AgentService

createTreePath

protected java.lang.String[] createTreePath(javax.management.ObjectName objectName)

getAttributes

public MBeanAttribute[] getAttributes(java.lang.String objectName)

Specified by:

getAttributes in interface AgentService

getAttributes

public MBeanAttribute[][] getAttributes(java.lang.String[] objectNames)

Specified by:

getAttributes in interface AgentService

getAttributes

public MBeanAttribute[][] getAttributes(java.lang.String[] objectNames,
                                        MBeanAttribute[] attributes)

Specified by:

getAttributes in interface AgentService

getMBeanInfo

public MBeanAttribute[] getMBeanInfo(javax.management.ObjectName objectName)
                              throws javax.management.ReflectionException,
                                     javax.management.InstanceNotFoundException,
                                     javax.management.IntrospectionException

Throws:

javax.management.ReflectionException

javax.management.InstanceNotFoundException

javax.management.IntrospectionException

getOperations

public MBeanOperation[] getOperations(java.lang.String name)

Specified by:

getOperations in interface AgentService

sendMessage

public java.lang.String sendMessage(java.lang.String destinationName,
                                    DestinationMessage message)
                             throws java.lang.Exception

Sends a text message to the given destination MBean name with the given headers and body

Specified by:

sendMessage in interface AgentService

Throws:

java.lang.Exception

invoke

public java.lang.String invoke(java.lang.String name,
                               java.lang.String operationName,
                               java.lang.String[] params,
                               java.lang.String[] signature)
                        throws java.lang.Exception

Specified by:

invoke in interface AgentService

Throws:

java.lang.Exception

getLogEvents

public LogResults getLogEvents(LogFilter filter)

Specified by:

getLogEvents in interface AgentService

doInvoke

protected java.lang.Object doInvoke(java.lang.String name,
                                    java.lang.String operationName,
                                    java.lang.Object[] params,
                                    java.lang.String[] signature)
                             throws java.lang.Exception

Throws:

java.lang.Exception

logFailed

protected void logFailed(java.lang.Throwable e)

getMbeanServer

public javax.management.MBeanServer getMbeanServer()

getBrokerFacade

public org.apache.activemq.web.BrokerFacade getBrokerFacade()

getBrokerService

public org.apache.activemq.broker.BrokerService getBrokerService()

setBrokerService

public void setBrokerService(org.apache.activemq.broker.BrokerService brokerService)

setMbeanServer

public void setMbeanServer(javax.management.MBeanServer mbeanServer)

createMBeanAttribute

protected MBeanAttribute createMBeanAttribute(javax.management.MBeanAttributeInfo info,
                                              java.lang.Object value)

findMBeanServer

protected javax.management.MBeanServer findMBeanServer()

createMBeanOperation

protected MBeanOperation createMBeanOperation(javax.management.MBeanOperationInfo info)

toString

protected java.lang.String toString(java.lang.Object value)

getDestinationMessages

public java.util.List<DestinationMessage> getDestinationMessages(java.lang.String destinationName)

Specified by:

getDestinationMessages in interface AgentService

handleException

protected void handleException(java.lang.Exception e)
                        throws java.lang.Exception

Throws:

java.lang.Exception

deleteMessages

public void deleteMessages(java.lang.String objectName,
                           java.util.List<java.lang.String> messageIDList)
                    throws java.lang.Exception

Specified by:

deleteMessages in interface AgentService

Throws:

java.lang.Exception

copyMessages

public void copyMessages(java.lang.String objectName,
                         java.util.List<java.lang.String> messageIDList,
                         java.lang.String destinationQueueName)
                  throws java.lang.Exception

Specified by:

copyMessages in interface AgentService

Throws:

java.lang.Exception

moveMessages

public void moveMessages(java.lang.String objectName,
                         java.util.List<java.lang.String> messageIDList,
                         java.lang.String destinationQueueName)
                  throws java.lang.Exception

Specified by:

moveMessages in interface AgentService

Throws:

java.lang.Exception

retryMessages

public int retryMessages(java.lang.String objectName,
                         java.util.List<java.lang.String> messageIDList)
                  throws java.lang.Exception

Specified by:

retryMessages in interface AgentService

Throws:

java.lang.Exception

getQueueMBean

protected org.apache.activemq.broker.jmx.QueueViewMBean getQueueMBean(java.lang.String objectName)
                                                               throws java.lang.Exception

Throws:

java.lang.Exception

createDestinationMessage

protected DestinationMessage createDestinationMessage(javax.management.openmbean.CompositeData compositeData)

getLogs

public SearchResults getLogs(java.lang.String file,
                             java.lang.String level,
                             int maxResult,
                             boolean includeStacks)

Specified by:

getLogs in interface AgentService

getLogFiles

public LogFile[] getLogFiles()

Specified by:

getLogFiles in interface AgentService

installOsgiBundle

public void installOsgiBundle(java.lang.String url)
                       throws AgentServiceException

Specified by:

installOsgiBundle in interface AgentService

Throws:

AgentServiceException

listOsgiBundle

public OsgiBundle[] listOsgiBundle()
                            throws AgentServiceException

Specified by:

listOsgiBundle in interface AgentService

Throws:

AgentServiceException

startOsgiBundle

public void startOsgiBundle(long id)
                     throws AgentServiceException

Specified by:

startOsgiBundle in interface AgentService

Throws:

AgentServiceException

stopOsgiBundle

public void stopOsgiBundle(long id)
                    throws AgentServiceException

Specified by:

stopOsgiBundle in interface AgentService

Throws:

AgentServiceException

uninstallOsgiBundle

public void uninstallOsgiBundle(long id)
                         throws AgentServiceException

Specified by:

uninstallOsgiBundle in interface AgentService

Throws:

AgentServiceException

moveMessageTo

public boolean moveMessageTo(java.lang.String messageId,
                             java.lang.String destinationSource,
                             java.lang.String targetDestination)

Specified by:

moveMessageTo in interface AgentService