org.joyqueue.client.internal.consumer.interceptor

类 ConsumeContext

java.lang.Object

org.joyqueue.client.internal.consumer.interceptor.ConsumeContext

public class ConsumeContext
extends Object

ConsumeContext author: gaohaoxiang date: 2019/1/11

构造器概要

构造器

构造器和说明
ConsumeContext(String topic, String app, NameServerConfig nameserver, List<ConsumeMessage> messages)

方法概要

限定符和类型	方法和说明
boolean	containsAttribute(Object key)
void	filterMessage(ConsumeMessage message)
String	getApp()
<T> T	getAttribute(Object key)
Map<Object,Object>	getAttributes()
List<ConsumeMessage>	getFilteredMessages()
Set<ConsumeMessage>	getMessageFilter()
List<ConsumeMessage>	getMessages()
NameServerConfig	getNameserver()
String	getTopic()
boolean	isFilteredMessage(ConsumeMessage message)
boolean	putAttribute(Object key, Object value)
boolean	removeAttribute(Object key)

从类继承的方法 java.lang.Object

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

构造器详细资料

ConsumeContext

public ConsumeContext(String topic,
                      String app,
                      NameServerConfig nameserver,
                      List<ConsumeMessage> messages)

方法详细资料

getTopic

public String getTopic()

getApp

public String getApp()

getNameserver

public NameServerConfig getNameserver()

getMessages

public List<ConsumeMessage> getMessages()

getMessageFilter

public Set<ConsumeMessage> getMessageFilter()

filterMessage

public void filterMessage(ConsumeMessage message)

isFilteredMessage

public boolean isFilteredMessage(ConsumeMessage message)

getFilteredMessages

public List<ConsumeMessage> getFilteredMessages()

getAttribute

public <T> T getAttribute(Object key)

removeAttribute

public boolean removeAttribute(Object key)

putAttribute

public boolean putAttribute(Object key,
                            Object value)

containsAttribute

public boolean containsAttribute(Object key)

getAttributes

public Map<Object,Object> getAttributes()