public class FilterableMessageHandler extends Object implements MessageHandler
Constructor and Description |
---|
FilterableMessageHandler(MessageHandler msgHandler,
org.apache.hedwig.filter.ClientMessageFilter msgFilter) |
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() |
public FilterableMessageHandler(MessageHandler msgHandler, org.apache.hedwig.filter.ClientMessageFilter msgFilter)
public boolean hasMessageHandler()
public MessageHandler getMessageHandler()
public boolean hasMessageFilter()
public org.apache.hedwig.filter.ClientMessageFilter getMessageFilter()
public void deliver(com.google.protobuf.ByteString topic, com.google.protobuf.ByteString subscriberId, PubSubProtocol.Message msg, Callback<Void> callback, Object context)
MessageHandler
deliver
in interface MessageHandler
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.Copyright © 2011–2017 The Apache Software Foundation. All rights reserved.