Modifier and Type | Method and Description |
---|---|
protected static byte[] |
ConnectionStrategyServerConnectorAdapter.encode(String aString)
Encodes an string with the configured encoding.
|
protected static String |
ConnectionStrategyServerConnectorAdapter.getEncoding()
Returns the configured encoding.
|
List<DomainEvent> |
ConnectionStrategyServerConnector.listen(UserInfo aUserInfo)
Listens for occurring events (can be retrieved from the
UserInfo with
de.novanic.eventservice.service.registry.user.UserInfo#retrieveEvents() ) and should prepare or transfer the retrieved events
directly. |
protected boolean |
ConnectionStrategyServerConnectorAdapter.waitMaxWaitingTime(UserInfo aUserInfo)
Waits for the configured max. waiting time and returns whether the max. waiting time
was exceed or was interrupted by an occurred event (notification).
|
protected void |
ConnectionStrategyServerConnectorAdapter.waitMinWaitingTime()
Waits for the configured min. waiting time.
|
Modifier and Type | Method and Description |
---|---|
List<DomainEvent> |
LongPollingServerConnector.listen(UserInfo aUserInfo)
Listens for occurring events with the long-polling strategy.
|
Modifier and Type | Method and Description |
---|---|
List<DomainEvent> |
StreamingServerConnector.listen(UserInfo aUserInfo)
Listens for occurring events (can be retrieved from the
UserInfo with
UserInfo.retrieveEvents(int) ) and should prepare or transfer the retrieved events
directly. |
void |
StreamingServerConnector.prepare(javax.servlet.http.HttpServletResponse aResponse)
Prepares the
StreamingServerConnector with a response. |
Constructor and Description |
---|
StreamingServerConnector(EventServiceConfiguration aConfiguration)
Creates a new
StreamingServerConnector . |
Copyright © 2012. All Rights Reserved.