Author: davsclaus
Date: Wed Apr 10 06:16:33 2013
New Revision: 1466341
URL: http://svn.apache.org/r1466341
Log:
CAMEL-6105: The direct-vm component should also thrown special exception if no
consumers avail, just like direct does.
Added:
camel/trunk/camel-core/src/main/java/org/apache/camel/component/directvm/DirectVmConsumerNotAvailableException.java
- copied, changed from r1466035,
camel/trunk/camel-core/src/main/java/org/apache/camel/component/direct/DirectConsumerNotAvailableException.java
Modified:
camel/trunk/camel-core/src/main/java/org/apache/camel/component/directvm/DirectVmProducer.java
Copied:
camel/trunk/camel-core/src/main/java/org/apache/camel/component/directvm/DirectVmConsumerNotAvailableException.java
(from r1466035,
camel/trunk/camel-core/src/main/java/org/apache/camel/component/direct/DirectConsumerNotAvailableException.java)
URL:
http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/component/directvm/DirectVmConsumerNotAvailableException.java?p2=camel/trunk/camel-core/src/main/java/org/apache/camel/component/directvm/DirectVmConsumerNotAvailableException.java&p1=camel/trunk/camel-core/src/main/java/org/apache/camel/component/direct/DirectConsumerNotAvailableException.java&r1=1466035&r2=1466341&rev=1466341&view=diff
==============================================================================
---
camel/trunk/camel-core/src/main/java/org/apache/camel/component/direct/DirectConsumerNotAvailableException.java
(original)
+++
camel/trunk/camel-core/src/main/java/org/apache/camel/component/directvm/DirectVmConsumerNotAvailableException.java
Wed Apr 10 06:16:33 2013
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.apache.camel.component.direct;
+package org.apache.camel.component.directvm;
import org.apache.camel.CamelExchangeException;
import org.apache.camel.Exchange;
@@ -24,9 +24,9 @@ import org.apache.camel.Exchange;
*
* @version
*/
-public class DirectConsumerNotAvailableException extends
CamelExchangeException {
+public class DirectVmConsumerNotAvailableException extends
CamelExchangeException {
- public DirectConsumerNotAvailableException(String message, Exchange
exchange) {
+ public DirectVmConsumerNotAvailableException(String message, Exchange
exchange) {
super(message, exchange);
}
}
\ No newline at end of file
Modified:
camel/trunk/camel-core/src/main/java/org/apache/camel/component/directvm/DirectVmProducer.java
URL:
http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/component/directvm/DirectVmProducer.java?rev=1466341&r1=1466340&r2=1466341&view=diff
==============================================================================
---
camel/trunk/camel-core/src/main/java/org/apache/camel/component/directvm/DirectVmProducer.java
(original)
+++
camel/trunk/camel-core/src/main/java/org/apache/camel/component/directvm/DirectVmProducer.java
Wed Apr 10 06:16:33 2013
@@ -45,7 +45,7 @@ public class DirectVmProducer extends De
DirectVmConsumer consumer =
endpoint.getComponent().getConsumer(endpoint);
if (consumer == null) {
LOG.warn("No consumers available on endpoint: " + endpoint + " to
process: " + exchange);
- throw new CamelExchangeException("No consumers available on
endpoint: " + endpoint, exchange);
+ throw new DirectVmConsumerNotAvailableException("No consumers
available on endpoint: " + endpoint, exchange);
} else {
consumer.getProcessor().process(exchange);
}
@@ -57,7 +57,7 @@ public class DirectVmProducer extends De
DirectVmConsumer consumer =
endpoint.getComponent().getConsumer(endpoint);
if (consumer == null) {
LOG.warn("No consumers available on endpoint: " + endpoint + " to
process: " + exchange);
- exchange.setException(new CamelExchangeException("No consumers
available on endpoint: " + endpoint, exchange));
+ exchange.setException(new
DirectVmConsumerNotAvailableException("No consumers available on endpoint: " +
endpoint, exchange));
callback.done(true);
return true;
} else {
