| Methods Summary |
|---|
| public boolean | accepts(org.jboss.deployment.DeploymentInfo di)Returns true if this deployer can deploy the given DeploymentInfo.
String urlStr = di.url.toString();
return urlStr.endsWith(".aop") || urlStr.endsWith(".aop/") ||
urlStr.endsWith("-aop.xml");
|
| public void | create(org.jboss.deployment.DeploymentInfo di)Describe create method here.
ClassLoader old = Thread.currentThread().getContextClassLoader();
try
{
URL docURL = getDocUrl(di);
ClassLoader scl = getScopedClassLoader(di, docURL);
if (scl != null)
{
log.info("AOP deployment is scoped using classloader " + scl);
}
Thread.currentThread().setContextClassLoader(di.ucl);
if (!di.isXML)
{
Iterator it = ArchiveBrowser.getBrowser(di.localUrl, new ClassFileFilter());
AspectManager manager = (scl != null) ? AspectManager.instance(scl) : AspectManager.instance();
AspectAnnotationLoader loader = new AspectAnnotationLoader(manager);
loader.setClassLoader(scl);
loader.deployInputStreamIterator(it);
}
AspectXmlLoader.deployXML(docURL, scl);
Notification msg = new Notification("AOP Deploy", this, getNextNotificationSequenceNumber());
sendNotification(msg);
log.debug("Deployed AOP: " + di.url);
}
catch (Exception ex)
{
ex.printStackTrace();
throw new DeploymentException(ex);
}
finally
{
Thread.currentThread().setContextClassLoader(old);
}
|
| public void | destroy(org.jboss.deployment.DeploymentInfo di)Describe destroy method here.
|
| private java.net.URL | getDocUrl(org.jboss.deployment.DeploymentInfo di)
URL docURL = di.localUrl;
if (di.isXML == false)
docURL = di.localCl.findResource("META-INF/jboss-aop.xml");
// Validate that the descriptor was found
if (docURL == null)
throw new DeploymentException("Failed to find META-INF/jboss-aop.xml");
return docURL;
|
| private org.jboss.mx.loading.LoaderRepository | getLoaderRepositoryIfAttaching(org.jboss.deployment.DeploymentInfo di, java.net.URL docUrl)
if (di.parent == null)
{
//We are a top-level deployment, check if we are meant to be attaching to a scoped repository
//TODO Use AspectXmlLoader.loadURL once AOP is added to repository
Document doc = AspectXmlLoader.loadURL(docUrl);
Element top = doc.getDocumentElement();
NodeList children = top.getChildNodes();
int childlength = children.getLength();
for (int i = 0; i < childlength ; i++)
{
Node child = children.item(i);
if (child.getNodeType() == Node.ELEMENT_NODE)
{
Element element = (Element)child;
if (element.getTagName().equals("loader-repository"))
{
String repositoryName = null;
NodeList nestedChildren = child.getChildNodes();
int nestedChildLength = nestedChildren.getLength();
for (int j = 0 ; j < nestedChildLength ; j++)
{
Node nestedChild = nestedChildren.item(j);
if (nestedChild.getNodeType() == Node.TEXT_NODE || nestedChild.getNodeType() == Node.CDATA_SECTION_NODE)
{
repositoryName = nestedChild.getNodeValue().trim();
break;
}
}
log.info("Should attach deployment to loader repository " + repositoryName);
ObjectName on;
try
{
on = new ObjectName(repositoryName);
}
catch (MalformedObjectNameException e)
{
throw new RuntimeException("loader-repository='" + repositoryName + "' is not a valid object name", e);
}
try
{
MBeanInfo info = server.getMBeanInfo(on);
}
catch (InstanceNotFoundException e)
{
log.warn("No scoped loader repository exists with the name " + on);
}
LoaderRepository repository = (LoaderRepository)server.getAttribute(on, "Instance");
if (repository instanceof HeirarchicalLoaderRepository3)
{
return repository;
}
else
{
log.warn("Loader repository " + on + " is not a isolated loader repository. Deploying aspects in default domain.");
}
}
}
}
}
return null;
|
| protected javax.management.ObjectName | getObjectName(javax.management.MBeanServer server, javax.management.ObjectName name)
return name == null ? OBJECT_NAME : name;
|
| private java.lang.ClassLoader | getScopedClassLoader(org.jboss.deployment.DeploymentInfo di, java.net.URL docUrl)
//Scoped AOP deployments are only available when deployed as part of a scoped sar, ear etc.
//It can contain an aop.xml file, or it can be part of a .aop file
//Linking a standalone -aop.xml file onto a scoped deployment is not possible at the moment
if (JBossScopedClassLoaderHelper.isScopedClassLoader(di.ucl))
{
return di.ucl;
}
LoaderRepository attachToRepository = getLoaderRepositoryIfAttaching(di, docUrl);
if (attachToRepository != null)
{
di.ucl.setRepository(attachToRepository);
attachToRepository.addClassLoader(di.ucl);
return di.ucl;
}
return null;
|
| public void | init(org.jboss.deployment.DeploymentInfo di)Describe init method here.
try
{
if (di.watch == null)
{
// resolve the watch
if (di.url.getProtocol().equals("file"))
{
File file = new File(di.url.getFile());
// If not directory we watch the package
if (!file.isDirectory())
{
di.watch = di.url;
}
// If directory we watch the xml files
else
{
di.watch = new URL(di.url, "META-INF/jboss-aop.xml");
}
}
else
{
// We watch the top only, no directory support
di.watch = di.url;
}
}
}
catch (Exception e)
{
log.error("failed to parse AOP document: ", e);
throw new DeploymentException(e);
}
super.init(di);
|
| protected void | initializeMainDeployer()Set the suffixes and relative order attributes.
Those are read at subdeployer registration time by the MainDeployer
to update its SuffixOrder list.
setSuffixes(new String[]{".aop", "-aop.xml"});
setRelativeOrder(100);
|
| public void | start(org.jboss.deployment.DeploymentInfo di)The start method starts all the mbeans in this DeploymentInfo..
|
| protected void | startService()The startService method gets the mbeanProxies for MainDeployer
and ServiceController, used elsewhere.
super.startService();
|
| public void | stop(org.jboss.deployment.DeploymentInfo di)Undeploys the package at the url string specified. This will: Undeploy
packages depending on this one. Stop, destroy, and unregister all the
specified mbeans Unload this package and packages this package deployed
via the classpath tag. Keep track of packages depending on this one that
we undeployed so that they can be redeployed should this one be
redeployed.
// Can happen on shutdown with a nested .aop module
// which is first stopped then undeployed.
if (di.state != DeploymentState.STARTED)
{
log.debug("Ignoring request to stop '" + di.url + "', current state: " + di.state);
return;
}
log.debug("undeploying document " + di.url);
ClassLoader old = Thread.currentThread().getContextClassLoader();
try
{
Thread.currentThread().setContextClassLoader(di.ucl);
if (!di.isXML)
{
Iterator it = ArchiveBrowser.getBrowser(di.localUrl, new ClassFileFilter());
AspectAnnotationLoader loader = new AspectAnnotationLoader(AspectManager.instance());
loader.undeployInputStreamIterator(it);
}
URL docURL = getDocUrl(di);
//long start = System.currentTimeMillis();
AspectXmlLoader.undeployXML(docURL);
AspectManager.instance().unregisterClassLoader(di.ucl);
/*
System.out.println("************************");
System.out.println("undeploy took: " + (System.currentTimeMillis() - start));
System.out.println("************************");
*/
Notification msg = new Notification("AOP Undeploy", this, getNextNotificationSequenceNumber());
sendNotification(msg);
}
catch (Exception ex)
{
log.error("failed to stop", ex);
}
finally
{
Thread.currentThread().setContextClassLoader(old);
}
|
