camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jstrac...@apache.org
Subject svn commit: r634667 - in /activemq/camel/trunk: camel-core/src/main/java/org/apache/camel/component/list/ camel-core/src/main/java/org/apache/camel/component/mock/ camel-core/src/main/java/org/apache/camel/component/seda/ camel-core/src/main/java/org/a...
Date Fri, 07 Mar 2008 13:31:58 GMT
Author: jstrachan
Date: Fri Mar  7 05:31:57 2008
New Revision: 634667

URL: http://svn.apache.org/viewvc?rev=634667&view=rev
Log:
fixed the BrowsableEndpoint API properly so we can use it with endpoints using a derived Exchange

Modified:
    activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/component/list/ListEndpoint.java
    activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/component/mock/MockEndpoint.java
    activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/component/seda/SedaEndpoint.java
    activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/spi/BrowsableEndpoint.java
    activemq/camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsQueueEndpoint.java

Modified: activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/component/list/ListEndpoint.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/component/list/ListEndpoint.java?rev=634667&r1=634666&r2=634667&view=diff
==============================================================================
--- activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/component/list/ListEndpoint.java
(original)
+++ activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/component/list/ListEndpoint.java
Fri Mar  7 05:31:57 2008
@@ -42,7 +42,7 @@
  *
  * @version $Revision$
  */
-public class ListEndpoint extends DefaultEndpoint<Exchange> implements BrowsableEndpoint
{
+public class ListEndpoint extends DefaultEndpoint<Exchange> implements BrowsableEndpoint<Exchange>
{
     private List<Exchange> exchanges;
     private TopicLoadBalancer loadBalancer = new TopicLoadBalancer();
     private PropertyChangeSupport propertyChangeSupport = new PropertyChangeSupport(this);

Modified: activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/component/mock/MockEndpoint.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/component/mock/MockEndpoint.java?rev=634667&r1=634666&r2=634667&view=diff
==============================================================================
--- activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/component/mock/MockEndpoint.java
(original)
+++ activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/component/mock/MockEndpoint.java
Fri Mar  7 05:31:57 2008
@@ -50,7 +50,7 @@
  * 
  * @version $Revision$
  */
-public class MockEndpoint extends DefaultEndpoint<Exchange> implements BrowsableEndpoint
{
+public class MockEndpoint extends DefaultEndpoint<Exchange> implements BrowsableEndpoint<Exchange>
{
     private static final transient Log LOG = LogFactory.getLog(MockEndpoint.class);
     private int expectedCount;
     private int counter;

Modified: activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/component/seda/SedaEndpoint.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/component/seda/SedaEndpoint.java?rev=634667&r1=634666&r2=634667&view=diff
==============================================================================
--- activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/component/seda/SedaEndpoint.java
(original)
+++ activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/component/seda/SedaEndpoint.java
Fri Mar  7 05:31:57 2008
@@ -36,7 +36,7 @@
  *
  * @version $Revision$
  */
-public class SedaEndpoint extends DefaultEndpoint<Exchange> implements BrowsableEndpoint
{
+public class SedaEndpoint extends DefaultEndpoint<Exchange> implements BrowsableEndpoint<Exchange>
{
     private BlockingQueue<Exchange> queue;
 
     public SedaEndpoint(String endpointUri, Component component, BlockingQueue<Exchange>
queue) {

Modified: activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/spi/BrowsableEndpoint.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/spi/BrowsableEndpoint.java?rev=634667&r1=634666&r2=634667&view=diff
==============================================================================
--- activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/spi/BrowsableEndpoint.java
(original)
+++ activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/spi/BrowsableEndpoint.java
Fri Mar  7 05:31:57 2008
@@ -28,19 +28,11 @@
  *
  * @version $Revision$
  */
-public interface BrowsableEndpoint {
+public interface BrowsableEndpoint<T extends Exchange> extends Endpoint<T> {
     /**
      * Return the exchanges available on this endpoint
      *
      * @return the exchanges on this endpoint
      */
     List<Exchange> getExchanges();
-
-    // TODO when we remove the generics on Endpoint we can zap the next bit
-    // and make this interface extend Endpoint
-
-    /**
-     * Returns the string representation of the endpoint URI
-     */
-    String getEndpointUri();
 }

Modified: activemq/camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsQueueEndpoint.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsQueueEndpoint.java?rev=634667&r1=634666&r2=634667&view=diff
==============================================================================
--- activemq/camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsQueueEndpoint.java
(original)
+++ activemq/camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsQueueEndpoint.java
Fri Mar  7 05:31:57 2008
@@ -36,7 +36,7 @@
  *
  * @version $Revision: 1.1 $
  */
-public class JmsQueueEndpoint extends JmsEndpoint implements BrowsableEndpoint {
+public class JmsQueueEndpoint extends JmsEndpoint implements BrowsableEndpoint<JmsExchange>
{
     private int maximumBrowseSize = -1;
 
     public JmsQueueEndpoint(String uri, JmsComponent component, String destination, JmsConfiguration
configuration) {



Mime
View raw message