com.sportradar.unifiedodds.sdk.internal.impl.rabbitconnection

Class SingleInstanceAmqpConnectionFactory

java.lang.Object

com.sportradar.unifiedodds.sdk.internal.impl.rabbitconnection.SingleInstanceAmqpConnectionFactory

All Implemented Interfaces:

AmqpConnectionFactory

public class SingleInstanceAmqpConnectionFactory
extends Object
implements AmqpConnectionFactory

A AmqpConnectionFactory implementation which creates only one connection instance. All subsequent calls to newConnection() method return instance created by the first call.

Constructor Summary

Constructors

Constructor and Description
SingleInstanceAmqpConnectionFactory(ConfiguredConnectionFactory configuredConnectionFactory, SdkInternalConfiguration config, SdkConnectionStatusListener connectionStatusListener, WhoAmIReader whoAmIReader, FirewallChecker firewallChecker, TimeUtils timeUtils, SslProtocolsProvider sslProtocolsProvider) Initializes a new instance of the SingleInstanceAmqpConnectionFactory class

Method Summary

Modifier and Type	Method and Description
boolean	canConnectionOpen() Check if the connection can or should be opened
void	close(boolean feedStopped) Close the AMQP connection
com.rabbitmq.client.Connection	getConnection() Returns a Connection instance representing connection to the AMQP broker
long	getConnectionStarted() Get the timestamp when the connection started
boolean	isConnectionHealthy() Check if the connection is currently alive

Methods inherited from class java.lang.Object

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

Constructor Detail

SingleInstanceAmqpConnectionFactory

@Inject
public SingleInstanceAmqpConnectionFactory(ConfiguredConnectionFactory configuredConnectionFactory,
                                                   SdkInternalConfiguration config,
                                                   SdkConnectionStatusListener connectionStatusListener,
                                                   WhoAmIReader whoAmIReader,
                                                   FirewallChecker firewallChecker,
                                                   TimeUtils timeUtils,
                                                   SslProtocolsProvider sslProtocolsProvider)

Initializes a new instance of the SingleInstanceAmqpConnectionFactory class

Parameters:

configuredConnectionFactory - A ConfiguredConnectionFactory instance used to create the Connection instance

config - A SdkInternalConfiguration instance representing odds feed configuration

connectionStatusListener - A SdkConnectionStatusListener used to notify the outside world when the connection is closed

Method Detail

getConnection

public com.rabbitmq.client.Connection getConnection()

Returns a Connection instance representing connection to the AMQP broker

Specified by:

getConnection in interface AmqpConnectionFactory

Returns:

a Connection instance representing connection to the AMQP broker

close

public void close(boolean feedStopped)
           throws IOException

Close the AMQP connection

Specified by:

close in interface AmqpConnectionFactory

Parameters:

feedStopped - indication if feed was stopped

Throws:

IOException - if the connection couldn't be terminated

isConnectionHealthy

public boolean isConnectionHealthy()

Description copied from interface: AmqpConnectionFactory

Check if the connection is currently alive

Specified by:

isConnectionHealthy in interface AmqpConnectionFactory

Returns:

the status of the connection

getConnectionStarted

public long getConnectionStarted()

Get the timestamp when the connection started

Specified by:

getConnectionStarted in interface AmqpConnectionFactory

Returns:

the timestamp when the connection started

canConnectionOpen

public boolean canConnectionOpen()

Check if the connection can or should be opened

Specified by:

canConnectionOpen in interface AmqpConnectionFactory

Returns:

value indicating if the connection can or should be opened