public class NetworkBridgeFilter extends Object implements DataStructure, BooleanExpression
Modifier and Type | Field and Description |
---|---|
protected int |
consumerTTL |
static byte |
DATA_STRUCTURE_TYPE |
protected int |
messageTTL |
protected BrokerId |
networkBrokerId |
Constructor and Description |
---|
NetworkBridgeFilter() |
NetworkBridgeFilter(ConsumerInfo consumerInfo,
BrokerId networkBrokerId,
int messageTTL,
int consumerTTL) |
Modifier and Type | Method and Description |
---|---|
static boolean |
contains(BrokerId[] brokerPath,
BrokerId brokerId) |
Object |
evaluate(MessageEvaluationContext message) |
int |
getConsumerTTL() |
byte |
getDataStructureType() |
int |
getMessageTTL() |
BrokerId |
getNetworkBrokerId() |
int |
getNetworkTTL() |
static boolean |
isAdvisoryInterpretedByNetworkBridge(Message message) |
boolean |
isMarshallAware() |
boolean |
matches(MessageEvaluationContext mec) |
protected boolean |
matchesForwardingFilter(Message message,
MessageEvaluationContext mec) |
void |
setConsumerTTL(int consumerTTL) |
void |
setMessageTTL(int messageTTL) |
void |
setNetworkBrokerId(BrokerId remoteBrokerPath) |
void |
setNetworkTTL(int networkTTL) |
public static final byte DATA_STRUCTURE_TYPE
protected BrokerId networkBrokerId
protected int messageTTL
protected int consumerTTL
public NetworkBridgeFilter()
public NetworkBridgeFilter(ConsumerInfo consumerInfo, BrokerId networkBrokerId, int messageTTL, int consumerTTL)
public byte getDataStructureType()
getDataStructureType
in interface DataStructure
public boolean isMarshallAware()
isMarshallAware
in interface DataStructure
public boolean matches(MessageEvaluationContext mec) throws JMSException
matches
in interface BooleanExpression
JMSException
public Object evaluate(MessageEvaluationContext message) throws JMSException
evaluate
in interface Expression
JMSException
protected boolean matchesForwardingFilter(Message message, MessageEvaluationContext mec)
public static boolean isAdvisoryInterpretedByNetworkBridge(Message message)
public int getNetworkTTL()
public void setNetworkTTL(int networkTTL)
public BrokerId getNetworkBrokerId()
public void setNetworkBrokerId(BrokerId remoteBrokerPath)
public void setMessageTTL(int messageTTL)
public int getMessageTTL()
public void setConsumerTTL(int consumerTTL)
public int getConsumerTTL()
Copyright © 2005–2016 FuseSource, Corp.. All rights reserved.