org.thales.punch.applications.gateway.services

Class BookService

java.lang.Object

org.thales.punch.applications.gateway.services.BookService

All Implemented Interfaces:

org.thales.punch.kafka.api.IRecordHandler<String,byte[]>

@Service
 @ConditionalOnBean(value=BooksConfiguration.class)
public class BookService
extends Object
implements org.thales.punch.kafka.api.IRecordHandler<String,byte[]>

Constructor Summary

Constructors

Constructor and Description
BookService(EnvironmentConfiguration environmentConfiguration, PunchplatformConfiguration configuration, SubprocessService subprocessService, BooksConfiguration booksConfiguration, ResourcesManagerService resourcesManagerService)

Method Summary

Modifier and Type	Method and Description
Book	getOne(String bookId)
String	listAll()
void	onReceive(org.thales.punch.kafka.api.IPartition partition, org.apache.kafka.clients.consumer.ConsumerRecord<String,byte[]> record)
org.thales.punch.settings.api.ISettingsMap	start(org.thales.punch.settings.api.SettingsMapBuilder bodyBuilder) Start a new book

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.thales.punch.kafka.api.IRecordHandler

onPartitionAssigned, onPartitionRevoked, onTick

Constructor Detail

BookService

public BookService(EnvironmentConfiguration environmentConfiguration,
                   PunchplatformConfiguration configuration,
                   SubprocessService subprocessService,
                   BooksConfiguration booksConfiguration,
                   ResourcesManagerService resourcesManagerService)

Method Detail

onReceive

public void onReceive(org.thales.punch.kafka.api.IPartition partition,
                      org.apache.kafka.clients.consumer.ConsumerRecord<String,byte[]> record)

Specified by:

onReceive in interface org.thales.punch.kafka.api.IRecordHandler<String,byte[]>

start

public org.thales.punch.settings.api.ISettingsMap start(org.thales.punch.settings.api.SettingsMapBuilder bodyBuilder)
                                                 throws IOException

Start a new book

Parameters:

bodyBuilder - body params

Returns:

Throws:

IOException

getOne

public Book getOne(String bookId)

listAll

public String listAll()