Return-Path: Delivered-To: apmail-geronimo-activemq-commits-archive@www.apache.org Received: (qmail 19303 invoked from network); 21 Mar 2006 14:13:23 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (209.237.227.199) by minotaur.apache.org with SMTP; 21 Mar 2006 14:13:23 -0000 Received: (qmail 68795 invoked by uid 500); 21 Mar 2006 14:13:19 -0000 Delivered-To: apmail-geronimo-activemq-commits-archive@geronimo.apache.org Received: (qmail 68753 invoked by uid 500); 21 Mar 2006 14:13:19 -0000 Mailing-List: contact activemq-commits-help@geronimo.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: activemq-dev@geronimo.apache.org Delivered-To: mailing list activemq-commits@geronimo.apache.org Received: (qmail 68744 invoked by uid 99); 21 Mar 2006 14:13:19 -0000 Received: from asf.osuosl.org (HELO asf.osuosl.org) (140.211.166.49) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 21 Mar 2006 06:13:19 -0800 X-ASF-Spam-Status: No, hits=-9.4 required=10.0 tests=ALL_TRUSTED,NO_REAL_NAME X-Spam-Check-By: apache.org Received: from [209.237.227.194] (HELO minotaur.apache.org) (209.237.227.194) by apache.org (qpsmtpd/0.29) with SMTP; Tue, 21 Mar 2006 06:13:18 -0800 Received: (qmail 19078 invoked by uid 65534); 21 Mar 2006 14:12:58 -0000 Message-ID: <20060321141253.19075.qmail@minotaur.apache.org> Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit 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 -0000 To: activemq-commits@geronimo.apache.org From: jstrachan@apache.org X-Mailer: svnmailer-1.0.7 X-Virus-Checked: Checked by ClamAV on apache.org X-Spam-Rating: minotaur.apache.org 1.6.2 0/1000/N 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() {