org.apache.hedwig.client.netty

Class FilterableMessageHandler

java.lang.Object

org.apache.hedwig.client.netty.FilterableMessageHandler

All Implemented Interfaces:

MessageHandler

public class FilterableMessageHandler
extends Object
implements MessageHandler

Handlers used by a subscription.

Constructor Summary

Constructors

Constructor and Description
FilterableMessageHandler(MessageHandler msgHandler, org.apache.hedwig.filter.ClientMessageFilter msgFilter)

Method Summary

Modifier and Type	Method and Description
void	deliver(com.google.protobuf.ByteString topic, com.google.protobuf.ByteString subscriberId, PubSubProtocol.Message msg, Callback<Void> callback, Object context) Delivers a message which has been published for topic.
org.apache.hedwig.filter.ClientMessageFilter	getMessageFilter()
MessageHandler	getMessageHandler()
boolean	hasMessageFilter()
boolean	hasMessageHandler()

Methods inherited from class java.lang.Object

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

Constructor Detail

FilterableMessageHandler

public FilterableMessageHandler(MessageHandler msgHandler,
                                org.apache.hedwig.filter.ClientMessageFilter msgFilter)

Method Detail

hasMessageHandler

public boolean hasMessageHandler()

getMessageHandler

public MessageHandler getMessageHandler()

hasMessageFilter

public boolean hasMessageFilter()

getMessageFilter

public org.apache.hedwig.filter.ClientMessageFilter getMessageFilter()

deliver

public void deliver(com.google.protobuf.ByteString topic,
                    com.google.protobuf.ByteString subscriberId,
                    PubSubProtocol.Message msg,
                    Callback<Void> callback,
                    Object context)

Description copied from interface: MessageHandler

Delivers a message which has been published for topic.

Specified by:

deliver in interface MessageHandler

Parameters:

topic - The topic name where the message came from.

subscriberId - ID of the subscriber.

msg - The message object to deliver.

callback - Callback to invoke when the message delivery has been done.

context - Calling context that the Callback needs since this is done asynchronously.