| Methods Summary |
|---|
| public java.util.Map | getActivationConfigProperties()
HashMap result = new HashMap();
MessageDriven mdAnnotation = (MessageDriven) resolveAnnotation(MessageDriven.class);
for (ActivationConfigProperty property : mdAnnotation.activationConfig())
{
addActivationSpecProperty(result, property);
}
DefaultActivationSpecs defaultSpecsAnnotation = (DefaultActivationSpecs)resolveAnnotation(DefaultActivationSpecs.class);
if (defaultSpecsAnnotation != null)
{
for (ActivationConfigProperty property : defaultSpecsAnnotation.value())
{
addActivationSpecProperty(result, property);
}
}
return result;
|
| public javax.management.ObjectName | getJmxName()
ObjectName jmxName = null;
String jndiName = ProxyFactoryHelper.getLocalJndiName(this);
// The name must be escaped since the jndiName may be arbitrary
String name = org.jboss.ejb.Container.BASE_EJB_CONTAINER_NAME + ",jndiName=" + jndiName;
try
{
jmxName = org.jboss.mx.util.ObjectNameConverter.convert(name);
}
catch (MalformedObjectNameException e)
{
e.printStackTrace();
throw new RuntimeException("Failed to create ObjectName, msg=" + e.getMessage());
}
return jmxName;
|
| public int | getKeepAliveMillis()
String keepAlive = activationSpec.get("keepAlive");
if (keepAlive != null)
return Integer.parseInt(keepAlive);
else
return 60000;
|
| public int | getMaxMessages()
String maxMessages = activationSpec.get("maxMessages");
if (maxMessages != null)
return Integer.parseInt(maxMessages);
else
return 1;
|
| public int | getMaxPoolSize()
String maxSession = activationSpec.get("maxSession");
if (maxSession != null)
return Integer.parseInt(maxSession);
else
return 15;
|
| public java.lang.Class | getMessagingType()
if (messagingType == null)
{
MessageDriven annotation = (MessageDriven) resolveAnnotation(MessageDriven.class);
messagingType = annotation.messageListenerInterface();
if (messagingType.getName().equals(Object.class.getName()))
{
ArrayList<Class> list = ProxyFactoryHelper.getBusinessInterfaces(clazz);
if (list.size() > 1 || list.size() == 0) throw new RuntimeException("unable to determine messagingType interface for MDB");
messagingType = list.get(0);
}
}
return messagingType;
|
| public org.jboss.aop.MethodInfo | getMethodInfo(java.lang.reflect.Method method)
long hash = MethodHashing.calculateHash(method);
MethodInfo info = (MethodInfo) methodInterceptors.get(hash);
return info;
|
| public int | getMinPoolSize()
String minSession = activationSpec.get("minSession");
if (minSession != null)
return Integer.parseInt(minSession);
else
return 1;
|
| protected void | populateActivationSpec()
DefaultActivationSpecs defaultSpecs = (DefaultActivationSpecs) resolveAnnotation(DefaultActivationSpecs.class);
if (defaultSpecs != null)
{
activationSpec.merge(defaultSpecs.value());
}
MessageDriven md = (MessageDriven) resolveAnnotation(MessageDriven.class);
activationSpec.merge(md.activationConfig());
|
| public void | start()
super.start();
|
