pmihalcin

#!/bin/awk -f
BEGIN {
  # Print the squares from 1 to 10
	for (i=1; i <= 10; i++) {
    printf "The square of ", i, " is ", i*i;
	}

  # now end
  exit;
}

pmihalcin

// https://github.com/spring-projects/spring-hateoas/issues/733#issuecomment-420903832
def requestFactory = new MockMvcClientHttpRequestFactory(mvc)
def traverson = new Traverson(new URI("/api"), HAL_JSON)
traverson.setRestOperations(new RestTemplate(requestFactory))

traverson.follow(rel("merchants").withParameters(["page": "", "size": "", "sort": "", "projection": ""])).toObject("\$")

ParameterizedTypeReference<Resource<Merchant>> resourceParameterizedTypeReference = new ParameterizedTypeReference<Resource<Merchant>>() {
};
Resource<Merchant> itemResource = traverson.follow(rel("merchants").withParameters(["page": "", "size": "", "sort": "", "projection": ""]))

pmihalcin

// Example how to use Traverson API
// please note, there is not MockMvc support yet
// fully-blown server is needed, RANDOM_PORT / DEFINED_PORT

@LocalServerPort
private int port;

def traverson = new Traverson(new URI("http://localhost:$port/api/"), HAL_JSON)
def object = traverson.follow(REL_SPEC_MER_CRITERIA, EXPORT_CSV_TEMPLATE_REL).toObject(String.class)
println object

pmihalcin

AMQP AcknowledgeMode

public static final AcknowledgeMode AUTO

• Auto - the container will issue the ack/nack based on whether the listener returns normally, or throws an exception.
• Do not confuse with RabbitMQ autoAck which is represented by NONE here.

The AUTO is involved in the commitIfNecessary() which is called only when your target listener returns normally

https://docs.spring.io/spring-amqp/reference/html/_reference.html#template-confirms

pmihalcin

three first class citizens in Spring Integration
Message, Channel and Endpoint

Message - an independent, immutable container of data to transfer throughout business logic
Channel - we have to decouple business logic and be able to distribute the last one when it is requested
Channel has two ends: producer and consumer(s)
But at the same time there are many different channel implementation
and depending on that we determine what type of Endpoint (consumer) to declare

See ConsumerEndpointFactoryBean for more details

pmihalcin

// first example
@Bean
public IntegrationFlow flow(ConnectionFactory cf) {
    return IntegrationFlows.from(Amqp.inboundAdapter(cf, "q").autoStartup(false))
            .publishSubscribeChannel(s -> s
                    .subscribe(f -> f.transform("headers['x-death'] ?: '{}'")
                                    .handle("deathCheckBean", "deathCheckMethod"))
                    .subscribe(f -> f.handle(System.out::println))) // main flow
            .get();
}

pmihalcin

package net.homecredit.mer.web

import org.springframework.amqp.rabbit.connection.Connection
import org.springframework.amqp.rabbit.connection.ConnectionFactory

import static java.lang.System.currentTimeMillis
import static net.homecredit.mer.web.WaitUtils.doWait
import static org.junit.Assert.fail

class AmqpUtils {

pmihalcin

package net.homecredit.mer.web;

import java.util.ArrayList;
import java.util.List;

/**
 * Created by Patrik.Mihalcin on 29.03.2018
 */
public class GenericsBoundedWildcards {

pmihalcin

import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.util.HashSet;
import java.util.Set;

// billion-laughs-style DoS for java serialization
public class SerialDOS {

pmihalcin

@RunWith(SpringRunner.class)
@SpringBootTest
public class DbCommitJmsRollback implements ApplicationContextAware {

    private Lifecycle lifecycle;

    @Autowired
    private JmsTemplate jmsTemplate;

    @Autowired