private final Path storagePath;
private final ShardingStrategy shardingStrategy;
private final ObjectMapper mapper;
+ private final String loggingCategory = FilesStorageStrategy.class.getSimpleName();
+ private final Level loggingLevel;
+ private final boolean showOperatorLine;
@Override
return chatRoomInfoFlux
.log(
- FilesStorageStrategy.class.getSimpleName(),
- Level.FINE,
- true)
+ loggingCategory,
+ loggingLevel,
+ showOperatorLine)
.doFirst(() ->
{
try
return Flux
.from(new JsonFilePublisher<ChatRoomInfoTo>(chatroomsPath(), mapper, type))
.log(
- FilesStorageStrategy.class.getSimpleName(),
- Level.FINE,
- true)
+ loggingCategory,
+ loggingLevel,
+ showOperatorLine)
.map(chatRoomInfoTo ->
{
UUID chatRoomId = chatRoomInfoTo.getId();
return messageFlux
.log(
- FilesStorageStrategy.class.getSimpleName(),
- Level.FINE,
- true)
+ loggingCategory,
+ loggingLevel,
+ showOperatorLine)
.doFirst(() ->
{
try
return Flux
.from(new JsonFilePublisher<MessageTo>(chatroomPath(chatRoomId), mapper, type))
.log(
- FilesStorageStrategy.class.getSimpleName(),
- Level.FINE,
- true)
+ loggingCategory,
+ loggingLevel,
+ showOperatorLine)
.map(MessageTo::toMessage);
}