summaryrefslogtreecommitdiff
path: root/qpid/java/common/src/main/java/org/apache/qpid/transport/network/Transport.java
diff options
context:
space:
mode:
Diffstat (limited to 'qpid/java/common/src/main/java/org/apache/qpid/transport/network/Transport.java')
-rw-r--r--qpid/java/common/src/main/java/org/apache/qpid/transport/network/Transport.java25
1 files changed, 19 insertions, 6 deletions
diff --git a/qpid/java/common/src/main/java/org/apache/qpid/transport/network/Transport.java b/qpid/java/common/src/main/java/org/apache/qpid/transport/network/Transport.java
index f0bf04d04f..3ab875262a 100644
--- a/qpid/java/common/src/main/java/org/apache/qpid/transport/network/Transport.java
+++ b/qpid/java/common/src/main/java/org/apache/qpid/transport/network/Transport.java
@@ -24,17 +24,30 @@ package org.apache.qpid.transport.network;
import org.apache.qpid.transport.TransportException;
public class Transport
-{
+{
+ public static final String TCP = "tcp";
+ public static final String TLS = "tls";
+ public static final String SSL = "ssl";
+ public static final String VM = "vm";
+ public static final String SOCKET = "socket";
+
+ public static final int DEFAULT_BUFFER_SIZE = 32 * 1024;
+ public static final long DEFAULT_TIMEOUT = 60000;
+
+ public static final boolean WINDOWS = ((String) System.getProperties().get("os.name")).matches("(?i).*windows.*");
+
+ public static final String IO_TRANSPORT = "org.apache.qpid.transport.network.io.IoNetworkTransport";
+ public static final String MINA_TRANSPORT = "org.apache.qpid.transport.network.mina.MinaNetworkTransport"; // TODO
+ public static final String NIO_TRANSPORT = "org.apache.qpid.transport.network.nio.NioNetworkTransport"; // TODO
+ public static final String NETTY_TRANSPORT = "org.apache.qpid.transport.network.netty.NettyNetworkTransport"; // TODO
+
private final static Class<?> transportClass;
static
{
try
{
- transportClass =
- Class.forName(System.getProperty("qpid.transport",
- "org.apache.qpid.transport.network.io.IoNetworkTransport"));
-
+ transportClass = Class.forName(System.getProperty("qpid.transport", IO_TRANSPORT));
}
catch(Exception e)
{
@@ -53,4 +66,4 @@ public class Transport
throw new TransportException("Error while creating a new transport instance",e);
}
}
-} \ No newline at end of file
+}