mox601

{
    "to-migrate": {
        "settings": {
            "index.version.created": "901399",
            "index.number_of_replicas": "0",
            "index.uuid": "SjIy18EvSECUT-QI_ONCgA",
            "index.number_of_shards": "2"
        }
    }
}

mox601

$ ./elasticsearch -f -Des.logger.level=DEBUG
[2014-04-28 12:40:04,069][INFO ][node                     ] [moxbook-pro] version[0.90.7], pid[3817], build[36897d0/2013-11-13T12:06:54Z]
[2014-04-28 12:40:04,069][INFO ][node                     ] [moxbook-pro] initializing ...
[2014-04-28 12:40:04,070][DEBUG][node                     ] [moxbook-pro] using home [/Users/mox/Dati/shared-libraries/elasticsearch-0.90.7], config [/Users/mox/Dati/shared-libraries/elasticsearch-0.90.7/config], data [[/Users/mox/Dati/shared-libraries/elasticsearch-0.90.7/data]], logs [/Users/mox/Dati/shared-libraries/elasticsearch-0.90.7/logs], work [/Users/mox/Dati/shared-libraries/elasticsearch-0.90.7/work], plugins [/Users/mox/Dati/shared-libraries/elasticsearch-0.90.7/plugins]
[2014-04-28 12:40:04,077][INFO ][plugins                  ] [moxbook-pro] loaded [], sites [head]
[2014-04-28 12:40:04,114][DEBUG][common.compress.lzf      ] using [UnsafeChunkDecoder] decoder
[2014-04-28 12:40:04,131][DEBUG][env                      ] [moxbook-

mox601

public class FilterTestCase {

    @Test
    public void shouldFilter() throws Exception {

        final TestScheduler testScheduler = new TestScheduler();
        final Observable<Integer> two = Observable.just(2);
        final Filter filter = new Filter(two, testScheduler);
        final Observable<Integer> gtEqTwo = filter.filterGtEq(2);

mox601

{
    "originCountries": [
        {
            "name": "IT",
            "count": 10,
            "cityCounts": [
                {
                    "name": "Rome",
                    "count": 8,
                    "lat": 10,

mox601

<repositories>
            <repository>
            <id>cybion-maven-repo-snapshots.googlecode.com</id>
            <name>Cybion Commons SNAPSHOTS Artifacts repository</name>
            <url>https://cybion-maven-repo.googlecode.com/svn/m2/snapshots</url>
            <releases>
                <enabled>false</enabled>
            </releases>
            <snapshots>
                <enabled>true</enabled>

mox601

{
    "_index": "es_datasift",
    "_type": "interactions",
    "_id": "1e44d65836dbac00e072e9c0679083b0",
    "_score": 1,
    "_source": {
        "interactionId": "1e44d65836dbac00e072e9c0679083b0",
        "subscriptionId": "92b645eb9f18e033c3a9c266f6cf677b",
        "hash": "7fdbea4b8238b5b04d59e34f58e3e2ea",
        "hashType": "stream",

mox601

{
    "es_datasift": {
        "interactions": {
            "properties": {
                "hash": {
                    "type": "string"
                },
                "hashType": {
                    "type": "string"
                },

mox601

//an event
// new ItemAdded("item-id-34", 45$, "2014-10-21-18:47:12")

//the handler

public class MonthlyCostsDenormalizer implements IHandle<ItemAddedToCart> {

    private MonthlyCostsDao dao

    public MonthlyCostsDenormalizer(MonthlyCostsDao dao) {

mox601

@Test
    public void testPaginatedCalls() throws Exception {

        Observable<Response> call = createPaginatedCall(-1L, 3L);

        Observable<List<Long>> pages = flattenPages(call);
        // Verify:
        List<List<Long>> paginated = pages.toList().toBlocking().first();
        assertEquals(paginated, Arrays.asList(Arrays.asList(1L, 2L, 3L), Arrays.asList(4L, 5L)));

mox601

package fm.mox.spikes.rx;

import org.testng.annotations.Test;
import rx.Observable;
import rx.Observer;
import rx.Subscriber;
import rx.Subscription;

import static org.easymock.EasyMock.createMock;
import static org.easymock.EasyMock.expectLastCall;