Package org.apache.activemq.command
Class NetworkBridgeFilter
- java.lang.Object
-
- org.apache.activemq.command.NetworkBridgeFilter
-
- All Implemented Interfaces:
DataStructure
,BooleanExpression
,Expression
public class NetworkBridgeFilter extends Object implements DataStructure, BooleanExpression
-
-
Field Summary
Fields Modifier and Type Field Description protected int
consumerTTL
static byte
DATA_STRUCTURE_TYPE
protected int
messageTTL
protected BrokerId
networkBrokerId
-
Constructor Summary
Constructors Constructor Description NetworkBridgeFilter()
NetworkBridgeFilter(ConsumerInfo consumerInfo, BrokerId networkBrokerId, int messageTTL, int consumerTTL)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method 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)
-
-
-
Field Detail
-
DATA_STRUCTURE_TYPE
public static final byte DATA_STRUCTURE_TYPE
- See Also:
- Constant Field Values
-
networkBrokerId
protected BrokerId networkBrokerId
-
messageTTL
protected int messageTTL
-
consumerTTL
protected int consumerTTL
-
-
Constructor Detail
-
NetworkBridgeFilter
public NetworkBridgeFilter()
-
NetworkBridgeFilter
public NetworkBridgeFilter(ConsumerInfo consumerInfo, BrokerId networkBrokerId, int messageTTL, int consumerTTL)
-
-
Method Detail
-
getDataStructureType
public byte getDataStructureType()
- Specified by:
getDataStructureType
in interfaceDataStructure
- Returns:
- The type of the data structure
-
isMarshallAware
public boolean isMarshallAware()
- Specified by:
isMarshallAware
in interfaceDataStructure
-
matches
public boolean matches(MessageEvaluationContext mec) throws JMSException
- Specified by:
matches
in interfaceBooleanExpression
- Returns:
- true if the expression evaluates to Boolean.TRUE.
- Throws:
JMSException
-
evaluate
public Object evaluate(MessageEvaluationContext message) throws JMSException
- Specified by:
evaluate
in interfaceExpression
- Returns:
- the value of this expression
- Throws:
JMSException
-
matchesForwardingFilter
protected boolean matchesForwardingFilter(Message message, MessageEvaluationContext mec)
-
isAdvisoryInterpretedByNetworkBridge
public static boolean isAdvisoryInterpretedByNetworkBridge(Message message)
-
getNetworkTTL
public int getNetworkTTL()
-
setNetworkTTL
public void setNetworkTTL(int networkTTL)
-
getNetworkBrokerId
public BrokerId getNetworkBrokerId()
-
setNetworkBrokerId
public void setNetworkBrokerId(BrokerId remoteBrokerPath)
-
setMessageTTL
public void setMessageTTL(int messageTTL)
-
getMessageTTL
public int getMessageTTL()
-
setConsumerTTL
public void setConsumerTTL(int consumerTTL)
-
getConsumerTTL
public int getConsumerTTL()
-
-