Package | Description |
---|---|
org.cometd.annotation.server | |
org.cometd.bayeux.server | |
org.cometd.oort | |
org.cometd.server | |
org.cometd.server.ext | |
org.cometd.server.filter |
Modifier and Type | Method and Description |
---|---|
protected ServerAnnotationProcessor |
AnnotationCometDServlet.newServerAnnotationProcessor(BayeuxServer bayeuxServer) |
Constructor and Description |
---|
ServerAnnotationProcessor(BayeuxServer bayeuxServer) |
ServerAnnotationProcessor(BayeuxServer bayeuxServer,
Object... injectables) |
Modifier and Type | Method and Description |
---|---|
default boolean |
SecurityPolicy.canCreate(BayeuxServer server,
ServerSession session,
String channelId,
ServerMessage message)
|
default void |
SecurityPolicy.canCreate(BayeuxServer server,
ServerSession session,
String channelId,
ServerMessage message,
Promise<Boolean> promise)
Checks if a message should be allowed to create a new channel.
|
default boolean |
SecurityPolicy.canHandshake(BayeuxServer server,
ServerSession session,
ServerMessage message)
Blocking version of
SecurityPolicy.canHandshake(BayeuxServer, ServerSession, ServerMessage, Promise) . |
default void |
SecurityPolicy.canHandshake(BayeuxServer server,
ServerSession session,
ServerMessage message,
Promise<Boolean> promise)
Checks if a handshake message should be accepted.
|
default boolean |
SecurityPolicy.canPublish(BayeuxServer server,
ServerSession session,
ServerChannel channel,
ServerMessage message)
|
default void |
SecurityPolicy.canPublish(BayeuxServer server,
ServerSession session,
ServerChannel channel,
ServerMessage message,
Promise<Boolean> promise)
Checks if a client can publish a message to a channel.
|
default boolean |
SecurityPolicy.canSubscribe(BayeuxServer server,
ServerSession session,
ServerChannel channel,
ServerMessage message)
|
default void |
SecurityPolicy.canSubscribe(BayeuxServer server,
ServerSession session,
ServerChannel channel,
ServerMessage message,
Promise<Boolean> promise)
Checks if a subscribe message from a client is allowed to subscribe to a channel.
|
Modifier and Type | Method and Description |
---|---|
BayeuxServer |
Oort.getBayeuxServer() |
Modifier and Type | Method and Description |
---|---|
protected Oort |
OortConfigServlet.newOort(BayeuxServer bayeux,
String url)
Creates and returns a new Oort instance.
|
protected void |
Oort.protectOortChannels(BayeuxServer bayeux) |
protected void |
Seti.protectSetiChannels(BayeuxServer bayeux) |
protected void |
Oort.unprotectOortChannels(BayeuxServer bayeux) |
protected void |
Seti.unprotectSetiChannels(BayeuxServer bayeux) |
Constructor and Description |
---|
Oort(BayeuxServer bayeux,
String url) |
Modifier and Type | Class and Description |
---|---|
class |
BayeuxServerImpl |
Modifier and Type | Method and Description |
---|---|
BayeuxServer |
AbstractService.getBayeux() |
Modifier and Type | Method and Description |
---|---|
boolean |
DefaultSecurityPolicy.canCreate(BayeuxServer server,
ServerSession session,
String channelId,
ServerMessage message) |
boolean |
DefaultSecurityPolicy.canHandshake(BayeuxServer server,
ServerSession session,
ServerMessage message) |
boolean |
DefaultSecurityPolicy.canPublish(BayeuxServer server,
ServerSession session,
ServerChannel channel,
ServerMessage message) |
boolean |
DefaultSecurityPolicy.canSubscribe(BayeuxServer server,
ServerSession session,
ServerChannel channel,
ServerMessage message) |
Constructor and Description |
---|
AbstractService(BayeuxServer bayeux,
String name)
Instantiates a CometD service with the given name.
|
AbstractService(BayeuxServer bayeux,
String name,
int maxThreads)
Instantiate a CometD service with the given name and max number of pooled threads.
|
Constructor and Description |
---|
BinarySessionExtension(BayeuxServer bayeuxServer) |
BinarySessionExtension(BayeuxServer bayeuxServer,
boolean decodeToByteBuffer) |
Constructor and Description |
---|
DataFilterMessageListener(BayeuxServer bayeux,
DataFilter... filters) |
Copyright © 2008–2024 The CometD Project. All rights reserved.