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

Interface AmqpConnectionFactory

All Known Implementing Classes:

SingleInstanceAmqpConnectionFactory

public interface AmqpConnectionFactory

Represents a factory used to create Connection instances

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

Method Detail

getConnection

com.rabbitmq.client.Connection getConnection()
                                      throws IOException,
                                             TimeoutException,
                                             NoSuchAlgorithmException,
                                             KeyManagementException

Returns a Connection instance representing connection to the AMQP broker

Returns:

a Connection instance representing connection to the AMQP broker

Throws:

IOException - An error occurred while creating the connection instance

TimeoutException - An error occurred while creating the connection instance

NoSuchAlgorithmException - An error occurred while configuring the factory to use SSL

KeyManagementException - An error occurred while configuring the factory to use SSL

close

void close(boolean feedStopped)
    throws IOException

Close the AMQP connection

Parameters:

feedStopped - indication if feed was stopped

Throws:

IOException - if the connection couldn't be terminated

isConnectionHealthy

boolean isConnectionHealthy()

Check if the connection is currently alive

Returns:

the status of the connection

getConnectionStarted

long getConnectionStarted()

Get the timestamp when the connection started

Returns:

the timestamp when the connection started

canConnectionOpen

boolean canConnectionOpen()

Check if the connection can or should be opened

Returns:

value indicating if the connection can or should be opened