Package com.ecom.winners.configurations

Class SelectWinner

java.lang.Object

com.ecom.winners.configurations.SelectWinner

@Configuration
public class SelectWinner
                    extends Object

Constructor Summary

Constructors

Constructor	Description
SelectWinner()

Method Summary

Modifier and Type	Method	Description
WinnerProcessor	processor()
org.springframework.batch.item.database.JdbcCursorItemReader<User>	reader (UserRepository userRepository, DataSource dataSource, float threshold)
org.springframework.batch.core.Step	selectLuckyWinner (org.springframework.batch.core.repository.JobRepository jobRepository, org.springframework.transaction.PlatformTransactionManager transactionManager, org.springframework.batch.item.kafka.KafkaItemWriter<String, UserDTO> writer, org.springframework.batch.item.database.JdbcCursorItemReader<User> reader)
org.springframework.batch.item.kafka.KafkaItemWriter<String, UserDTO>	writer (org.springframework.kafka.core.KafkaTemplate<String, UserDTO> kafkaTemplate)

Methods inherited from class java.lang.Object

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

Constructor Details

SelectWinner

public SelectWinner()
                                        

Method Details

reader

@Bean(name="queryLuckyWinner")
public org.springframework.batch.item.database.JdbcCursorItemReader<User> reader
                                            
                                            (UserRepository userRepository,
 DataSource dataSource,
 @Value("${select.winner.amount.threshold}")
 float threshold)

processor

@Bean(name="winnerProcessor")
public WinnerProcessor processor()
                                        

writer

@Bean(name="winnerWriter")
public org.springframework.batch.item.kafka.KafkaItemWriter<String,UserDTO> writer
                                            
                                            (org.springframework.kafka.core.KafkaTemplate<String,UserDTO> kafkaTemplate)
                                        

selectLuckyWinner

@Bean(name="selectLuckyWinner")
public org.springframework.batch.core.Step selectLuckyWinner
                                            
                                            (org.springframework.batch.core.repository.JobRepository jobRepository,
 org.springframework.transaction.PlatformTransactionManager transactionManager,
 org.springframework.batch.item.kafka.KafkaItemWriter<String,UserDTO> writer,
 org.springframework.batch.item.database.JdbcCursorItemReader<User> reader)