Package org.cometd.server.filter

Class DataFilterMessageListener

java.lang.Object

org.cometd.server.filter.DataFilterMessageListener

All Implemented Interfaces:

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

public class DataFilterMessageListener
extends java.lang.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	Description
DataFilterMessageListener(BayeuxServer bayeux, DataFilter... filters)
DataFilterMessageListener(DataFilter... filters)

Method Summary

Modifier and Type	Method	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