Package org.apache.activemq.util

Class NetworkBridgeUtils

java.lang.Object

org.apache.activemq.util.NetworkBridgeUtils

public class NetworkBridgeUtils
extends Object

Constructor Summary

Constructors

Constructor	Description
NetworkBridgeUtils()

Method Summary

Modifier and Type	Method	Description
static ActiveMQDestination	findMatchingDestination(ActiveMQDestination[] dests, ActiveMQDestination destination)
static BrokerSubscriptionInfo	getBrokerSubscriptionInfo(BrokerService brokerService, NetworkBridgeConfiguration config)	Generate the BrokerSubscriptionInfo which is used to tell the broker on the other side of the network bridge which NC durable subscriptions are still needed for demand.
static boolean	isDestForcedDurable(ActiveMQDestination destination)
static boolean	isForcedDurable(ConsumerInfo info, List<ActiveMQDestination> dynamicallyIncludedDestinations)
static boolean	isForcedDurable(ConsumerInfo info, ActiveMQDestination[] dynamicallyIncludedDestinations, ActiveMQDestination[] staticallyIncludedDestinations)
static boolean	matchesDestinations(ActiveMQDestination[] dests, ActiveMQDestination destination)
static boolean	matchesNetworkConfig(NetworkBridgeConfiguration config, ActiveMQDestination destination)

Methods inherited from class java.lang.Object

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

Constructor Detail

NetworkBridgeUtils

public NetworkBridgeUtils()

Method Detail

getBrokerSubscriptionInfo

public static BrokerSubscriptionInfo getBrokerSubscriptionInfo(BrokerService brokerService,
                                                               NetworkBridgeConfiguration config)

Generate the BrokerSubscriptionInfo which is used to tell the broker on the other side of the network bridge which NC durable subscriptions are still needed for demand.

Parameters:

brokerService -

config -

Returns:

isForcedDurable

public static boolean isForcedDurable(ConsumerInfo info,
                                      List<ActiveMQDestination> dynamicallyIncludedDestinations)

isForcedDurable

public static boolean isForcedDurable(ConsumerInfo info,
                                      ActiveMQDestination[] dynamicallyIncludedDestinations,
                                      ActiveMQDestination[] staticallyIncludedDestinations)

matchesNetworkConfig

public static boolean matchesNetworkConfig(NetworkBridgeConfiguration config,
                                           ActiveMQDestination destination)

matchesDestinations

public static boolean matchesDestinations(ActiveMQDestination[] dests,
                                          ActiveMQDestination destination)

findMatchingDestination

public static ActiveMQDestination findMatchingDestination(ActiveMQDestination[] dests,
                                                          ActiveMQDestination destination)

isDestForcedDurable

public static boolean isDestForcedDurable(ActiveMQDestination destination)