Package org.apache.cassandra.streaming
Class DefaultConnectionFactory
- java.lang.Object
-
- org.apache.cassandra.streaming.DefaultConnectionFactory
-
- All Implemented Interfaces:
StreamConnectionFactory
- Direct Known Subclasses:
BulkLoadConnectionFactory
public class DefaultConnectionFactory extends java.lang.Object implements StreamConnectionFactory
-
-
Field Summary
Fields Modifier and Type Field Description static int
MAX_CONNECT_ATTEMPTS
-
Constructor Summary
Constructors Constructor Description DefaultConnectionFactory()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description io.netty.channel.Channel
createConnection(OutboundConnectionSettings template, int messagingVersion)
-
-
-
Method Detail
-
createConnection
public io.netty.channel.Channel createConnection(OutboundConnectionSettings template, int messagingVersion) throws java.io.IOException
- Specified by:
createConnection
in interfaceStreamConnectionFactory
- Throws:
java.io.IOException
-
-