| Methods Summary |
|---|
| public boolean | accepts(org.jboss.deployment.DeploymentInfo di)Returns true if this deployer can deploy the given DeploymentInfo.
String urlStr = di.url.getFile();
if (urlStr.endsWith(".ejb3") || urlStr.endsWith(".ejb3/") || urlStr.endsWith(".par") || urlStr.endsWith(".par/"))
{
return true;
}
// To be accepted the deployment's root name must end in jar
if (!urlStr.endsWith(".jar") && !urlStr.endsWith(".jar/"))
{
return false;
}
if (ignoredJarsSet.contains(di.shortName))
{
return false;
}
if (has30EjbJarXml(di)) return true;
if (!deployEjb3ExtensionOnly)
{
if (hasPersistenceXml(di)) return true;
if (hasOnlyJbossXml(di)) return true;
if (hasEjbAnnotation(di)) return true;
}
return false;
|
| public synchronized void | create(org.jboss.deployment.DeploymentInfo di)
log.debug("create, " + di.shortName);
try
{
// initialize the annotations loader
URL loaderURL = (di.localUrl != null ? di.localUrl : di.url);
di.annotationsCl = new URLClassLoader(new URL[]{loaderURL}, di.ucl);
Ejb3Module ejbModule = new Ejb3Module(di);
String name = jmxNames.get(di);
if (name == null)
name = Ejb3Module.BASE_EJB3_JMX_NAME + ",module=" + di.shortName;
// Build an escaped JMX name including deployment shortname
ObjectName ejbModuleName = ObjectNameConverter.convert(name);
// Check that the name is not registered
if (server.isRegistered(ejbModuleName) == true)
{
log.debug("The EJBModule name: " + ejbModuleName
+ "is already registered, adding uid=" + System.identityHashCode(ejbModule));
name = name + ",uid=" + System.identityHashCode(ejbModule);
ejbModuleName = ObjectNameConverter.convert(name);
}
server.registerMBean(ejbModule, ejbModuleName);
di.deployedObject = ejbModuleName;
log.debug("Deploying: " + di.url);
// Invoke the create life cycle method
serviceController.create(di.deployedObject);
}
catch (Exception e)
{
throw new DeploymentException("Error during create of EjbModule: "
+ di.url, e);
}
super.create(di);
|
| protected void | createService()Overriden to set the hibernate.bytecode.provider from the
URL propsUrl = this.getClass().getClassLoader().getResource("META-INF/persistence.properties");
DefaultProperties = new Properties();
DefaultProperties.load(propsUrl.openStream());
log.debug("Default persistence.properties: " + DefaultProperties);
/* Current hack to establish the hibernate bytecode provider from the
externalized persistence.properties
*/
String bcprovider = DefaultProperties.getProperty("hibernate.bytecode.provider", "javassist");
System.setProperty("hibernate.bytecode.provider", bcprovider);
super.createService();
|
| public void | destroy(org.jboss.deployment.DeploymentInfo di)
// FIXME: If the put() is obsolete above, this is obsolete, too
deployments.remove(di.url);
try
{
serviceController.destroy(di.deployedObject);
serviceController.remove(di.deployedObject);
}
catch (Exception e)
{
throw new DeploymentException("problem destroying ejb module: " +
di.url, e);
}
jmxNames.remove(di);
super.destroy(di);
|
| public java.util.Properties | getDefaultProperties()
return DefaultProperties;
|
| public boolean | getDeployEjb3ExtensionOnly()
return deployEjb3ExtensionOnly;
|
| public static boolean | has30EjbJarXml(org.jboss.deployment.DeploymentInfo di)
if (!hasFile(di, "META-INF/ejb-jar.xml")) return false;
InputStream ddStream = di.localCl.getResourceAsStream("META-INF/ejb-jar.xml");
return has30EjbJarXml(ddStream);
|
| public static boolean | has30EjbJarXml(java.io.InputStream ddStream)
try
{
// look for version="3.0" in the file
byte[] stringToFind = "version=\"3.0\"".getBytes();
InputStreamReader reader = new InputStreamReader(ddStream);
try
{
int idx = 0;
int len = stringToFind.length;
while (reader.ready())
{
int read = reader.read();
if (read == stringToFind[idx])
{
idx++;
if (idx == len)
{
return true;
}
}
else
{
idx = 0;
}
}
}
finally
{
try
{
reader.close();
ddStream.close();
}
catch (IOException ignored)
{
}
}
}
catch (Exception ignore)
{
}
return false;
|
| public boolean | hasEjbAnnotation(org.jboss.deployment.DeploymentInfo di)
Iterator it = ArchiveBrowser.getBrowser(di.localUrl, new ClassFileFilter());
try
{
while (it.hasNext())
{
InputStream stream = (InputStream) it.next();
DataInputStream dstream = new DataInputStream(new BufferedInputStream(stream));
ClassFile cf = null;
try
{
cf = new ClassFile(dstream);
AnnotationsAttribute visible = (AnnotationsAttribute) cf.getAttribute(AnnotationsAttribute.visibleTag);
if (visible != null)
{
if (EJB3Util.isStateless(visible)) return true;
if (EJB3Util.isStatefulSession(visible)) return true;
if (EJB3Util.isMessageDriven(visible)) return true;
if (EJB3Util.isConsumer(visible)) return true;
if (EJB3Util.isService(visible)) return true;
}
}
finally
{
dstream.close();
stream.close();
}
}
}
catch (IOException e)
{
throw new RuntimeException(e);
}
return false;
|
| public static boolean | hasFile(org.jboss.deployment.DeploymentInfo di, java.lang.String filePath)
String urlStr = di.url.getFile();
try
{
URL dd = di.localCl.findResource(filePath);
if (dd != null)
{
// If the DD url is not a subset of the urlStr then this is coming
// from a jar referenced by the deployment jar manifest and the
// this deployment jar it should not be treated as persistence
if (di.localUrl != null)
{
urlStr = di.localUrl.toString();
}
String ddStr = dd.toString();
if (ddStr.indexOf(urlStr) >= 0)
{
return true;
}
}
}
catch (Exception ignore)
{
}
return false;
|
| protected boolean | hasOnlyJbossXml(org.jboss.deployment.DeploymentInfo di)
if (!hasFile(di, "META-INF/ejb-jar.xml")
&& hasFile(di, "META-INF/jboss.xml"))
{
return true;
}
return false;
|
| public static boolean | hasPersistenceXml(org.jboss.deployment.DeploymentInfo di)
return hasFile(di, "META-INF/persistence.xml");
|
| public void | init(org.jboss.deployment.DeploymentInfo di)
try
{
if( di.url.getProtocol().equalsIgnoreCase("file") )
{
File file = new File(di.url.getFile());
if( !file.isDirectory() )
{
// If not directory we watch the package
di.watch = di.url;
}
else
{
// If directory we watch the xml files
di.watch = new URL(di.url, "META-INF/ejb-jar.xml");
}
}
else
{
// We watch the top only, no directory support
di.watch = di.url;
}
XmlFileLoader xfl = new XmlFileLoader();
InputStream in = di.localCl.getResourceAsStream("META-INF/jboss.xml");
if( in != null )
{
try
{
Element jboss = xfl.getDocument(in, "META-INF/jboss.xml").getDocumentElement();
// Check for a ejb level class loading config
Element loader = MetaData.getOptionalChild(jboss, "loader-repository");
if( loader != null )
{
LoaderRepositoryFactory.LoaderRepositoryConfig config =
LoaderRepositoryFactory.parseRepositoryConfig(loader);
di.setRepositoryInfo(config);
}
Element jmxNameElement = MetaData.getOptionalChild(jboss, "jmx-name");
if (jmxNameElement != null)
{
jmxNames.put(di, jmxNameElement.getChildNodes().item(0).getNodeValue());
}
}
finally
{
in.close();
}
}
}
catch (Exception e)
{
if (e instanceof DeploymentException)
{
throw (DeploymentException) e;
}
throw new DeploymentException( "failed to initialize", e );
}
// invoke super-class initialization
super.init(di);
|
| public static void | initializeJavaComp(javax.naming.InitialContext iniCtx)
RefAddr refAddr = new StringRefAddr("nns", "ENC-EJB3");
Reference envRef = new Reference("javax.naming.Context", refAddr, ThreadLocalENCFactory.class.getName(), null);
Context ctx = (Context) iniCtx.lookup("java:");
ctx.rebind("comp.ejb3", envRef);
multiplexJNDI(ctx);
|
| private static void | multiplexJNDI(javax.naming.Context ctx)
log.info("Starting java:comp multiplexer");
// rename to something SimpleMultiPlexer knows.
// (doesn't work, because rename starts with a lookup and thus resolves
// to a enc context bound to the current class loader).
//ctx.rename("comp", "comp.original");
{
ctx.unbind("comp");
// copied out of NamingBeanImpl
RefAddr refAddr = new StringRefAddr("nns", "ENC");
Reference envRef = new Reference("javax.namingMain.Context", refAddr, ENCFactory.class.getName(), null);
ctx.bind("comp.original", envRef);
}
{
RefAddr refAddr = new StringRefAddr("nns", "ENC-MULTIPLEXER");
Reference ref = new Reference("javax.naming.Context", refAddr, SimpleMultiplexer.class.getName(), null);
ctx.bind("comp", ref);
}
|
| public void | setDeployEjb3ExtensionOnly(boolean deployEjb3ExtensionOnly)
this.deployEjb3ExtensionOnly = deployEjb3ExtensionOnly;
|
| public void | setJarsIgnoredForScanning(JarsIgnoredForScanningMBean mbean)
ignoredJarsSet = mbean.getIgnoredJarsSet();
|
| public synchronized void | start(org.jboss.deployment.DeploymentInfo di)
try
{
// Start application
log.debug("start application, deploymentInfo: " + di +
", short name: " + di.shortName +
", parent short name: " +
(di.parent == null ? "null" : di.parent.shortName));
serviceController.start(di.deployedObject);
log.info("Deployed: " + di.url); // Register deployment. Use the application name in the hashtable
// FIXME: this is obsolete!! (really?!)
deployments.put(di.url, di);
}
catch (Exception e)
{
stop(di);
destroy(di);
throw new DeploymentException("Could not deploy " + di.url, e);
}
super.start(di);
|
| protected void | startService()Get a reference to the ServiceController
serviceController = (ServiceControllerMBean)
MBeanProxyExt.create(ServiceControllerMBean.class,
ServiceControllerMBean.OBJECT_NAME, server);
// make a proxy to myself, so that calls from the MainDeployer
// can go through the MBeanServer, so interceptors can be added
thisProxy = (SubDeployer)
MBeanProxyExt.create(SubDeployer.class, super.getServiceName(), super.getServer());
// register with the main deployer
mainDeployer.addDeployer(thisProxy);
// todo remove when we merge older model of ENC
InitialContext iniCtx = new InitialContext();
initializeJavaComp(iniCtx);
|
| public void | stop(org.jboss.deployment.DeploymentInfo di)
log.debug("init, " + di.shortName);
try
{
serviceController.stop(di.deployedObject);
}
catch (Exception e)
{
throw new DeploymentException("problem stopping ejb module: " +
di.url, e);
}
super.stop(di);
|
| protected void | stopService()Implements the template method in superclass. This method stops all the
applications in this server.
for (Iterator modules = deployments.values().iterator();
modules.hasNext();)
{
DeploymentInfo di = (DeploymentInfo) modules.next();
stop(di);
} // avoid concurrent modification exception
for (Iterator modules = new ArrayList(deployments.values()).iterator();
modules.hasNext();)
{
DeploymentInfo di = (DeploymentInfo) modules.next();
destroy(di);
}
deployments.clear();
// deregister with MainDeployer
mainDeployer.removeDeployer(thisProxy);
serviceController = null;
|
