RichardHightower

    @RequestMapping("/returnEmployeeCallback2")
    public void returnEmployeeWithCallback2(Callback<HttpTextResponse> employeeCallback) {

        HttpTextResponse response = (HttpTextResponse) HttpResponseBuilder.httpResponseBuilder()
                .setBody("" + new Employee(1, "Rick"))
                .setContentType("crap/crap").setCode(777).build();

        employeeCallback.returnThis(response);

RichardHightower

The benchmark uses JMH. JMH is what the OpenJDK uses for benchmarking.

```java
    @GenerateMicroBenchmark
    @OutputTimeUnit( TimeUnit.SECONDS)
    public void actionLabel(BlackHole bh) throws Exception {
        bh.consume(parse(STR_ACTION_LABEL_BYTES));
    }

```

RichardHightower

./gradlew idea

FAILURE: Build failed with an exception.

* What went wrong:
A problem occurred configuring root project 'vert.x'.
> Could not resolve all dependencies for configuration ':classpath'.
   > Could not download artifact 'junit:junit:4.8.2@jar'
      > Artifact 'junit:junit:4.8.2@jar' not found.

RichardHightower

Here is an example of how to change the root address from /services to something else. And this is also an example of working with the Docker, Mesos, Heroku friendly version of QBit.

package qbit.todo;

import io.advantageous.qbit.admin.ManagedServiceBuilder;

RichardHightower

@RequestMapping("/hr")
public class HRService {

    final Map<Integer, Department> departmentMap = new HashMap<>();


    @RequestMapping("/department/")
    public List<Department> getDepartments() {
        return new ArrayList<>(departmentMap.values());

RichardHightower

package io.advantageous.qbit.queue;

import io.advantageous.qbit.QBit;
import io.advantageous.qbit.concurrent.PeriodicScheduler;
import io.advantageous.qbit.json.JsonMapper;

import java.util.ArrayList;
import java.util.Collection;
import java.util.Map;
import java.util.concurrent.TimeUnit;

RichardHightower

import com.examples.model.test.Email;
import com.examples.model.test.UserEmail;

...
import java.util.List;
import java.util.Objects;
import static org.boon.criteria.CriteriaFactory.eqNested;

RichardHightower

    <dependencies>
    
        <dependency>
            <groupId>org.boon</groupId>
            <artifactId>boon</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
    
    </dependencies>

RichardHightower

There is a new release of QBit. This has the bug fixes and features that the some of our clients requested, and some bridge tech. (included is JS and Java example of using new bridge tech).

New version just released.

compile 'io.advantageous.qbit:qbit-admin:0.9.3-M2'

RichardHightower

This class uses an async supplier to connect to cassandra.

Example of circuit breaker for Cassandra.

import com.datastax.driver.core.ResultSet;
import com.datastax.driver.core.ResultSetFuture;