org.cometd.server.filter

Class DataFilterMessageListener

java.lang.Object

org.cometd.server.filter.DataFilterMessageListener

All Implemented Interfaces:

EventListener, Bayeux.BayeuxListener, ConfigurableServerChannel.ServerChannelListener, ServerChannel.MessageListener

public class DataFilterMessageListener
extends Object
implements ServerChannel.MessageListener

A MessageListener that applies DataFilters to the received messages.

Nested Class Summary

Nested classes/interfaces inherited from interface org.cometd.bayeux.server.ConfigurableServerChannel.ServerChannelListener

ConfigurableServerChannel.ServerChannelListener.Weak

Constructor Summary

Constructors

Constructor and Description
DataFilterMessageListener(BayeuxServer bayeux, DataFilter... filters)
DataFilterMessageListener(DataFilter... filters)

Method Summary

Modifier and Type	Method and Description
boolean	onMessage(ServerSession from, ServerChannel channel, ServerMessage.Mutable message) Blocking version of ServerChannel.MessageListener.onMessage(ServerSession, ServerChannel, ServerMessage.Mutable, Promise).

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.cometd.bayeux.server.ServerChannel.MessageListener

onMessage

Constructor Detail

DataFilterMessageListener

public DataFilterMessageListener(DataFilter... filters)

DataFilterMessageListener

public DataFilterMessageListener(BayeuxServer bayeux,
                                 DataFilter... filters)

Method Detail

onMessage

public boolean onMessage(ServerSession from,
                         ServerChannel channel,
                         ServerMessage.Mutable message)

Description copied from interface: ServerChannel.MessageListener

Blocking version of ServerChannel.MessageListener.onMessage(ServerSession, ServerChannel, ServerMessage.Mutable, Promise).

Specified by:

onMessage in interface ServerChannel.MessageListener

Parameters:

from - the session that publishes the message

channel - the channel the message is published to

message - the message to be published

Returns:

whether the message processing should continue