com.xeiam.xchange.bitstamp.service.streaming

Class BitstampStreamingConfiguration

java.lang.Object

com.xeiam.xchange.bitstamp.service.streaming.BitstampStreamingConfiguration

All Implemented Interfaces:

ExchangeStreamingConfiguration

public class BitstampStreamingConfiguration
extends Object
implements ExchangeStreamingConfiguration

Value object to provide the following

• Access to streaming data configuration specific to Bitstamp exchange streaming API

Constructor Summary

Constructors

Constructor and Description
BitstampStreamingConfiguration()
BitstampStreamingConfiguration(com.pusher.client.PusherOptions pusherOptions, int maxReconnectAttempts, int reconnectWaitTimeInMs, int timeoutInMs, boolean isEncryptedChannel, String pusherKey, Set<String> channels) Constructor

Method Summary

Modifier and Type	Method and Description
Set<String>	getChannels()
int	getMaxReconnectAttempts() What are the maximum number of reconnect attempts?
String	getPusherKey()
int	getReconnectWaitTimeInMs() Before attempting reconnect, how much of a delay?
int	getTimeoutInMs() How much time should elapse before the connection is considered dead and a reconnect attempt should be made?
boolean	isEncryptedChannel() should it use an encrypted channel or not? (ws vs.
boolean	keepAlive() should it keep the socket alive? (send ping every 15s)
com.pusher.client.PusherOptions	pusherOptions()

Methods inherited from class java.lang.Object

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

Constructor Detail

BitstampStreamingConfiguration

public BitstampStreamingConfiguration(com.pusher.client.PusherOptions pusherOptions,
                                      int maxReconnectAttempts,
                                      int reconnectWaitTimeInMs,
                                      int timeoutInMs,
                                      boolean isEncryptedChannel,
                                      String pusherKey,
                                      Set<String> channels)

Constructor

Parameters:

maxReconnectAttempts -

reconnectWaitTimeInMs -

timeoutInMs -

isEncryptedChannel - - should it use an encrypted channel or not? (ws vs. wss protocol)

channel - - the specific data channel you want to tap into (https://mtgox.com/api/2/stream/list_public), null if none

BitstampStreamingConfiguration

public BitstampStreamingConfiguration()

Method Detail

pusherOptions

public final com.pusher.client.PusherOptions pusherOptions()

getMaxReconnectAttempts

public int getMaxReconnectAttempts()

Description copied from interface: ExchangeStreamingConfiguration

What are the maximum number of reconnect attempts?

Specified by:

getMaxReconnectAttempts in interface ExchangeStreamingConfiguration

Returns:

getReconnectWaitTimeInMs

public int getReconnectWaitTimeInMs()

Description copied from interface: ExchangeStreamingConfiguration

Before attempting reconnect, how much of a delay?

Specified by:

getReconnectWaitTimeInMs in interface ExchangeStreamingConfiguration

Returns:

getTimeoutInMs

public int getTimeoutInMs()

Description copied from interface: ExchangeStreamingConfiguration

How much time should elapse before the connection is considered dead and a reconnect attempt should be made?

Specified by:

getTimeoutInMs in interface ExchangeStreamingConfiguration

Returns:

isEncryptedChannel

public boolean isEncryptedChannel()

Description copied from interface: ExchangeStreamingConfiguration

should it use an encrypted channel or not? (ws vs. wss protocol)

Specified by:

isEncryptedChannel in interface ExchangeStreamingConfiguration

Returns:

keepAlive

public boolean keepAlive()

Description copied from interface: ExchangeStreamingConfiguration

should it keep the socket alive? (send ping every 15s)

Specified by:

keepAlive in interface ExchangeStreamingConfiguration

Returns:

getPusherKey

public String getPusherKey()

getChannels

public Set<String> getChannels()