kenota

final Handler handler = new Handler(hThread.getLooper());
final long oneMinuteMs = 60 * 1000;
		
Runnable eachMinute = new Runnable() {	
	@Override
	public void run() {
		Log.d(TAG, "Each minute task executing");
		handler.postDelayed(this, oneMinuteMs);
	}
};

kenota

HandlerThread hThread = new HandlerThread("HandlerThread");
hThread.start();
Handler handler = new Handler(hThread.getLooper());

kenota

public final boolean sendMessageDelayed(Message msg, long delayMillis) {
	if (delayMillis < 0) {
		delayMillis = 0;
	}
	return sendMessageAtTime(msg, SystemClock.uptimeMillis() + delayMillis);
}

kenota

package com.binarybuffer.test.bufferbuilder;

import org.apache.commons.math3.stat.descriptive.StatisticalSummary;
import org.apache.commons.math3.stat.descriptive.SummaryStatistics;
import org.junit.Test;



/**
 * Unit test for simple App.

kenota

message query {
  required string request = 1;
  optional int64 limit = 2
}

kenota

// msg contains Parsed Query protobuf message
String query = msg.getQuery();
Long limit = msg.getLimit();

kenota

Long limit = msg.hasLimit() ? msg.getLimit() : null;

kenota

def message = Message.lock(messageId)
processMessage(message)

kenota

import org.hibernate.LockMode

// Some code skipped

Message.withTransaction {
  try {
    def msg = Message.withCriteria {
      eq "id", Long.valueOf(messageId)
      delegate.criteria.lockMode = LockMode.UPGRADE_NOWAIT
    }

kenota

package com.binarybuffer.postgres;

import org.hibernate.LockMode;
import org.hibernate.dialect.PostgreSQLDialect;

/**
 * Simple extension to standard {@link PostgreSQLDialect} adding support for
 * {@link LockMode#UPGRADE_NOWAIT} lock mode which is achieved using
 * "FOR UPDATE NOWAIT" syntax in PostgreSQL
 *