You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by js...@apache.org on 2008/03/07 14:31:58 UTC
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...
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) {