You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by js...@apache.org on 2006/03/21 15:12:53 UTC
svn commit: r387532 - in
/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/udp:
UdpTransport.java UdpTransportServer.java
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() {