sjednac

package com.example;

import org.junit.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.config.BeanDefinition;
import org.springframework.context.ApplicationContext;
import org.springframework.context.annotation.AnnotationConfigApplicationContext;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Scope;

sjednac

#! /usr/bin/env python
# -*- encoding: utf-8 -*-

import os

# Config
checkstyle_jar = os.getenv('CHECKSTYLE_JAR', "checkstyle-5.7-all.jar")
checkstyle_cfg = os.getenv('CHECKSTYLE_CFG', "checkstyle.xml")

failing_test_should_prevent_commit = True

sjednac

import rapture._
import core._, io._, net._, uri._, json._, codec._

import encodings.`UTF-8`
import jsonBackends.jackson._

case class PostContainer(kind: String, data: Post)
case class Post(id: String, subreddit: String, score: Int, title: String, author: String, permalink: String) {
	lazy val topComment = {
		val json = Json.parse(uri"http://www.reddit.com/r/${subreddit}/comments/${id}.json?sort=top&limit=1&depth=1".slurp[Char])

sjednac

object Log4j2WithMongoAppenderDemo extends App {
    val logger = org.slf4j.LoggerFactory.getLogger(Log4j2WithMongoAppenderDemo.getClass)

    logger.trace("A trace message")
    logger.debug("A debug message")
    logger.info("An info message")
    logger.warn("A warning message")
    logger.error("An error message")
    logger.error("An error message with an exception", new Exception("Some serious problem"))

sjednac

import javax.servlet.ServletContext
import org.eclipse.jetty.server.Server
import org.eclipse.jetty.webapp.WebAppContext
import org.json4s.{DefaultFormats, Formats}
import org.scalatra._
import org.scalatra.json._
import org.scalatra.servlet.ScalatraListener

case class User(id: Int, name: String)

sjednac

import collection.JavaConversions._
import org.springframework.beans.factory.annotation._
import org.springframework.context.ApplicationContext
import org.springframework.context.annotation._
import org.springframework.stereotype._

package com.example.core {

    @ComponentScan(basePackages = Array("com.example.core"))
    @Configuration

sjednac

import java.math.BigInteger;
import java.text.MessageFormat;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Collection;
import java.util.Collections;
import java.util.List;
import java.util.Scanner;
import java.util.function.BiFunction;
import java.util.stream.Collectors;

sjednac

import org.junit.runner.RunWith
import org.scalatest.selenium.HtmlUnit
import org.scalatest.{FlatSpec, ShouldMatchers}
import org.springframework.boot.test.{SpringApplicationConfiguration, WebIntegrationTest}
import org.springframework.test.context.TestContextManager
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner

@RunWith(classOf[SpringJUnit4ClassRunner])
@SpringApplicationConfiguration(classes = Array(classOf[Application]))
@WebIntegrationTest(value = Array("server.port=9000"))

sjednac

import java.time._
import org.apache.curator.framework._
import org.apache.curator.retry._
import org.apache.zookeeper.CreateMode._

object ZooKeeperReader extends App {
  val connectionString = "192.168.59.201:2181,192.168.59.202:2181,192.168.59.203:2181,192.168.59.204:2181,192.168.59.205:2181"
  val retryPolicy = new RetryOneTime(1000)
  val client = CuratorFrameworkFactory.newClient(connectionString, retryPolicy)
   

sjednac

import scala.io.Source

case class Observation(time: Int, value: BigDecimal)

class Memory(val length: Int, val observation: Option[Observation], val pastEvents: List[Observation]) {

  def record(newObservation: Observation): Memory = {
      val newEvents = (newObservation :: pastEvents).takeWhile(_.time > newObservation.time - length)
      new Memory(length, Some(newObservation), newEvents)
  }