diff --git a/plugins/jvm/jvm.h b/plugins/jvm/jvm.h
index fa7554fe..52682d47 100644
--- a/plugins/jvm/jvm.h
+++ b/plugins/jvm/jvm.h
@@ -25,7 +25,9 @@ struct uwsgi_jvm {
 	jclass hashmap_class;
 	jclass set_class;
 	jclass iterator_class;
+
 	jclass runtime_exception;
+	jclass io_exception;
 
 	jmethodID api_signal_handler_mid;
 	jmethodID api_rpc_function_mid;
@@ -47,6 +49,7 @@ int uwsgi_jvm_exception(void);
 char *uwsgi_jvm_str2c(jobject);
 
 void uwsgi_jvm_throw(char *);
+void uwsgi_jvm_throw_io(char *);
 
 jobject uwsgi_jvm_call_objectA(jobject o, jmethodID mid, jvalue *);
 void uwsgi_jvm_release_chars(jobject, char *);
diff --git a/plugins/jvm/jvm_plugin.c b/plugins/jvm/jvm_plugin.c
index d763449e..063f977e 100644
--- a/plugins/jvm/jvm_plugin.c
+++ b/plugins/jvm/jvm_plugin.c
@@ -52,6 +52,25 @@ static JNINativeMethod uwsgi_jvm_api_methods[] = {
 	{"worker_id", "()I", (void *) &uwsgi_jvm_api_worker_id},
 };
 
+JNIEXPORT jint JNICALL uwsgi_jvm_request_body_read(JNIEnv *env, jobject o) {
+	struct wsgi_request *wsgi_req = current_wsgi_req();
+	ssize_t rlen = 0;
+        char *chunk = uwsgi_request_body_read(wsgi_req, 1, &rlen);
+	if (!chunk) {
+		uwsgi_jvm_throw_io("error reading request body");	
+		return -1;
+	}
+	if (chunk == uwsgi.empty) {
+		return -1;
+	}
+	uint8_t byte = chunk[0];
+	return (jint) byte;
+}
+
+static JNINativeMethod uwsgi_jvm_request_body_methods[] = {
+	{"read", "()I", (void *) &uwsgi_jvm_request_body_read},
+};
+
 static struct uwsgi_option uwsgi_jvm_options[] = {
         {"jvm-main-class", required_argument, 0, "load the specified class and call its main() function", uwsgi_opt_add_string_list, &ujvm.main_classes, 0},
         {"jvm-opt", required_argument, 0, "add the specified jvm option", uwsgi_opt_add_string_list, &ujvm.opts, 0},
@@ -485,6 +504,10 @@ void uwsgi_jvm_throw(char *message) {
 	(*ujvm_env)->ThrowNew(ujvm_env, ujvm.runtime_exception, message);
 }
 
+void uwsgi_jvm_throw_io(char *message) {
+        (*ujvm_env)->ThrowNew(ujvm_env, ujvm.io_exception, message);
+}
+
 static int uwsgi_jvm_init(void) {
 
 	return 0;
@@ -592,6 +615,9 @@ static void uwsgi_jvm_create(void) {
 	ujvm.runtime_exception = uwsgi_jvm_class("java/lang/RuntimeException");
 	if (!ujvm.runtime_exception) exit(1);
 
+	ujvm.io_exception = uwsgi_jvm_class("java/io/IOException");
+	if (!ujvm.io_exception) exit(1);
+
 	jclass uwsgi_class = uwsgi_jvm_class("uwsgi");
 	if (!uwsgi_class) {
 		exit(1);
@@ -614,6 +640,11 @@ static void uwsgi_jvm_create(void) {
 	ujvm.request_body_class = uwsgi_jvm_class("uwsgi$RequestBody");
 	if (!ujvm.request_body_class) exit(1);
 
+	(*ujvm_env)->RegisterNatives(ujvm_env, ujvm.request_body_class, uwsgi_jvm_request_body_methods, sizeof(uwsgi_jvm_request_body_methods)/sizeof(uwsgi_jvm_request_body_methods[0]));
+	if (uwsgi_jvm_exception()) {
+		exit(1);
+	}
+
 	usl = ujvm.main_classes;
 	while(usl) {
 		jclass c = uwsgi_jvm_class(usl->value);