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 and Description
static int	MAX_CONNECT_ATTEMPTS

Constructor Summary

Constructors

Constructor and Description
DefaultConnectionFactory()

Method Summary

Modifier and Type	Method and Description
io.netty.channel.Channel	createConnection(OutboundConnectionSettings template, int messagingVersion)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.cassandra.streaming.StreamConnectionFactory

supportsPreferredIp

Field Detail

MAX_CONNECT_ATTEMPTS

public static int MAX_CONNECT_ATTEMPTS

Constructor Detail

DefaultConnectionFactory

public DefaultConnectionFactory()

Method Detail

createConnection

public io.netty.channel.Channel createConnection(OutboundConnectionSettings template,
                                                 int messagingVersion)
                                          throws java.io.IOException

Specified by:

createConnection in interface StreamConnectionFactory

Throws:

java.io.IOException