activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jstrac...@apache.org
Subject svn commit: r387532 - in /incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/udp: UdpTransport.java UdpTransportServer.java
Date Tue, 21 Mar 2006 14:12:53 GMT
Author: jstrachan
Date: Tue Mar 21 06:12:51 2006
New Revision: 387532

URL: http://svn.apache.org/viewcvs?rev=387532&view=rev
Log:
removed some unnecessary cruft

Modified:
    incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/udp/UdpTransport.java
    incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/udp/UdpTransportServer.java

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/udp/UdpTransport.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/udp/UdpTransport.java?rev=387532&r1=387531&r2=387532&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/udp/UdpTransport.java
(original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/udp/UdpTransport.java
Tue Mar 21 06:12:51 2006
@@ -63,11 +63,9 @@
     private DatagramChannel channel;
     private boolean trace = false;
     private boolean useLocalHost = true;
-    private boolean checkSequenceNumbers = true;
     private int port;
     private int minmumWireFormatVersion;
     private String description = null;
-    private Runnable runnable;
     private IntSequenceGenerator sequenceGenerator;
     private boolean replayEnabled = true;
 
@@ -126,10 +124,6 @@
         commandChannel.write(command, address);
     }
 
-    public void setStartupRunnable(Runnable runnable) {
-        this.runnable = runnable;
-    }
-
     /**
      * @return pretty print of 'this'
      */
@@ -147,9 +141,6 @@
      */
     public void run() {
         log.trace("Consumer thread starting for: " + toString());
-        if (runnable != null) {
-            runnable.run();
-        }
         while (!isStopped()) {
             try {
                 Command command = commandChannel.read();
@@ -311,15 +302,6 @@
     public OpenWireFormat getWireFormat() {
         return wireFormat;
     }
-
-    public boolean isCheckSequenceNumbers() {
-        return checkSequenceNumbers;
-    }
-
-    public void setCheckSequenceNumbers(boolean checkSequenceNumbers) {
-        this.checkSequenceNumbers = checkSequenceNumbers;
-    }
-
 
     public IntSequenceGenerator getSequenceGenerator() {
         if (sequenceGenerator == null) {

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/udp/UdpTransportServer.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/udp/UdpTransportServer.java?rev=387532&r1=387531&r2=387532&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/udp/UdpTransportServer.java
(original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/udp/UdpTransportServer.java
Tue Mar 21 06:12:51 2006
@@ -59,10 +59,6 @@
         this.serverTransport = serverTransport;
         this.configuredTransport = configuredTransport;
         this.replayStrategy = replayStrategy;
-
-        // lets disable the incremental checking of the sequence numbers
-        // as we are getting messages from many different clients
-        serverTransport.setCheckSequenceNumbers(false);
     }
 
     public String toString() {



Mime
View raw message