jklingsporn’s gists

jklingsporn / create_env_local.config

Created May 24, 2022 15:01

Creates a Symfony .env.local-File based on ElasticBeanstalk's environment variables. Comes in handy when running outside the container (e.g. cronjobs)

	#this goes into .ebextensions-Folder
	files:
	"/var/app/current/.env.local" :
	mode: "000644"
	owner: root
	group: root
	content: \|
	NO_SUCH_KEY=NO_SUCH_VALUE

	container_commands:

jklingsporn / Mixed handler registration fails

Last active September 21, 2020 11:54

After both handlers have been registered and received a message the unregistration of the second handler fails

	import com.hazelcast.core.Hazelcast;
	import io.vertx.core.Promise;
	import io.vertx.core.Vertx;
	import io.vertx.core.VertxOptions;
	import io.vertx.core.eventbus.MessageConsumer;
	import io.vertx.spi.cluster.hazelcast.HazelcastClusterManager;
	import org.slf4j.Logger;
	import org.slf4j.LoggerFactory;

	/**

jklingsporn / run.sh

Created December 8, 2017 13:11

Expose public IP to JMX on EC2 instance

	JMX_IP=$(curl http://169.254.169.254/latest/meta-data/public-ipv4)
	exec java $JAVA_OPTS -Djava.rmi.server.hostname=$JMX_IP -jar app.jar $JAVA_ARGS

jklingsporn / build.sh

Created December 8, 2017 13:08

Expose public IP to JMX on EC2 instance

	#!/bin/bash
	set -e
	now=$(date +"%Y-%m-%d_%H-%M-%S")
	tag="./target/app-$now.zip"
	mvn clean install
	echo "web: ./run.sh" > target/Procfile
	echo "JMX_IP=\$(curl http://169.254.169.254/latest/meta-data/public-ipv4)" > target/run.sh
	echo "exec java \$JAVA_OPTS -Djava.rmi.server.hostname=\$JMX_IP -jar app.jar \$JAVA_ARGS" >> target/run.sh
	chmod +x target/run.sh
	zip -j ${tag} target/Procfile target/run.sh target/app.jar

jklingsporn / build.sh

Created December 8, 2017 13:08

Expose public IP to JMX on EC2 instance

	#!/bin/bash
	set -e
	now=$(date +"%Y-%m-%d_%H-%M-%S")
	tag="./target/app-$now.zip"
	mvn clean install
	echo "web: ./run.sh" > target/Procfile
	echo "JMX_IP=\$(curl http://169.254.169.254/latest/meta-data/public-ipv4)" > target/run.sh
	echo "exec java \$JAVA_OPTS -Djava.rmi.server.hostname=\$JMX_IP -jar app.jar \$JAVA_ARGS" >> target/run.sh
	chmod +x target/run.sh
	zip -j ${tag} target/Procfile target/run.sh target/app.jar

jklingsporn / CompletableFutureCollector2.java

Last active November 9, 2022 07:30

Converts a Stream<CompletableFuture<X>> to a CompletableFuture<List<X>> or a Stream<CompletableFuture<Void>> to a CompletableFuture<Void>

	import java.util.List;
	import java.util.concurrent.CompletableFuture;
	import java.util.function.Function;
	import java.util.stream.Collector;
	import java.util.stream.Collectors;

	public class CompletableFutureCollector2 {

	private CompletableFutureCollector2(){
	}

jklingsporn / CompletableFutureCollectorUsage.java

Created November 16, 2017 18:54

How to use CompletableFutureCollector

	public static void main(String[] args) {
	CompletableFuture<List<Integer>> collect = Stream.of(1,2,3).map(CompletableFuture::completedFuture).collect(CompletableFutureCollector.allOf());
	}

jklingsporn / CompletableFutureSequence.java

Created November 16, 2017 18:41

Converts List<CompletableFuture<X>> to a CompletableFuture<List<X>>

	static<T> CompletableFuture<List<T>> sequence(List<CompletableFuture<T>> com) {
	return CompletableFuture.allOf(com.toArray(new CompletableFuture[com.size()]))
	.thenApply(v -> com.stream()
	.map(CompletableFuture::join)
	.collect(toList())
	);
	}

jklingsporn / CompletableFutureCollector.java

Last active May 22, 2021 20:52

Converts a Stream<CompletableFuture<X>> to a CompletableFuture<List<X>>

	import java.util.ArrayList;
	import java.util.Collections;
	import java.util.List;
	import java.util.Set;
	import java.util.concurrent.CompletableFuture;
	import java.util.function.BiConsumer;
	import java.util.function.BinaryOperator;
	import java.util.function.Function;
	import java.util.function.Supplier;
	import java.util.stream.Collector;

jklingsporn / SomeJsonTest.java

Last active August 30, 2017 09:51

Record into Map

	public class SomeJsonTest {

	public void getJsonFromRecord2(){
	SomethingDao somethingDao = new SomethingDao();
	CompletableFuture<JsonObject> jsonFuture = somethingDao.executeAsync(dslContext -> dslContext
	.select(Tables.SOMETHING.SOMEID)
	.select(Tables.SOMEOTHERTHING.SOMEVALUE)
	.join(Tables.SOMEOTHERTHING)
	.on(Tables.SOMETHING.SOMEID.eq(Tables.SOMEOTHERTHING.SOMEOTHERID))
	.where(Tables.SOMETHING.SOMEID.eq(1))