nbuesing

version: '3.4'

services:

  cassandra:
    image: cassandra:3.11
    restart: unless-stopped
    ports:
      - "9042:9042"

nbuesing

FROM debian:stretch-slim

RUN set -eux; \
	apt-get update; \
	apt-get -y install \
                vim \
		xorg \
	; \
	rm -rf /var/lib/apt/lists/*

nbuesing

FROM cgswong/confluent-platform:2.0.1

RUN set -eux; \
	apt-get update; \
	apt-get -y install \
                vim \
		xorg \
	; \
	rm -rf /var/lib/apt/lists/*

nbuesing

version: '3.4'
services:
  zookeeper:
    image: confluentinc/cp-zookeeper:5.0.0-beta30
    hostname: zookeeper
    environment:
      ZOOKEEPER_CLIENT_PORT: 2181
    healthcheck:
      test: echo stat | nc localhost 2181
      start_period: 30s

nbuesing

package com.objectpartners.buesing.util;

import com.google.common.collect.ImmutableMap;
import org.junit.Assert;
import org.junit.Test;

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

nbuesing

package com.objectpartners.buesing.util;

import org.junit.Assert;
import org.junit.Test;

import javax.naming.OperationNotSupportedException;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Map;

nbuesing

package com.objectpartners.buesing.util;

import java.util.Collections;
import java.util.HashMap;
import java.util.LinkedHashMap;
import java.util.Map;

/**
 * @author Neil Buesing
 */

nbuesing

package com.objectpartners.buesing.sample;

import com.google.gwt.event.dom.client.ClickEvent;
import com.google.gwt.event.dom.client.ClickHandler;
import com.google.gwt.event.shared.SimpleEventBus;
import com.google.gwt.user.client.Element;
import com.google.gwt.user.client.rpc.AsyncCallback;
import com.google.gwt.user.client.ui.Button;
import com.google.gwt.user.client.ui.HTML;
import com.google.gwt.user.client.ui.Label;

nbuesing

  Mockito.doAnswer(new Answer() {
    public Object answer(InvocationOnMock invocation) throws Throwable {
      String msg = (String)invocation.getArguments()[0];
      AsyncCallback callback = (AsyncCallback) invocation.getArguments()[1];
      callback.onSuccess("Client said: \"" + msg + "\"<br>Server answered: \"Hi!\"");
      return null;
    }
  }).when(sampleApplicationService).getMessage(Mockito.any(String.class), (AsyncCallback) Mockito.any());

nbuesing

    private SampleWidget sampleWidget;
    private ClickHandler clickHandler;

    @Before
    public void setUp() {
        Mockito.when(button.addClickHandler(Mockito.any(ClickHandler.class))).thenAnswer(new Answer() {
            public Object answer(InvocationOnMock aInvocation) throws Throwable {
                clickHandler = (ClickHandler) aInvocation.getArguments()[0];
                return null;
            }