[jboss-cvs] JBossAS SVN: r72277 - projects/ejb3/trunk/core/src/main/java/org/jboss/ejb3/mdb.
jboss-cvs-commits at lists.jboss.org
jboss-cvs-commits at lists.jboss.org
Wed Apr 16 08:38:32 EDT 2008
Author: wolfc
Date: 2008-04-16 08:38:31 -0400 (Wed, 16 Apr 2008)
New Revision: 72277
Modified:
projects/ejb3/trunk/core/src/main/java/org/jboss/ejb3/mdb/MessagingContainer.java
Log:
EJBTHREE-1293: cleaned up old (/unused) queue creation code
Modified: projects/ejb3/trunk/core/src/main/java/org/jboss/ejb3/mdb/MessagingContainer.java
===================================================================
--- projects/ejb3/trunk/core/src/main/java/org/jboss/ejb3/mdb/MessagingContainer.java 2008-04-16 12:38:11 UTC (rev 72276)
+++ projects/ejb3/trunk/core/src/main/java/org/jboss/ejb3/mdb/MessagingContainer.java 2008-04-16 12:38:31 UTC (rev 72277)
@@ -177,11 +177,6 @@
protected void innerStart() throws Exception
{
log.debug("Initializing");
-
- /* See forum thread: http://www.jboss.com/index.html?module=bb&op=viewtopic&p=4032454#4032454
- if (getResourceAdaptorName().equals(JMS_ADAPTOR))
- jmsCreate();
- */
}
public ObjectName getJmxName()
@@ -360,51 +355,6 @@
return property.getValue();
return null;
}
-
- protected void jmsCreate() throws Exception
- {
- // Get the JMS provider
- // todo get rid of server module dependency
- JMSProviderAdapter adapter = getJMSProviderAdapter();
- log.debug("Provider adapter: " + adapter);
-
- // Connect to the JNDI server and get a reference to root context
- Context context = adapter.getInitialContext();
- log.debug("context: " + context);
-
- // if we can't get the root context then exit with an exception
- if (context == null)
- {
- throw new RuntimeException("Failed to get the root context");
- }
-
- // Unfortunately the destination is optional, so if we do not have one
- // here we have to look it up if we have a destinationJNDI, else give it
- // a default.
- String destinationType = getDestinationType();
- if (destinationType == null)
- {
- log.warn("No message-driven-destination given; using; guessing type");
- destinationType = getDestinationType(context, getDestination());
- }
-
- if ("javax.jms.Topic".equals(destinationType))
- {
- innerCreateTopic(context);
-
- }
- else if ("javax.jms.Queue".equals(destinationType))
- {
- innerCreateQueue(context);
-
- }
- else
- throw new DeploymentException("Unknown destination-type " + destinationType);
-
- log.debug("Initialized with config " + toString());
-
- context.close();
- }
protected void innerCreateQueue(Context context)
throws Exception
More information about the jboss-cvs-commits
mailing list