mgenov

import com.google.appengine.tools.mapreduce.AppEngineMapper;
import com.google.appengine.tools.mapreduce.MapReduceServlet;
import com.google.appengine.tools.mapreduce.MapperFactory;
import com.google.inject.Inject;
import com.google.inject.Injector;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.mapreduce.Mapper;
import org.apache.hadoop.util.ReflectionUtils;

/**

mgenov

public class DateInput implements Validatable {

  public interface Display {

    HasValue<Date> getDate();

    void showError(boolean error);

    void clear();

mgenov

  public enum MyEnum {
    TEST, ABC
  }

  public static class Bar {
    @Id
    Integer myKey;

    Map<MyEnum, Integer> map = new HashMap<MyEnum, Integer>();
  }

mgenov

  public static class ReceiptItemBuilder {
    private DateTime from;
    private DateTime to;
    private String name;
    private Double quantity;
    private Double price;
    private Double discount;
    private String referenceId;

    public ReceiptItemBuilder from(DateTime from) {

mgenov

public class PrintArrayTest {

  interface Display {
    void print(String message);
  }

  public void printArray(int[] array, Display display) {
    int index = 0;
    for (int item : array) {
      display.print("array[" + index + "]=" + item + ",");

mgenov

class Sample {

  interface Source<T> {
    T get();
  }

  class WordsSource implements Source<List<Word>> {
    private final Document document;
    private final List<String> listOfWords;

mgenov

import com.google.appengine.api.taskqueue.Queue;
import com.google.appengine.api.taskqueue.QueueFactory;
import com.google.appengine.api.taskqueue.TaskQueuePb;
import com.google.appengine.api.taskqueue.dev.LocalTaskQueueCallback;
import com.google.appengine.api.urlfetch.URLFetchServicePb;
import com.google.appengine.tools.development.testing.LocalDatastoreServiceTestConfig;
import com.google.appengine.tools.development.testing.LocalServiceTestHelper;
import com.google.appengine.tools.development.testing.LocalTaskQueueTestConfig;
import com.google.apphosting.api.ApiProxy;
import org.junit.After;

mgenov

public class PollingProvisioningServicePortType implements ProvisioningServicePortType {

  private final ProvisioningServicePortType service;

  public PollingProvisioningServicePortType(ProvisioningServicePortType service) {
    this.service = service;
  }

  public String activateCustomer(final String cust_id) throws RemoteException {
    return Polling.poll(new Poll<String>() {

mgenov

  @Test
  public void installSingleDevice() {
    selectedPremisesEquipment = PremisesEquipmentType.copper;
    boxNumber.setText("box1");
    macAddress.setText("00:aa");
    serialNumber.setText("sn1");

    presenter.onInstallInternetService("123");

    InstallDeviceAction action = service.lastAction();

mgenov

      log.info("Generate bills for " + billsCount + " months.");
      log.info("Expiration date: " + expireDate);
      List<BillEntity> bills = planner.getNextBills(services, lastBill, billsCount, paymentDay, expireDate, installationTax);
      filterEmptyCharges(bills);

      /**
       * Apply value added services over generated bills.
       */
      vasManager.applyValueAddedServices(contract, bills);