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 org.apache.activemq.command.ActiveMQDestination	findMatchingDestination(org.apache.activemq.command.ActiveMQDestination[] dests, org.apache.activemq.command.ActiveMQDestination destination)
static org.apache.activemq.command.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(org.apache.activemq.command.ActiveMQDestination destination)
static boolean	isDirectBridgeConsumer(NetworkBridgeConfiguration config, String clientId, String subName)
static boolean	isForcedDurable(org.apache.activemq.command.ConsumerInfo info, List<org.apache.activemq.command.ActiveMQDestination> dynamicallyIncludedDestinations)
static boolean	isForcedDurable(org.apache.activemq.command.ConsumerInfo info, org.apache.activemq.command.ActiveMQDestination[] dynamicallyIncludedDestinations, org.apache.activemq.command.ActiveMQDestination[] staticallyIncludedDestinations)
static boolean	isProxyBridgeSubscription(NetworkBridgeConfiguration config, String clientId, String subName)
static boolean	matchesConfigForDurableSync(NetworkBridgeConfiguration config, String clientId, String subscriptionName, org.apache.activemq.command.ActiveMQDestination destination)	This method is used to determine which durable subscriptions should be sent from a broker to a remote broker so that the remote broker can process the subscriptions to re-add demand when the bridge is first started during the durable sync phase of a bridge starting.
static boolean	matchesDestination(org.apache.activemq.command.ActiveMQDestination destFilter, org.apache.activemq.command.ActiveMQDestination destToMatch)
static boolean	matchesDestinations(List<org.apache.activemq.command.ActiveMQDestination> includedDests, org.apache.activemq.command.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 org.apache.activemq.command.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(org.apache.activemq.command.ConsumerInfo info,
                                      List<org.apache.activemq.command.ActiveMQDestination> dynamicallyIncludedDestinations)

isForcedDurable

public static boolean isForcedDurable(org.apache.activemq.command.ConsumerInfo info,
                                      org.apache.activemq.command.ActiveMQDestination[] dynamicallyIncludedDestinations,
                                      org.apache.activemq.command.ActiveMQDestination[] staticallyIncludedDestinations)

matchesConfigForDurableSync

public static boolean matchesConfigForDurableSync(NetworkBridgeConfiguration config,
                                                  String clientId,
                                                  String subscriptionName,
                                                  org.apache.activemq.command.ActiveMQDestination destination)

This method is used to determine which durable subscriptions should be sent from a broker to a remote broker so that the remote broker can process the subscriptions to re-add demand when the bridge is first started during the durable sync phase of a bridge starting. We can cut down on the amount of durables sent/processed based on how the bridge is configured.

Parameters:

config -

clientId -

subscriptionName -

destination -

Returns:

matchesDestination

public static boolean matchesDestination(org.apache.activemq.command.ActiveMQDestination destFilter,
                                         org.apache.activemq.command.ActiveMQDestination destToMatch)

matchesDestinations

public static boolean matchesDestinations(List<org.apache.activemq.command.ActiveMQDestination> includedDests,
                                          org.apache.activemq.command.ActiveMQDestination destination)

findMatchingDestination

public static org.apache.activemq.command.ActiveMQDestination findMatchingDestination(org.apache.activemq.command.ActiveMQDestination[] dests,
                                                                                      org.apache.activemq.command.ActiveMQDestination destination)

isDestForcedDurable

public static boolean isDestForcedDurable(org.apache.activemq.command.ActiveMQDestination destination)

isDirectBridgeConsumer

public static boolean isDirectBridgeConsumer(NetworkBridgeConfiguration config,
                                             String clientId,
                                             String subName)

isProxyBridgeSubscription

public static boolean isProxyBridgeSubscription(NetworkBridgeConfiguration config,
                                                String clientId,
                                                String subName)