Package org.apache.cassandra.streaming.async

Class NettyStreamingConnectionFactory

java.lang.Object

org.apache.cassandra.streaming.async.NettyStreamingConnectionFactory

All Implemented Interfaces:

StreamingChannel.Factory

Direct Known Subclasses:

BulkLoadConnectionFactory

public class NettyStreamingConnectionFactory
extends Object
implements StreamingChannel.Factory

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.cassandra.streaming.StreamingChannel.Factory

StreamingChannel.Factory.Global

Field Summary

Fields

Modifier and Type	Field	Description
static int	MAX_CONNECT_ATTEMPTS

Constructor Summary

Constructors

Constructor	Description
NettyStreamingConnectionFactory()

Method Summary

Modifier and Type	Method	Description
static NettyStreamingChannel	connect(OutboundConnectionSettings template, int messagingVersion, StreamingChannel.Kind kind)
StreamingChannel	create(InetSocketAddress to, int messagingVersion, StreamingChannel.Kind kind)
StreamingChannel	create(InetSocketAddress to, InetSocketAddress preferred, int messagingVersion, StreamingChannel.Kind kind)

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.StreamingChannel.Factory

supportsPreferredIp

Field Details

MAX_CONNECT_ATTEMPTS

public static int MAX_CONNECT_ATTEMPTS

Constructor Details

NettyStreamingConnectionFactory

public NettyStreamingConnectionFactory()

Method Details

connect

public static NettyStreamingChannel connect(OutboundConnectionSettings template,
 int messagingVersion,
 StreamingChannel.Kind kind)
                                     throws IOException

Throws:

IOException

create

public StreamingChannel create(InetSocketAddress to,
 int messagingVersion,
 StreamingChannel.Kind kind)
                        throws IOException

Specified by:

create in interface StreamingChannel.Factory

Throws:

IOException

create

public StreamingChannel create(InetSocketAddress to,
 InetSocketAddress preferred,
 int messagingVersion,
 StreamingChannel.Kind kind)
                        throws IOException

Specified by:

create in interface StreamingChannel.Factory

Throws:

IOException