clientSettings.ClusterConfigurator = clusterBuilder =>
|
{
|
clusterBuilder.Subscribe<ClusterSelectingServerFailedEvent>(evnt =>
|
{
|
var logger = loggerFactory.CreateLogger<MongoModule>();
|
logger.LogCritical("Cluster selecting server failed! {@Event}", evnt);
|
})
|
// .Subscribe<CommandFailedEvent>(evnt =>
|
// {
|
// var logger = loggerFactory.CreateLogger<MongoModule>();
|
// logger.LogWarning("Command failed! {@Event}", evnt);
|
// })
|
.Subscribe<ConnectionFailedEvent>(evnt =>
|
{
|
var logger = loggerFactory.CreateLogger<MongoModule>();
|
logger.LogCritical("Connection failed! {@Event}", evnt);
|
})
|
.Subscribe<ConnectionOpeningFailedEvent>(evnt =>
|
{
|
var logger = loggerFactory.CreateLogger<MongoModule>();
|
logger.LogCritical("Connection opening failed! {@Event}", evnt);
|
})
|
.Subscribe<ConnectionPoolCheckingOutConnectionFailedEvent>(evnt =>
|
{
|
var logger = loggerFactory.CreateLogger<MongoModule>();
|
logger.LogCritical("Connection pool checking out connection failed! {@Event}", evnt);
|
})
|
.Subscribe<ConnectionReceivingMessageFailedEvent>(evnt =>
|
{
|
var logger = loggerFactory.CreateLogger<MongoModule>();
|
logger.LogWarning("Connection receiving message failed! {@Event}", evnt);
|
})
|
.Subscribe<ConnectionSendingMessagesFailedEvent>(evnt =>
|
{
|
var logger = loggerFactory.CreateLogger<MongoModule>();
|
logger.LogWarning("Connection sending messages failed! {@Event}", evnt);
|
})
|
.Subscribe<ServerHeartbeatFailedEvent>(evnt =>
|
{
|
var logger = loggerFactory.CreateLogger<MongoModule>();
|
logger.LogCritical("Server heart beat failed! {@Event}", evnt);
|
})
|
.Subscribe<ServerClosedEvent>(evnt =>
|
{
|
var logger = loggerFactory.CreateLogger<MongoModule>();
|
logger.LogCritical("Server closed! {@Event}", evnt);
|
})
|
.Subscribe<ServerOpenedEvent>(evnt =>
|
{
|
var logger = loggerFactory.CreateLogger<MongoModule>();
|
logger.LogInformation("Server opened! {@Event}", evnt);
|
})
|
.Subscribe<ConnectionOpenedEvent>(evnt =>
|
{
|
var logger = loggerFactory.CreateLogger<MongoModule>();
|
logger.LogInformation("Connection opened! {@Event}", evnt);
|
});
|
};
|