activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jstrac...@apache.org
Subject svn commit: r655516 - in /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/camel: CamelMessageProducer.java component/JournalEndpoint.java
Date Mon, 12 May 2008 15:18:56 GMT
Author: jstrachan
Date: Mon May 12 08:18:52 2008
New Revision: 655516

URL: http://svn.apache.org/viewvc?rev=655516&view=rev
Log:
added refactor to make it easier to create endpoint instances from a spring.xml with minimal
constructors for https://issues.apache.org/activemq/browse/CAMEL-505

Modified:
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/camel/CamelMessageProducer.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/camel/component/JournalEndpoint.java

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/camel/CamelMessageProducer.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/camel/CamelMessageProducer.java?rev=655516&r1=655515&r2=655516&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/camel/CamelMessageProducer.java
(original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/camel/CamelMessageProducer.java
Mon May 12 08:18:52 2008
@@ -87,7 +87,7 @@
             throw new IllegalArgumentException("Invalid destination setting: " + destination
+ " when expected: " + this.destination);
         }
         try {
-            JmsExchange exchange = new JmsExchange(endpoint.getContext(), ExchangePattern.InOnly,
camelDestination.getBinding(), message);
+            JmsExchange exchange = new JmsExchange(endpoint.getCamelContext(), ExchangePattern.InOnly,
camelDestination.getBinding(), message);
             producer.process(exchange);
         } catch (JMSException e) {
             throw e;

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/camel/component/JournalEndpoint.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/camel/component/JournalEndpoint.java?rev=655516&r1=655515&r2=655516&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/camel/component/JournalEndpoint.java
(original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/camel/component/JournalEndpoint.java
Mon May 12 08:18:52 2008
@@ -58,6 +58,11 @@
         this.directory = directory;
     }
 
+    public JournalEndpoint(String endpointUri, File directory) {
+        super(endpointUri);
+        this.directory = directory;
+    }
+
     public boolean isSingleton() {
         return true;
     }



Mime
View raw message