Created project

mark.george / jooby-sse

Browse code Created project master
0 parent commit ff10e94a2996b7966dd621b33700df345e198106 Mark George authored on 4 May 2021

Patch

Showing 5 changed files

Ignore Space Show notes View .gitignore 0 → 100644
.gradle build

Ignore Space Show notes View README.md 0 → 100644
# Jooby SSE Server A simple server-sent events server that supports multiple concurrent clients, and properly handles client-side disconnects. Uses Jooby 2. ## Apache Camel as SSE consumer TLDR — Camel can't be used as an SSE consumer. Documenting this here since I created this server to test if Camel can be used as an SSE consumer. Camel doesn't seem to have a component for this (as at version 3.9.0) and the built in HTTP support does not seem to nicely handle it — there is no support for `from('http://...')` and using `to('http://...')` will not return a response until the response stream closes (which is entirely reasonable). Tested with both the `http` and `ahc` components. I know that Camel does work as a WebSocket consumer, so there is not a lot of point in spending more time on this.

Ignore Space Show notes View

README.md 0 → 100644

Ignore Space Show notes View build.gradle 0 → 100644
plugins { id 'application' } repositories { jcenter() mavenCentral() } dependencies { def joobyVer='2.9.5' implementation group: 'io.jooby', name: 'jooby-netty', version: joobyVer } task createMissingSourceDirs { group = "Source Directories" description = "Create all of the missing source directories for this project." doFirst { sourceSets.each { def sourceRoot -> sourceRoot.allSource.srcDirTrees.each { def sourceDir -> if(!sourceDir.dir.exists()) { println "Creating ${sourceDir}" mkdir sourceDir.dir } } } } } task deleteEmptySourceDirs { group = "Source Directories" description = "Delete all empty source directories." doFirst { sourceSets.each { def sourceRoot -> sourceRoot.allSource.srcDirTrees.each { def sourceDir -> if(sourceDir.dir.exists() && sourceDir.dir.isDirectory() && sourceDir.dir.list().length == 0) { println "Removing empty ${sourceDir}" sourceDir.dir.delete() } } } } } mainClassName = 'route.Server'

Ignore Space Show notes View

build.gradle 0 → 100644

plugins {
	id 'application'
}

repositories {
	jcenter()
	mavenCentral()
}

dependencies {
	def joobyVer='2.9.5'
	implementation group: 'io.jooby', name: 'jooby-netty', version: joobyVer
}

task createMissingSourceDirs {
	group = "Source Directories"
	description = "Create all of the missing source directories for this project."
	doFirst {
		sourceSets.each { def sourceRoot ->
			sourceRoot.allSource.srcDirTrees.each { def sourceDir ->
				if(!sourceDir.dir.exists()) {
					println "Creating ${sourceDir}"
					mkdir sourceDir.dir
				}
			}
		}
	}
}

task deleteEmptySourceDirs {
	group = "Source Directories"
	description = "Delete all empty source directories."
	doFirst {
		sourceSets.each { def sourceRoot ->
			sourceRoot.allSource.srcDirTrees.each { def sourceDir ->
				if(sourceDir.dir.exists() && sourceDir.dir.isDirectory() && sourceDir.dir.list().length == 0) {
					println "Removing empty ${sourceDir}"
					sourceDir.dir.delete()
				}
			}
		}
	}
}

mainClassName = 'route.Server'

Ignore Space Show notes View src/main/java/route/Server.java 0 → 100644
package route; import io.jooby.Jooby; import io.jooby.ServerOptions; /** * * @author Mark George */ public class Server extends Jooby { { setServerOptions(new ServerOptions().setPort(8888)); mount(new SseRoute()); } public static void main(String[] args) { new Server().start(); } }

Ignore Space Show notes View src/main/java/route/SseRoute.java 0 → 100644
package route; import io.jooby.Jooby; import java.util.concurrent.TimeUnit; /** * A simple SSE server using Jooby 2. * * Supports multiple concurrent clients and handles client disconnects. * * Created to test if Apache Camel can consume SSE (it can't - boo) as a way * of bridging webhooks payloads into a Camel router. * * @author Mark George */ public class SseRoute extends Jooby { { sse("/api/sales/{usercode}", (sse) -> { String usercode = sse.getContext().path("usercode").value(); // loop so that we can stream new messages while (true) { // check if client is still connected if (sse.isOpen()) { // sent a message sse.send("Hi " + usercode); System.out.println("sent"); TimeUnit.SECONDS.sleep(1); } else { System.out.println("Client closed connection"); break; } } }); } }

Ignore Space Show notes View

src/main/java/route/SseRoute.java 0 → 100644

Show line notes below