Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

removed some unnecessary cruft 

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@387532 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
James Strachan 2006-03-21 14:12:51 +00:00
parent 0cc5d24dcb
commit cff515e024
2 changed files with 0 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
activemq-core/src/main/java/org/apache/activemq/transport/udp/UdpTransport.java
View File

@ -63,11 +63,9 @@ public class UdpTransport extends TransportThreadSupport implements Transport, S
private DatagramChannel channel; private DatagramChannel channel;
private boolean trace = false; private boolean trace = false;
private boolean useLocalHost = true; private boolean useLocalHost = true;
private boolean checkSequenceNumbers = true;
private int port; private int port;
private int minmumWireFormatVersion; private int minmumWireFormatVersion;
private String description = null; private String description = null;
private Runnable runnable;
private IntSequenceGenerator sequenceGenerator; private IntSequenceGenerator sequenceGenerator;
private boolean replayEnabled = true; private boolean replayEnabled = true;
@ -126,10 +124,6 @@ public class UdpTransport extends TransportThreadSupport implements Transport, S
commandChannel.write(command, address); commandChannel.write(command, address);
} }
public void setStartupRunnable(Runnable runnable) {
this.runnable = runnable;
}
/** /**
* @return pretty print of 'this' * @return pretty print of 'this'
*/ */
@ -147,9 +141,6 @@ public class UdpTransport extends TransportThreadSupport implements Transport, S
*/ */
public void run() { public void run() {
log.trace("Consumer thread starting for: " + toString()); log.trace("Consumer thread starting for: " + toString());
if (runnable != null) {
runnable.run();
}
while (!isStopped()) { while (!isStopped()) {
try { try {
Command command = commandChannel.read(); Command command = commandChannel.read();
@ -312,15 +303,6 @@ public class UdpTransport extends TransportThreadSupport implements Transport, S
return wireFormat; return wireFormat;
} }
public boolean isCheckSequenceNumbers() {
return checkSequenceNumbers;
}
public void setCheckSequenceNumbers(boolean checkSequenceNumbers) {
this.checkSequenceNumbers = checkSequenceNumbers;
}
public IntSequenceGenerator getSequenceGenerator() { public IntSequenceGenerator getSequenceGenerator() {
if (sequenceGenerator == null) { if (sequenceGenerator == null) {
sequenceGenerator = new IntSequenceGenerator(); sequenceGenerator = new IntSequenceGenerator();

4
activemq-core/src/main/java/org/apache/activemq/transport/udp/UdpTransportServer.java
View File

@ -59,10 +59,6 @@ public class UdpTransportServer extends TransportServerSupport {
this.serverTransport = serverTransport; this.serverTransport = serverTransport;
this.configuredTransport = configuredTransport; this.configuredTransport = configuredTransport;
this.replayStrategy = replayStrategy; 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() { public String toString() {