diff --git a/crm-microservice-event-sourcesing-cqrs/src/main/java/com/example/crm/events/CustomerBaseEvent.java b/crm-microservice-event-sourcesing-cqrs/src/main/java/com/example/crm/events/CustomerBaseEvent.java index dbac62b..1eee442 100644 --- a/crm-microservice-event-sourcesing-cqrs/src/main/java/com/example/crm/events/CustomerBaseEvent.java +++ b/crm-microservice-event-sourcesing-cqrs/src/main/java/com/example/crm/events/CustomerBaseEvent.java @@ -22,11 +22,11 @@ public class CustomerBaseEvent { private long sequenceId; private String sourceId; private String identity; - @LastModifiedDate - private Date lastModified; - @CreatedDate - private Date createdAt; - + @LastModifiedDate + private Date lastModified; + @CreatedDate + private Date createdAt; + public CustomerBaseEvent() { } @@ -70,24 +70,24 @@ public void setIdentity(String identity) { this.identity = identity; } - @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd'T'HH:mm:ss.SSSZ") - public Date getLastModified() { - return lastModified; - } + @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd'T'HH:mm:ss.SSSZ") + public Date getLastModified() { + return lastModified; + } + + public void setLastModified(Date lastModified) { + this.lastModified = lastModified; + } - public void setLastModified(Date lastModified) { - this.lastModified = lastModified; - } + @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd'T'HH:mm:ss.SSSZ") + public Date getCreatedAt() { + return createdAt; + } - @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd'T'HH:mm:ss.SSSZ") - public Date getCreatedAt() { - return createdAt; - } + public void setCreatedAt(Date createdAt) { + this.createdAt = createdAt; + } - public void setCreatedAt(Date createdAt) { - this.createdAt = createdAt; - } - @Override public String toString() { return "CustomerBaseEvent [eventId=" + eventId + ", conversationId=" + conversationId + ", sequenceId=" diff --git a/crm-microservice-event-sourcesing-cqrs/src/main/java/com/example/crm/events/CustomerPhotoChangedEvent.java b/crm-microservice-event-sourcesing-cqrs/src/main/java/com/example/crm/events/CustomerPhotoChangedEvent.java index 6b8ac52..337dfe3 100644 --- a/crm-microservice-event-sourcesing-cqrs/src/main/java/com/example/crm/events/CustomerPhotoChangedEvent.java +++ b/crm-microservice-event-sourcesing-cqrs/src/main/java/com/example/crm/events/CustomerPhotoChangedEvent.java @@ -20,5 +20,5 @@ public void setPhoto(String photo) { public String toString() { return "CustomerPhotoChangedEvent []"; } - + } diff --git a/crm-microservice-event-sourcesing-cqrs/src/main/java/com/example/crm/repository/BaseEventRepository.java b/crm-microservice-event-sourcesing-cqrs/src/main/java/com/example/crm/repository/BaseEventRepository.java index 42c04da..bb5a61c 100644 --- a/crm-microservice-event-sourcesing-cqrs/src/main/java/com/example/crm/repository/BaseEventRepository.java +++ b/crm-microservice-event-sourcesing-cqrs/src/main/java/com/example/crm/repository/BaseEventRepository.java @@ -14,6 +14,7 @@ */ public interface BaseEventRepository extends MongoRepository { List findAll(PageRequest page); + List findAllByIdentity(String identity); } diff --git a/crm-microservice-event-sourcesing-cqrs/src/main/java/com/example/crm/repository/CustomerRepository.java b/crm-microservice-event-sourcesing-cqrs/src/main/java/com/example/crm/repository/CustomerRepository.java index f308842..53e13a4 100644 --- a/crm-microservice-event-sourcesing-cqrs/src/main/java/com/example/crm/repository/CustomerRepository.java +++ b/crm-microservice-event-sourcesing-cqrs/src/main/java/com/example/crm/repository/CustomerRepository.java @@ -9,6 +9,6 @@ * @author Binnur Kurt * */ -public interface CustomerRepository extends MongoRepository{ - +public interface CustomerRepository extends MongoRepository { + } diff --git a/crm-reactive-microservice/src/main/java/com/example/crm/CrmReactiveMicroserviceApplication.java b/crm-reactive-microservice/src/main/java/com/example/crm/CrmReactiveMicroserviceApplication.java index 5e075dc..ea9908d 100644 --- a/crm-reactive-microservice/src/main/java/com/example/crm/CrmReactiveMicroserviceApplication.java +++ b/crm-reactive-microservice/src/main/java/com/example/crm/CrmReactiveMicroserviceApplication.java @@ -20,17 +20,17 @@ @EnableWebFlux @EnableReactiveMongoRepositories public class CrmReactiveMicroserviceApplication implements ApplicationRunner { - @Autowired private CustomerReactiveRepository customerReactiveRepository; - + @Autowired + private CustomerReactiveRepository customerReactiveRepository; + public static void main(String[] args) { SpringApplication.run(CrmReactiveMicroserviceApplication.class, args); } @Override public void run(ApplicationArguments args) throws Exception { - customerReactiveRepository.findAllFlux(PageRequest.of(0, 10)) - .subscribe(System.err::println); - + customerReactiveRepository.findAllFlux(PageRequest.of(0, 10)).subscribe(System.err::println); + } } diff --git a/crm-reactive-microservice/src/main/java/com/example/crm/repository/CustomerReactiveRepository.java b/crm-reactive-microservice/src/main/java/com/example/crm/repository/CustomerReactiveRepository.java index cfc4c51..b03e120 100644 --- a/crm-reactive-microservice/src/main/java/com/example/crm/repository/CustomerReactiveRepository.java +++ b/crm-reactive-microservice/src/main/java/com/example/crm/repository/CustomerReactiveRepository.java @@ -13,7 +13,7 @@ * @author Binnur Kurt * */ -public interface CustomerReactiveRepository extends ReactiveMongoRepository{ +public interface CustomerReactiveRepository extends ReactiveMongoRepository { @Query("{}") Flux findAllFlux(PageRequest page); diff --git a/hr-microservice-hexagonal/src/main/java/com/example/hr/adapter/EmployeeRepositoryMongoAdapter.java b/hr-microservice-hexagonal/src/main/java/com/example/hr/adapter/EmployeeRepositoryMongoAdapter.java index 30f4ead..76bf41a 100644 --- a/hr-microservice-hexagonal/src/main/java/com/example/hr/adapter/EmployeeRepositoryMongoAdapter.java +++ b/hr-microservice-hexagonal/src/main/java/com/example/hr/adapter/EmployeeRepositoryMongoAdapter.java @@ -22,23 +22,24 @@ */ @Repository @Persistence(PersistenceTarget.MONGO) -public class EmployeeRepositoryMongoAdapter implements EmployeeRepository{ +public class EmployeeRepositoryMongoAdapter implements EmployeeRepository { @Autowired private EmployeeMongoRepository empRepo; @Autowired private ModelMapper mapper; - + @Override public Optional findByIdentity(TcKimlikNo identity) { Optional empDoc = empRepo.findById(identity.getValue()); - if (!empDoc.isEmpty()) return Optional.empty(); + if (!empDoc.isEmpty()) + return Optional.empty(); Employee employee = mapper.map(empDoc.get(), Employee.class); return Optional.of(employee); } @Override public void save(Employee employee) { - //EmployeeDocument empDoc= mapper.map(employee, EmployeeDocument.class); + // EmployeeDocument empDoc= mapper.map(employee, EmployeeDocument.class); EmployeeDocument employeeDocument = new EmployeeDocument(); employeeDocument.setIdentity(employee.getIdentityNo().getValue()); FullName fullname = employee.getFullname(); @@ -54,7 +55,7 @@ public void save(Employee employee) { @Override public void remove(Employee employee) { - empRepo.deleteById(employee.getIdentityNo().getValue()); + empRepo.deleteById(employee.getIdentityNo().getValue()); } } diff --git a/hr-microservice-hexagonal/src/main/java/com/example/hr/meta/Persistence.java b/hr-microservice-hexagonal/src/main/java/com/example/hr/meta/Persistence.java index 7ee6a38..b90bfdb 100644 --- a/hr-microservice-hexagonal/src/main/java/com/example/hr/meta/Persistence.java +++ b/hr-microservice-hexagonal/src/main/java/com/example/hr/meta/Persistence.java @@ -13,8 +13,8 @@ * */ @Retention(RetentionPolicy.RUNTIME) -@Target({ElementType.TYPE, ElementType.PARAMETER, ElementType.FIELD}) +@Target({ ElementType.TYPE, ElementType.PARAMETER, ElementType.FIELD }) @Qualifier public @interface Persistence { - PersistenceTarget value() ; + PersistenceTarget value(); } diff --git a/hr-microservice-hexagonal/src/main/java/com/example/hr/repository/EmployeeJpaRepository.java b/hr-microservice-hexagonal/src/main/java/com/example/hr/repository/EmployeeJpaRepository.java index 8e7f4fa..e2815dd 100644 --- a/hr-microservice-hexagonal/src/main/java/com/example/hr/repository/EmployeeJpaRepository.java +++ b/hr-microservice-hexagonal/src/main/java/com/example/hr/repository/EmployeeJpaRepository.java @@ -13,5 +13,5 @@ * */ public interface EmployeeJpaRepository extends JpaRepository { - List findByBirthYearBetween(int fromYear,int toYear); + List findByBirthYearBetween(int fromYear, int toYear); } diff --git a/hr-microservice-hexagonal/src/main/java/com/example/hr/repository/EmployeeMongoRepository.java b/hr-microservice-hexagonal/src/main/java/com/example/hr/repository/EmployeeMongoRepository.java index f327f5a..ae8231e 100644 --- a/hr-microservice-hexagonal/src/main/java/com/example/hr/repository/EmployeeMongoRepository.java +++ b/hr-microservice-hexagonal/src/main/java/com/example/hr/repository/EmployeeMongoRepository.java @@ -13,9 +13,10 @@ * @author Binnur Kurt * */ -public interface EmployeeMongoRepository extends MongoRepository{ - List findAllByBirthYearBetweenAndDepartment(int fromYear,int toYear,Department department); +public interface EmployeeMongoRepository extends MongoRepository { + List findAllByBirthYearBetweenAndDepartment(int fromYear, int toYear, Department department); + @Query(value = "{'birthYear': {'$gt': ?0, '$lt': ?1}}") - List araBul(int fromYear,int toYear); + List araBul(int fromYear, int toYear); } diff --git a/identity-card-microservice/src/main/java/com/example/IdentityCardMicroserviceApplication.java b/identity-card-microservice/src/main/java/com/example/IdentityCardMicroserviceApplication.java index 408b767..1dae5d7 100644 --- a/identity-card-microservice/src/main/java/com/example/IdentityCardMicroserviceApplication.java +++ b/identity-card-microservice/src/main/java/com/example/IdentityCardMicroserviceApplication.java @@ -3,6 +3,11 @@ import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; +/** + * + * @author Binnur Kurt + * + */ @SpringBootApplication public class IdentityCardMicroserviceApplication { diff --git a/identity-card-microservice/src/main/java/com/example/icard/service/CardService.java b/identity-card-microservice/src/main/java/com/example/icard/service/CardService.java index 0c15bc6..c19c24d 100644 --- a/identity-card-microservice/src/main/java/com/example/icard/service/CardService.java +++ b/identity-card-microservice/src/main/java/com/example/icard/service/CardService.java @@ -7,6 +7,11 @@ import com.example.hr.events.BusinessEvent; +/** + * + * @author Binnur Kurt + * + */ @Service public class CardService { diff --git a/identity-card-microservice/src/main/java/com/example/icard/service/SimpleKafkaConsumer.java b/identity-card-microservice/src/main/java/com/example/icard/service/SimpleKafkaConsumer.java index e839a93..ddff059 100644 --- a/identity-card-microservice/src/main/java/com/example/icard/service/SimpleKafkaConsumer.java +++ b/identity-card-microservice/src/main/java/com/example/icard/service/SimpleKafkaConsumer.java @@ -13,6 +13,11 @@ import com.example.hr.events.BusinessEvent; +/** + * + * @author Binnur Kurt + * + */ @Service public class SimpleKafkaConsumer { private KafkaConsumer kafkaConsumer; diff --git a/lottery-client-java-se/src/com/example/lottery/client/MarketApiHttpClient.java b/lottery-client-java-se/src/com/example/lottery/client/MarketApiHttpClient.java index 7a294fe..9bd9472 100644 --- a/lottery-client-java-se/src/com/example/lottery/client/MarketApiHttpClient.java +++ b/lottery-client-java-se/src/com/example/lottery/client/MarketApiHttpClient.java @@ -7,6 +7,11 @@ import java.net.http.HttpResponse; import java.util.concurrent.TimeUnit; +/** + * + * @author Binnur Kurt + * + */ public class MarketApiHttpClient { private static final String URL = "https://api.binance.com/api/v3/ticker/price?symbol=BTCUSDT"; @@ -14,7 +19,7 @@ public class MarketApiHttpClient { public static void main(String[] args) throws IOException, InterruptedException { var client = HttpClient.newHttpClient(); var request = HttpRequest.newBuilder().uri(URI.create(URL)).header("Accept", "application/json").build(); - while(true) { + while (true) { var response = client.send(request, HttpResponse.BodyHandlers.ofString()).body(); System.out.println(response); TimeUnit.SECONDS.sleep(1); diff --git a/lottery-client-java-se/src/com/example/lottery/client/MarketApiWebsocketClient.java b/lottery-client-java-se/src/com/example/lottery/client/MarketApiWebsocketClient.java index 54c087c..2c24980 100644 --- a/lottery-client-java-se/src/com/example/lottery/client/MarketApiWebsocketClient.java +++ b/lottery-client-java-se/src/com/example/lottery/client/MarketApiWebsocketClient.java @@ -6,12 +6,17 @@ import java.net.http.WebSocket.Listener; import java.util.concurrent.CompletionStage; +/** + * + * @author Binnur Kurt + * + */ public class MarketApiWebsocketClient { private static final String URL = "wss://stream.binance.com:9443/ws/btcusdt@trade"; public static void main(String[] args) throws InterruptedException { Listener listener = new MarketWebsocketListener(); - HttpClient.newHttpClient().newWebSocketBuilder().buildAsync(URI.create(URL),listener); + HttpClient.newHttpClient().newWebSocketBuilder().buildAsync(URI.create(URL), listener); Thread.sleep(60_000); } } @@ -26,9 +31,9 @@ public void onOpen(WebSocket webSocket) { @Override public CompletionStage onText(WebSocket webSocket, CharSequence data, boolean last) { - System.err.println(data); - webSocket.request(1); - return null; + System.err.println(data); + webSocket.request(1); + return null; } @Override @@ -39,7 +44,7 @@ public CompletionStage onClose(WebSocket webSocket, int statusCode, String re @Override public void onError(WebSocket webSocket, Throwable error) { - System.err.println("An error has occured: "+error.getMessage()+" at session "+webSocket); + System.err.println("An error has occured: " + error.getMessage() + " at session " + webSocket); } - + } diff --git a/lottery-consumer-service/src/main/java/com/example/lottery/client/FallbackLotteryService.java b/lottery-consumer-service/src/main/java/com/example/lottery/client/FallbackLotteryService.java index 9b37905..9161298 100644 --- a/lottery-consumer-service/src/main/java/com/example/lottery/client/FallbackLotteryService.java +++ b/lottery-consumer-service/src/main/java/com/example/lottery/client/FallbackLotteryService.java @@ -13,7 +13,8 @@ public class FallbackLotteryService implements LotteryService { @Override public LotteryResponse getLotteryNumbers(int column) { - return new LotteryResponse(IntStream.range(0, column).mapToObj(i -> List.of(1,2,3,4,5,6)).collect(Collectors.toList())); + return new LotteryResponse( + IntStream.range(0, column).mapToObj(i -> List.of(1, 2, 3, 4, 5, 6)).collect(Collectors.toList())); } } diff --git a/lottery-consumer-service/src/main/java/com/example/lottery/client/LotteryService.java b/lottery-consumer-service/src/main/java/com/example/lottery/client/LotteryService.java index 94076ad..8493e41 100644 --- a/lottery-consumer-service/src/main/java/com/example/lottery/client/LotteryService.java +++ b/lottery-consumer-service/src/main/java/com/example/lottery/client/LotteryService.java @@ -6,7 +6,7 @@ import com.example.lottery.dto.LotteryResponse; -@FeignClient(name="lottery",fallback = FallbackLotteryService.class) +@FeignClient(name = "lottery", fallback = FallbackLotteryService.class) public interface LotteryService { @GetMapping("/lottery/api/v1/numbers") LotteryResponse getLotteryNumbers(@RequestParam int column); diff --git a/lottery-consumer-service/src/main/java/com/example/lottery/service/LotteryConsumerServiceWithCircuitBreaker.java b/lottery-consumer-service/src/main/java/com/example/lottery/service/LotteryConsumerServiceWithCircuitBreaker.java index cd95f1f..8fbd606 100644 --- a/lottery-consumer-service/src/main/java/com/example/lottery/service/LotteryConsumerServiceWithCircuitBreaker.java +++ b/lottery-consumer-service/src/main/java/com/example/lottery/service/LotteryConsumerServiceWithCircuitBreaker.java @@ -18,22 +18,23 @@ */ @Service public class LotteryConsumerServiceWithCircuitBreaker { - // integration client -> http -> Rest API (server) - // tomcat -> http/websocket (synchronous) -> (thread pool) - // capacity - // reactive system jetty -> http/websokcet (event queue, asynchronous) -> (thread pool) - // Fixed Thread Pool -> fixed (30) - // Cached Thread Pool -> variable - @CircuitBreaker(name="lotterySrvCircuitBreaker", - fallbackMethod = "getLotteryNumbersFallback") + // integration client -> http -> Rest API (server) + // tomcat -> http/websocket (synchronous) -> (thread pool) + // capacity + // reactive system jetty -> http/websokcet (event queue, asynchronous) -> + // (thread pool) + // Fixed Thread Pool -> fixed (30) + // Cached Thread Pool -> variable + @CircuitBreaker(name = "lotterySrvCircuitBreaker", fallbackMethod = "getLotteryNumbersFallback") public LotteryResponse getNumbers() { System.err.println("Calling lottery service from LotteryClientWithCircuitBreaker..."); RestTemplate rt = new RestTemplate(); return rt.getForObject("http://localhost:8001/lottery/api/v1/numbers?column=10", LotteryResponse.class); } - + public LotteryResponse getLotteryNumbersFallback(Exception e) { System.err.println("getLotteryNumbersFallback()"); - return new LotteryResponse(IntStream.range(0, 5).mapToObj(i -> List.of(1,2,3,4,5,6)).collect(Collectors.toList())); + return new LotteryResponse( + IntStream.range(0, 5).mapToObj(i -> List.of(1, 2, 3, 4, 5, 6)).collect(Collectors.toList())); } } \ No newline at end of file diff --git a/lottery-consumer-service/src/main/java/com/example/lottery/service/StudyRetryStrategy.java b/lottery-consumer-service/src/main/java/com/example/lottery/service/StudyRetryStrategy.java index 16c7dda..103a6f7 100644 --- a/lottery-consumer-service/src/main/java/com/example/lottery/service/StudyRetryStrategy.java +++ b/lottery-consumer-service/src/main/java/com/example/lottery/service/StudyRetryStrategy.java @@ -20,7 +20,7 @@ @Service public class StudyRetryStrategy { - @Retryable(value = { SocketTimeoutException.class, // exponential backoff: 2^{n} * 3 seconds + @Retryable(value = { SocketTimeoutException.class, // exponential backoff: 2^{n} * 3 seconds SocketException.class }, maxAttempts = 3, backoff = @Backoff(multiplier = 2, delay = 3_000)) public LotteryResponse getNumbers() { System.err.println("Calling lottery service from StudyRetryStrategy..."); diff --git a/lottery-microservice-v1/src/main/java/com/example/lottery/LotteryMicroserviceV1Application.java b/lottery-microservice-v1/src/main/java/com/example/lottery/LotteryMicroserviceV1Application.java index ee85981..d497708 100644 --- a/lottery-microservice-v1/src/main/java/com/example/lottery/LotteryMicroserviceV1Application.java +++ b/lottery-microservice-v1/src/main/java/com/example/lottery/LotteryMicroserviceV1Application.java @@ -3,6 +3,11 @@ import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; +/** + * + * @author Binnur Kurt + * + */ @SpringBootApplication public class LotteryMicroserviceV1Application { diff --git a/lottery-microservice-v1/src/main/java/com/example/lottery/config/WebSecurityConfig.java b/lottery-microservice-v1/src/main/java/com/example/lottery/config/WebSecurityConfig.java index 2eb0972..8235793 100644 --- a/lottery-microservice-v1/src/main/java/com/example/lottery/config/WebSecurityConfig.java +++ b/lottery-microservice-v1/src/main/java/com/example/lottery/config/WebSecurityConfig.java @@ -16,6 +16,11 @@ import com.example.lottery.filter.JwtTokenFilter; +/** + * + * @author Binnur Kurt + * + */ @Configuration public class WebSecurityConfig extends WebSecurityConfigurerAdapter { @@ -23,15 +28,15 @@ public class WebSecurityConfig extends WebSecurityConfigurerAdapter { private UserDetailsService userDetailsService; @Value("${security.jwt.token.secret-key}") private String secret; - + @Override protected void configure(HttpSecurity http) throws Exception { System.out.println("configurating security..."); http.csrf().disable().authorizeRequests().antMatchers("/signin").permitAll().anyRequest().authenticated().and() .sessionManagement().sessionCreationPolicy(SessionCreationPolicy.STATELESS); - - - http.addFilterBefore(new JwtTokenFilter(userDetailsService, secret), UsernamePasswordAuthenticationFilter.class); + + http.addFilterBefore(new JwtTokenFilter(userDetailsService, secret), + UsernamePasswordAuthenticationFilter.class); } diff --git a/lottery-microservice-v1/src/main/java/com/example/lottery/controller/LoginController.java b/lottery-microservice-v1/src/main/java/com/example/lottery/controller/LoginController.java index be5889d..7ebe12a 100644 --- a/lottery-microservice-v1/src/main/java/com/example/lottery/controller/LoginController.java +++ b/lottery-microservice-v1/src/main/java/com/example/lottery/controller/LoginController.java @@ -14,6 +14,11 @@ import com.example.lottery.dto.WebUser; import com.example.lottery.provider.JwtTokenProvider; +/** + * + * @author Binnur Kurt + * + */ @RestController @RequestScope @RequestMapping("signin") diff --git a/lottery-microservice-v1/src/main/java/com/example/lottery/controller/LotteryRestController.java b/lottery-microservice-v1/src/main/java/com/example/lottery/controller/LotteryRestController.java index 04fac26..68863f1 100644 --- a/lottery-microservice-v1/src/main/java/com/example/lottery/controller/LotteryRestController.java +++ b/lottery-microservice-v1/src/main/java/com/example/lottery/controller/LotteryRestController.java @@ -13,22 +13,27 @@ import com.example.lottery.dto.LotteryResponse; import com.example.lottery.service.LotteryService; +/** + * + * @author Binnur Kurt + * + */ @RestController @RequestScope @RequestMapping("numbers") @CrossOrigin public class LotteryRestController { - @Autowired + @Autowired private LotteryService lotteryService; - @Value("${server.address}") + @Value("${server.address}") private String host; - @Value("${server.port}") + @Value("${server.port}") private int port; // GET http://localhost:8001/lottery/api/v1/numbers?column=10 - @GetMapping(params = {"column"},produces = MediaType.APPLICATION_JSON_VALUE) - public LotteryResponse getNumbers(@RequestParam int column){ - System.err.println(String.format("Lottery Service @ %s:%d is serving now...",host,port)); + @GetMapping(params = { "column" }, produces = MediaType.APPLICATION_JSON_VALUE) + public LotteryResponse getNumbers(@RequestParam int column) { + System.err.println(String.format("Lottery Service @ %s:%d is serving now...", host, port)); return new LotteryResponse(lotteryService.draw(column)); } } diff --git a/lottery-microservice-v1/src/main/java/com/example/lottery/dto/LotteryResponse.java b/lottery-microservice-v1/src/main/java/com/example/lottery/dto/LotteryResponse.java index 40c85ef..fc3f0b7 100644 --- a/lottery-microservice-v1/src/main/java/com/example/lottery/dto/LotteryResponse.java +++ b/lottery-microservice-v1/src/main/java/com/example/lottery/dto/LotteryResponse.java @@ -2,6 +2,11 @@ import java.util.List; +/** + * + * @author Binnur Kurt + * + */ public class LotteryResponse { private List> numbers; diff --git a/lottery-microservice-v1/src/main/java/com/example/lottery/dto/WebUser.java b/lottery-microservice-v1/src/main/java/com/example/lottery/dto/WebUser.java index 83c4d7c..baf0ef0 100644 --- a/lottery-microservice-v1/src/main/java/com/example/lottery/dto/WebUser.java +++ b/lottery-microservice-v1/src/main/java/com/example/lottery/dto/WebUser.java @@ -2,6 +2,11 @@ import javax.validation.constraints.NotNull; +/** + * + * @author Binnur Kurt + * + */ public class WebUser { @NotNull private String username; diff --git a/lottery-microservice-v1/src/main/java/com/example/lottery/filter/JwtTokenFilter.java b/lottery-microservice-v1/src/main/java/com/example/lottery/filter/JwtTokenFilter.java index d163563..b1f5ca2 100644 --- a/lottery-microservice-v1/src/main/java/com/example/lottery/filter/JwtTokenFilter.java +++ b/lottery-microservice-v1/src/main/java/com/example/lottery/filter/JwtTokenFilter.java @@ -22,53 +22,58 @@ import io.jsonwebtoken.Claims; import io.jsonwebtoken.Jwts; +/** + * + * @author Binnur Kurt + * + */ public class JwtTokenFilter extends GenericFilterBean { private String secret; - private static final String BEARER = "Bearer"; + private static final String BEARER = "Bearer"; - private UserDetailsService userDetailsService; + private UserDetailsService userDetailsService; - public JwtTokenFilter(UserDetailsService userDetailsService, String secret) { - this.userDetailsService = userDetailsService; - this.secret = Base64.getEncoder().encodeToString(secret.getBytes()); - } + public JwtTokenFilter(UserDetailsService userDetailsService, String secret) { + this.userDetailsService = userDetailsService; + this.secret = Base64.getEncoder().encodeToString(secret.getBytes()); + } - @Override - public void doFilter(ServletRequest req, ServletResponse res, FilterChain filterChain) - throws IOException, ServletException { - System.err.println("doFilter()"); - String headerValue = ((HttpServletRequest)req).getHeader("Authorization"); - getBearerToken(headerValue).ifPresent(token-> { - String username = getClaimFromToken(token, Claims::getSubject); - UserDetails userDetails = userDetailsService.loadUserByUsername(username); + @Override + public void doFilter(ServletRequest req, ServletResponse res, FilterChain filterChain) + throws IOException, ServletException { + System.err.println("doFilter()"); + String headerValue = ((HttpServletRequest) req).getHeader("Authorization"); + getBearerToken(headerValue).ifPresent(token -> { + String username = getClaimFromToken(token, Claims::getSubject); + UserDetails userDetails = userDetailsService.loadUserByUsername(username); - if (username.equals(userDetails.getUsername()) && !isJwtExpired(token)) { - UsernamePasswordAuthenticationToken usernamePasswordAuthenticationToken = - new UsernamePasswordAuthenticationToken(userDetails, null, userDetails.getAuthorities()); - usernamePasswordAuthenticationToken.setDetails( - new WebAuthenticationDetailsSource().buildDetails((HttpServletRequest)req)); - SecurityContextHolder.getContext().setAuthentication(usernamePasswordAuthenticationToken); - } - }); + if (username.equals(userDetails.getUsername()) && !isJwtExpired(token)) { + UsernamePasswordAuthenticationToken usernamePasswordAuthenticationToken = new UsernamePasswordAuthenticationToken( + userDetails, null, userDetails.getAuthorities()); + usernamePasswordAuthenticationToken + .setDetails(new WebAuthenticationDetailsSource().buildDetails((HttpServletRequest) req)); + SecurityContextHolder.getContext().setAuthentication(usernamePasswordAuthenticationToken); + } + }); - filterChain.doFilter(req, res); - } + filterChain.doFilter(req, res); + } - private Optional getBearerToken(String headerVal) { - if (headerVal != null && headerVal.startsWith(BEARER)) { - return Optional.of(headerVal.replace(BEARER, "").trim()); - } - return Optional.empty(); - } + private Optional getBearerToken(String headerVal) { + if (headerVal != null && headerVal.startsWith(BEARER)) { + return Optional.of(headerVal.replace(BEARER, "").trim()); + } + return Optional.empty(); + } - private T getClaimFromToken(String token, Function claimsResolver) { - final Claims claims = Jwts.parser().setSigningKey(secret).parseClaimsJws(token).getBody(); - return claimsResolver.apply(claims); - } + private T getClaimFromToken(String token, Function claimsResolver) { + final Claims claims = Jwts.parser().setSigningKey(secret).parseClaimsJws(token).getBody(); + return claimsResolver.apply(claims); + } - private Boolean isJwtExpired(String token) { - Date expirationDate = getClaimFromToken(token, Claims::getExpiration); - return expirationDate.before(new Date()); - } + private Boolean isJwtExpired(String token) { + Date expirationDate = getClaimFromToken(token, Claims::getExpiration); + return expirationDate.before(new Date()); + } } \ No newline at end of file diff --git a/lottery-microservice-v1/src/main/java/com/example/lottery/provider/JwtTokenProvider.java b/lottery-microservice-v1/src/main/java/com/example/lottery/provider/JwtTokenProvider.java index e5f884a..3b963c5 100644 --- a/lottery-microservice-v1/src/main/java/com/example/lottery/provider/JwtTokenProvider.java +++ b/lottery-microservice-v1/src/main/java/com/example/lottery/provider/JwtTokenProvider.java @@ -11,6 +11,11 @@ import io.jsonwebtoken.Jwts; import io.jsonwebtoken.SignatureAlgorithm; +/** + * + * @author Binnur Kurt + * + */ @Service public class JwtTokenProvider { diff --git a/lottery-microservice-v1/src/main/java/com/example/lottery/service/LotteryService.java b/lottery-microservice-v1/src/main/java/com/example/lottery/service/LotteryService.java index a56f0c2..4410417 100644 --- a/lottery-microservice-v1/src/main/java/com/example/lottery/service/LotteryService.java +++ b/lottery-microservice-v1/src/main/java/com/example/lottery/service/LotteryService.java @@ -2,6 +2,11 @@ import java.util.List; +/** + * + * @author Binnur Kurt + * + */ public interface LotteryService { List> draw(int column); diff --git a/lottery-microservice-v1/src/main/java/com/example/lottery/service/business/SimpleLotteryService.java b/lottery-microservice-v1/src/main/java/com/example/lottery/service/business/SimpleLotteryService.java index 609a09b..9866793 100644 --- a/lottery-microservice-v1/src/main/java/com/example/lottery/service/business/SimpleLotteryService.java +++ b/lottery-microservice-v1/src/main/java/com/example/lottery/service/business/SimpleLotteryService.java @@ -10,29 +10,28 @@ import com.example.lottery.service.LotteryService; +/** + * + * @author Binnur Kurt + * + */ @Service -public class SimpleLotteryService implements LotteryService{ - @Value("${lottery.min}") +public class SimpleLotteryService implements LotteryService { + @Value("${lottery.min}") private int lotteryMin; - @Value("${lottery.max}") + @Value("${lottery.max}") private int lotteryMax; - @Value("${lottery.size}") + @Value("${lottery.size}") private int lotterySize; - + public List draw() { - return ThreadLocalRandom.current().ints(lotteryMin, lotteryMax) - .distinct() - .limit(lotterySize) - .sorted() - .boxed() - .collect(Collectors.toList()); + return ThreadLocalRandom.current().ints(lotteryMin, lotteryMax).distinct().limit(lotterySize).sorted().boxed() + .collect(Collectors.toList()); } - + @Override public List> draw(int column) { - return IntStream.range(0, column) - .mapToObj(i -> this.draw()) - .collect(Collectors.toList()); + return IntStream.range(0, column).mapToObj(i -> this.draw()).collect(Collectors.toList()); } } diff --git a/lottery-microservice-v2/src/main/java/com/example/lottery/LotteryMicroserviceV2Application.java b/lottery-microservice-v2/src/main/java/com/example/lottery/LotteryMicroserviceV2Application.java index 57e181e..1870352 100644 --- a/lottery-microservice-v2/src/main/java/com/example/lottery/LotteryMicroserviceV2Application.java +++ b/lottery-microservice-v2/src/main/java/com/example/lottery/LotteryMicroserviceV2Application.java @@ -3,6 +3,11 @@ import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; +/** + * + * @author Binnur Kurt + * + */ @SpringBootApplication public class LotteryMicroserviceV2Application { diff --git a/lottery-microservice-v2/src/main/java/com/example/lottery/controller/LotteryRestController.java b/lottery-microservice-v2/src/main/java/com/example/lottery/controller/LotteryRestController.java index 04fac26..68863f1 100644 --- a/lottery-microservice-v2/src/main/java/com/example/lottery/controller/LotteryRestController.java +++ b/lottery-microservice-v2/src/main/java/com/example/lottery/controller/LotteryRestController.java @@ -13,22 +13,27 @@ import com.example.lottery.dto.LotteryResponse; import com.example.lottery.service.LotteryService; +/** + * + * @author Binnur Kurt + * + */ @RestController @RequestScope @RequestMapping("numbers") @CrossOrigin public class LotteryRestController { - @Autowired + @Autowired private LotteryService lotteryService; - @Value("${server.address}") + @Value("${server.address}") private String host; - @Value("${server.port}") + @Value("${server.port}") private int port; // GET http://localhost:8001/lottery/api/v1/numbers?column=10 - @GetMapping(params = {"column"},produces = MediaType.APPLICATION_JSON_VALUE) - public LotteryResponse getNumbers(@RequestParam int column){ - System.err.println(String.format("Lottery Service @ %s:%d is serving now...",host,port)); + @GetMapping(params = { "column" }, produces = MediaType.APPLICATION_JSON_VALUE) + public LotteryResponse getNumbers(@RequestParam int column) { + System.err.println(String.format("Lottery Service @ %s:%d is serving now...", host, port)); return new LotteryResponse(lotteryService.draw(column)); } } diff --git a/lottery-microservice-v2/src/main/java/com/example/lottery/dto/LotteryResponse.java b/lottery-microservice-v2/src/main/java/com/example/lottery/dto/LotteryResponse.java index 40c85ef..fc3f0b7 100644 --- a/lottery-microservice-v2/src/main/java/com/example/lottery/dto/LotteryResponse.java +++ b/lottery-microservice-v2/src/main/java/com/example/lottery/dto/LotteryResponse.java @@ -2,6 +2,11 @@ import java.util.List; +/** + * + * @author Binnur Kurt + * + */ public class LotteryResponse { private List> numbers; diff --git a/lottery-microservice-v2/src/main/java/com/example/lottery/service/LotteryService.java b/lottery-microservice-v2/src/main/java/com/example/lottery/service/LotteryService.java index a56f0c2..4410417 100644 --- a/lottery-microservice-v2/src/main/java/com/example/lottery/service/LotteryService.java +++ b/lottery-microservice-v2/src/main/java/com/example/lottery/service/LotteryService.java @@ -2,6 +2,11 @@ import java.util.List; +/** + * + * @author Binnur Kurt + * + */ public interface LotteryService { List> draw(int column); diff --git a/lottery-microservice-v2/src/main/java/com/example/lottery/service/business/SimpleLotteryService.java b/lottery-microservice-v2/src/main/java/com/example/lottery/service/business/SimpleLotteryService.java index 609a09b..9866793 100644 --- a/lottery-microservice-v2/src/main/java/com/example/lottery/service/business/SimpleLotteryService.java +++ b/lottery-microservice-v2/src/main/java/com/example/lottery/service/business/SimpleLotteryService.java @@ -10,29 +10,28 @@ import com.example.lottery.service.LotteryService; +/** + * + * @author Binnur Kurt + * + */ @Service -public class SimpleLotteryService implements LotteryService{ - @Value("${lottery.min}") +public class SimpleLotteryService implements LotteryService { + @Value("${lottery.min}") private int lotteryMin; - @Value("${lottery.max}") + @Value("${lottery.max}") private int lotteryMax; - @Value("${lottery.size}") + @Value("${lottery.size}") private int lotterySize; - + public List draw() { - return ThreadLocalRandom.current().ints(lotteryMin, lotteryMax) - .distinct() - .limit(lotterySize) - .sorted() - .boxed() - .collect(Collectors.toList()); + return ThreadLocalRandom.current().ints(lotteryMin, lotteryMax).distinct().limit(lotterySize).sorted().boxed() + .collect(Collectors.toList()); } - + @Override public List> draw(int column) { - return IntStream.range(0, column) - .mapToObj(i -> this.draw()) - .collect(Collectors.toList()); + return IntStream.range(0, column).mapToObj(i -> this.draw()).collect(Collectors.toList()); } } diff --git a/lottery-microservice/src/main/java/com/example/lottery/LotteryMicroserviceApplication.java b/lottery-microservice/src/main/java/com/example/lottery/LotteryMicroserviceApplication.java index 1b13bbb..a67dc42 100644 --- a/lottery-microservice/src/main/java/com/example/lottery/LotteryMicroserviceApplication.java +++ b/lottery-microservice/src/main/java/com/example/lottery/LotteryMicroserviceApplication.java @@ -5,6 +5,11 @@ import org.springframework.cloud.client.discovery.EnableDiscoveryClient; import org.springframework.cloud.netflix.eureka.EnableEurekaClient; +/** + * + * @author Binnur Kurt + * + */ // set PATH=c:\DEVEL\stage\opt\curl-7.45.0\bin;%PATH% // curl localhost:8001/lottery/api/v1/actuator/refresh -X POST -d {} -H "Content-Type: application/json" @SpringBootApplication diff --git a/lottery-microservice/src/main/java/com/example/lottery/controller/LotteryRestController.java b/lottery-microservice/src/main/java/com/example/lottery/controller/LotteryRestController.java index 04fac26..68863f1 100644 --- a/lottery-microservice/src/main/java/com/example/lottery/controller/LotteryRestController.java +++ b/lottery-microservice/src/main/java/com/example/lottery/controller/LotteryRestController.java @@ -13,22 +13,27 @@ import com.example.lottery.dto.LotteryResponse; import com.example.lottery.service.LotteryService; +/** + * + * @author Binnur Kurt + * + */ @RestController @RequestScope @RequestMapping("numbers") @CrossOrigin public class LotteryRestController { - @Autowired + @Autowired private LotteryService lotteryService; - @Value("${server.address}") + @Value("${server.address}") private String host; - @Value("${server.port}") + @Value("${server.port}") private int port; // GET http://localhost:8001/lottery/api/v1/numbers?column=10 - @GetMapping(params = {"column"},produces = MediaType.APPLICATION_JSON_VALUE) - public LotteryResponse getNumbers(@RequestParam int column){ - System.err.println(String.format("Lottery Service @ %s:%d is serving now...",host,port)); + @GetMapping(params = { "column" }, produces = MediaType.APPLICATION_JSON_VALUE) + public LotteryResponse getNumbers(@RequestParam int column) { + System.err.println(String.format("Lottery Service @ %s:%d is serving now...", host, port)); return new LotteryResponse(lotteryService.draw(column)); } } diff --git a/lottery-microservice/src/main/java/com/example/lottery/dto/LotteryResponse.java b/lottery-microservice/src/main/java/com/example/lottery/dto/LotteryResponse.java index 40c85ef..fc3f0b7 100644 --- a/lottery-microservice/src/main/java/com/example/lottery/dto/LotteryResponse.java +++ b/lottery-microservice/src/main/java/com/example/lottery/dto/LotteryResponse.java @@ -2,6 +2,11 @@ import java.util.List; +/** + * + * @author Binnur Kurt + * + */ public class LotteryResponse { private List> numbers; diff --git a/lottery-microservice/src/main/java/com/example/lottery/service/LotteryService.java b/lottery-microservice/src/main/java/com/example/lottery/service/LotteryService.java index a56f0c2..4410417 100644 --- a/lottery-microservice/src/main/java/com/example/lottery/service/LotteryService.java +++ b/lottery-microservice/src/main/java/com/example/lottery/service/LotteryService.java @@ -2,6 +2,11 @@ import java.util.List; +/** + * + * @author Binnur Kurt + * + */ public interface LotteryService { List> draw(int column); diff --git a/lottery-microservice/src/main/java/com/example/lottery/service/business/SimpleLotteryService.java b/lottery-microservice/src/main/java/com/example/lottery/service/business/SimpleLotteryService.java index 7380b9c..7c82321 100644 --- a/lottery-microservice/src/main/java/com/example/lottery/service/business/SimpleLotteryService.java +++ b/lottery-microservice/src/main/java/com/example/lottery/service/business/SimpleLotteryService.java @@ -11,32 +11,31 @@ import com.example.lottery.service.LotteryService; +/** + * + * @author Binnur Kurt + * + */ // set PATH=c:\DEVEL\stage\opt\curl-7.45.0\bin;%PATH% // curl localhost:8001/lottery/api/v1/actuator/refresh -X POST -d {} -H "Content-Type: application/json" @Service @RefreshScope // Spring Actuator -> REST POST -public class SimpleLotteryService implements LotteryService{ - @Value("${lottery.min}") +public class SimpleLotteryService implements LotteryService { + @Value("${lottery.min}") private int lotteryMin; - @Value("${lottery.max}") + @Value("${lottery.max}") private int lotteryMax; - @Value("${lottery.size}") + @Value("${lottery.size}") private int lotterySize; - + public List draw() { - return ThreadLocalRandom.current().ints(lotteryMin, lotteryMax) - .distinct() - .limit(lotterySize) - .sorted() - .boxed() - .collect(Collectors.toList()); + return ThreadLocalRandom.current().ints(lotteryMin, lotteryMax).distinct().limit(lotterySize).sorted().boxed() + .collect(Collectors.toList()); } - + @Override public List> draw(int column) { - return IntStream.range(0, column) - .mapToObj(i -> this.draw()) - .collect(Collectors.toList()); + return IntStream.range(0, column).mapToObj(i -> this.draw()).collect(Collectors.toList()); } } diff --git a/market-stomp-client-spring-boot/src/main/java/com/example/MarketStompClientSpringBootApplication.java b/market-stomp-client-spring-boot/src/main/java/com/example/MarketStompClientSpringBootApplication.java index 54585b5..8b7e8d4 100644 --- a/market-stomp-client-spring-boot/src/main/java/com/example/MarketStompClientSpringBootApplication.java +++ b/market-stomp-client-spring-boot/src/main/java/com/example/MarketStompClientSpringBootApplication.java @@ -3,6 +3,11 @@ import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; +/** + * + * @author Binnur Kurt + * + */ @SpringBootApplication public class MarketStompClientSpringBootApplication { diff --git a/market-stomp-client-spring-boot/src/main/java/com/example/config/AppConfig.java b/market-stomp-client-spring-boot/src/main/java/com/example/config/AppConfig.java index 59d57ba..538473d 100644 --- a/market-stomp-client-spring-boot/src/main/java/com/example/config/AppConfig.java +++ b/market-stomp-client-spring-boot/src/main/java/com/example/config/AppConfig.java @@ -13,13 +13,18 @@ import org.springframework.web.socket.sockjs.client.Transport; import org.springframework.web.socket.sockjs.client.WebSocketTransport; +/** + * + * @author Binnur Kurt + * + */ @Configuration public class AppConfig { @Bean public WebSocketClient webSocketClient() { return new StandardWebSocketClient(); } - + @Bean public WebSocketStompClient webSocketStompClient(WebSocketClient client) { List transports = new ArrayList<>(1); diff --git a/market-stomp-client-spring-boot/src/main/java/com/example/event/TradeEvent.java b/market-stomp-client-spring-boot/src/main/java/com/example/event/TradeEvent.java index 242abc0..e19f5e8 100644 --- a/market-stomp-client-spring-boot/src/main/java/com/example/event/TradeEvent.java +++ b/market-stomp-client-spring-boot/src/main/java/com/example/event/TradeEvent.java @@ -2,8 +2,13 @@ import com.fasterxml.jackson.annotation.JsonProperty; +/** + * + * @author Binnur Kurt + * + */ public class TradeEvent { - private String id; + private String id; @JsonProperty("s") private String symbol; @JsonProperty("p") @@ -92,5 +97,4 @@ public String toString() { + ", timestamp=" + timestamp + ", eventId=" + eventId + ", askId=" + askId + ", bidId=" + bidId + "]"; } - } diff --git a/market-stomp-client-spring-boot/src/main/java/com/example/service/MarketStompClientService.java b/market-stomp-client-spring-boot/src/main/java/com/example/service/MarketStompClientService.java index 120688f..ed2bfd3 100644 --- a/market-stomp-client-spring-boot/src/main/java/com/example/service/MarketStompClientService.java +++ b/market-stomp-client-spring-boot/src/main/java/com/example/service/MarketStompClientService.java @@ -15,6 +15,11 @@ import com.example.event.TradeEvent; +/** + * + * @author Binnur Kurt + * + */ @Service public class MarketStompClientService implements StompSessionHandler { @Autowired diff --git a/market-websocket-client-spring-boot/src/main/java/com/example/MarketWebsocketClientSpringBootApplication.java b/market-websocket-client-spring-boot/src/main/java/com/example/MarketWebsocketClientSpringBootApplication.java index 14dd669..2a09ad9 100644 --- a/market-websocket-client-spring-boot/src/main/java/com/example/MarketWebsocketClientSpringBootApplication.java +++ b/market-websocket-client-spring-boot/src/main/java/com/example/MarketWebsocketClientSpringBootApplication.java @@ -3,6 +3,11 @@ import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; +/** + * + * @author Binnur Kurt + * + */ @SpringBootApplication public class MarketWebsocketClientSpringBootApplication { diff --git a/market-websocket-client-spring-boot/src/main/java/com/example/config/WebsocketClientConfig.java b/market-websocket-client-spring-boot/src/main/java/com/example/config/WebsocketClientConfig.java index d8d6949..deddb6c 100644 --- a/market-websocket-client-spring-boot/src/main/java/com/example/config/WebsocketClientConfig.java +++ b/market-websocket-client-spring-boot/src/main/java/com/example/config/WebsocketClientConfig.java @@ -5,6 +5,11 @@ import org.springframework.web.socket.client.WebSocketClient; import org.springframework.web.socket.client.standard.StandardWebSocketClient; +/** + * + * @author Binnur Kurt + * + */ @Configuration public class WebsocketClientConfig { @Bean diff --git a/market-websocket-client-spring-boot/src/main/java/com/example/config/WebsocketConfig.java b/market-websocket-client-spring-boot/src/main/java/com/example/config/WebsocketConfig.java index 7e1ffe6..4e9caff 100644 --- a/market-websocket-client-spring-boot/src/main/java/com/example/config/WebsocketConfig.java +++ b/market-websocket-client-spring-boot/src/main/java/com/example/config/WebsocketConfig.java @@ -6,6 +6,11 @@ import org.springframework.web.socket.config.annotation.StompEndpointRegistry; import org.springframework.web.socket.config.annotation.WebSocketMessageBrokerConfigurer; +/** + * + * @author Binnur Kurt + * + */ @Configuration @EnableWebSocketMessageBroker public class WebsocketConfig implements WebSocketMessageBrokerConfigurer { diff --git a/market-websocket-client-spring-boot/src/main/java/com/example/event/TradeEvent.java b/market-websocket-client-spring-boot/src/main/java/com/example/event/TradeEvent.java index c127822..930c398 100644 --- a/market-websocket-client-spring-boot/src/main/java/com/example/event/TradeEvent.java +++ b/market-websocket-client-spring-boot/src/main/java/com/example/event/TradeEvent.java @@ -5,10 +5,15 @@ import com.fasterxml.jackson.annotation.JsonProperty; -@Document(collection = "trades") +/** + * + * @author Binnur Kurt + * + */ +@Document(collection = "trades") public class TradeEvent { @Id - private String id; + private String id; @JsonProperty("s") private String symbol; @JsonProperty("p") @@ -97,6 +102,4 @@ public String toString() { + ", timestamp=" + timestamp + ", eventId=" + eventId + ", askId=" + askId + ", bidId=" + bidId + "]"; } - - } diff --git a/market-websocket-client-spring-boot/src/main/java/com/example/repository/TradeEventRepository.java b/market-websocket-client-spring-boot/src/main/java/com/example/repository/TradeEventRepository.java index 4f0f14b..5c4b753 100644 --- a/market-websocket-client-spring-boot/src/main/java/com/example/repository/TradeEventRepository.java +++ b/market-websocket-client-spring-boot/src/main/java/com/example/repository/TradeEventRepository.java @@ -4,6 +4,11 @@ import com.example.event.TradeEvent; +/** + * + * @author Binnur Kurt + * + */ public interface TradeEventRepository extends MongoRepository { } diff --git a/market-websocket-client-spring-boot/src/main/java/com/example/service/MarketClientService.java b/market-websocket-client-spring-boot/src/main/java/com/example/service/MarketClientService.java index 35b7d5e..1e3bb99 100644 --- a/market-websocket-client-spring-boot/src/main/java/com/example/service/MarketClientService.java +++ b/market-websocket-client-spring-boot/src/main/java/com/example/service/MarketClientService.java @@ -15,13 +15,22 @@ import com.example.event.TradeEvent; import com.fasterxml.jackson.databind.ObjectMapper; +/** + * + * @author Binnur Kurt + * + */ @Service public class MarketClientService implements WebSocketHandler { - @Autowired private WebSocketClient websocketClient; - @Value("${market.url}") private String marketUrl; - @Autowired private ObjectMapper mapper; - @Autowired private ApplicationEventPublisher eventPublisher; - + @Autowired + private WebSocketClient websocketClient; + @Value("${market.url}") + private String marketUrl; + @Autowired + private ObjectMapper mapper; + @Autowired + private ApplicationEventPublisher eventPublisher; + @PostConstruct public void init() { websocketClient.doHandshake(this, marketUrl); @@ -35,13 +44,13 @@ public void afterConnectionEstablished(WebSocketSession session) throws Exceptio @Override public void handleMessage(WebSocketSession session, WebSocketMessage message) throws Exception { String payload = message.getPayload().toString(); - TradeEvent trade = mapper.readValue(payload,TradeEvent.class); + TradeEvent trade = mapper.readValue(payload, TradeEvent.class); eventPublisher.publishEvent(trade); } @Override public void handleTransportError(WebSocketSession session, Throwable exception) throws Exception { - System.err.println("An error has occurred: "+exception.getMessage()); + System.err.println("An error has occurred: " + exception.getMessage()); } @Override @@ -53,6 +62,5 @@ public void afterConnectionClosed(WebSocketSession session, CloseStatus closeSta public boolean supportsPartialMessages() { return false; } - - + } diff --git a/market-websocket-client-spring-boot/src/main/java/com/example/service/TradeMongoService.java b/market-websocket-client-spring-boot/src/main/java/com/example/service/TradeMongoService.java index 87236f9..36c891d 100644 --- a/market-websocket-client-spring-boot/src/main/java/com/example/service/TradeMongoService.java +++ b/market-websocket-client-spring-boot/src/main/java/com/example/service/TradeMongoService.java @@ -7,14 +7,19 @@ import com.example.event.TradeEvent; import com.example.repository.TradeEventRepository; +/** + * + * @author Binnur Kurt + * + */ @Service public class TradeMongoService { @Autowired private TradeEventRepository repository; - + @EventListener public void handleEvent(TradeEvent trade) { repository.save(trade); - System.err.println("TradeMongoService has received one trade event: "+trade); + System.err.println("TradeMongoService has received one trade event: " + trade); } } diff --git a/market-websocket-client-spring-boot/src/main/java/com/example/service/TradeWebsocketService.java b/market-websocket-client-spring-boot/src/main/java/com/example/service/TradeWebsocketService.java index 748ad0e..e8e9a43 100644 --- a/market-websocket-client-spring-boot/src/main/java/com/example/service/TradeWebsocketService.java +++ b/market-websocket-client-spring-boot/src/main/java/com/example/service/TradeWebsocketService.java @@ -7,15 +7,20 @@ import com.example.event.TradeEvent; +/** + * + * @author Binnur Kurt + * + */ @Service public class TradeWebsocketService { @Autowired private SimpMessagingTemplate template; - + @EventListener public void handleEvent(TradeEvent trade) { - System.err.println("TradeWebsocketService has received one trade event: "+trade); - template.convertAndSend("/topic/changes", trade); + System.err.println("TradeWebsocketService has received one trade event: " + trade); + template.convertAndSend("/topic/changes", trade); } } diff --git a/reactive-gateway/src/main/java/com/example/ReactiveGatewayApplication.java b/reactive-gateway/src/main/java/com/example/ReactiveGatewayApplication.java index f1fadf4..0416732 100644 --- a/reactive-gateway/src/main/java/com/example/ReactiveGatewayApplication.java +++ b/reactive-gateway/src/main/java/com/example/ReactiveGatewayApplication.java @@ -3,6 +3,11 @@ import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; +/** + * + * @author Binnur Kurt + * + */ @SpringBootApplication public class ReactiveGatewayApplication { diff --git a/registry-service/src/main/java/com/example/RegistryServiceApplication.java b/registry-service/src/main/java/com/example/RegistryServiceApplication.java index e28ef0b..6737073 100644 --- a/registry-service/src/main/java/com/example/RegistryServiceApplication.java +++ b/registry-service/src/main/java/com/example/RegistryServiceApplication.java @@ -4,6 +4,11 @@ import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer; +/** + * + * @author Binnur Kurt + * + */ @SpringBootApplication @EnableEurekaServer public class RegistryServiceApplication {