Package io.undertow.server.handlers.sse

Class ServerSentEventConnection

java.lang.Object

io.undertow.server.handlers.sse.ServerSentEventConnection

All Implemented Interfaces:

Attachable, java.io.Closeable, java.lang.AutoCloseable, java.nio.channels.Channel

public class ServerSentEventConnection
extends java.lang.Object
implements java.nio.channels.Channel, Attachable

Represents the server side of a Server Sent Events connection. The class implements Attachable, which provides access to the underlying exchanges attachments.

Author:

Stuart Douglas

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	ServerSentEventConnection.EventCallback

Constructor Summary

Constructors

Constructor	Description
ServerSentEventConnection(HttpServerExchange exchange, org.xnio.channels.StreamSinkChannel sink)

Method Summary

Modifier and Type	Method	Description
void	addCloseTask(org.xnio.ChannelListener<ServerSentEventConnection> listener)	Adds a listener that will be invoked when the channel is closed
<T> void	addToAttachmentList(AttachmentKey<AttachmentList<T>> key, T value)	Add a value to a list-typed attachment key.
void	close()
Account	getAccount()
<T> T	getAttachment(AttachmentKey<T> key)	Get an attachment value.
<T> java.util.List<T>	getAttachmentList(AttachmentKey<? extends java.util.List<T>> key)	Gets a list attachment value.
long	getKeepAliveTime()
java.lang.String	getParameter(java.lang.String name)
java.security.Principal	getPrincipal()
java.util.Map<java.lang.String,java.lang.Object>	getProperties()
java.util.Map<java.lang.String,java.util.Deque<java.lang.String>>	getQueryParameters()
java.lang.String	getQueryString()
HeaderMap	getRequestHeaders()
java.lang.String	getRequestURI()
HeaderMap	getResponseHeaders()
boolean	isOpen()
<T> T	putAttachment(AttachmentKey<T> key, T value)	Set an attachment value.
<T> T	removeAttachment(AttachmentKey<T> key)	Remove an attachment, returning its previous value.
void	send(java.lang.String data)	Sends an event to the remote client
void	send(java.lang.String data, ServerSentEventConnection.EventCallback callback)	Sends an event to the remote client
void	send(java.lang.String data, java.lang.String event, java.lang.String id, ServerSentEventConnection.EventCallback callback)	Sends an event to the remote client
void	sendRetry(long retry)	Sends the 'retry' message to the client, instructing it how long to wait before attempting a reconnect.
void	sendRetry(long retry, ServerSentEventConnection.EventCallback callback)	Sends the 'retry' message to the client, instructing it how long to wait before attempting a reconnect.
void	setKeepAliveTime(long keepAliveTime)	Sets the keep alive time in milliseconds.
void	setParameter(java.lang.String name, java.lang.String value)
void	shutdown()	execute a graceful shutdown once all data has been sent

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ServerSentEventConnection

public ServerSentEventConnection(HttpServerExchange exchange,
                                 org.xnio.channels.StreamSinkChannel sink)

Method Detail

addCloseTask

public void addCloseTask(org.xnio.ChannelListener<ServerSentEventConnection> listener)

Adds a listener that will be invoked when the channel is closed

Parameters:

listener - The listener to invoke

getPrincipal

public java.security.Principal getPrincipal()

Returns:

The principal that was associated with the SSE request

getAccount

public Account getAccount()

Returns:

The account that was associated with the SSE request

getRequestHeaders

public HeaderMap getRequestHeaders()

Returns:

The request headers from the initial request that opened this connection

getResponseHeaders

public HeaderMap getResponseHeaders()

Returns:

The response headers from the initial request that opened this connection

getRequestURI

public java.lang.String getRequestURI()

Returns:

The request URI from the initial request that opened this connection

getQueryParameters

public java.util.Map<java.lang.String,java.util.Deque<java.lang.String>> getQueryParameters()

Returns:

the query parameters

getQueryString

public java.lang.String getQueryString()

Returns:

the query string

send

public void send(java.lang.String data)

Sends an event to the remote client

Parameters:

data - The event data

send

public void send(java.lang.String data,
                 ServerSentEventConnection.EventCallback callback)

Sends an event to the remote client

Parameters:

data - The event data

callback - A callback that is notified on Success or failure

sendRetry

public void sendRetry(long retry)

Sends the 'retry' message to the client, instructing it how long to wait before attempting a reconnect.

Parameters:

retry - The retry time in milliseconds

sendRetry

public void sendRetry(long retry,
                      ServerSentEventConnection.EventCallback callback)

Sends the 'retry' message to the client, instructing it how long to wait before attempting a reconnect.

Parameters:

retry - The retry time in milliseconds

callback - The callback that is notified on success or failure

send

public void send(java.lang.String data,
                 java.lang.String event,
                 java.lang.String id,
                 ServerSentEventConnection.EventCallback callback)

Sends an event to the remote client

Parameters:

data - The event data

event - The event name

id - The event ID

callback - A callback that is notified on Success or failure

getParameter

public java.lang.String getParameter(java.lang.String name)

setParameter

public void setParameter(java.lang.String name,
                         java.lang.String value)

getProperties

public java.util.Map<java.lang.String,java.lang.Object> getProperties()

getKeepAliveTime

public long getKeepAliveTime()

Returns:

The keep alive time

setKeepAliveTime

public void setKeepAliveTime(long keepAliveTime)

Sets the keep alive time in milliseconds. If this is larger than zero a ':' message will be sent this often (assuming there is no activity) to keep the connection alive. The spec recommends a value of 15000 (15 seconds).

Parameters:

keepAliveTime - The time in milliseconds between keep alive messaged

shutdown

public void shutdown()

execute a graceful shutdown once all data has been sent

isOpen

public boolean isOpen()

Specified by:

isOpen in interface java.nio.channels.Channel

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.nio.channels.Channel

Specified by:

close in interface java.io.Closeable

Throws:

java.io.IOException

getAttachment

public <T> T getAttachment(AttachmentKey<T> key)

Description copied from interface: Attachable

Get an attachment value. If no attachment exists for this key, null is returned.

Specified by:

getAttachment in interface Attachable

Type Parameters:

T - the value type

Parameters:

key - the attachment key

Returns:

the value, or null if there is none

getAttachmentList

public <T> java.util.List<T> getAttachmentList(AttachmentKey<? extends java.util.List<T>> key)

Description copied from interface: Attachable

Gets a list attachment value. If not attachment exists for this key an empty list is returned

Specified by:

getAttachmentList in interface Attachable

Type Parameters:

T - the value type

Parameters:

key - the attachment key

Returns:

the value, or an empty list if there is none

putAttachment

public <T> T putAttachment(AttachmentKey<T> key,
                           T value)

Description copied from interface: Attachable

Set an attachment value. If an attachment for this key was already set, return the original value. If the value being set is null, the attachment key is removed.

Specified by:

putAttachment in interface Attachable

Type Parameters:

T - the value type

Parameters:

key - the attachment key

value - the new value

Returns:

the old value, or null if there was none

removeAttachment

public <T> T removeAttachment(AttachmentKey<T> key)

Description copied from interface: Attachable

Remove an attachment, returning its previous value.

Specified by:

removeAttachment in interface Attachable

Type Parameters:

T - the value type

Parameters:

key - the attachment key

Returns:

the old value, or null if there was none

addToAttachmentList

public <T> void addToAttachmentList(AttachmentKey<AttachmentList<T>> key,
                                    T value)

Description copied from interface: Attachable

Add a value to a list-typed attachment key. If the key is not mapped, add such a mapping.

Specified by:

addToAttachmentList in interface Attachable

Type Parameters:

T - the list value type

Parameters:

key - the attachment key

value - the value to add