Package | Description |
---|---|
org.cometd.bayeux.server | |
org.cometd.oort | |
org.cometd.server | |
org.cometd.server.filter |
Modifier and Type | Method and Description |
---|---|
ServerChannel |
BayeuxServer.getChannel(String channelId) |
Modifier and Type | Method and Description |
---|---|
MarkedReference<ServerChannel> |
BayeuxServer.createChannelIfAbsent(String channelName,
ConfigurableServerChannel.Initializer... initializers)
Creates a
ServerChannel and initializes it atomically if the
channel does not exist, or returns it if it already exists. |
List<ServerChannel> |
BayeuxServer.getChannels() |
Set<ServerChannel> |
ServerSession.getSubscriptions() |
Modifier and Type | Method and Description |
---|---|
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.
|
default void |
BayeuxServer.ChannelListener.channelAdded(ServerChannel channel)
Callback invoked when a
ServerChannel has been added to a BayeuxServer object. |
default boolean |
ServerChannel.MessageListener.onMessage(ServerSession sender,
ServerChannel channel,
ServerMessage.Mutable message)
|
default void |
ServerChannel.MessageListener.onMessage(ServerSession sender,
ServerChannel channel,
ServerMessage.Mutable message,
Promise<Boolean> promise)
Callback invoked when a message is being published.
|
default void |
BayeuxServer.SubscriptionListener.subscribed(ServerSession session,
ServerChannel channel,
ServerMessage message)
Callback invoked when a
ServerSession subscribes to a ServerChannel . |
default void |
ServerChannel.SubscriptionListener.subscribed(ServerSession session,
ServerChannel channel,
ServerMessage message)
Callback invoked when the given
ServerSession subscribes to the given ServerChannel . |
default void |
BayeuxServer.SubscriptionListener.unsubscribed(ServerSession session,
ServerChannel channel,
ServerMessage message)
Callback invoked when a
ServerSession unsubscribes from a ServerChannel . |
default void |
ServerChannel.SubscriptionListener.unsubscribed(ServerSession session,
ServerChannel channel,
ServerMessage message)
Callback invoked when the given
ServerSession unsubscribes from the given ServerChannel . |
Modifier and Type | Method and Description |
---|---|
boolean |
OortService.onMessage(ServerSession from,
ServerChannel channel,
ServerMessage.Mutable message) |
boolean |
Oort.CloudListener.onMessage(ServerSession from,
ServerChannel channel,
ServerMessage.Mutable message) |
Modifier and Type | Class and Description |
---|---|
class |
ServerChannelImpl |
Modifier and Type | Method and Description |
---|---|
ServerChannel |
BayeuxServerImpl.getChannel(String channelId) |
Modifier and Type | Method and Description |
---|---|
MarkedReference<ServerChannel> |
BayeuxServerImpl.createChannelIfAbsent(String channelName,
ConfigurableServerChannel.Initializer... initializers) |
List<ServerChannel> |
BayeuxServerImpl.getChannels() |
Set<ServerChannel> |
ServerSessionImpl.getSubscriptions() |
Modifier and Type | Method and Description |
---|---|
boolean |
DefaultSecurityPolicy.canPublish(BayeuxServer server,
ServerSession session,
ServerChannel channel,
ServerMessage message) |
boolean |
DefaultSecurityPolicy.canSubscribe(BayeuxServer server,
ServerSession session,
ServerChannel channel,
ServerMessage message) |
Modifier and Type | Method and Description |
---|---|
Object |
JSONDataFilter.filter(ServerSession session,
ServerChannel channel,
Object data) |
Object |
DataFilter.filter(ServerSession session,
ServerChannel channel,
Object data)
Modifies the given message data.
|
protected Object |
JSONDataFilter.filterArray(ServerSession session,
ServerChannel channel,
Object array) |
protected Object |
JSONDataFilter.filterBoolean(ServerSession session,
ServerChannel channel,
Boolean bool) |
protected Object |
JSONDataFilter.filterCollection(ServerSession session,
ServerChannel channel,
Collection<Object> collection) |
protected Object |
JSONDataFilter.filterList(ServerSession session,
ServerChannel channel,
List<Object> list) |
protected Object |
JSONDataFilter.filterMap(ServerSession session,
ServerChannel channel,
Map<String,Object> map) |
protected Object |
JSONDataFilter.filterNumber(ServerSession session,
ServerChannel channel,
Number number) |
protected Object |
JSONDataFilter.filterObject(ServerSession session,
ServerChannel channel,
Object data) |
protected Object |
JSONDataFilter.filterString(ServerSession session,
ServerChannel channel,
String string) |
protected Object |
RegexFilter.filterString(ServerSession session,
ServerChannel channel,
String string) |
protected Object |
NoMarkupFilter.filterString(ServerSession session,
ServerChannel channel,
String string) |
protected Object |
NoScriptsFilter.filterString(ServerSession session,
ServerChannel channel,
String string) |
boolean |
DataFilterMessageListener.onMessage(ServerSession from,
ServerChannel channel,
ServerMessage.Mutable message) |
Copyright © 2008–2024 The CometD Project. All rights reserved.