leosilvadev

package br.leosilvadev

import spock.lang.Specification
import spock.util.concurrent.BlockingVariable

import java.util.concurrent.TimeUnit
import java.util.function.Consumer

class MySpec extends Specification {

leosilvadev

package com.finleap.bot.model;

import java.util.HashMap;
import java.util.Map;

import com.finleap.bot.service.BotResultPublisher;
import com.finleap.core.model.converstion.MessageType;
import com.finleap.resources.VerimiResource;
import com.finleap.service.StateUpdator;

leosilvadev

package com.github.leosilvadev.verticle;

import io.vertx.core.AbstractVerticle;
import io.vertx.core.DeploymentOptions;
import io.vertx.core.Vertx;

import java.util.concurrent.atomic.AtomicLong;

/**
 * Created by leonardo on 11/18/17.

leosilvadev

sudo apt-get update

sudo apt-get install -y \
    apt-transport-https \
    ca-certificates \
    curl \
    software-properties-common
    
curl -fsSL https://download.docker.com/linux/ubuntu/gpg | sudo apt-key add -

leosilvadev

apt-get update && apt-get install -y apt-transport-https curl
curl -s https://packages.cloud.google.com/apt/doc/apt-key.gpg | apt-key add -
cat <<EOF >/etc/apt/sources.list.d/kubernetes.list
deb http://apt.kubernetes.io/ kubernetes-xenial main
EOF
apt-get update
apt-get install -y kubelet kubeadm kubectl
apt-mark hold kubelet kubeadm kubectl

leosilvadev

import com.sksamuel.avro4s.{AvroSchema, SchemaFor}
import org.apache.avro.Schema
import org.apache.avro.util.Utf8

case class MyClass(id: Utf8, name: Utf8, familyName: Option[Utf8])

object Main extends App {
  implicit object Utf8Schema extends SchemaFor[Utf8] {
    override def schema: Schema = Schema.create(Schema.Type.STRING)
  }

leosilvadev

package com.github.leosilvadev.detectorapp;

import jakarta.jms.*;
import org.apache.activemq.artemis.api.core.client.loadbalance.RoundRobinConnectionLoadBalancingPolicy;
import org.apache.activemq.artemis.core.remoting.impl.netty.NettyConnectorFactory;
import org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory;
import org.springframework.aot.hint.MemberCategory;
import org.springframework.aot.hint.RuntimeHints;
import org.springframework.aot.hint.RuntimeHintsRegistrar;
import org.springframework.aot.hint.TypeReference;