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();