You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@activemq.apache.org by ra...@apache.org on 2006/03/10 18:04:26 UTC

svn commit: r384854 - /incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/activeio/ActiveIOTransport.java

Author: rajdavies
Date: Fri Mar 10 09:04:23 2006
New Revision: 384854

URL: http://svn.apache.org/viewcvs?rev=384854&view=rev
Log:
Added request(Command. timeout) to transport 

Modified:
    incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/activeio/ActiveIOTransport.java

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/activeio/ActiveIOTransport.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/activeio/ActiveIOTransport.java?rev=384854&r1=384853&r2=384854&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/activeio/ActiveIOTransport.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/activeio/ActiveIOTransport.java Fri Mar 10 09:04:23 2006
@@ -102,6 +102,10 @@
     public Response request(Command command) throws IOException {
         throw new AssertionError("Unsupported Method");
     }
+    
+    public Response request(Command command,int timeout) throws IOException {
+        throw new AssertionError("Unsupported Method");
+    }
 
     public void start() throws Exception {
         commandChannel.start();