Skip to content

Instantly share code, notes, and snippets.

View ru-rocker's full-sized avatar

ru rocker ru-rocker

View GitHub Profile
ru-rocker /
Last active April 8, 2024 17:19
SpringWebFlux Unit Test with MockWebServer from OkHttp
public class TokenValidatorServiceImpl implements TokenValidatorService {
private String fileAttUrlPath;
private String fileAttRoute;
private ClientProperties clientProperties;
private final WebClient.Builder webClientBuilder;
# sample for lifecycle config
variable "bucket_lifecycle_config" {
type = list(any)
description = "Bucket lifecycle. Set empty list if you want to ignore the lifecycle configuration."
default = []
bucket_lifecycle_config = [{
"id" = "DisposePLIST"
"prefix" = "disposable"
apiVersion: apps/v1
kind: Deployment
name: mock-endpoint
namespace: ns1
name: mock-endpoint
import org.apache.commons.lang.StringUtils;
import java.lang.reflect.Field;
import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
import java.sql.Timestamp;
import java.util.Date;
import java.util.Set;
import static org.assertj.core.api.Assertions.assertThat;
packer {
required_plugins {
amazon = {
version = ">= 0.0.2"
source = ""
source "amazon-ebs" "centos7" {
ru-rocker /
Last active April 26, 2021 13:33
CDK CloudWatch Lambda Java
// snippet code
public void process(RequestDto requestDto) {
if(reentrantLock.isLocked()) {"Another thread is processing the processor!");
vim ~/.aws/config
region = ap-southeast-1
vim ~/.aws/credentials
aws_access_key_id = XXXXXXXX
aws_secret_access_key = YYYYYYYYYYYYYYYY
Scenario Outline: Accumulative transaction during 5 minutes interval: amount above $1500 then notify
Given Customer has a credit card with account number "<cc>"
When Customer transacts $<amount1> at "<event1>"
And Customer transacts $<amount2> at "<event2>"
And Customer transacts $<amount3> at "<event3>"
Then Fraud flag is "<flag>"
And total suspicious amount is $<total>
public class AuctionProcessor implements Processor<String, AuctionDto> {
private KeyValueStore<String, AuctionDto> kvStore;
private ProcessorContext context;
public void init(ProcessorContext context) {
this.context = context;
kvStore = (KeyValueStore<String, AuctionDto>) context.getStateStore("action-key-store");
@ConditionalOnProperty(value = "features.job-processor.hello-world", havingValue = "active")
public class HelloWorldJobProcessor {
private final Logger logger = LoggerFactory.getLogger(this.getClass());
private JobBuilderFactory jobBuilderFactory;
private StepBuilderFactory stepBuilderFactory;