You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@servicemix.apache.org by gn...@apache.org on 2007/03/05 10:08:12 UTC
svn commit: r514613 -
/incubator/servicemix/trunk/common/servicemix-common/src/main/java/org/apache/servicemix/common/BaseComponent.java
Author: gnodet
Date: Mon Mar 5 01:08:11 2007
New Revision: 514613
URL: http://svn.apache.org/viewvc?view=rev&rev=514613
Log:
Fix BaseComponent to implement the added method
Modified:
incubator/servicemix/trunk/common/servicemix-common/src/main/java/org/apache/servicemix/common/BaseComponent.java
Modified: incubator/servicemix/trunk/common/servicemix-common/src/main/java/org/apache/servicemix/common/BaseComponent.java
URL: http://svn.apache.org/viewvc/incubator/servicemix/trunk/common/servicemix-common/src/main/java/org/apache/servicemix/common/BaseComponent.java?view=diff&rev=514613&r1=514612&r2=514613
==============================================================================
--- incubator/servicemix/trunk/common/servicemix-common/src/main/java/org/apache/servicemix/common/BaseComponent.java (original)
+++ incubator/servicemix/trunk/common/servicemix-common/src/main/java/org/apache/servicemix/common/BaseComponent.java Mon Mar 5 01:08:11 2007
@@ -151,7 +151,7 @@
protected BaseServiceUnitManager createServiceUnitManager() {
return null;
}
-
+
protected Registry createRegistry() {
return new Registry(this);
}
@@ -159,14 +159,14 @@
public ComponentContext getComponentContext() {
return lifeCycle.getContext();
}
-
+
public String getComponentName() {
if (getComponentContext() == null) {
return "Component (" + getClass().getName() + ") not yet initialized";
}
return getComponentContext().getComponentName();
}
-
+
/**
* @return Returns the logger.
*/
@@ -180,7 +180,7 @@
public Registry getRegistry() {
return registry;
}
-
+
/**
* Shortcut to retrieve this component's executor.
*
@@ -194,8 +194,12 @@
lifeCycle.sendConsumerExchange(exchange, endpoint);
}
+ public void prepareConsumerExchange(MessageExchange exchange, Endpoint endpoint) throws MessagingException {
+ lifeCycle.prepareConsumerExchange(exchange, endpoint);
+ }
+
public QName getEPRElementName() {
return null;
}
-
+
}