baybatu

# create exchange
curl -i -u guest:guest -H "content-type:application/json" \
    -XPUT -d'{"type":"fanout","durable":true}' \
    http://localhost:15672/api/exchanges/%2f/my.exchange.name
    
# create queue
curl -i -u guest:guest -H "content-type:application/json" \
    -XPUT -d'{"durable":true,"arguments":{"x-dead-letter-exchange":"", "x-dead-letter-routing-key": "my.queue.dead-letter"}}' \
    http://localhost:15672/api/queues/%2f/my.queue

baybatu

@Document
public class OrnekDokuman {
    @Id
    @GeneratedValue(strategy = GenerationStrategy.UNIQUE) // UUID
    String id;
}

baybatu

java -jar liquibase.jar \
      --driver=org.postgresql.Driver \
      --classpath=postgresql-9.4.1208.jre6.jar \
      --changeLogFile=/workspace/product-api/src/main/resources/db/changelog.xml \
      --url="jdbc:postgresql://localhost:5432/product" \
      --username=root \
      --password=123qwe \
      updateSQL

baybatu

#!/usr/bin/env groovy

node {
    stage('checkout') {
        checkout scm
    }
    stage("Reindex") {
        String esHost = params.esHost //example: localhost:9200
        String oldIndexVersion = params.oldIndexVersion //example: v1
        String newIndexVersion = params.newIndexVersion //example: v2

baybatu

#!/usr/bin/env groovy

node {
    stage('checkout') {
        checkout scm
    }
    stage("Switch alias between index versions") {
        String esHost = params.esHost //example: localhost:9200
        String oldIndexVersion = params.oldIndexVersion //example: v1
        String newIndexVersion = params.newIndexVersion //example: v2

baybatu

https://stackoverflow.com/a/7747342

baybatu

@ControllerAdvice
public class PageResponseAdvice implements ResponseBodyAdvice<Object> {

    @Override
    public boolean supports(MethodParameter returnType, Class<? extends HttpMessageConverter<?>> converterType) {
        return PageResponse.class.isAssignableFrom(returnType.getParameterType());
    }

    @Override
    public Object beforeBodyWrite(Object body,

baybatu

RabbitMQ: Mesajı Geciktirerek Tüketmek

• delay-exchange: Geciktirilecek mesajın bırakıldığı exchange.
• delay-queue: delay-exchange'e bağlı. Herhangi bir tüketicisi olmamalı.
• ana-exchange: Geciktirilmeden tüketilmek istenen mesajların bırakılabileceği exchange.
• ana-queue: ana-exchange'e bağlı kuyruk. Tüketicisi var.

delay-queue şu parametrelerle oluşturulur:

• x-dead-letter-exchange: -- boş
• x-message-ttl: 3000 -- mesajın bekletileceği milisaniye

baybatu

for index_name in `curl -XGET "$ES_HOST/products_*" | jq -r 'keys[]'`; do
    curl -XDELETE "$ES_HOST/$index_name"
done

baybatu

public class ThreadPoolTaskExecutorWithMdcPropagation extends ThreadPoolExecutor {

    private static final Logger LOGGER = LoggerFactory.getLogger(ThreadPoolTaskExecutorWithMdcPropagation.class);

    private final Map<String, String> parentMdcContextMap;

    public ThreadPoolTaskExecutorWithMdcPropagation(int corePoolSize, int maxPoolSize, long keepAliveTime, TimeUnit keepAliveTimeUnit) {
        super(corePoolSize, maxPoolSize, keepAliveTime, keepAliveTimeUnit, new LinkedBlockingQueue<>());
        parentMdcContextMap = MDC.getCopyOfContextMap();
    }