diff --git a/activemq-core/src/main/java/org/apache/activemq/transport/udp/UdpTransport.java b/activemq-core/src/main/java/org/apache/activemq/transport/udp/UdpTransport.java
index 0a97403376..d5337bec0d 100755
--- a/activemq-core/src/main/java/org/apache/activemq/transport/udp/UdpTransport.java
+++ b/activemq-core/src/main/java/org/apache/activemq/transport/udp/UdpTransport.java
@@ -63,11 +63,9 @@ public class UdpTransport extends TransportThreadSupport implements Transport, S
     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 @@ public class UdpTransport extends TransportThreadSupport implements Transport, S
         commandChannel.write(command, address);
     }
 
-    public void setStartupRunnable(Runnable runnable) {
-        this.runnable = runnable;
-    }
-
     /**
      * @return pretty print of 'this'
      */
@@ -147,9 +141,6 @@ public class UdpTransport extends TransportThreadSupport implements Transport, S
      */
     public void run() {
         log.trace("Consumer thread starting for: " + toString());
-        if (runnable != null) {
-            runnable.run();
-        }
         while (!isStopped()) {
             try {
                 Command command = commandChannel.read();
@@ -312,15 +303,6 @@ public class UdpTransport extends TransportThreadSupport implements Transport, S
         return wireFormat;
     }
 
-    public boolean isCheckSequenceNumbers() {
-        return checkSequenceNumbers;
-    }
-
-    public void setCheckSequenceNumbers(boolean checkSequenceNumbers) {
-        this.checkSequenceNumbers = checkSequenceNumbers;
-    }
-
-
     public IntSequenceGenerator getSequenceGenerator() {
         if (sequenceGenerator == null) {
             sequenceGenerator = new IntSequenceGenerator();
diff --git a/activemq-core/src/main/java/org/apache/activemq/transport/udp/UdpTransportServer.java b/activemq-core/src/main/java/org/apache/activemq/transport/udp/UdpTransportServer.java
index e94249e622..8ba6869741 100755
--- a/activemq-core/src/main/java/org/apache/activemq/transport/udp/UdpTransportServer.java
+++ b/activemq-core/src/main/java/org/apache/activemq/transport/udp/UdpTransportServer.java
@@ -59,10 +59,6 @@ public class UdpTransportServer extends TransportServerSupport {
         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() {